GitHub user ricardoalexanderh closed the discussion with a comment: Real
Sequential Dynamic Task
To close this discussion, I will put my workaround for now, at least it will
prevent subsequent map task (next index) to run when the previous map task
(previous index) failed or retrying. Because in my case, running the subsequent
task before the previous one succeeds will break the data.
Basically, in my run_dbt_snapshot method that will be expanded, I will raise an
AirflowSkipException('Some error messages') if some condition is not met. In my
case by checking my log table of the dates that has successfully run.
GitHub link:
https://github.com/apache/airflow/discussions/44789#discussioncomment-11538902
----
This is an automatically sent email for commits@airflow.apache.org.
To unsubscribe, please send an email to: commits-unsubscr...@airflow.apache.org
