Update for black (#4081)

Update for black-20.8b1

distributed/actor.py

@@ -11,7 +11,7 @@
 
 
 class Actor(WrappedKey):
-    """ Controls an object on a remote worker
+    """Controls an object on a remote worker
 
     An actor allows remote control of a stateful object living on a remote
     worker.  Method calls on this object trigger operations on the remote
@@ -195,7 +195,7 @@ async def func(**msg):
 
 
 class ActorFuture:
-    """ Future to an actor's method call
+    """Future to an actor's method call
 
     Whenever you call a method on an Actor you get an ActorFuture immediately
     while the computation happens in the background.  You can call ``.result``

distributed/batched.py

@@ -13,7 +13,7 @@
 
 
 class BatchedSend:
-    """ Batch messages in batches on a stream
+    """Batch messages in batches on a stream
 
     This takes an IOStream and an interval (in ms) and ensures that we send no
     more than one message every interval milliseconds.  We send lists of
@@ -109,7 +109,7 @@ def _background_send(self):
         self.stopped.set()
 
     def send(self, msg):
-        """ Schedule a message for sending to the other side
+        """Schedule a message for sending to the other side
 
         This completes quickly and synchronously
         """
@@ -124,7 +124,7 @@ def send(self, msg):
 
     @gen.coroutine
     def close(self, timeout=None):
-        """ Flush existing messages and then close comm
+        """Flush existing messages and then close comm
 
         If set, raises `tornado.util.TimeoutError` after a timeout.
         """

distributed/cli/tests/test_dask_scheduler.py

@@ -320,7 +320,7 @@ def test_preload_remote_module(loop, tmp_path):
                 str(tmp_path / "scheduler-file.json"),
                 "--preload",
                 "http://localhost:9382/scheduler_info.py",
-            ],
+            ]
         ) as proc:
             with Client(
                 scheduler_file=tmp_path / "scheduler-file.json", loop=loop