File tree Expand file tree Collapse file tree 2 files changed +3
-2
lines changed Expand file tree Collapse file tree 2 files changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -335,7 +335,9 @@ def _count_errors(
335335 valid_mask = (time_indices >= 0 ) & (time_indices < counts .size )
336336 if not np .all (valid_mask ):
337337 invalid_count = np .count_nonzero (~ valid_mask )
338- logger .warning (f"{ invalid_count } timestamps outside expected time range — ignored." )
338+ logger .warning (
339+ f"{ invalid_count } timestamps outside expected time range — ignored."
340+ )
339341 time_indices = time_indices [valid_mask ]
340342 unique_counts = unique_counts [valid_mask ]
341343
Original file line number Diff line number Diff line change @@ -270,7 +270,6 @@ def test_count_errors_valid_and_out_of_range(
270270
271271 np .testing .assert_array_equal (result , expected )
272272
273-
274273 @patch ("src.inspector.inspector.ClickHouseKafkaSender" )
275274 @patch ("src.inspector.inspector.ExactlyOnceKafkaProduceHandler" )
276275 @patch ("src.inspector.inspector.ExactlyOnceKafkaConsumeHandler" )
You can’t perform that action at this time.
0 commit comments