Documentation

const ticketCreated = defineWorkflow<{ ticketId: string; subject: string }>({
  name: "ticket.created",
  retry: { maxAttempts: 3 },
  handler: async (ctx) => {
    const { text } = await ctx.step.ai.generate("triage", {
      model: "claude-opus-4-8",
      prompt: `Summarise this refund request: ${ctx.event.data.subject}`,
    });

    const decision = await ctx.step.approval("refund-gate", {
      tool: "issue-refund",
      args: { ticketId: ctx.event.data.ticketId },
      risk: "high",
      summary: text,
    });

    if (decision.status === "denied") return { outcome: "denied" };

    return await ctx.step.run("refund", () => issueRefund(decision.args));
  },
});

from duraton import ApprovalRequest, GenerateOptions, RetryConfig, define_workflow
from duraton.context import StepContext


async def handle_ticket(ctx: StepContext) -> object:
    triage = await ctx.step.ai.generate("triage", GenerateOptions(
        model="claude-opus-4-8",
        prompt=f"Summarise this refund request: {ctx.event.data['subject']}",
    ))

    decision = await ctx.step.approval("refund-gate", ApprovalRequest(
        tool="issue-refund",
        args={"ticketId": ctx.event.data["ticketId"]},
        risk="high",
        summary=triage.text,
    ))

    if decision.status == "denied":
        return {"outcome": "denied"}

    return await ctx.step.run("refund", lambda: issue_refund(decision.args))


ticket_created = define_workflow(
    "ticket.created",
    handle_ticket,
    retry=RetryConfig(max_attempts=3),
)

import "duraton.dev/sdk-go/duraton"

var ticketCreated = duraton.DefineWorkflow(duraton.WorkflowDefinition{
	Name:  "ticket.created",
	Retry: &duraton.RetryConfig{MaxAttempts: 3},
	Handler: func(c *duraton.Context) (any, error) {
		ticket, err := duraton.EventData[Ticket](c)
		if err != nil {
			return nil, err
		}
		triage, err := duraton.Generate(c, "triage", duraton.GenerateOptions{
			Model:  "claude-opus-4-8",
			Prompt: "Summarise this refund request: " + ticket.Subject,
		})
		if err != nil {
			return nil, err
		}
		decision, err := duraton.Approval[RefundArgs](c, "refund-gate", duraton.ApprovalRequest{
			Tool:    "issue-refund",
			Args:    RefundArgs{TicketID: ticket.ID},
			Risk:    duraton.RiskHigh,
			Summary: triage.Text,
		})
		if err != nil {
			return nil, err
		}
		if decision.Status == duraton.Denied {
			return map[string]any{"outcome": "denied"}, nil
		}
		return duraton.Run(c, "refund", func() (Refund, error) {
			return issueRefund(decision.Args)
		})
	},
})

// inside a workflow handler
await ctx.step.emit("notify", {
  name: "ticket.created",
  app: "support-app",
  data: { ticketId: "T-421", subject: "Charged twice" },
});

# inside a workflow handler
await ctx.step.emit("notify", name="ticket.created", app="support-app", data={"ticketId": "T-421", "subject": "Charged twice"})

// inside a workflow handler
err := duraton.Emit(c, "notify", duraton.EmitOptions{
	Name: "ticket.created",
	App:  "support-app",
	Data: json.RawMessage(`{"ticketId":"T-421","subject":"Charged twice"}`),
})

curl -X POST "$DURATON_URL/events" \
  -H "Authorization: Bearer $DURATON_API_KEY" \
  -d '{"name":"ticket.created","app":"support-app","data":{"ticketId":"T-421","subject":"Charged twice"}}'