Jelajahi Sumber

updated test dag

Avik Datta 4 tahun lalu
induk
melakukan
2928e4fd54
1 mengubah file dengan 6 tambahan dan 4 penghapusan
  1. 6 4
      dags/test_dag.py

+ 6 - 4
dags/test_dag.py

@@ -20,14 +20,16 @@ with dag:
     BashOperator(
       task_id='task1',
       dag=dag,
-      bash_command='echo "Test1"',
-      queue='hpc_4G'
+      bash_command='hostname -A',
+      queue='hpc_4G',
+      do_xcom_push=True
     )
   task2 = \
     BashOperator(
       task_id='task2',
       dag=dag,
-      bash_command='echo "Test2"',
-      queue='hpc_1G'
+      bash_command='hostname -A',
+      queue='hpc_1G',
+      do_xcom_push=True
     )
   task1 >> task2