bugfixes

Author: idanasulin2706

memphis/memphis.py

@@ -1,5 +1,3 @@
-from __future__ import annotations
-
 import asyncio
 import json
 import random
@@ -962,8 +960,8 @@ async def destroy(self):
             raise Exception(e)
 
 
-async def default_error_handler(e):
-    await print("ping exception raised", e)
+def default_error_handler(e):
+    print("ping exception raised", e)
 
 
 class Consumer:
@@ -1056,7 +1054,7 @@ async def __consume_dls(self, callback):
                 )
         except Exception as e:
             print("dls", e)
-            await callback([], MemphisError(str(e)))
+            await callback([], MemphisError(str(e)), self.context)
             return
 
     async def __ping_consumer(self, callback):
@@ -1069,7 +1067,7 @@ async def __ping_consumer(self, callback):
                 )
 
             except Exception as e:
-                await callback(e)
+                callback(e)
 
     async def destroy(self):
         """Destroy the consumer."""

setup.py

@@ -8,7 +8,7 @@
 setup(
     name="memphis-py",
     packages=["memphis"],
-    version="0.3.0",
+    version="0.3.1",
     license="Apache-2.0",
     description="A powerful messaging platform for modern developers",
     long_description=long_description,
@@ -17,7 +17,7 @@
     author="Memphis.dev",
     author_email="team@memphis.dev",
     url="https://github.com/memphisdev/memphis.py",
-    download_url="https://github.com/memphisdev/memphis.py/archive/refs/tags/v0.3.0.tar.gz",
+    download_url="https://github.com/memphisdev/memphis.py/archive/refs/tags/v0.3.1.tar.gz",
     keywords=["message broker", "devtool", "streaming", "data"],
     install_requires=["asyncio", "nats-py", "protobuf", "jsonschema", "graphql-core"],
     classifiers=[

version.conf

@@ -1 +1 @@
-0.3.0
+0.3.1