Created
July 15, 2021 21:58
-
-
Save mrocklin/0c01c5427358c167a89d5bd34582cd30 to your computer and use it in GitHub Desktop.
It looks like since this example was created we stopped allowing types in
the register_worker_plugin method. You'll have to instantiate the
AddProcessPool class before sending it to the workers. Something
like client.register_worker_plugin(AddProcessPool())
…On Fri, Jan 6, 2023 at 1:08 PM Renan Francisco Santos Souza < ***@***.***> wrote:
***@***.**** commented on this gist.
------------------------------
Hi, I tried to run this example as is, but I get error here:
TypeError: AddProcessPool.setup() missing 1 required positional argument:
'self'
I'm trying to access the worker instance inside the WorkerPlugin, like in
the ErrorLogger example
<https://distributed.dask.org/en/stable/plugins.html>:
ts = self.worker.tasks[key]
and I'm struggling with it.
Any advice?
I'm on Dask '2022.12.0'
—
Reply to this email directly, view it on GitHub
<https://gist.github.com/0c01c5427358c167a89d5bd34582cd30#gistcomment-4427362>
or unsubscribe
<https://github.com/notifications/unsubscribe-auth/AACKZTB4ATKXAGCSFMR6LZLWRCCUHBFKMF2HI4TJMJ2XIZLTSKBKK5TBNR2WLJDHNFZXJJDOMFWWLK3UNBZGKYLEL52HS4DFQKSXMYLMOVS2I5DSOVS2I3TBNVS3W5DIOJSWCZC7OBQXE5DJMNUXAYLOORPWCY3UNF3GS5DZVRZXKYTKMVRXIX3UPFYGLK2HNFZXIQ3PNVWWK3TUUZ2G64DJMNZZDAVEOR4XAZNEM5UXG5FFOZQWY5LFVEYTCMBWHE4DSMRVU52HE2LHM5SXFJTDOJSWC5DF>
.
You are receiving this email because you authored the thread.
Triage notifications on the go with GitHub Mobile for iOS
<https://apps.apple.com/app/apple-store/id1477376905?ct=notification-email&mt=8&pt=524675>
or Android
<https://play.google.com/store/apps/details?id=com.github.android&referrer=utm_campaign%3Dnotification-email%26utm_medium%3Demail%26utm_source%3Dgithub>
.
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
This notebook corresponds to the video: Advanced Dask Customization | Customizing Dask Workers | Matt Rocklin.
Note that while executing the cells, you need to create and register the
WorkerPluginbefore uncommentingwith dask.annotate(executor="processes", retries=10)::)