Update dags/groupuser/01ka0xkya3cevfzg5dngre9z7e.py

2025-11-14 10:19:13 +00:00 · 2025-11-14 10:19:13 +00:00 · 038598325b
commit 038598325b
parent 654eae4e50
1 changed files with 14 additions and 13 deletions
--- a/dags/groupuser/01ka0xkya3cevfzg5dngre9z7e.py
+++ b/dags/groupuser/01ka0xkya3cevfzg5dngre9z7e.py
@ -22,18 +22,19 @@ def test_logging():

@cheetah_pipeline()
 def es_index_test():
-        with DAG(
-            dag_id={DAG_ID_ENV},
-            start_date=datetime(2024, 1, 1),
-            schedule=None,
-            catchup=False,
-            tags=['test'],
-        ) as dag:
-            
-            test = PythonOperator(
-                task_id='test_task',
-                python_callable=test_logging,
-            )
-return dag
+    with DAG(
+        dag_id={DAG_ID_ENV},
+        start_date=datetime(2024, 1, 1),
+        schedule=None,
+        catchup=False,
+        tags=['test'],
+    ) as dag:
+        
+        test = PythonOperator(
+            task_id='test_task',
+            python_callable=test_logging,
+        )
+    
+    return dag

 dag = es_index_test()