diff --git a/teste_dag.py b/teste_dag.py index 91eb0fb572af43f59764bf4e59a7d5c85e8f60f3..1ee44edb89a69fd0add11d049580b3e5bcbf3b56 100644 --- a/teste_dag.py +++ b/teste_dag.py @@ -60,4 +60,8 @@ with DAG( conf={ "input_file": file } ) - ops.append(op) + # Chain operators + if len(ops) > 0: + for i in range(1, len(ops) - 1): + ops[i] >> ops[i + 1] +