p101-cl-5.console

16:15:20.543 | INFO    | prefect.engine - Created flow run 'blue-flounder' for flow 'Previously unreliable pipeline'
16:15:20.612 | INFO    | Flow run 'blue-flounder' - Created task run 'Get data from API-466f2784-0' for task 'Get data from API'
16:15:20.613 | INFO    | Flow run 'blue-flounder' - Executing 'Get data from API-466f2784-0' immediately...
16:15:20.625 | ERROR   | Task run 'Get data from API-466f2784-0' - Encountered exception during execution:
Traceback (most recent call last):
  File "/Users/jeffhale/miniforge3/lib/python3.10/site-packages/prefect/engine.py", line 1048, in orchestrate_task_run
    result = await run_sync(task.fn, *args, **kwargs)
  File "/Users/jeffhale/miniforge3/lib/python3.10/site-packages/prefect/utilities/asyncutils.py", line 56, in run_sync_in_worker_thread
    return await anyio.to_thread.run_sync(call, cancellable=True)
  File "/Users/jeffhale/miniforge3/lib/python3.10/site-packages/anyio/to_thread.py", line 31, in run_sync
    return await get_asynclib().run_sync_in_worker_thread(
  File "/Users/jeffhale/miniforge3/lib/python3.10/site-packages/anyio/_backends/_asyncio.py", line 937, in run_sync_in_worker_thread
    return await future
  File "/Users/jeffhale/miniforge3/lib/python3.10/site-packages/anyio/_backends/_asyncio.py", line 867, in run
    result = context.run(func, *args)
  File "/var/folders/8q/819stl696vz3fxzpbnnsp2540000gn/T/ipykernel_55323/4175880648.py", line 9, in call_unreliable_api
    raise Exception("Our unreliable service failed")
Exception: Our unreliable service failed
16:15:20.640 | INFO    | Task run 'Get data from API-466f2784-0' - Received non-final state 'AwaitingRetry' when proposing final state 'Failed' and will attempt to run again...
16:15:21.687 | INFO    | Task run 'Get data from API-466f2784-0' - Finished in state Completed()
16:15:21.715 | INFO    | Flow run 'blue-flounder' - Created task run 'Add message to data-960bb844-0' for task 'Add message to data'
16:15:21.715 | INFO    | Flow run 'blue-flounder' - Executing 'Add message to data-960bb844-0' immediately...
16:15:21.746 | INFO    | Task run 'Add message to data-960bb844-0' - Finished in state Completed()
16:15:21.762 | INFO    | Flow run 'blue-flounder' - Created task run 'Write results to database-fbbf5571-0' for task 'Write results to database'
16:15:21.763 | INFO    | Flow run 'blue-flounder' - Executing 'Write results to database-fbbf5571-0' immediately...
16:15:21.789 | INFO    | Task run 'Write results to database-fbbf5571-0' - Finished in state Completed()
16:15:21.803 | INFO    | Flow run 'blue-flounder' - Finished in state Completed('All states completed.')
Wrote {'data': 42, 'message': "Now we're cooking!"} to database successfully!
[Completed(message=None, type=COMPLETED, result={'data': 42}),
 Completed(message=None, type=COMPLETED, result={'data': 42, 'message': "Now we're cooking!"}),
 Completed(message=None, type=COMPLETED, result='Success!')]