Felipe Saldana
05/26/2021, 1:09 AMKevin Kho
Kevin Kho
Felipe Saldana
05/26/2021, 1:58 AMKevin Kho
Felipe Saldana
05/26/2021, 2:18 AMclock2 = clocks.IntervalClock(start_date=now + datetime.timedelta(seconds=30),
Zanie
Felipe Saldana
05/26/2021, 2:46 AMFelipe Saldana
05/26/2021, 9:35 PMdata_qa1 = StartFlowRun(flow_name="data_flow_multi", project_name="FelipeFirst", wait=True, parameters=qa1_params)
data_qa2 = StartFlowRun(flow_name="data_flow_multi", project_name="FelipeFirst", wait=True, parameters=qa2_params)
with Flow("data_qa1_flow") as data_qa1_flow:
data_qa1()
with Flow("data_qa2_flow") as data_qa2_flow:
data_qa2()
This gives me a descriptive name and also works when kicking off manually around the same time. The logs have a link to the underlying flow which is helpful but not entirely ideal
Flow Run: <https://cloud.prefect.io/enverus-data/flow-run/4e8b06ab-83d5-4e9c-ad48-d3926514be76>
1. Are there any plans or already a way to have to underlying flow have its logs expanded directly in the outer flow log?
2. What are your thoughts on what I have using StartFlowRun
vs clock
to point a single base flow data_flow_multi
to multiple environments?Zanie
Felipe Saldana
05/26/2021, 10:34 PM