Skip to content

Commit 54a99ab

Browse files
committed
fix tests for slice
1 parent 77555f6 commit 54a99ab

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

unit_tests/sources/streams/concurrent/test_adapters.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -143,6 +143,7 @@ def test_stream_partition(transformer, expected_records):
143143
def test_stream_partition_raising_exception(exception_type, expected_display_message):
144144
stream = Mock()
145145
stream.get_error_display_message.return_value = expected_display_message
146+
stream.name = _STREAM_NAME
146147

147148
message_repository = InMemoryMessageRepository()
148149
_slice = None
@@ -169,10 +170,10 @@ def test_stream_partition_raising_exception(exception_type, expected_display_mes
169170
[
170171
pytest.param(
171172
{"partition": 1, "k": "v"},
172-
hash(("stream", '{"k": "v", "partition": 1}')),
173+
1088629586613270006,
173174
id="test_hash_with_slice",
174175
),
175-
pytest.param(None, hash("stream"), id="test_hash_no_slice"),
176+
pytest.param(None, 5149571505982114308, id="test_hash_no_slice"),
176177
],
177178
)
178179
def test_stream_partition_hash(_slice, expected_hash):

0 commit comments

Comments
 (0)