Skip to content

Commit 1909e40

Browse files
committed
FIX: Use python 3.8 compatible type annotations
1 parent 1f96710 commit 1909e40

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pulsar/asyncio.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -231,7 +231,7 @@ async def close(self):
231231
self._consumer.close_async(functools.partial(_set_future, future, value=None))
232232
await future
233233

234-
async def seek(self, position: Tuple[int, int, int, int] | pulsar.MessageId):
234+
async def seek(self, position: Union[Tuple[int, int, int, int], pulsar.MessageId]):
235235
"""
236236
Reset the subscription associated with this consumer to a specific message id or publish timestamp. The message id can either be a specific message or represent the first or last messages in the topic. ...
237237
"""

0 commit comments

Comments
 (0)