Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
from prefect.schedules import IntervalSchedule
schedule = IntervalSchedule(
start_date=datetime.utcnow() + timedelta(seconds=1),
interval=timedelta(minutes=1),
)
data_engineering_flow = ...
data_science_flow = ...
with Flow("main-flow", schedule=schedule) as flow:
data_science = data_science_flow(upstream_tasks=[data_engineering_flow])
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment