We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b052a89 commit 3372590Copy full SHA for 3372590
unit_tests/sources/declarative/stream_slicers/test_stream_slicer_read_decorator.py
@@ -166,7 +166,7 @@ def test_isinstance_substrea_partition_router():
166
assert isinstance(wrapped_slicer, SubstreamPartitionRouter)
167
assert not isinstance(wrapped_slicer, GlobalSubstreamCursor)
168
assert not isinstance(wrapped_slicer, AsyncJobPartitionRouter)
169
- assert not isinstance(partition_router, PerPartitionWithGlobalCursor)
+ assert not isinstance(wrapped_slicer, PerPartitionWithGlobalCursor)
170
171
assert isinstance(partition_router, SubstreamPartitionRouter)
172
assert not isinstance(partition_router, GlobalSubstreamCursor)
0 commit comments