DEFAULT_ARGS = {
        "owner": "test",
        "depends_on_past": True,
        "start_date": timezone.utcnow(),
        "retries": 1,
        "retry_delay": timedelta(minutes=1),
    }
    DEFAULT_DATE = timezone.datetime(2016, 1, 1)
    VALUE = 42
    def setup_method(self):
        self.operator = None
    def teardown_method(self):
        clear_db_runs()
    def test_fileloc(self):
        @dag_decorator(default_args=self.DEFAULT_ARGS)
        def noop_pipeline():
            ...
        dag = noop_pipeline()
        assert isinstance(dag, DAG)
        assert dag.dag_id == "noop_pipeline"
        assert dag.fileloc == __file__
    def test_set_dag_id(self):
        """Test that checks you can set dag_id from decorator."""
        @dag_decorator("test", default_args=self.DEFAULT_ARGS)
        def noop_pipeline():