GitHub user Saratqpy added a comment to the discussion: Support "cron AND 
dataset" condition for DAG scheduling

Thanks for the idea!
I solved it by writing a custom Timetable that wraps a normal cron timetable.
On every cron tick it checks the Airflow metadata DB:

Find the latest dataset_event for my dataset.

If the producing DAG run was success and the event is newer than the last cron 
tick → allow the run.

Otherwise → skip this tick.

This way the DAG only runs when cron time + dataset ready are both satisfied, 
no extra “cron asset” DAG needed.

GitHub link: 
https://github.com/apache/airflow/discussions/54095#discussioncomment-14124855

----
This is an automatically sent email for commits@airflow.apache.org.
To unsubscribe, please send an email to: commits-unsubscr...@airflow.apache.org

Reply via email to