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?