最新消息:雨落星辰是一个专注网站SEO优化、网站SEO诊断、搜索引擎研究、网络营销推广、网站策划运营及站长类的自媒体原创博客

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

programmeradmin2浏览0评论

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?

发布评论

评论列表(0)

  1. 暂无评论