GitHub user pdavidovicmsft created a discussion: TriggerDagRunOperator dynamic
mapping sequential execution
### 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
- [x] I agree to follow this project's [Code of
Conduct](https://github.com/apache/airflow/blob/main/CODE_OF_CONDUCT.md)
GitHub link: https://github.com/apache/airflow/discussions/68752
----
This is an automatically sent email for [email protected].
To unsubscribe, please send an email to: [email protected]
