Skip to content
This repository was archived by the owner on Mar 26, 2025. It is now read-only.

Commit 3b8510f

Browse files
authored
fix: expose listener on hatchet (#159)
* fix: expose listener on Hatchet client * release: 0.36.9
1 parent 2eb5176 commit 3b8510f

File tree

3 files changed

+7
-2
lines changed

3 files changed

+7
-2
lines changed

examples/fanout/stream.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,11 +9,12 @@
99
from hatchet_sdk import new_client
1010
from hatchet_sdk.clients.admin import TriggerWorkflowOptions
1111
from hatchet_sdk.clients.run_event_listener import StepRunEventType
12+
from hatchet_sdk.v2.hatchet import Hatchet
1213

1314

1415
async def main():
1516
load_dotenv()
16-
hatchet = new_client()
17+
hatchet = Hatchet()
1718

1819
# Generate a random stream key to use to track all
1920
# stream events for this workflow run.

hatchet_sdk/hatchet.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -197,6 +197,10 @@ def event(self):
197197
def rest(self):
198198
return self._client.rest
199199

200+
@property
201+
def listener(self):
202+
return self._client.listener
203+
200204
concurrency = staticmethod(concurrency)
201205

202206
workflow = staticmethod(workflow)

pyproject.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
[tool.poetry]
22
name = "hatchet-sdk"
3-
version = "0.36.8"
3+
version = "0.36.9"
44
description = ""
55
authors = ["Alexander Belanger <[email protected]>"]
66
readme = "README.md"

0 commit comments

Comments
 (0)