Merge pull request #78 from anomaly/alpha-11

Alpha 11 - Event refactor

Author: devraj

docs/docs/python-sdk.md

@@ -298,7 +298,6 @@ async def main():
 
     # Used to control the event loop
     asyncio_event = asyncio.Event()
-    asyncio_event.set()
 
     async for updates in Alarms.follow(
         asyncio_event=asyncio_event,
@@ -310,7 +309,7 @@ async def main():
         # Examples of stopping the loop if
         # we got no updates
         if len(updates.updates) == 0:
-            asyncio_event.clear()
+            asyncio_event.set()
 
 if __name__ == "__main__":
     asyncio.run(main())

examples/alarm.py

@@ -15,7 +15,6 @@ async def main():
     cc.api_key = api_key
 
     event = asyncio.Event()
-    event.set()
 
     async for updates in Alarms.follow(
         asyncio_event=event,
@@ -25,7 +24,7 @@ async def main():
             print(update)
 
         if len(updates.updates) == 0:
-            event.clear()
+            event.set()
 
 
 

examples/events.py

@@ -46,7 +46,6 @@ async def main():
     cc.api_key = api_key
 
     event = asyncio.Event()
-    event.set()
 
     async for updates in Event.follow(
         asyncio_event=event,

gallagher/cc/core.py

@@ -520,7 +520,7 @@ async def follow(
                 verify=cls._ssl_context(),
             ) as _httpx_async:
 
-            while asyncio_event.is_set():
+            while not asyncio_event.is_set():
                 try:
                     response = await _httpx_async.get(
                         f"{url}",  # required to turn pydantic object to str

poetry.lock

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "gallagher"
-version = "0.1.0-alpha.10"
+version = "0.1.0-alpha.11"
 description = "The missing developer toolkit for Gallagher Command Centre"
 authors = ["Dev Mukherjee <[email protected]>"]
 readme = "README.md"
@@ -32,7 +32,7 @@ typing-extensions = "^4.11.0"
 annotated-types = "^0.7.0"
 certifi = "^2025.1.31"
 idna = "^3.7"
-packaging = "^24.1"
+packaging = "^25.0"
 pluggy = "^1.3.0"
 anyio = "^4.3.0"
 aiohttp = "^3.9.4"

pyproject.toml

@@ -65,7 +65,6 @@ async def test_event_updates():
     # Make an asyncio Event, this is used to signal the event to stop
     # use this to cancel the loop
     event = asyncio.Event()
-    event.set()
     count = 0
 
     async for updates in Event.follow(
@@ -75,5 +74,4 @@ async def test_event_updates():
             assert type(update_event) is EventSummary
             count += 1
             if count > 3:
-                event.clear()
-                break
+                event.set()