Hourglass.Workflow.Info (hourglass v0.1.0)

Per-activation context the evaluator exposes via Hourglass.Workflow.info/0.

Built lazily from the active Hourglass.Workflow.State (set in the evaluator's process dict by mark_evaluator_active/1) when a workflow body calls Workflow.info/0. Cleared by the evaluator's unmark_evaluator/0 on exit, regardless of completion shape.

The task_queue is the queue the workflow itself is running on. The v3 source-ingest workflow threads this through to the parse_and_emit_source / chunk_and_emit_markdown_bytes activities so that the :workflow_start outbox entries those activities append for child workflows carry the same queue, keeping all per-source per-chunk workflows on the same worker.

Summary

Types

t()

Types

t()

@type t() :: %Hourglass.Workflow.Info{
  run_id: String.t() | nil,
  task_queue: String.t()
}