Skip to content

Commit

Permalink
Fix import
Browse files Browse the repository at this point in the history
  • Loading branch information
hweawer committed Aug 27, 2024
1 parent 937dcc3 commit c69e7de
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions src/bots/pauser.py
Original file line number Diff line number Diff line change
Expand Up @@ -9,13 +9,13 @@
from metrics.metrics import UNEXPECTED_EXCEPTIONS
from metrics.transport_message_metrics import message_metrics_filter
from schema import Or, Schema

from transport.msg_providers.data_bus import DataBusSinks, DataBusProvider
from transport.msg_providers.data_bus import DataBusProvider, DataBusSinks
from transport.msg_providers.kafka import KafkaMessageProvider
from transport.msg_providers.rabbit import MessageType, RabbitProvider
from transport.msg_storage import MessageStorage
from transport.msg_types.common import get_messages_sign_filter
from transport.msg_types.pause import PauseMessage, PauseMessageSchema
from transport.msg_types.ping import PingMessageDataBusSchema, PingMessageSchema, to_check_sum_address
from transport.types import TransportType
from web3.types import BlockData

Expand Down Expand Up @@ -61,7 +61,7 @@ def __init__(self, w3: Web3):
transports.append(
DataBusProvider(
message_schema=Schema(Or(PauseMessageSchema, PingMessageDataBusSchema)),
sinks=[DataBusSinks.PAUSE_V2, DataBusSinks.PING_V1]
sinks=[DataBusSinks.PAUSE_V2, DataBusSinks.PING_V1],
)
)

Expand Down

0 comments on commit c69e7de

Please sign in to comment.