NoneType' object is not callable [Airflow Dag Error while creating dependencies] - Stack Overflow

In my use case I want to trigger another DAG from one DAG. My first DAG is as below :-with DAG(dag_id

In my use case I want to trigger another DAG from one DAG. My first DAG is as below :-

 with DAG(
dag_id = "data_insertion",
start_date = datetime(2024, 10, 8),
schedule_interval = SCHEDULE,
dagrun_timeout = timedelta(minutes=15), 
default_args = default_args,
 ) as directed_acyclic_graph:

datainsertiontask= Job(
    { #here another json with callables is called }
   
)

dataprocessing=TriggerDagRunOperator(
    task_id='dataprocessing',
    trigger_dag_id='dataprocessing_DAG')

datainsertiontask >> dataprocessing

I am trying to run the task datainsertiontask and when this finishes then trying to trigger another task present in another dag called dataprocessing_DAG. However I see the below error :-

Traceback (most recent call last):
 File "/home/airflow/.local/lib/python3.10/site-packages/airflow/models/taskmixin.py", line 271, in set_upstream
self._set_relatives(task_or_task_list, upstream=True, edge_modifier=edge_modifier)
File "/home/airflow/.local/lib/python3.10/site-packages/airflow/models/taskmixin.py", line 215, in _set_relatives
 task_object.update_relative(self, not upstream, edge_modifier=edge_modifier)
TypeError: 'NoneType' object is not callable

Not aware of this error. What am i doing wrong?

发布者:admin,转转请注明出处:http://www.yc00.com/questions/1744801025a4594490.html

相关推荐

发表回复

评论列表(0条)

  • 暂无评论

联系我们

400-800-8888

在线咨询: QQ交谈

邮件:admin@example.com

工作时间:周一至周五,9:30-18:30,节假日休息

关注微信