diff --git a/teste_dag.py b/teste_dag.py index 3f90cbd51643315fb44735f4bb4b8e5d39fcb03b..341fd7ca6efa45cbd95fd84c0c910e981153ad83 100644 --- a/teste_dag.py +++ b/teste_dag.py @@ -59,6 +59,7 @@ with DAG( trigger_dag_id=dag1.dag_id, conf={ "input_file": file } ) + ops.append(op) # Chain operators if len(ops) > 0: