From e5860248605d2abfb1f75c940df9d25458eaf24b Mon Sep 17 00:00:00 2001
From: IshanRattan <ishanrattan12@gmail.com>
Date: Sat, 9 Mar 2024 23:37:07 -0800
Subject: [PATCH] added code for to execute python operator

---
 programming/airflow/dags/demo.py | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/programming/airflow/dags/demo.py b/programming/airflow/dags/demo.py
index 30793eb..628936c 100644
--- 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)
+