#
#
#
from __future__ import annotations
import datetime
import sys
from subprocess import CalledProcessError
import pytest
from airflow.decorators import task
from airflow.utils import timezone
DEFAULT_DATE = timezone.datetime(2016, 1, 1)
PYTHON_VERSION = sys.version_info[0]
class TestPythonVirtualenvDecorator:
    def test_add_dill(self, dag_maker):
        @task.virtualenv(use_dill=True, system_site_packages=False)
        def f():
            """Ensure dill is correctly installed."""
            import dill  
        with dag_maker():
            ret = f()
        ret.operator.run(start_date=DEFAULT_DATE, end_date=DEFAULT_DATE)
    def test_no_requirements(self, dag_maker):