TriggerDagRunOperator dynamic mapping sequential execution

[pdavidovicmsft]

Description

Hey folks,

I have code like this:

trigger_matcher_tasks = TriggerDagRunOperator.partial(
task_id='trigger_dag',
trigger_dag_id='example_dag',
wait_for_completion=True,
poke_interval=60,
).expand(
conf=configs_array
)

And I'd like to enforce triggering to work this way:
TriggerDag(config1) -> TriggerDag(config2) -> TriggerDag(config3)...

Essentially, I'd like to every triggering to wait for run started with previous triggering to be finished.

Can I do this with dynamic task mapping ?

Use case/motivation

No response

Related issues

No response

Are you willing to submit a PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct

[boring-cyborg[bot]]

Thanks for opening your first issue here! Be sure to follow the issue template! If you are willing to raise PR to address this issue please do so, no need to wait for approval.

[omd10]

You can do sequential dynamic tasks by adding max_active_tasks=1 to your dag configuration. It works with TriggerDagRunOperator as described in your question. Thanks for sharing this specific example!