@@ -84,7 +84,6 @@ def test_run(self, dag_maker):
8484 dag_maker .create_dagrun ()
8585 task .run (start_date = DEFAULT_DATE , end_date = DEFAULT_DATE )
8686
87- # FIXME: See inlined comment in the test
8887 def test_skipping_non_latest (self , dag_maker ):
8988 with dag_maker (
9089 default_args = {"owner" : "airflow" , "start_date" : DEFAULT_DATE }, schedule = INTERVAL , serialized = True
@@ -100,7 +99,6 @@ def test_skipping_non_latest(self, dag_maker):
10099
101100 triggered_by_kwargs = {"triggered_by" : DagRunTriggeredByType .TEST } if AIRFLOW_V_3_0_PLUS else {}
102101
103- # dr0 =
104102 dr0 = dag_maker .create_dagrun (
105103 run_type = DagRunType .SCHEDULED ,
106104 start_date = timezone .utcnow (),
@@ -110,7 +108,6 @@ def test_skipping_non_latest(self, dag_maker):
110108 ** triggered_by_kwargs ,
111109 )
112110
113- # dr1 =
114111 dr1 = dag_maker .create_dagrun (
115112 run_type = DagRunType .SCHEDULED ,
116113 start_date = timezone .utcnow (),
@@ -122,7 +119,6 @@ def test_skipping_non_latest(self, dag_maker):
122119 ** triggered_by_kwargs ,
123120 )
124121
125- # dr2 =
126122 dr2 = dag_maker .create_dagrun (
127123 run_type = DagRunType .SCHEDULED ,
128124 start_date = timezone .utcnow (),
0 commit comments