Skip to content

Commit

Permalink
Fixed flake8 errors
Browse files Browse the repository at this point in the history
  • Loading branch information
agronholm committed Nov 22, 2016
1 parent e90c843 commit 116fffa
Show file tree
Hide file tree
Showing 3 changed files with 10 additions and 10 deletions.
10 changes: 5 additions & 5 deletions asphalt/wamp/__init__.py
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
from .client import *
from .component import *
from .context import *
from .events import *
from .registry import *
from .client import * # noqa
from .component import * # noqa
from .context import * # noqa
from .events import * # noqa
from .registry import * # noqa
6 changes: 3 additions & 3 deletions asphalt/wamp/client.py
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import logging
from asyncio import wait, wait_for, sleep, Future, get_event_loop, FIRST_EXCEPTION, Task
from asyncio import wait, wait_for, sleep, Future, get_event_loop, FIRST_EXCEPTION, Task # noqa
from asyncio.futures import CancelledError
from functools import partial
from inspect import isawaitable
Expand Down Expand Up @@ -361,8 +361,8 @@ async def do_connect() -> None:
transport.close()

self._session = self._session_details = transport = None
if (self.max_reconnection_attempts is not None
and attempts > self.max_reconnection_attempts):
if (self.max_reconnection_attempts is not None and
attempts > self.max_reconnection_attempts):
raise

logger.info('Connection failed (attempt %d): %s(%s); reconnecting in %d '
Expand Down
4 changes: 2 additions & 2 deletions asphalt/wamp/component.py
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@ class WAMPComponent(Component):
context variables.
"""

def __init__(self, clients: Dict[str, Dict[str, Any]]=None, **default_client_args):
def __init__(self, clients: Dict[str, Dict[str, Any]] = None, **default_client_args):
"""
If the ``clients`` argument is omitted or empty, a default client with the context
attribute ``wamp`` will be created that connects to the realm named ``default``.
Expand All @@ -34,7 +34,7 @@ def __init__(self, clients: Dict[str, Dict[str, Any]]=None, **default_client_arg
for the default client if ``clients`` is not specified
"""
check_argument_types()
assert check_argument_types()
if not clients:
default_client_args.setdefault('context_attr', 'wamp')
clients = {'default': default_client_args}
Expand Down

0 comments on commit 116fffa

Please sign in to comment.