What is the appropriate way to create an aggregate...
# ask-communityc
Carlo
11/16/2021, 9:46 PMWhat is the appropriate way to create an aggregate flow, such that flow A runs when the aggregate flow kicks off, flow B runs at 9pm, and Flow C runs once A and B are complete?
Carlo
11/16/2021, 9:46 PMFlow B doesn't wait for the scheduled start time
z
Zanie
11/16/2021, 9:50 PM
Hm. From looking at the code, the scheduled start time should definitely be passed to the created flow run. If you look at the states of the flow run created for B can you see the Scheduled state’s start time?
c
Carlo
11/16/2021, 10:01 PMLooking in our prefect server (self hosted), I couldn't find Flow B start time in the schematic. Where should I be looking for that state?
z
Zanie
11/16/2021, 10:05 PM
Oh I see, you haven’t passed
wait=TrueStartFlowRunZanie
11/16/2021, 10:05 PM
You should be able to see the flow run for B under its flow page. There should also be an artifact linking to the flow run on the main flow’s page
c
Carlo
11/16/2021, 10:21 PMhmm. I see the task for Flow B under the Aggregate Flow page -> run instance. If I go t the Flow Page for B, it doesn't show the artifact linking to the aggregate flow. Also I don't see a subflow running in the project overview, even though it is, only the agg flow shows up
Carlo
11/16/2021, 10:22 PMNot sure it matters, but we are on 0.15.3
k
Kevin Kho
11/16/2021, 10:40 PM
A bit confused. What do you mean by artifact? You should definitely see if though in the project overview. Do you not see it even if you refresh?
Kevin Kho
11/16/2021, 10:41 PM
Ah yeah I think there will be nothing linking it to the parent flow. The parent flow will have logs that link to the subflow. The subflow just knows it was triggered. For Orion (Prefect 2.0) though, we will be making this experience a lot better. You could rename the flow runs to make it more explicit
c
Carlo
11/17/2021, 12:19 AMYeah, it doesn't show up in the overview. That's fine if it's not linked.
I'm really just trying to figure out how to have flow B respect the scheduled start time, even though it was kicked off from an aggregating flow