Viet Nguyen
07/27/2022, 11:40 AMImportError: cannot import name 'DaskTaskRunner' from partially initialized module 'prefect_dask' (most likely due to a circular import)
I used 2.0b15
latest prefect-dask
on Python 3.8.13
3.9
3.8.4
3.7.13
(freshly installed Conda envs), I'm wondering if you have come across this issue before? Many thanksAnna Geller
07/27/2022, 11:55 AM(qa) ➜ prefect-deployment-patterns git:(main) ✗ python mapping_and_state_handling/dask_flow.py
07:54:53.000 | DEBUG | prefect.client - Connecting to API at <http://127.0.0.1:4200/api/>
07:54:53.120 | INFO | prefect.engine - Created flow run 'hopping-turaco' for flow 'greetings'
07:54:53.120 | INFO | Flow run 'hopping-turaco' - Starting 'DaskTaskRunner'; submitted tasks will be run concurrently...
07:54:53.120 | DEBUG | prefect.task_runner.dask - Starting task runner...
07:54:53.121 | INFO | prefect.task_runner.dask - Creating a new Dask cluster with `distributed.deploy.local.LocalCluster`
07:54:55.157 | DEBUG | prefect.client - Connecting to API at <http://127.0.0.1:4200/api/>
07:54:55.712 | INFO | prefect.task_runner.dask - The Dask dashboard is available at <http://127.0.0.1:8787/status>
07:54:55.721 | DEBUG | prefect.client - Connecting to API at <http://127.0.0.1:4200/api/>
07:54:56.075 | DEBUG | Flow run 'hopping-turaco' - Executing flow 'greetings' for flow run 'hopping-turaco'...
07:54:56.078 | DEBUG | Flow run 'hopping-turaco' - Beginning execution...
07:54:56.113 | INFO | Flow run 'hopping-turaco' - Created task run 'say_hello-811087cd-0' for task 'say_hello'
07:54:57.112 | INFO | Flow run 'hopping-turaco' - Submitted task run 'say_hello-811087cd-0' for execution.
07:54:57.147 | INFO | Flow run 'hopping-turaco' - Created task run 'say_goodbye-261e56a8-0' for task 'say_goodbye'
07:54:57.162 | INFO | Flow run 'hopping-turaco' - Submitted task run 'say_goodbye-261e56a8-0' for execution.
07:54:57.219 | INFO | Flow run 'hopping-turaco' - Created task run 'say_hello-811087cd-1' for task 'say_hello'
07:54:57.235 | INFO | Flow run 'hopping-turaco' - Submitted task run 'say_hello-811087cd-1' for execution.
07:54:57.248 | DEBUG | prefect.client - Connecting to API at <http://127.0.0.1:4200/api/>
07:54:57.296 | INFO | Flow run 'hopping-turaco' - Created task run 'say_goodbye-261e56a8-1' for task 'say_goodbye'
07:54:57.312 | INFO | Flow run 'hopping-turaco' - Submitted task run 'say_goodbye-261e56a8-1' for execution.
07:54:57.347 | INFO | Flow run 'hopping-turaco' - Created task run 'say_hello-811087cd-2' for task 'say_hello'
07:54:57.353 | INFO | Flow run 'hopping-turaco' - Submitted task run 'say_hello-811087cd-2' for execution.
07:54:57.390 | INFO | Flow run 'hopping-turaco' - Created task run 'say_goodbye-261e56a8-2' for task 'say_goodbye'
07:54:57.396 | INFO | Flow run 'hopping-turaco' - Submitted task run 'say_goodbye-261e56a8-2' for execution.
07:54:57.434 | INFO | Flow run 'hopping-turaco' - Created task run 'say_hello-811087cd-3' for task 'say_hello'
07:54:57.443 | INFO | Flow run 'hopping-turaco' - Submitted task run 'say_hello-811087cd-3' for execution.
07:54:57.472 | INFO | Flow run 'hopping-turaco' - Created task run 'say_goodbye-261e56a8-3' for task 'say_goodbye'
07:54:57.482 | INFO | Flow run 'hopping-turaco' - Submitted task run 'say_goodbye-261e56a8-3' for execution.
07:54:57.590 | DEBUG | prefect.task_runner.dask - Shutting down task runner...
07:54:58.052 | INFO | Flow run 'hopping-turaco' - Finished in state Completed('All states completed.')
07:54:58.057 | DEBUG | prefect.client - Connecting to API at <http://127.0.0.1:4200/api/>
Viet Nguyen
07/27/2022, 11:57 AMAnna Geller
07/27/2022, 12:01 PMViet Nguyen
07/27/2022, 12:04 PMpyenv
and conda
, nothing worked 😿