teste

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]
+