dag_test

helxplatform · Dec 7, 2024 · b3e8035 · b3e8035
1 parent 9f56a82
commit b3e8035
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dags/roger/tasks.py b/dags/roger/tasks.py
@@ -325,7 +325,7 @@ def create_python_task(dag, name, a_callable, func_kwargs=None, external_repos =
     :param name: The name of the task.
     :param a_callable: The code to run in this task.
     """
-    return PythonOperator(task_id="print_the_context_2", python_callable=a_callable)
+    return PythonOperator(task_id=name, python_callable=a_callable)
     # these are actual arguments passed down to the task function
     op_kwargs = {
         "python_callable": a_callable,