Martim Lobao
09/12/2021, 9:52 AMKevin Kho
Kevin Kho
Martim Lobao
09/13/2021, 3:05 PMINFO
martim_peopledatalabs_com restarted this flow run
INFO
martim_peopledatalabs_com restarted this flow run
INFO agent
Submitted for execution: Task arn:aws:ecs:us-west-2:5567...
INFO GitHub
Downloading flow from GitHub storage - repo: 'peopledatalabs/prefect', path: 'src/pdlapps/orchestration/flows/build_then_release.py', ref: 'prefect-testing'
INFO GitHub
Flow successfully downloaded. Using commit: bac24...
INFO CloudFlowRunner
Beginning Flow run for 'build-then-release'
INFO CloudTaskRunner
Task 'Flow person-build': Starting task run...
INFO Flow person-build
Flow Run: <https://cloud.prefect.io/pdl/flow-run/5133d6be>...
INFO CloudTaskRunner
FAIL signal raised: FAIL('5133d6be... finished in state <Failed: "Some reference tasks failed.">')
flow setup:
person_build_flow = StartFlowRun(flow_name="person-build", project_name=get_stage(), wait=True)
release_flow = StartFlowRun(flow_name="release", project_name=get_stage(), wait=True)
with Flow(
"build-then-release",
executor=LocalDaskExecutor(num_workers=8),
result=PrefectResult(),
state_handlers=[slack_notifier, terminate_on_cancel],
) as flow:
release_flow(upstream_tasks=[person_build_flow])
Kevin Kho
Martim Lobao
09/13/2021, 3:11 PMKevin Kho
StartFlowRun
has an idempotency key by default. The idempotency key will try to start a new flow run, but because there was already an existing run with the same idempotency key so it won’t restart that sub flow. The subflow needs to be individually restartedKevin Kho
Martim Lobao
09/13/2021, 3:19 PM