mirror/hatchet
1
0
Fork 0
mirror of https://github.com/hatchet-dev/hatchet.git synced 2026-04-21 09:19:32 -05:00
Code Issues Packages Projects Releases Wiki Activity

chore: cleanup example (#184)

Browse Source
This commit is contained in:
Gabe Ruttner
2024-02-22 12:15:07 -08:00
committed by GitHub
parent 4e32c91a5f
commit 5bd42b16ec
2 changed files with 0 additions and 34 deletions
Download Patch File Download Diff File Expand all files Collapse all files
python-sdk/examples/manual_trigger/trigger-generator.py
-32
View File
@@ -1,32 +0,0 @@
from hatchet_sdk import Hatchet
from dotenv import load_dotenv
import json
class StepRunEventType:
STEP_RUN_EVENT_TYPE_STARTED = 'STEP_RUN_EVENT_TYPE_STARTED'
STEP_RUN_EVENT_TYPE_COMPLETED = 'STEP_RUN_EVENT_TYPE_COMPLETED'
STEP_RUN_EVENT_TYPE_FAILED = 'STEP_RUN_EVENT_TYPE_FAILED'
STEP_RUN_EVENT_TYPE_CANCELLED = 'STEP_RUN_EVENT_TYPE_CANCELLED'
STEP_RUN_EVENT_TYPE_TIMED_OUT = 'STEP_RUN_EVENT_TYPE_TIMED_OUT'
load_dotenv()
hatchet = Hatchet().client
workflowRunId = hatchet.admin.run_workflow("ManualTriggerWorkflow", {
"test": "test"
})
listener = hatchet.listener.stream(workflowRunId)
for event in listener:
# TODO FIXME step run is not exported easily from the hatchet_sdk and event type and event.step is not defined on
# the event object, so fix this before merging...
# if event.step == 'step2' and event.type == StepRunEventType.STEP_RUN_EVENT_TYPE_COMPLETED:
# listener.abort()
if event.type == StepRunEventType.STEP_RUN_EVENT_TYPE_COMPLETED:
print('Step completed: ' + json.dumps(event.payload))
print('Workflow finished')
python-sdk/examples/manual_trigger/trigger-on.py
-2
View File
@@ -12,5 +12,3 @@ workflowRunId = client.admin.run_workflow("ManualTriggerWorkflow", {
client.listener.on(workflowRunId, lambda event: print(
'EVENT: ' + event.type + ' ' + json.dumps(event.payload)))
# TODO - need to hangup the listener if the workflow is completed