Skip to content

Commit b27ee5f

Browse files
committed
Fix lint
Signed-off-by: Tim Paine <3105306+timkpaine@users.noreply.github.com>
1 parent 2f65492 commit b27ee5f

1 file changed

Lines changed: 1 addition & 4 deletions

File tree

csp/tests/adapters/test_kafka.py

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@
1616
)
1717
from csp.utils.datetime import utc_now
1818

19-
2019
from .kafka_utils import _precreate_topic
2120

2221

@@ -206,9 +205,7 @@ def graph(symbols: list, count: int):
206205
_precreate_topic(kafkaadapter, topic)
207206
symbols = ["AAPL", "MSFT"]
208207
count = 50
209-
results = csp.run(
210-
graph, symbols, count * 2, starttime=utc_now(), endtime=timedelta(seconds=10), realtime=True
211-
)
208+
results = csp.run(graph, symbols, count * 2, starttime=utc_now(), endtime=timedelta(seconds=10), realtime=True)
212209
for symbol in symbols:
213210
pub = results[f"pall_{symbol}"]
214211
sub = results[f"sall_{symbol}"]

0 commit comments

Comments
 (0)