Rafał Bielicki
05/12/2023, 11:40 AMJeff Hale
05/12/2023, 3:25 PMprefect version
?run_deployment
or a schedule?
• Are you using Cloud or OSS?
• If Cloud, provide workspace and flow run ids
If using OSS, state transitions can be retrieved with the client with this script, and that information could be helpful:
# usage: python <file>.py <FLOW_RUN_ID>
from prefect import get_client
async def main(flow_run_id):
async with get_client() as client:
states = await client.read_flow_run_states(flow_run_id)
for state in states:
print(state.timestamp, state.type.name, state.name)
import asyncio
import sys
asyncio.run(main(sys.argv[1]))
Rafał Bielicki
05/12/2023, 8:15 PMProcess
2. Flow has 0 retries & task has 3 retreis with bachoff. But this run is not failing just running 2 times in a row.
3. Run is managed by agnet 2.7.10
4. It is just task inside a flow.
5. run_deployment
6. OSSZanie
05/12/2023, 8:39 PMRafał Bielicki
05/15/2023, 6:28 PM2023-05-15T16:15:41.963169+00:00 SCHEDULED Scheduled
2023-05-15T16:15:42.289343+00:00 PENDING Pending
2023-05-15T16:15:42.304417+00:00 PENDING Pending
2023-05-15T16:15:48.667443+00:00 RUNNING Running
2023-05-15T16:15:49.092928+00:00 RUNNING Running
2023-05-15T16:15:49.396154+00:00 COMPLETED Completed
2023-05-15T16:15:49.489030+00:00 FAILED Failed
Zanie
05/15/2023, 7:04 PMRafał Bielicki
05/15/2023, 7:49 PMFinished in state Cached(type=COMPLETED)
Zanie
05/15/2023, 7:53 PMFinished in state
is a log from the run itselfSubmitting flow run <id>
displayed on one agent twice or both agents once?Rafał Bielicki
05/15/2023, 7:56 PMZanie
05/15/2023, 8:00 PMRafał Bielicki
05/15/2023, 8:03 PMZanie
05/15/2023, 8:33 PMRafał Bielicki
05/16/2023, 6:46 AMZanie
05/16/2023, 2:15 PMRafał Bielicki
05/16/2023, 2:17 PMProcess
infra runs.Zanie
05/16/2023, 4:59 PMRafał Bielicki
05/16/2023, 5:40 PMZanie
05/16/2023, 8:54 PMRafał Bielicki
05/17/2023, 7:38 AM