Skip to content

Commit

Permalink
format
Browse files Browse the repository at this point in the history
  • Loading branch information
sheldygg committed Nov 29, 2024
1 parent b236f2a commit e53b675
Show file tree
Hide file tree
Showing 18 changed files with 39 additions and 24 deletions.
2 changes: 1 addition & 1 deletion faststream/broker/publisher/fake.py
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
from collections.abc import Sequence
from functools import partial
from itertools import chain
from typing import TYPE_CHECKING, Any, Iterable, Optional
from typing import TYPE_CHECKING, Any, Optional

from faststream.broker.publisher.proto import BasePublisherProto

Expand Down
10 changes: 9 additions & 1 deletion faststream/broker/publisher/proto.py
Original file line number Diff line number Diff line change
@@ -1,5 +1,13 @@
from abc import abstractmethod
from typing import TYPE_CHECKING, Any, Callable, Generic, Iterable, Optional, Protocol, Sequence
from typing import (
TYPE_CHECKING,
Any,
Callable,
Generic,
Optional,
Protocol,
Sequence,
)

from typing_extensions import override

Expand Down
4 changes: 2 additions & 2 deletions faststream/broker/publisher/usecase.py
Original file line number Diff line number Diff line change
Expand Up @@ -4,10 +4,10 @@
TYPE_CHECKING,
Any,
Callable,
Iterable,
List,
Optional,
Tuple, Sequence,
Sequence,
Tuple,
)
from unittest.mock import MagicMock

Expand Down
4 changes: 2 additions & 2 deletions faststream/broker/utils.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,11 +8,11 @@
AsyncContextManager,
Awaitable,
Callable,
Iterable,
Optional,
Sequence,
Type,
Union,
cast, Sequence,
cast,
)

import anyio
Expand Down
4 changes: 2 additions & 2 deletions faststream/confluent/publisher/asyncapi.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,13 +2,13 @@
TYPE_CHECKING,
Any,
Dict,
Iterable,
Literal,
Optional,
Sequence,
Tuple,
Union,
cast,
overload, Sequence,
overload,
)

from typing_extensions import override
Expand Down
3 changes: 2 additions & 1 deletion faststream/confluent/publisher/usecase.py
Original file line number Diff line number Diff line change
Expand Up @@ -9,9 +9,10 @@
Dict,
Iterable,
Optional,
Sequence,
Tuple,
Union,
cast, Sequence,
cast,
)

from confluent_kafka import Message
Expand Down
3 changes: 2 additions & 1 deletion faststream/kafka/broker/broker.py
Original file line number Diff line number Diff line change
Expand Up @@ -9,10 +9,11 @@
List,
Literal,
Optional,
Sequence,
Tuple,
Type,
TypeVar,
Union, Sequence,
Union,
)

import aiokafka
Expand Down
4 changes: 2 additions & 2 deletions faststream/kafka/publisher/asyncapi.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,12 +2,12 @@
TYPE_CHECKING,
Any,
Dict,
Iterable,
Literal,
Optional,
Sequence,
Tuple,
Union,
overload, Sequence,
overload,
)

from typing_extensions import override
Expand Down
3 changes: 2 additions & 1 deletion faststream/kafka/publisher/usecase.py
Original file line number Diff line number Diff line change
Expand Up @@ -9,9 +9,10 @@
Dict,
Iterable,
Optional,
Sequence,
Tuple,
Union,
cast, Sequence,
cast,
)

from aiokafka import ConsumerRecord
Expand Down
3 changes: 2 additions & 1 deletion faststream/kafka/subscriber/factory.py
Original file line number Diff line number Diff line change
Expand Up @@ -3,9 +3,10 @@
Iterable,
Literal,
Optional,
Sequence,
Tuple,
Union,
overload, Sequence,
overload,
)

from faststream.exceptions import SetupError
Expand Down
3 changes: 2 additions & 1 deletion faststream/nats/broker/broker.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,8 +8,9 @@
Iterable,
List,
Optional,
Sequence,
Type,
Union, Sequence,
Union,
)

import anyio
Expand Down
2 changes: 1 addition & 1 deletion faststream/nats/publisher/asyncapi.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
from typing import TYPE_CHECKING, Any, Dict, Iterable, Optional, Sequence
from typing import TYPE_CHECKING, Any, Dict, Optional, Sequence

from typing_extensions import override

Expand Down
4 changes: 2 additions & 2 deletions faststream/nats/publisher/usecase.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,9 +7,9 @@
Awaitable,
Callable,
Dict,
Iterable,
Optional,
Union, Sequence,
Sequence,
Union,
)

from nats.aio.msg import Msg
Expand Down
3 changes: 2 additions & 1 deletion faststream/rabbit/broker/broker.py
Original file line number Diff line number Diff line change
Expand Up @@ -5,9 +5,10 @@
Callable,
Iterable,
Optional,
Sequence,
Type,
Union,
cast, Sequence,
cast,
)
from urllib.parse import urlparse

Expand Down
2 changes: 1 addition & 1 deletion faststream/rabbit/publisher/asyncapi.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
from typing import TYPE_CHECKING, Any, Dict, Iterable, Optional, Sequence
from typing import TYPE_CHECKING, Any, Dict, Optional, Sequence

from typing_extensions import override

Expand Down
4 changes: 2 additions & 2 deletions faststream/rabbit/publisher/usecase.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,9 +7,9 @@
Any,
Awaitable,
Callable,
Iterable,
Optional,
Union, Sequence,
Sequence,
Union,
)

from aio_pika import IncomingMessage
Expand Down
3 changes: 2 additions & 1 deletion faststream/redis/broker/broker.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,8 +7,9 @@
Iterable,
Mapping,
Optional,
Sequence,
Type,
Union, Sequence,
Union,
)
from urllib.parse import urlparse

Expand Down
2 changes: 1 addition & 1 deletion faststream/redis/publisher/asyncapi.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
from typing import TYPE_CHECKING, Any, Dict, Iterable, Optional, Union, Sequence
from typing import TYPE_CHECKING, Any, Dict, Optional, Sequence, Union

from typing_extensions import TypeAlias, override

Expand Down

0 comments on commit e53b675

Please sign in to comment.