https://prefect.io logo
Title
m

Manoj

03/26/2023, 8:45 AM
Hi, I am getting this error when using DaskTaskRunner, could you please help
__init__(__self__, *args, **kwargs)
File "C:\Users\Administrator\anaconda3\envs\prefect_test\Lib\site-packages\prefect\flows.py", line 183, in __init__
self.parameters = parameter_schema(self.fn)
^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\Administrator\anaconda3\envs\prefect_test\Lib\site-packages\prefect\utilities\callables.py", line 306, in parameter_schema
model = pydantic.create_model("Parameters", __config__=ModelConfig, **model_fields)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "pydantic\main.py", line 1026, in pydantic.main.create_model
File "pydantic\main.py", line 197, in pydantic.main.ModelMetaclass.__new__
File "pydantic\fields.py", line 506, in pydantic.fields.ModelField.infer
File "pydantic\fields.py", line 436, in pydantic.fields.ModelField.__init__
File "pydantic\fields.py", line 546, in pydantic.fields.ModelField.prepare
File "pydantic\fields.py", line 570, in pydantic.fields.ModelField._set_default_and_type
File "pydantic\fields.py", line 439, in pydantic.fields.ModelField.get_default
File "pydantic\utils.py", line 693, in pydantic.utils.smart_deepcopy
File "C:\Users\Administrator\anaconda3\envs\prefect_test\Lib\copy.py", line 172, in deepcopy
y = _reconstruct(x, memo, *rv)
^^^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\Administrator\anaconda3\envs\prefect_test\Lib\copy.py", line 273, in _reconstruct
y.__setstate__(state)
File "C:\Users\Administrator\anaconda3\envs\prefect_test\Lib\site-packages\prefect_dask\task_runners.py", line 330, in __setstate__
self._client = distributed.get_client()
^^^^^^^^^^^^^^^^^^^^^^^^
File "C:\Users\Administrator\anaconda3\envs\prefect_test\Lib\site-packages\distributed\worker.py", line 2782, in get_client
raise ValueError("No global client found and no address provi