Bruno Murino02/07/2022, 2:14 PM
Fabrice Toussaint02/07/2022, 2:33 PM
ValueError("Couldn't infer a flow in the current context")
Ryan Brennan02/07/2022, 2:39 PM
. Right now we just have one big project for all of our flows. Is there any benefit to breaking them out further? Is it possible to do things like “run all flows in project X” or are projects only for organizational aesthetics?
Ken Nguyen02/07/2022, 5:17 PM
Heeje Cho02/07/2022, 5:20 PM
@task def generator(limit: int): logger = prefect.context.get("logger") for i in range(limit): <http://logger.info|logger.info>(i) yield i*i
Nick Hart02/07/2022, 6:17 PM
. Basically, I want to know how I can take the final state signal from
and decide whether I want to run
. I was having trouble matching the task signal with a value so that the case works properly. I was hoping you would be able to help me out. Would I need to use the
or is there a better way I can just grab the task result? Here is a snippet of my current test code:
var1 = Parameter("var1", default = 4) var2 = Parameter("var2", default = 12) conditional_id = StartFlowRun(flow_name="Conditional-Flow", project_name="Test", wait=True) flow_if_success_id = StartFlowRun(flow_name="Flow_if_success", project_name="Test", wait=True) flow_if_failure_id = StartFlowRun(flow_name="Flow_if_failure", project_name="Test", wait=True) # Idea: Conditional flow runs first. If it succeeds with Success signal, run flow_if_success, if it fails with failure signal, run flow_if_failure with Flow("Conditional FoF") as parent_flow: conditional_run = conditional_id() with case (conditional_run, Success): #Conditional_run never matches Success even if successful task run flow_if_success_run = flow_if_success_id(parameters=dict(num=var1)) with case (conditional_run, Failed): flow_if_failure_run = flow_if_failure_id(parameters=dict(number=var2))
Andrea Haessly02/07/2022, 6:23 PM
Brian Phillips02/07/2022, 7:55 PM
Tim Enders02/07/2022, 8:40 PM
The load still seems to run OK, but it is marked as failure. How can I get rid of this error?
Clients have non-trivial state that is local and unpickleable.
Vamsi Reddy02/08/2022, 12:08 AM
Daniel Saxton02/08/2022, 1:19 AM
Ovo Ojameruaye02/08/2022, 7:58 AM
Amichai Ben Ami02/08/2022, 12:16 PM
I could not find anything that changed from our side. any idea? Thanks 🙏
db-upgrade] Error applying Hasura metadata from /prefect-server/services/hasura/migrations/metadata.yaml
Antonio Manuel BR02/08/2022, 12:58 PM
). When I wrote the code, I read the docs, knowing this way was not valid for remote executions. I would like to know the proper way to gather results when working in a remote distributed environment. Can anyone help me?
Brett Naul02/08/2022, 1:19 PM
Thomas Pedersen02/08/2022, 2:37 PM
Bruno Murino02/08/2022, 2:54 PM
Archie Kennedy-Dyson02/08/2022, 3:09 PM
Andrew Lawlor02/08/2022, 3:24 PM
Matthew Seligson02/08/2022, 5:42 PM
Madison Schott02/08/2022, 8:19 PM
re_data notify slack \ --start-date 2021-01-01 \ --end-date 2021-01-31 \ --webhook-url <https://hooks.slack.com/services/T00000000/B00000000/XXXXXXXXXXXXXXXXXXXXXXXX> \ --subtitle="[Optional] Markdown text to be added as a subtitle in the slack message generated"
Tom Shaffner02/08/2022, 8:42 PM
Leon Kozlowski02/08/2022, 9:47 PM
Tony Yun02/08/2022, 9:51 PM
but when released to Cloud, it says the CONTEXT not exists. But I don’t find where can create that on UI.
Ifeanyi Okwuchi02/08/2022, 10:39 PM
to run a flow multiple times with different parameters. Here is my code and the error i'm getting.
vinoth paari02/09/2022, 5:00 AM
Kevin02/09/2022, 5:07 AM
Romain02/09/2022, 7:10 AM