Hello everyone
I ran into a problem when I uploaded client.upload_file to dask and received the link “Scheduler.register_worker_plugin() received an unexpected argument for the keyword ‘idempotent’”
The error is reproduced only when the code is run to the prefecture after the deployment.
If I run the same code, but from my local PC, then the code works.
Function for uploading a file:
@task(name=‘test_func’)
def upload_file():
log = get_run_logger()
try:
responses = client.upload_file("test_file.py ")
log.info (answers)
except for the exception in the form of e:
log.error(“An error occurred: {}”.format(str(e)))
task_runner uses DaskTaskRunner