Explorar o código

minor fix for dag7

Avik Datta %!s(int64=4) %!d(string=hai) anos
pai
achega
c0c45dce7c
Modificáronse 1 ficheiros con 1 adicións e 1 borrados
  1. 1 1
      dags/dag7_hpc_scheduler.py

+ 1 - 1
dags/dag7_hpc_scheduler.py

@@ -57,4 +57,4 @@ with dag:
       command="docker restart airflow_flower")
 
   ## PIPELNE
-  run_hpc_scheduler > restart_flower_server
+  run_hpc_scheduler >> restart_flower_server