added code for to execute python operator

IshanRattan · Mar 10, 2024 · e586024 · e586024
1 parent 3e9bf86
commit e586024
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/programming/airflow/dags/demo.py b/programming/airflow/dags/demo.py
@@ -28,3 +28,9 @@ def save_time_stamp():
 copy_files_task = BashOperator(task_id='copy_files_task',
                                bash_command=bash_cp_cmd,
                                dag=dag)
+
+
+write_log = PythonOperator(task_id='save_ts',
+                           python_callable=save_time_stamp,
+                           dag=dag)
+