Adam Brusselback
09/01/2022, 1:45 AMSep 1 01:41:12 check-prefectagent01 prefect[14263]: 01:41:12.436 | INFO | prefect.agent - Submitting flow run '49507f89-c9e5-49b5-8b28-4e522f9f4253'
Sep 1 01:41:14 check-prefectagent01 prefect[14263]: 01:41:14.575 | INFO | prefect.infrastructure.process - Opening process 'abstract-roadrunner'...
Sep 1 01:41:14 check-prefectagent01 prefect[14263]: 01:41:14.585 | INFO | prefect.agent - Completed submission of flow run '49507f89-c9e5-49b5-8b28-4e522f9f4253'
Sep 1 01:41:16 check-prefectagent01 prefect[14263]: 01:41:16.336 | ERROR | Flow run 'abstract-roadrunner' - Flow could not be retrieved from deployment.
Sep 1 01:41:16 check-prefectagent01 prefect[14263]: Traceback (most recent call last):
Sep 1 01:41:16 check-prefectagent01 prefect[14263]: File "/usr/local/lib/python3.7/dist-packages/prefect/engine.py", line 256, in retrieve_flow_then_begin_flow_run
Sep 1 01:41:16 check-prefectagent01 prefect[14263]: flow = await load_flow_from_flow_run(flow_run, client=client)
Sep 1 01:41:16 check-prefectagent01 prefect[14263]: File "/usr/local/lib/python3.7/dist-packages/prefect/client.py", line 103, in with_injected_client
Sep 1 01:41:16 check-prefectagent01 prefect[14263]: return await fn(*args, **kwargs)
Sep 1 01:41:16 check-prefectagent01 prefect[14263]: File "/usr/local/lib/python3.7/dist-packages/prefect/deployments.py", line 54, in load_flow_from_flow_run
Sep 1 01:41:16 check-prefectagent01 prefect[14263]: await storage_block.get_directory(from_path=deployment.path, local_path=".")
Sep 1 01:41:16 check-prefectagent01 prefect[14263]: File "/usr/local/lib/python3.7/dist-packages/prefect/filesystems.py", line 132, in get_directory
Sep 1 01:41:16 check-prefectagent01 prefect[14263]: shutil.copytree(from_path, local_path)
Sep 1 01:41:16 check-prefectagent01 prefect[14263]: File "/usr/lib/python3.7/shutil.py", line 321, in copytree
Sep 1 01:41:16 check-prefectagent01 prefect[14263]: os.makedirs(dst)
Sep 1 01:41:16 check-prefectagent01 prefect[14263]: File "/usr/lib/python3.7/os.py", line 221, in makedirs
Sep 1 01:41:16 check-prefectagent01 prefect[14263]: mkdir(name, mode)
Sep 1 01:41:16 check-prefectagent01 prefect[14263]: FileExistsError: [Errno 17] File exists: '.'
Sep 1 01:41:16 check-prefectagent01 prefect[14263]: 01:41:16.648 | INFO | prefect.infrastructure.process - Process 'abstract-roadrunner' exited cleanly.
Looks like the difference is my VM that is having the issue is running Debian 10 and Python 3.7, and the Docker container is running Python 3.9.if sys.version_info < (3, 8):
shutil.copytree(from_path, local_path)
else:
shutil.copytree(from_path, local_path, dirs_exist_ok=True)
Jeff Hale
09/01/2022, 12:05 PMAdam Brusselback
09/01/2022, 12:09 PM