Liel Bach
05/02/2023, 7:01 AMpending
stage.
Attaching an example flow run log from the pod itself (flow names and IDs are redacted):
22:11:09.051 | DEBUG | prefect.profiles - Using profile 'default'
/usr/local/lib/python3.10/runpy.py:126: RuntimeWarning: 'prefect.engine' found in sys.modules after import of package 'prefect', but prior to execution of 'prefect.engine'; this may result in unpredictable behaviour
warn(RuntimeWarning(msg))
22:11:09.084 | DEBUG | prefect.client - Connecting to API at <https://api.prefect.cloud/api/accounts/><redacted>/workspaces/<redacted>/
22:11:09.916 | INFO | Flow run 'lambda6-tarakis-instability' - Downloading flow code from storage at '/flexor'
22:11:09.918 | DEBUG | Flow run 'lambda6-tarakis-instability' - Importing flow code from 'transformations/example_flow.py:example_flow'
22:11:09.928 | DEBUG | prefect.client - Connecting to API at <https://api.prefect.cloud/api/accounts/><redacted>/workspaces/<redacted>/
It’s worth mentioning that we don’t use any special storage block, we just use the preloaded code in the image (using the --path
parameter in a flow deployment)