Channels
#prefect-community
Title
r
Ryan Kelly
01/31/2021, 3:29 PMhas 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 PMi 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 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 PMflow_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 PMah 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 PMsubmitted thanks for your help @Dylan!
d
Dylan
02/03/2021, 3:48 PM
You bet!
5 Views