I’m deploying my production workflow on prefect 2. However, there’s one issue that I have yet figured out a (good) solution so I’m truly looking for help here.
Say I want to deploy 3 flows like below but each having different schedules:
@flow def run_A(): pass @flow def run_B(): pass @flow def run_C(): a = run_A() b = run_B(wait_for=[a])
In other words, flow B depends on A, but might have a very different time schedule.
For example, B is scheduled to run every 10 minutes, and A is scheduled to run every 5 minutes, both from 09:30am onwards. At 10:00am, A and B both get triggered, but A takes time. I hope that B would respect the dependency (i.e. wait until A finishes) then execute B itself. Note once again that A and B are two separate deployments.
My question is - how can I do it in Prefect 2 in Python (no GUI)?