Skip to content

Commit 6d248bf

Browse files
authored
Run black and fix setup.cfg to add E701 and E704 to flake8 ignore (#609)
1 parent 4a09533 commit 6d248bf

File tree

165 files changed

+749
-1227
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

165 files changed

+749
-1227
lines changed

faust/__main__.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
"""Command-line entry point."""
2+
23
# pragma: no cover
34
from faust.cli.faust import cli
45

faust/agents/__init__.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
"""Agents."""
2+
23
from .agent import Agent, AgentFun, AgentT, SinkT, current_agent
34
from .manager import AgentManager, AgentManagerT
45
from .replies import ReplyConsumer

faust/agents/actor.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
"""Actor - Individual Agent instances."""
2+
23
from typing import Any, AsyncGenerator, AsyncIterator, Coroutine, Optional, Set, cast
34

45
from mode import Service

faust/agents/agent.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
"""Agent implementation."""
2+
23
import asyncio
34
import typing
45
from contextlib import suppress
@@ -79,8 +80,7 @@
7980
from faust.app.base import App as _App
8081
else:
8182

82-
class _App:
83-
... # noqa
83+
class _App: ... # noqa
8484

8585

8686
__all__ = ["Agent"]

faust/agents/manager.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
"""Agent manager."""
2+
23
import asyncio
34
from collections import defaultdict
45
from typing import Any, Dict, List, Mapping, MutableMapping, MutableSet, Set

faust/agents/models.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
"""Models used by agents internally."""
2+
23
from typing import Any
34

45
from faust.models import Record

faust/agents/replies.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
"""Agent replies: waiting for replies, sending them, etc."""
2+
23
import asyncio
34
from collections import defaultdict
45
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
3334
self.__post_init__()
3435
super().__init__(**kwargs)
3536

36-
def __post_init__(self) -> None:
37-
...
37+
def __post_init__(self) -> None: ...
3838

3939
def _verify_correlation_id(self, correlation_id: str) -> None:
4040
if not correlation_id:

faust/app/__init__.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
"""Application."""
2+
23
from .base import App, BootStrategy
34

45
__all__ = ["App", "BootStrategy"]

faust/app/_attached.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22
33
Attachments were used before transactions support.
44
"""
5+
56
import asyncio
67
import typing
78
from collections import defaultdict
@@ -29,8 +30,7 @@
2930
from faust.events import Event as _Event
3031
else:
3132

32-
class _Event:
33-
... # noqa
33+
class _Event: ... # noqa
3434

3535

3636
__all__ = ["Attachment", "Attachments"]

faust/app/base.py

Lines changed: 5 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@
44
Everything starts here.
55
66
"""
7+
78
import asyncio
89
import importlib
910
import inspect
@@ -113,17 +114,13 @@
113114
from faust.worker import Worker as _Worker
114115
else:
115116

116-
class _AppCommand:
117-
... # noqa
117+
class _AppCommand: ... # noqa
118118

119-
class _LiveCheck:
120-
... # noqa
119+
class _LiveCheck: ... # noqa
121120

122-
class _Fetcher:
123-
... # noqa
121+
class _Fetcher: ... # noqa
124122

125-
class _Worker:
126-
... # noqa
123+
class _Worker: ... # noqa
127124

128125

129126
__all__ = ["App", "BootStrategy"]

0 commit comments

Comments
 (0)