My big stumbling point I think, is that I either need to combine both sequential and parallel executions
aggregator and campaign statistics have to run sequentially, and dump_raw should run in parallel to both of those.
That makes me think that there are two ways to go about this -
1) aggregator should be a flow that calls campaign_statistics as a task, and dump_raw is either a flow or a task that runs parallel
2) All three processes are tasks, and I call (aggregator then campaign statistics) in a sequential task runner which is itself inside a parallel task runner with dump_raw.
I'm looking at the recipe here, which seems promising -
https://github.com/PrefectHQ/prefect-recipes/blob/main/flows-advanced/parent-orchestrator/pokemon_weight.py