Skip to content

Commit 7396b22

Browse files
committed
ruffed scripts
Signed-off-by: Krzysztof Milde <Krzysztof.Milde@Point72.com>
1 parent 8ce67ec commit 7396b22

2 files changed

Lines changed: 132 additions & 125 deletions

File tree

csp/adapters/kafka.py

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,14 @@
2121
from csp.impl.wiring import ReplayMode, input_adapter_def, output_adapter_def, status_adapter_def
2222
from csp.lib import _kafkaadapterimpl
2323

24-
_ = AvroMessageMapper, BytesMessageProtoMapper, DateTimeType, JSONTextMessageMapper, RawBytesMessageMapper, RawTextMessageMapper
24+
_ = (
25+
AvroMessageMapper,
26+
BytesMessageProtoMapper,
27+
DateTimeType,
28+
JSONTextMessageMapper,
29+
RawBytesMessageMapper,
30+
RawTextMessageMapper,
31+
)
2532
T = TypeVar("T")
2633

2734

0 commit comments

Comments
 (0)