Skip to content

Commit

Permalink
fix tests for slice
Browse files Browse the repository at this point in the history
  • Loading branch information
maxi297 committed Nov 14, 2024
1 parent 77555f6 commit 54a99ab
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions unit_tests/sources/streams/concurrent/test_adapters.py
Original file line number Diff line number Diff line change
Expand Up @@ -143,6 +143,7 @@ def test_stream_partition(transformer, expected_records):
def test_stream_partition_raising_exception(exception_type, expected_display_message):
stream = Mock()
stream.get_error_display_message.return_value = expected_display_message
stream.name = _STREAM_NAME

message_repository = InMemoryMessageRepository()
_slice = None
Expand All @@ -169,10 +170,10 @@ def test_stream_partition_raising_exception(exception_type, expected_display_mes
[
pytest.param(
{"partition": 1, "k": "v"},
hash(("stream", '{"k": "v", "partition": 1}')),
1088629586613270006,
id="test_hash_with_slice",
),
pytest.param(None, hash("stream"), id="test_hash_no_slice"),
pytest.param(None, 5149571505982114308, id="test_hash_no_slice"),
],
)
def test_stream_partition_hash(_slice, expected_hash):
Expand Down

0 comments on commit 54a99ab

Please sign in to comment.