Run black and update setup.cfg for flake8 to ignore E701 and E704

faust/__main__.py

@@ -1,4 +1,5 @@
 """Command-line entry point."""
+
 # pragma: no cover
 from faust.cli.faust import cli
 

faust/agents/__init__.py

@@ -1,4 +1,5 @@
 """Agents."""
+
 from .agent import Agent, AgentFun, AgentT, SinkT, current_agent
 from .manager import AgentManager, AgentManagerT
 from .replies import ReplyConsumer

faust/agents/actor.py

@@ -1,4 +1,5 @@
 """Actor - Individual Agent instances."""
+
 from typing import Any, AsyncGenerator, AsyncIterator, Coroutine, Optional, Set, cast
 
 from mode import Service

faust/agents/agent.py

@@ -1,4 +1,5 @@
 """Agent implementation."""
+
 import asyncio
 import typing
 from contextlib import suppress
@@ -79,8 +80,7 @@
     from faust.app.base import App as _App
 else:
 
-    class _App:
-        ...  # noqa
+    class _App: ...  # noqa
 
 
 __all__ = ["Agent"]

faust/agents/manager.py

@@ -1,4 +1,5 @@
 """Agent manager."""
+
 import asyncio
 from collections import defaultdict
 from typing import Any, Dict, List, Mapping, MutableMapping, MutableSet, Set

faust/agents/models.py

@@ -1,4 +1,5 @@
 """Models used by agents internally."""
+
 from typing import Any
 
 from faust.models import Record

faust/agents/replies.py

@@ -1,4 +1,5 @@
 """Agent replies: waiting for replies, sending them, etc."""
+
 import asyncio
 from collections import defaultdict
 from typing import Any, AsyncIterator, MutableMapping, MutableSet, NamedTuple, Optional
@@ -33,8 +34,7 @@ def __init__(self, reply_to: str, correlation_id: str = "", **kwargs: Any) -> No
         self.__post_init__()
         super().__init__(**kwargs)
 
-    def __post_init__(self) -> None:
-        ...
+    def __post_init__(self) -> None: ...
 
     def _verify_correlation_id(self, correlation_id: str) -> None:
         if not correlation_id:

faust/app/__init__.py

@@ -1,4 +1,5 @@
 """Application."""
+
 from .base import App, BootStrategy
 
 __all__ = ["App", "BootStrategy"]

faust/app/_attached.py

@@ -2,6 +2,7 @@
 
 Attachments were used before transactions support.
 """
+
 import asyncio
 import typing
 from collections import defaultdict
@@ -29,8 +30,7 @@
     from faust.events import Event as _Event
 else:
 
-    class _Event:
-        ...  # noqa
+    class _Event: ...  # noqa
 
 
 __all__ = ["Attachment", "Attachments"]

faust/app/base.py

@@ -4,6 +4,7 @@
 Everything starts here.
 
 """
+
 import asyncio
 import importlib
 import inspect
@@ -113,17 +114,13 @@
     from faust.worker import Worker as _Worker
 else:
 
-    class _AppCommand:
-        ...  # noqa
+    class _AppCommand: ...  # noqa
 
-    class _LiveCheck:
-        ...  # noqa
+    class _LiveCheck: ...  # noqa
 
-    class _Fetcher:
-        ...  # noqa
+    class _Fetcher: ...  # noqa
 
-    class _Worker:
-        ...  # noqa
+    class _Worker: ...  # noqa
 
 
 __all__ = ["App", "BootStrategy"]

faust/app/router.py

@@ -1,4 +1,5 @@
 """Route messages to Faust nodes by partitioning."""
+
 from typing import Tuple
 
 from yarl import URL

faust/assignor/client_assignment.py

@@ -1,4 +1,5 @@
 """Client Assignment."""
+
 import copy
 from typing import List, Mapping, MutableMapping, Sequence, Set, Tuple, cast
 

faust/assignor/cluster_assignment.py

@@ -1,4 +1,5 @@
 """Cluster assignment."""
+
 from typing import List, MutableMapping, Sequence, Set, cast
 
 from faust.models import Record

faust/assignor/copartitioned_assignor.py

@@ -1,4 +1,5 @@
 """Copartitioned Assignor."""
+
 from itertools import cycle
 from math import ceil, floor
 from typing import Iterable, Iterator, MutableMapping, Optional, Sequence, Set

faust/assignor/leader_assignor.py

@@ -1,4 +1,5 @@
 """Leader assignor."""
+
 from typing import Any
 
 from mode import Service

faust/assignor/partition_assignor.py

@@ -1,4 +1,5 @@
 """Partition assignor."""
+
 import socket
 import zlib
 from collections import defaultdict

faust/auth.py

@@ -1,4 +1,5 @@
 """Authentication Credentials."""
+
 import ssl
 from typing import Any, Optional, Union
 

faust/channels.py

@@ -5,6 +5,7 @@
 The stream will iterate over incoming events in the channel.
 
 """
+
 import asyncio
 from typing import (
     Any,

faust/cli/__init__.py

@@ -1,4 +1,5 @@
 """Command-line Interface."""
+
 from .base import AppCommand, Command, argument, call_command, option
 
 __all__ = ["AppCommand", "Command", "argument", "call_command", "option"]

faust/cli/agents.py

@@ -1,4 +1,5 @@
 """Program ``faust agents`` used to list agents."""
+
 from operator import attrgetter
 from typing import Any, Callable, Optional, Sequence, Type, cast
 

faust/cli/base.py

@@ -1,4 +1,5 @@
 """Command-line programs using :pypi:`click`."""
+
 import abc
 import asyncio
 import inspect
@@ -49,8 +50,7 @@
     from faust.app import App as _App
 else:
 
-    class _App:
-        ...  # noqa
+    class _App: ...  # noqa
 
 
 try:

faust/cli/clean_versions.py

@@ -1,4 +1,5 @@
 """Program ``faust reset`` used to delete local table state."""
+
 from shutil import rmtree
 
 from .base import AppCommand

faust/cli/completion.py

@@ -2,6 +2,7 @@
 
 Supports ``bash``, ``ksh``, ``zsh``, etc.
 """
+
 import os
 from pathlib import Path
 

faust/cli/livecheck.py

@@ -1,4 +1,5 @@
 """Program ``faust worker`` used to start application from console."""
+
 from typing import Any
 
 from .worker import worker

faust/cli/model.py

@@ -1,4 +1,5 @@
 """Program ``faust model`` used to list details about a model."""
+
 from datetime import datetime
 from typing import Any, Optional, Sequence, Type
 

faust/cli/models.py

@@ -1,4 +1,5 @@
 """Program ``faust models`` used to list models available."""
+
 from operator import attrgetter
 from typing import Any, Callable, Sequence, Type, cast
 

faust/cli/params.py

@@ -1,4 +1,5 @@
 """Python :pypi:`click` parameter types."""
+
 from typing import Any, Iterable, Optional
 
 import click

faust/cli/reset.py

@@ -1,4 +1,5 @@
 """Program ``faust reset`` used to delete local table state."""
+
 from .base import AppCommand
 
 __all__ = ["reset"]

faust/cli/send.py

@@ -1,4 +1,5 @@
 """Program ``faust send`` used to send events to agents and topics."""
+
 import asyncio
 import random
 from typing import Any, Optional

faust/cli/tables.py

@@ -1,4 +1,5 @@
 """Program ``faust tables`` used to list tables."""
+
 from .base import AppCommand
 
 DEFAULT_TABLE_HELP = 'Missing description: use Table(.., help="str")'

faust/cli/worker.py

@@ -1,4 +1,5 @@
 """Program ``faust worker`` used to start application from console."""
+
 import asyncio
 import os
 import platform

faust/contrib/sentry.py

@@ -31,8 +31,7 @@
     from raven.handlers.logging import SentryHandler as _SentryHandler
 else:
 
-    class _SentryHandler:
-        ...  # noqa: E701
+    class _SentryHandler: ...  # noqa: E701
 
 
 __all__ = ["handler_from_dsn", "setup"]

faust/events.py

@@ -1,4 +1,5 @@
 """Events received in streams."""
+
 import typing
 from types import TracebackType
 from typing import Any, Awaitable, Optional, Type, Union, cast
@@ -21,8 +22,7 @@
     from .app.base import App as _App
 else:
 
-    class _App:
-        ...  # noqa
+    class _App: ...  # noqa
 
 
 USE_EXISTING_KEY = object()

faust/exceptions.py

@@ -1,4 +1,5 @@
 """Faust exceptions."""
+
 import typing
 
 __all__ = [
@@ -25,8 +26,7 @@
     from .types.models import FieldDescriptorT as _FieldDescriptorT
 else:
 
-    class _FieldDescriptorT:
-        ...  # noqa
+    class _FieldDescriptorT: ...  # noqa
 
 
 class FaustError(Exception):

faust/fixups/__init__.py

@@ -1,4 +1,5 @@
 """Transport registry."""
+
 from typing import Iterator, Type
 
 from mode.utils.imports import FactoryMapping

faust/fixups/base.py

@@ -1,4 +1,5 @@
 """Fixups - Base implementation."""
+
 from typing import Iterable
 
 from faust.types import AppT, FixupT

faust/fixups/django.py

@@ -1,4 +1,5 @@
 """Django Fixups - Integration with Django."""
+
 import os
 import typing
 import warnings
@@ -14,11 +15,9 @@
     from django.settings import Settings as _Settings
 else:
 
-    class _Apps:
-        ...  # noqa
+    class _Apps: ...  # noqa
 
-    class _Settings:
-        ...  # noqa
+    class _Settings: ...  # noqa
 
 
 __all__ = ["Fixup"]

faust/joins.py

@@ -1,4 +1,5 @@
 """Join strategies."""
+
 from typing import Any, Optional, Tuple
 
 from .types import EventT, FieldDescriptorT, JoinableT, JoinT

faust/livecheck/__init__.py

@@ -1,4 +1,5 @@
 """LiveCheck - End-to-end testing of asynchronous systems."""
+
 from .app import LiveCheck
 from .case import Case
 from .locals import current_test

faust/livecheck/app.py

@@ -1,4 +1,5 @@
 """LiveCheck - Faust Application."""
+
 import asyncio
 from datetime import timedelta
 from typing import (

faust/livecheck/case.py

@@ -1,4 +1,5 @@
 """LiveCheck - Test cases."""
+
 import traceback
 import typing
 from collections import deque
@@ -29,8 +30,7 @@
     from .app import LiveCheck as _LiveCheck
 else:
 
-    class _LiveCheck:
-        ...  # noqa
+    class _LiveCheck: ...  # noqa
 
 
 __all__ = ["Case"]
@@ -318,8 +318,7 @@ async def _send_frequency(self) -> None:
                 if self.app.is_leader():
                     await self.make_fake_request()
 
-    async def make_fake_request(self) -> None:
-        ...
+    async def make_fake_request(self) -> None: ...
 
     @Service.task
     async def _check_frequency(self) -> None:

faust/livecheck/locals.py

@@ -1,4 +1,5 @@
 """Locals - Current test & execution context."""
+
 import typing
 from typing import Optional
 
@@ -10,8 +11,7 @@
     from .runners import TestRunner as _TestRunner
 else:  # pragma: no cover
 
-    class _TestRunner:
-        ...  # noqa
+    class _TestRunner: ...  # noqa
 
 
 __all__ = [

faust/livecheck/models.py

@@ -1,4 +1,5 @@
 """LiveCheck - Models."""
+
 from datetime import datetime, timezone
 from enum import Enum
 from typing import Any, Dict, List, Mapping, Optional