Use black autoformatting

Author: syrusakbary

promise/__init__.py

@@ -10,7 +10,7 @@
     __SETUP__ = False
 
 
-VERSION = (2, 1, 0, 'final', 0)
+VERSION = (2, 1, 0, "final", 0)
 
 __version__ = get_version(VERSION)
 
@@ -22,17 +22,17 @@
         is_thenable,
         async_instance,
         get_default_scheduler,
-        set_default_scheduler
+        set_default_scheduler,
     )
     from .schedulers.immediate import ImmediateScheduler
 
     __all__ = [
-        'Promise',
-        'promise_for_dict',
-        'promisify',
-        'is_thenable',
-        'async_instance',
-        'get_default_scheduler',
-        'set_default_scheduler',
-        'ImmediateScheduler'
+        "Promise",
+        "promise_for_dict",
+        "promisify",
+        "is_thenable",
+        "async_instance",
+        "get_default_scheduler",
+        "set_default_scheduler",
+        "ImmediateScheduler",
     ]

promise/async_.py

@@ -1,12 +1,12 @@
 # Based on https://github.com/petkaantonov/bluebird/blob/master/src/promise.js
 from collections import deque
+
 if False:
     from .promise import Promise
     from typing import Any, Callable, Optional, Union  # flake8: noqa
 
 
 class Async(object):
-
     def __init__(self, trampoline_enabled=True):
         self.is_tick_used = False
         self.late_queue = deque()  # type: ignore
@@ -48,18 +48,14 @@ def invoke(self, fn, scheduler):
         if self.trampoline_enabled:
             self._async_invoke(fn, scheduler)
         else:
-            scheduler.call(
-                fn
-            )
+            scheduler.call(fn)
 
     def settle_promises(self, promise):
         # type: (Promise) -> None
         if self.trampoline_enabled:
             self._async_settle_promise(promise)
         else:
-            promise.scheduler.call(
-                promise._settle_promises
-            )
+            promise.scheduler.call(promise._settle_promises)
 
     def throw_later(self, reason, scheduler):
         # type: (Exception, Any) -> None
@@ -74,22 +70,24 @@ def fn():
     def drain_queue(self, queue):
         # type: (deque) -> None
         from .promise import Promise
+
         while queue:
             fn = queue.popleft()
-            if (isinstance(fn, Promise)):
+            if isinstance(fn, Promise):
                 fn._settle_promises()
                 continue
             fn()
 
     def drain_queue_until_resolved(self, promise):
         # type: (Promise) -> None
         from .promise import Promise
+
         queue = self.normal_queue
         while queue:
             if not promise.is_pending:
                 return
             fn = queue.popleft()
-            if (isinstance(fn, Promise)):
+            if isinstance(fn, Promise):
                 fn._settle_promises()
                 continue
             fn()

promise/compat.py

@@ -3,7 +3,6 @@
 except ImportError:
 
     class Future:  # type: ignore
-
         def __init__(self):
             raise Exception("You need asyncio for using Futures")
 
@@ -19,10 +18,10 @@ def ensure_future():  # type: ignore
     def iscoroutine(obj):  # type: ignore
         return False
 
+
 try:
     from .iterate_promise import iterate_promise
 except (SyntaxError, ImportError):
 
     def iterate_promise(promise):  # type: ignore
-        raise Exception(
-            'You need "yield from" syntax for iterate in a Promise.')
+        raise Exception('You need "yield from" syntax for iterate in a Promise.')