Update condition.py

Author: nadzhou

distributed/condition.py

@@ -158,7 +158,9 @@ async def wait(self, timeout=None):
             raise RuntimeError("Cannot wait on un-acquired condition")
 
         scheduler = self._get_scheduler_rpc()
-        result = await scheduler.condition_wait(name=self.name, id=self.id, timeout=timeout)
+        result = await scheduler.condition_wait(
+            name=self.name, id=self.id, timeout=timeout
+        )
         return result
 
     async def notify(self, n=1):