Normalize noqa directives

warning: Invalid rule code provided to `# noqa`

Author: DimitriPapadopoulos

distributed/cfexecutor.py

@@ -30,7 +30,7 @@ def _cascade_future(future, cf_future):
         try:
             typ, exc, tb = result
             raise exc.with_traceback(tb)
-        except BaseException as exc:  # noqa: B036
+        except BaseException as exc:
             cf_future.set_exception(exc)
 
 

distributed/tests/test_client.py

@@ -6390,7 +6390,7 @@ async def test_profile_server_disabled(c, s, a, b):
 async def test_await_future(c, s, a, b):
     future = c.submit(inc, 1)
 
-    async def f():  # flake8: noqa
+    async def f():
         result = await future
         assert result == 2
 

distributed/utils.py

@@ -468,7 +468,7 @@ def __init__(self, target: Callable[[], None], daemon: bool, name: str):
         def wrapper() -> None:
             try:
                 target()
-            except BaseException as e:  # noqa: B036
+            except BaseException as e:
                 self._exception = e
 
         self._thread = thread = threading.Thread(

distributed/worker.py

@@ -2994,7 +2994,7 @@ def _run_task_simple(
             # Any other `BaseException` types would ultimately be ignored by asyncio if
             # raised here, after messing up the worker state machine along their way.
             raise
-        except BaseException as e:  # noqa: B036
+        except BaseException as e:
             # Users _shouldn't_ use `BaseException`s, but if they do, we can assume they
             # aren't a reason to shut down the whole system (since we allow the
             # system-shutting-down `SystemExit` and `KeyboardInterrupt` to pass through)
@@ -3038,7 +3038,7 @@ async def _run_task_async(
             # Any other `BaseException` types would ultimately be ignored by asyncio if
             # raised here, after messing up the worker state machine along their way.
             raise
-        except BaseException as e:  # noqa: B036
+        except BaseException as e:
             # NOTE: this includes `CancelledError`! Since it's a user task, that's _not_
             # a reason to shut down the worker.
             # Users _shouldn't_ use `BaseException`s, but if they do, we can assume they