teste

teste_dag.py

@@ -57,6 +57,7 @@ def run_tests():
     ops = []
     for file in files:
         op = TriggerDagRunOperator(
+            task_id=file,
             trigger_dag_id=dag1.dag_id,
             conf={ "input_file": file }
         )