Linnea Sahlberg
04/27/2021, 7:15 PMStartFlowRun
and running into an issue where the flow cannot be found, even though that flow exists. I’ve attached the stack trace of the error as well as a screenshot of our flows, to show that we do have one named final_stats-staging
. Any help here would be great- thanks!Jenny
04/27/2021, 7:20 PMLinnea Sahlberg
04/27/2021, 7:24 PMdef build_flow() -> Flow:
start_final_stats_flow = StartFlowRun(wait=False)
with Flow(
FLOW_NAME,
executor=LocalDaskExecutor(scheduler="threads"),
) as flow:
final_stats_flow_name = resolve_final_stats_flow_name()
final_stats_params = generate_final_stats_params.map(map_result)
start_final_stats_flow.map(
parameters=final_stats_params,
project_name="minion_pipeline",
flow_name=unmapped(final_stats_flow_name),
)
return flow
@task(result=PrefectResult())
def resolve_final_stats_flow_name() -> str:
if is_production():
return "final_stats-production"
return "final_stats-staging"
Linnea Sahlberg
04/27/2021, 7:25 PMLinnea Sahlberg
04/27/2021, 7:28 PMStartFlowRun
is v0.14+ and the final_stats-staging
flow is prefect v0.12Jenny
04/27/2021, 7:33 PMproject_name=unmapped("minion_pipeline")
Linnea Sahlberg
04/27/2021, 7:57 PM