Fix linting

dask · Sep 29, 2022 · 582bc2c · 582bc2c
1 parent 514dc68
commit 582bc2c
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/distributed/comm/ucx.py b/distributed/comm/ucx.py
@@ -330,8 +330,9 @@ async def read(self, deserializers=("cuda", "dask", "pickle", "error")):
             # "low-level" exception. The only safe thing to do is to abort.
             # (See also https://github.com/dask/distributed/pull/6574).
             self.abort()
-            raise CommClosedError("Connection closed by writer.\n"
-                                  f"Inner exception: {e!r}")
+            raise CommClosedError(
+                f"Connection closed by writer.\nInner exception: {e!r}"
+            )
         else:
             # Recv frames
             frames = [