Merge pull request #34 from upstash/http-client-fix

Make HttpClient Reachable

.github/workflows/release.yml

@@ -16,7 +16,7 @@ jobs:
           python-version: 3.8
 
       - name: Install Poetry
-        run: curl -sSL https://install.python-poetry.org | python3 -
+        run: curl -sSL https://install.python-poetry.org | python3 - --version 1.8.4
 
       - name: Build and publish
         run: |

.github/workflows/tests.yml

@@ -23,7 +23,7 @@ jobs:
           python-version: 3.8
 
       - name: Install Poetry
-        run: curl -sSL https://install.python-poetry.org | python3 -
+        run: curl -sSL https://install.python-poetry.org | python3 - --version 1.8.4
 
       - name: Set up Poetry environment
         run: |

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "qstash"
-version = "2.0.2"
+version = "2.0.3"
 description = "Python SDK for Upstash QStash"
 license = "MIT"
 authors = ["Upstash <[email protected]>"]

qstash/__init__.py

@@ -2,5 +2,5 @@
 from qstash.client import QStash
 from qstash.receiver import Receiver
 
-__version__ = "2.0.2"
+__version__ = "2.0.3"
 __all__ = ["QStash", "AsyncQStash", "Receiver"]

qstash/asyncio/client.py

@@ -24,31 +24,31 @@ def __init__(
         :param token: The authorization token from the Upstash console.
         :param retry: Configures how the client should retry requests.
         """
-        http = AsyncHttpClient(
+        self.http = AsyncHttpClient(
             token,
             retry,
             base_url,
         )
-        self.message = AsyncMessageApi(http)
+        self.message = AsyncMessageApi(self.http)
         """Message api."""
 
-        self.url_group = AsyncUrlGroupApi(http)
+        self.url_group = AsyncUrlGroupApi(self.http)
         """Url group api."""
 
-        self.queue = AsyncQueueApi(http)
+        self.queue = AsyncQueueApi(self.http)
         """Queue api."""
 
-        self.schedule = AsyncScheduleApi(http)
+        self.schedule = AsyncScheduleApi(self.http)
         """Schedule api."""
 
-        self.signing_key = AsyncSigningKeyApi(http)
+        self.signing_key = AsyncSigningKeyApi(self.http)
         """Signing key api."""
 
-        self.event = AsyncEventApi(http)
+        self.event = AsyncEventApi(self.http)
         """Event api."""
 
-        self.dlq = AsyncDlqApi(http)
+        self.dlq = AsyncDlqApi(self.http)
         """Dlq (Dead Letter Queue) api."""
 
-        self.chat = AsyncChatApi(http)
+        self.chat = AsyncChatApi(self.http)
         """Chat api."""

qstash/client.py

@@ -25,31 +25,31 @@ def __init__(
         :param token: The authorization token from the Upstash console.
         :param retry: Configures how the client should retry requests.
         """
-        http = HttpClient(
+        self.http = HttpClient(
             token,
             retry,
             base_url,
         )
-        self.message = MessageApi(http)
+        self.message = MessageApi(self.http)
         """Message api."""
 
-        self.url_group = UrlGroupApi(http)
+        self.url_group = UrlGroupApi(self.http)
         """Url group api."""
 
-        self.queue = QueueApi(http)
+        self.queue = QueueApi(self.http)
         """Queue api."""
 
-        self.schedule = ScheduleApi(http)
+        self.schedule = ScheduleApi(self.http)
         """Schedule api."""
 
-        self.signing_key = SigningKeyApi(http)
+        self.signing_key = SigningKeyApi(self.http)
         """Signing key api."""
 
-        self.event = EventApi(http)
+        self.event = EventApi(self.http)
         """Event api."""
 
-        self.dlq = DlqApi(http)
+        self.dlq = DlqApi(self.http)
         """Dlq (Dead Letter Queue) api."""
 
-        self.chat = ChatApi(http)
+        self.chat = ChatApi(self.http)
         """Chat api."""

tests/asyncio/test_message.py

@@ -35,7 +35,7 @@ async def assertion() -> None:
         assertion,
         initial_delay=1.0,
         retry_delay=1.0,
-        timeout=10.0,
+        timeout=60.0,
     )
 
 

tests/test_message.py

@@ -31,7 +31,7 @@ def assertion() -> None:
         assertion,
         initial_delay=1.0,
         retry_delay=1.0,
-        timeout=10.0,
+        timeout=60.0,
     )