leozitor commented on issue #16610:
URL: https://github.com/apache/airflow/issues/16610#issuecomment-1777677946
Hey guys is anyone facing issues regarding this, I notices in my code that
if i have a TriggerDagRunOperator inside task_group like this, it shows the dag
dependency on viewer
```
@task_group(group_id='concat_video')
def concatenate_video(task_id: int):
print("triggering job")
submit_job = TriggerDagRunOperator(
task_id='submit_job',
trigger_dag_id='video_concatenation_job',
wait_for_completion=True,
deferrable=True,
poke_interval=10,
conf={
'task_id': task_id,
},
)
submit_job
```
but if I use without a task_group ( for this example doesn't make sense to
use a group for a unique task)
it doesn't show in dag dependency viewer
```
@task
def concatenate_video(task_id: int):
print("triggering job")
submit_job = TriggerDagRunOperator(
task_id='submit_job',
trigger_dag_id='video_concatenation_job',
wait_for_completion=True,
deferrable=True,
# max_active_tis_per_dag=2, # it may be used if not deferrable
poke_interval=10,
conf={
'task_id': task_id,
},
)
submit_job
```
Does this make a sense?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
