Josephine Douglas
04/26/2022, 11:33 PMFailed to load and execute Flow's environment: TypeError("got an unexpected keyword argument 'raise_final_state'")
What am I doing incorrectly here?Kevin Kho
raise_final_state
was added in 0.15.8 hereJosephine Douglas
04/26/2022, 11:46 PMdaily_schedule = CronSchedule("30 9 * * *", start_date=pendulum.now(tz="US/Pacific"))
flow = Flow("primary_flow", schedule=daily_schedule)
with flow:
x, y = task1()
secondary_flow = create_flow_run(flow_name='secondary_flow', project_name='ProjectName', parameters={'x': x})
wait_for_secondary_flow = wait_for_flow_run(secondary_flow, raise_final_state=True)
task2_task = task2(y)
task2_task.set_upstream(wait_for_secondary_flow)
# STORAGE
flow.storage = GitLab(...)
flow.run_config = KubernetesRun(
labels=["dev"],
image="",
cpu_limit="400m",
cpu_request="100m",
memory_limit="4096Mi",
memory_request="256Mi"
)
secondary_flow looks like this:
flow = Flow("secondary_flow", executor=LocalDaskExecutor(scheduler="threads", num_workers=8))
with flow:
brand_ids = Parameter("x", default=["test_not_exist_prefect"])
...
# STORAGE
flow.storage = GitLab(...)
flow.run_config = KubernetesRun(
labels=["dev"],
image="",
cpu_limit="400m",
cpu_request="100m",
memory_limit="4096Mi",
memory_request="256Mi"
)
Kevin Kho
Josephine Douglas
04/26/2022, 11:49 PM