Raise only on plugin_add exceptions

dask · Jan 14, 2022 · dc3aaeb · dc3aaeb
1 parent 560bb55
commit dc3aaeb
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/distributed/worker.py b/distributed/worker.py
@@ -1504,13 +1504,17 @@ async def start(self):
 
         setproctitle("dask-worker [%s]" % self.address)
 
-        plugins_exceptions = await asyncio.gather(
+        plugins_msgs = await asyncio.gather(
             *(
                 self.plugin_add(plugin=plugin, catch_errors=False)
                 for plugin in self._pending_plugins
             ),
             return_exceptions=True,
         )
+        plugins_exceptions = []
+        for msg in plugins_msgs:
+            if isinstance(msg, Exception):
+                plugins_exceptions.append(msg)
         if len(plugins_exceptions) >= 1:
             if len(plugins_exceptions) > 1:
                 logger.error(