Skip to content

Commit 3fd9e60

Browse files
bugfix , missing context + version upgrade
1 parent 040306d commit 3fd9e60

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

memphis/memphis.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -805,7 +805,7 @@ async def __consume(self, callback):
805805
await callback(memphis_messages, None, self.context)
806806
await asyncio.sleep(self.pull_interval_ms/1000)
807807
except asyncio.TimeoutError:
808-
await callback([], MemphisError("Memphis: TimeoutError"))
808+
await callback([], MemphisError("Memphis: TimeoutError"), self.context)
809809
continue
810810
except Exception as e:
811811
if self.connection.is_connection_active:

setup.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
setup(
88
name='memphis-py',
99
packages=['memphis'],
10-
version='0.2.8',
10+
version='0.2.9',
1111
license='Apache-2.0',
1212
description='A powerful messaging platform for modern developers',
1313
long_description=long_description,
@@ -16,7 +16,7 @@
1616
author='Memphis.dev',
1717
author_email='team@memphis.dev',
1818
url='https://github.com/memphisdev/memphis.py',
19-
download_url='https://github.com/memphisdev/memphis.py/archive/refs/tags/v0.2.8.tar.gz',
19+
download_url='https://github.com/memphisdev/memphis.py/archive/refs/tags/v0.2.9.tar.gz',
2020
keywords=['message broker', 'devtool', 'streaming', 'data'],
2121
install_requires=[
2222
'asyncio',

version.conf

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
0.2.8
1+
0.2.9

0 commit comments

Comments
 (0)