chore: regenerate examples (#2208)

Co-authored-by: GitHub Action <action@github.com>
This commit is contained in:
github-actions[bot]
2025-08-26 15:24:07 -04:00
committed by GitHub
parent cf0aa21623
commit a50579d837
2 changed files with 58 additions and 0 deletions

View File

@@ -0,0 +1,19 @@
from pydantic import BaseModel
from hatchet_sdk import Context, Hatchet
class TaskInput(BaseModel):
user_id: int
class TaskOutput(BaseModel):
ok: bool
hatchet = Hatchet()
@hatchet.task(name="externally-triggered-task", input_validator=TaskInput)
async def externally_triggered_task(input: TaskInput, ctx: Context) -> TaskOutput:
return TaskOutput(ok=True)

View File

@@ -0,0 +1,39 @@
import asyncio
from pydantic import BaseModel
from hatchet_sdk import Context, Hatchet
# > Define models
class TaskInput(BaseModel):
user_id: int
class TaskOutput(BaseModel):
ok: bool
async def main() -> None:
hatchet = Hatchet()
# > Create a stub task
stub = hatchet.stubs.task(
# make sure the name and schemas exactly match the implementation
name="externally-triggered-task",
input_validator=TaskInput,
output_validator=TaskOutput,
)
# > Trigger the task
# input type checks properly
result = await stub.aio_run(input=TaskInput(user_id=1234))
# `result.ok` type checks properly
print("Is successful:", result.ok)
if __name__ == "__main__":
asyncio.run(main())