https://prefect.io
Join Slack
has anyone else had issues with the sample code hanging from the flow-to-flow documentation? <https:...
# ask-community
r
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
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
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
Since you’re running locally, make sure that the agent’s labels and the Flow’s labels match up
r
@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
Ah okay then the labels are configured correctly
Let me dig into this a bit
r
@Dylan thanks! been racking my brain on what im missing in this small scale test 🤪
d
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
@Dylan yep everything in the screenshot is everything thats registered and run
its the way the sample code in the documentation is outlined
d
Can you share the error you’re experiencing?
r
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
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
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
I’m not sure, may be worth a shot though
r
@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
Yes for sure 👍
r
submitted thanks for your help @Dylan!
d
You bet!
4 Views
Open in Slack
PreviousNext
Powered by

Prefect Community

Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.

Powered by