Bruno Murino
02/07/2022, 2:14 PMFabrice Toussaint
02/07/2022, 2:33 PMValueError("Couldn't infer a flow in the current context")
Ryan Brennan
02/07/2022, 2:39 PMProjects
. 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 Nguyen
02/07/2022, 5:17 PMHeeje Cho
02/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 Hart
02/07/2022, 6:17 PMflow_if_success
or flow_if_failure
. Basically, I want to know how I can take the final state signal from conditional-flow
and decide whether I want to run flow_if_success
or flow_if_failure
. 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 get_task_run_result
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 Haessly
02/07/2022, 6:23 PMBrian Phillips
02/07/2022, 7:55 PMTim Enders
02/07/2022, 8:40 PMClients have non-trivial state that is local and unpickleable.
The load still seems to run OK, but it is marked as failure. How can I get rid of this error?David Yang
02/07/2022, 9:20 PMVamsi Reddy
02/08/2022, 12:08 AMDaniel Saxton
02/08/2022, 1:19 AMOvo Ojameruaye
02/08/2022, 7:58 AMAmichai Ben Ami
02/08/2022, 12:16 PMdb-upgrade] Error applying Hasura metadata from /prefect-server/services/hasura/migrations/metadata.yaml
I could not find anything that changed from our side.
any idea?
Thanks 🙏Antonio Manuel BR
02/08/2022, 12:58 PMsubflow_res.result[deployed_model].result
). 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 Naul
02/08/2022, 1:19 PMThomas Pedersen
02/08/2022, 2:37 PMBruno Murino
02/08/2022, 2:54 PMArchie Kennedy-Dyson
02/08/2022, 3:09 PMAndrew Lawlor
02/08/2022, 3:24 PMMatthew Seligson
02/08/2022, 5:42 PMMadison Schott
02/08/2022, 8:19 PMre_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 Shaffner
02/08/2022, 8:42 PMLeon Kozlowski
02/08/2022, 9:47 PMTony Yun
02/08/2022, 9:51 PM[context]
local /.prefect/config.yaml
but when released to Cloud, it says the CONTEXT not exists. But I don’t find where can create that on UI.Gaurang Katre
02/08/2022, 10:25 PMtable_dest
, to write to a GCS bucket. Is there a Task or a way to do this?Ifeanyi Okwuchi
02/08/2022, 10:39 PMcreate_flow_run
to run a flow multiple times with different parameters. Here is my code and the error i'm getting.vinoth paari
02/09/2022, 5:00 AMKevin
02/09/2022, 5:07 AMRomain
02/09/2022, 7:10 AM