https://prefect.io logo
r

Ryan Kelly

01/31/2021, 3:29 PM
has anyone else had issues with the sample code hanging from the flow-to-flow documentation? https://docs.prefect.io/core/idioms/flow-to-flow.html
as you can see from the picture theres 3 flows registered with 1 of them being the parent and when the parent is run it says its starting flow A but it never finishes
d

Dylan

02/01/2021, 3:37 PM
Hi @Ryan Kelly! Be sure to have an agent running that can pick up these Flows. The Flows-of-Flows pattern relies on the central Prefect Cloud / Prefect Server scheduler
r

Ryan Kelly

02/01/2021, 3:38 PM
i did it through cloud first and it hung as well
used prefect cli to run the local agent and the parent flow script had a 10min schedule instead of calling flow.run()
d

Dylan

02/01/2021, 3:44 PM
Since you’re running locally, make sure that the agent’s labels and the Flow’s labels match up
r

Ryan Kelly

02/01/2021, 5:28 PM
@Dylan is this a facet of flow of flows? these individuals flows (a and b) are picked up by the agent when they have their own schedules
d

Dylan

02/01/2021, 5:47 PM
Ah okay then the labels are configured correctly
Let me dig into this a bit
r

Ryan Kelly

02/01/2021, 6:57 PM
@Dylan thanks! been racking my brain on what im missing in this small scale test 🤪
d

Dylan

02/01/2021, 7:14 PM
One thing that’s sticking out to me is that
flow_a()
is never called in the flow context?
Is that the exact sample code?
r

Ryan Kelly

02/01/2021, 10:35 PM
@Dylan yep everything in the screenshot is everything thats registered and run
its the way the sample code in the documentation is outlined
d

Dylan

02/01/2021, 10:39 PM
Can you share the error you’re experiencing?
r

Ryan Kelly

02/01/2021, 10:39 PM
flow_a is above the parent flow context and then only dependent flows are called in the context
its in the top left window of the screenshot
oh
it stopped hanging
Copy code
[2021-01-31 10:27:07-0500] INFO - prefect.FlowRunner | Beginning Flow run for 'parent-flow'
[2021-01-31 10:27:07-0500] INFO - prefect.TaskRunner | Task 'Flow a': Starting task run...
[2021-02-01 10:59:51-0500] INFO - prefect.TaskRunner | FAIL signal raised: FAIL('94609a76-09a3-4052-b002-9b4295be6ccf finished in state <Failed: "Failed after exceeding scheduled work SLA.">')
[2021-02-01 10:59:51-0500] INFO - prefect.TaskRunner | Task 'Flow a': Finished task run for task with final state: 'Failed'
[2021-02-01 10:59:51-0500] INFO - prefect.TaskRunner | Task 'Flow b': Starting task run...
[2021-02-01 10:59:51-0500] INFO - prefect.TaskRunner | Task 'Flow b': Finished task run for task with final state: 'TriggerFailed'
[2021-02-01 10:59:51-0500] INFO - prefect.FlowRunner | Flow run FAILED: some reference tasks failed.
hung for a little over 24 hours
d

Dylan

02/02/2021, 3:15 PM
Hey @Ryan Kelly would you mind opening an issue for this? We’ll take a look
It might be something with the 0.14.0 upgrade
r

Ryan Kelly

02/02/2021, 3:18 PM
ah interesting
yeah im on prefect version 0.14.4
in theory i should be able to install 0.13.x and it will work?
d

Dylan

02/02/2021, 3:28 PM
I’m not sure, may be worth a shot though
r

Ryan Kelly

02/02/2021, 6:25 PM
@Dylan didnt work on 0.13 or 0.12 still hangs… is opening a bug still worth it if its not tied to a specific version?
d

Dylan

02/02/2021, 6:28 PM
Yes for sure 👍
r

Ryan Kelly

02/03/2021, 3:48 PM
submitted thanks for your help @Dylan!
d

Dylan

02/03/2021, 3:48 PM
You bet!
5 Views