Crate autumn_harvest 

Durable workflow orchestration engine core.

Re-exports

pub use adaptive_limit::AdaptiveLimitConfig;

pub use admission_gate::AdmissionGate;

pub use admission_gate::AdmissionGateCache;

pub use admission_gate::AdmissionGateId;

pub use admission_gate::AdmissionGateView;

pub use admission_gate::GateMode;

pub use admission_gate::GateScope;

pub use admission_gate::MAX_ACTIVE_GATES;

pub use admission_gate::ProducerContractEntry;

pub use admission_gate::ProducerGateStatus;

pub use admission_gate::StartProducer;

pub use admission_gate::check_admission;

pub use admission_gate::global_admission_gate_cache;

pub use admission_gate::producer_contract;

pub use admission_gate::set_global_admission_gate_cache;

pub use analyzer::AnalyzerRule;

pub use analyzer::AnalyzerWarning;

pub use analyzer::ExcessiveRetriesRule;

pub use analyzer::HistoryAnalyzer;

pub use analyzer::LargePayloadRule;

pub use analyzer::SuspiciousTimerRule;

pub use builder::BuiltHarvest;

pub use builder::HarvestBuilder;

pub use builder::HarvestBuilderError;

pub use builder::StickyRoutingConfig;

pub use builder::WorkerConfig;

pub use cache::CachedWorkflowState;

pub use cache::WorkflowCache;

pub use calendar::BackfillSlot;

pub use calendar::create_calendar;

pub use calendar::delete_calendar;

pub use calendar::get_calendar;

pub use calendar::list_calendars;

pub use calendar::load_exclusions_for_calendar;

pub use calendar::plan_backfill_with_calendar;

pub use calendar::preview_schedule_firings;

pub use calendar::replace_calendar_exclusions;

pub use calendar::BusinessCalendars;

pub use calendar::BusinessDayRejection;

pub use calendar::BusinessDayResolution;

pub use calendar::Calendar;

pub use calendar::MAX_BUSINESS_DAYS;

pub use calendar::ScheduleFirePreview;

pub use calendar::add_business_days;

pub use calendar::add_business_days_bounded;

pub use calendar::apply_skip_policy;

pub use calendar::calendar_excludes_weekends;

pub use calendar::is_business_day;

pub use calendar::is_excluded_date;

pub use calendar::next_business_day_at_or_after;

pub use calendar::schedule_local_date;

pub use canary::CANARY_ACTIVITY_NAME;

pub use canary::CANARY_WORKFLOW_NAME_PREFIX;

pub use canary::is_canary_workflow;

pub use canary::is_reserved_canary_name;

pub use cancellation_scope::CancellationScope;

pub use cancellation_scope::NonCancellable;

pub use cancellation_scope::ScopeRun;

pub use completion_trigger::CompletionTrigger;

pub use completion_trigger::ConditionGate;

pub use completion_trigger::InputMapping;

pub use completion_trigger::MAX_CONDITION_DEPTH;

pub use completion_trigger::MAX_CONDITION_IN_VALUES;

pub use completion_trigger::MAX_CONDITION_NODES;

pub use completion_trigger::TerminalState;

pub use completion_trigger::TriggerCondition;

pub use completion_trigger::gate_stored_condition;

pub use context::ActivityContext;

pub use context::ActivityExecutionInfo;

pub use context::ActivityIdentity;

pub use context::AutoHeartbeatGuard;

pub use context::DEFAULT_CONTINUE_AS_NEW_DEADLINE_FRACTION;

pub use context::DEFAULT_HISTORY_BLOAT_WARN_FRACTION;

pub use context::DEFAULT_HISTORY_BYTE_HARD_CAP;

pub use context::DEFAULT_HISTORY_CONTINUE_AS_NEW_THRESHOLD;

pub use context::DEFAULT_HISTORY_EVENT_HARD_CAP;

pub use context::DEFAULT_SESSION_ACQUISITION_TIMEOUT;

pub use context::DEFAULT_WORKFLOW_LOG_MAX_LINES;

pub use context::DEFAULT_WORKFLOW_LOG_MAX_MESSAGE_BYTES;

pub use context::LoserCancelReason;

pub use context::MutexGuard;

pub use context::MutexHandle;

pub use context::RaceBuilder;

pub use context::RaceWinner;

pub use context::Session;

pub use context::SessionOptions;

pub use context::TimerHandle;

pub use context::TimerOutcome;

pub use context::WorkflowCommand;

pub use context::WorkflowContext;

pub use context::WorkflowExecutionInfo;

pub use context::WorkflowHistoryPolicy;

pub use context::WorkflowLogLevel;

pub use context::WorkflowLogPolicy;

pub use context::WorkflowLogger;

pub use context::is_reserved_session_activity_name;

pub use critical_path::CriticalPathAnalyzer;

pub use critical_path::CriticalPathResult;

pub use dag::DagBuildError;

pub use dag::DagBuilder;

pub use dag::DagCondition;

pub use dag::DagDefinition;

pub use dag::DagDispatchDecision;

pub use dag::DagInputBinding;

pub use dag::DagMapTaskRef;

pub use dag::DagMergeSource;

pub use dag::DagSignalGate;

pub use dag::DagTask;

pub use dag::DagTaskRef;

pub use dag::GateTimeoutAction;

pub use dag_export::export_dot;

pub use dag_export::export_mermaid;

pub use dag_export::export_mermaid_with_critical_path;

pub use dag_linter::DagLinter;

pub use dag_linter::DagRule;

pub use dag_linter::DagWarning;

pub use dag_linter::DuplicateNodeNameRule;

pub use dag_linter::ExcessiveParallelismRule;

pub use dag_linter::MissingRetryPolicyRule;

pub use dag_linter::MissingTimeoutRule;

pub use det_check::DetCheckReport;

pub use det_check::DetFinding;

pub use det_check::DetLocation;

pub use det_check::DetSeverity;

pub use det_check::DetSuppression;

pub use det_check::check_dir;

pub use det_check::check_file;

pub use det_check::check_paths;

pub use det_check::check_source;

pub use diagnostic::DiagnosticReport;

pub use diagnostic::SimulatorResultExt;

pub use error::CapabilityMissPhase;

pub use error::HarvestError;

pub use error::HarvestResult;

pub use error::TimeoutType;

pub use event::SideEffectKind;

pub use event::WorkflowEvent;

pub use executor::WorkflowOutcome;

pub use executor::run_workflow;

pub use guardrail::GuardrailFinding;

pub use guardrail::GuardrailSuppression;

pub use guardrail::GuardrailSuppressionError;

pub use guardrail::RuleCategory;

pub use guardrail::RuleEntry;

pub use guardrail::Severity;

pub use guardrail::catalog as guardrail_catalog;

pub use guardrail::rule_by_id as guardrail_rule_by_id;

pub use handle::StartedWorkflowHandle;

pub use handle::TransactionalStartOptions;

pub use handle::TransactionalStartOutcome;

pub use handle::WorkflowHandle;

pub use handle::WorkflowHandleClient;

pub use handle::WorkflowResult;

pub use handle::WorkflowResultState;

pub use handle::start_or_load_workflow_execution_with_handle;

pub use handle_typed::TypedSignalWithStartOptions;

pub use handle_typed::TypedStartOptions;

pub use handle_typed::TypedUpdateWithStartOptions;

pub use handle_typed::TypedWorkflowHandle;

pub use handle_typed::TypedWorkflowResult;

pub use history_export::DEFAULT_HISTORY_EXPORT_MAX_BYTES;

pub use history_export::HISTORY_EXPORT_SCHEMA;

pub use history_export::HISTORY_EXPORT_VERSION;

pub use history_export::HistoryExportDocument;

pub use history_export::HistoryExportError;

pub use history_export::HistoryExportRequest;

pub use history_export::HistoryExportSizeLimit;

pub use history_export::HistoryExportStatus;

pub use history_export::HistoryPayloadPolicy;

pub use history_export::export_history;

pub use history_export::export_mermaid_sequence;

pub use info::ActivityHandlerFn;

pub use info::ActivityInfo;

pub use info::DagInfo;

pub use info::InterfaceHandlerRecord;

pub use info::QueryHandlerFn;

pub use info::QueryHandlerInfo;

pub use info::SideEffectInfo;

pub use info::SignalHandlerInfo;

pub use info::UpdateHandlerFn;

pub use info::UpdateHandlerInfo;

pub use info::UpdateValidatorFn;

pub use info::WorkflowHandlerFn;

pub use info::WorkflowInfo;

pub use info::WorkflowInterfaceRecord;

pub use interceptor::ActivityInterceptor;

pub use interceptor::ActivityInterceptorFuture;

pub use interceptor::ActivityInterceptorNext;

pub use interceptor::ActivityInvocation;

pub use mutex::DEFAULT_MUTEX_LEASE_TTL;

pub use mutex::MutexGrantOutcome;

pub use mutex::MutexWakeTarget;

pub use mutex::effective_mutex_lease_ttl;

pub use mutex::set_mutex_lease_ttl;

pub use payload_codec::CodecError;

pub use payload_codec::IdentityCodec;

pub use payload_codec::LossyDecodeOutcome;

pub use payload_codec::PayloadCodec;

pub use payload_codec::PayloadCodecs;

pub use payload_codec::UNDECODABLE_MARKER_KEY;

pub use payload_codec::UNDECODABLE_REASON_CODEC_ERROR;

pub use payload_codec::UNDECODABLE_REASON_INVALID_BASE64;

pub use payload_codec::UNDECODABLE_REASON_INVALID_JSON;

pub use payload_codec::UNDECODABLE_REASON_UNKNOWN_CODEC;

pub use payload_codec::undecodable_marker;

pub use payload_store::OffloadedRef;

pub use payload_store::PayloadOffloader;

pub use payload_store::PayloadStore;

pub use payload_store::PayloadStoreError;

pub use payload_store::PayloadStoreFuture;

pub use policy::validate_schedule;

pub use policy::AdaptiveLimitPolicy;

pub use policy::CatchupPolicy;

pub use policy::JitterPolicy;

pub use policy::MapFailurePolicy;

pub use policy::OverlapPolicy;

pub use policy::RetryBudgetPolicy;

pub use policy::RetryPolicy;

pub use policy::Schedule;

pub use policy::SkipPolicy;

pub use policy::TaskStatus;

pub use policy::TriggerRule;

pub use policy::WorkflowSchedule;

pub use pool::HarvestPoolConfig;

pub use pool::compute_pool_sizes;

pub use query::QueryRegistry;

pub use replay::CONTINUE_AS_NEW_SIDE_EFFECT_NAME;

pub use replay::ChildOrTimerMatch;

pub use replay::ContinueAsNewMatch;

pub use replay::DEADLINE_PROBE_SIDE_EFFECT_NAME;

pub use replay::HistoryMatch;

pub use replay::HistoryMatcher;

pub use replay::MutexGrantMatch;

pub use replay::PatchMarkerMatch;

pub use replay::SagaMarkerMatch;

pub use replay::SideEffectNowMatch;

pub use replay::SignalOrTimerMatch;

pub use replay::TimerFireMatch;

pub use reset::BatchResetItem;

pub use reset::BatchResetOutcome;

pub use reset::ResetInvalidPoint;

pub use reset::ResetPlan;

pub use reset::ResetPoint;

pub use reset::ResetResult;

pub use reset::ResetSignalReapplyPolicy;

pub use reset::ResetSkipReason;

pub use reset::ResetUnresolvedSideEffect;

pub use reset::WorkflowResetError;

pub use reset::WorkflowResetRequest;

pub use reset::batch_skip_reason;

pub use reset::preview_workflow_reset;

pub use reset::reset_workflow_execution;

pub use reset::resolve_batch_reset_one;

pub use reset::resolve_reset_point;

pub use reset::validate_reset_point;

pub use retention::ArchiveFetchError;

pub use retention::ArchiveFetchFuture;

pub use retention::ArchiverFuture;

pub use retention::HistoryArchiver;

pub use retention::LegalHoldOutcome;

pub use retention::RetentionConfig;

pub use retention::legal_hold_active;

pub use retention::RetentionHooks;

pub use retention::RetentionMonitor;

pub use retention::RetentionRuntime;

pub use retention::RetentionStatus;

pub use retention::RetentionTickResult;

pub use retention::release_legal_hold;

pub use retention::set_legal_hold;

pub use retry_budget::RetryBudgetConfig;

pub use run_chain::RunChainRecord;

pub use run_chain::RunChainResponse;

pub use run_chain::RunChainRow;

pub use run_chain::assemble_run_chain;

pub use run_chain::outcome_for_state;

pub use saga::Saga;

pub use schedule_decision::record_decision_graceful;

pub use scheduler::DagCatalog;

pub use scheduler::RegisteredDag;

pub use scheduler::SchedulerMonitor;

pub use scheduler::SchedulerRuntime;

pub use scheduler::compile_dag_catalog;

pub use scheduler::register_schedules;

pub use scheduler::register_workflow_schedules;

pub use scheduler::register_workflow_schedules_with_codecs;

pub use scheduler::tick_once;

pub use scheduler::trigger_unified_dag;

pub use schema_contract::AcknowledgedBreakingChange;

pub use schema_contract::ActivitySchemaEntry;

pub use schema_contract::ChangeKind;

pub use schema_contract::CompatibilityRules;

pub use schema_contract::DEFAULT_SCHEMA_CONTRACT_PATH;

pub use schema_contract::MAX_DELTAS;

pub use schema_contract::SCHEMA_CONTRACT_VERSION;

pub use schema_contract::SchemaContractDiff;

pub use schema_contract::SchemaContractError;

pub use schema_contract::SchemaCoverage;

pub use schema_contract::SchemaDelta;

pub use schema_contract::SchemaRole;

pub use schema_contract::SchemaSubject;

pub use schema_contract::SideEffectSchemaEntry;

pub use schema_contract::Verdict;

pub use schema_contract::WorkflowSchemaContract;

pub use schema_contract::WorkflowSchemaEntry;

pub use schema_contract::canonicalize_schema;

pub use schema_contract::diff_schema_contracts;

pub use schema_contract::dropped_acknowledgements;

pub use schema_contract::subject_label;

pub use schema_contract::unacknowledged_breaking;

pub use shard::ShardedDbPool;

pub use shard::ShardPlacement;

pub use shard::ShardPlacementError;

pub use shard::ShardRouter;

pub use shard::ShardRouterParts;

pub use shared_json::SharedJson;

pub use signal_handler::SignalHandlerRegistry;

pub use simulator::SimulatorResult;

pub use simulator::WorkflowSimulator;

pub use stall_diagnosis::AwaitedSignalFacts;

pub use stall_diagnosis::BlockedOn;

pub use stall_diagnosis::BlockingCircuitPhase;

pub use stall_diagnosis::DiagnosisInputs;

pub use stall_diagnosis::ExecutionHealth;

pub use stall_diagnosis::ExternalHandoffFacts;

pub use stall_diagnosis::NdBlockFacts;

pub use stall_diagnosis::PendingActivityFacts;

pub use stall_diagnosis::PendingChildFacts;

pub use stall_diagnosis::PendingTimerFacts;

pub use stall_diagnosis::ReplayWaitFacts;

pub use stall_diagnosis::TIMER_OVERDUE_GRACE_SECONDS;

pub use stall_diagnosis::WorkflowTaskFacts;

pub use stall_diagnosis::activity_precedence;

pub use stall_diagnosis::classify_execution;

pub use stall_diagnosis::classify_pending_activity;

pub use stall_diagnosis::classify_workflow_task;

pub use stall_diagnosis::summarize;

pub use stall_diagnosis::workflow_task_hard_impediment;

pub use stall_diagnosis::workflow_wake_was_missed;

pub use telemetry::ActivityStatus;

pub use telemetry::MetricsRecorder;

pub use telemetry::NoOpMetrics;

pub use telemetry::NoOpPropagator;

pub use telemetry::ResidentOutcome;

pub use telemetry::SCANNER_SHARD_LABEL_NONE;

pub use telemetry::TelemetryConfig;

pub use telemetry::TelemetryConfigBuilder;

pub use telemetry::TraceContextCarrier;

pub use telemetry::TraceContextPropagator;

pub use telemetry::USER_METRIC_PREFIX;

pub use telemetry::UserMetricError;

pub use telemetry::UserMetrics;

pub use telemetry::WebhookOutcome;

pub use telemetry::WorkflowStatus;

pub use telemetry::validate_user_metric;

pub use timeline::SlowestStep;

pub use timeline::StepKind;

pub use timeline::StepOutcome;

pub use timeline::Timeline;

pub use timeline::TimelineEventRow;

pub use timeline::TimelineRollup;

pub use timeline::TimelineStep;

pub use timeline::derive_timeline;

pub use types::ActivityExecId;

pub use types::BuildId;

pub use types::DeploymentName;

pub use types::ExecutionId;

pub use types::ExternalActivityToken;

pub use types::ExternalAwaitId;

pub use types::ExternalCancelId;

pub use types::ExternalSignalId;

pub use types::ExternalTarget;

pub use types::ParentClosePolicy;

pub use types::Priority;

pub use types::SessionId;

pub use types::ShardId;

pub use types::StartProvenance;

pub use types::StartSource;

pub use types::TimerId;

pub use types::UpdateId;

pub use types::WorkerId;

pub use types::WorkflowId;

pub use types::WorkflowIdConflictPolicy;

pub use types::WorkflowIdReusePolicy;

pub use update::UpdateRegistry;

pub use version_usage::VersionExecutionStateGroup;

pub use version_usage::VersionUsageFilters;

pub use version_usage::VersionUsageShardRow;

pub use version_usage::load_version_usage;

pub use webhook_trigger::WebhookCtx;

pub use webhook_trigger::WebhookHandlerError;

pub use webhook_trigger::WebhookHandlerFn;

pub use webhook_trigger::WebhookTarget;

pub use webhook_trigger::WebhookTriggerInfo;

pub use webhook_trigger::validate_webhook_triggers;

pub use diesel;

pub use diesel_async;

pub use serde_json;

pub use serde;

pub use chrono;

pub use uuid;

Modules

activity_pause

Per-activity-type pause/resume for surgical outage containment (issue #807). Per-activity-type pause/resume — surgical outage containment (issue #807).

activity_progress

Live progress from inside an activity (issue #2268). Live progress from inside an activity (issue #2268).

adaptive_limit

Adaptive concurrency limit per activity type (issue #1836). Adaptive concurrency limit per activity type (issue #1836).

admission_gate

Admission gate primitive for incident-response operators (issue #377). Admission gate primitive for incident-response operators (issue #377).

aead_codec

AES-256-GCM payload codec and data-key providers (issue #1825). AES-256-GCM payload codec and its key providers (issue #1825).

analyzer

History analyzer and linter. Workflow history analyzer and linter.

api_token

Pure token-secret helpers shared by the mint route and the CLI (issue #942). Pure token-secret helpers for the management API (issue #942).

append_only

The database guard on append-only harvest_events (issue #1817). The database guard on append-only harvest_events (issue #1817).

audit

Audit trail for management API mutations (issue #158). Management API audit trail (issue #158).

audit_chain

Keyed hash chain over exported audit rows (issue #1838). Keyed hash chain over exported audit rows (issue #1838).

audit_export

Audit-record export to an external sink for SIEM compliance (issue #953). Streaming the management-API audit trail to an external sink (issue #953).

awaitables

Open-awaitables diagnostic projection (issue #615). Open-awaitables diagnostic projection (issue #615).

backup_verify

Post-restore resumability verification for backup/PITR drills (issue #943). Post-restore resumability verification for backup/PITR drills (issue #943).

batch

Batch operations for fleet-wide workflow cancel/terminate/signal (issue #102). Batch operations for fleet-wide workflow management (issue #102).

batch_start

Batch workflow start types: caps and per-item request/result structs (issue #357). Batch workflow start types (issue #357).

build_routing

Worker build-id routing for safe rolling deploys (issue #171). Worker build-id routing for safe rolling deploys (issue #171).

builder

Fluent API for registering workflows, activities, and configuring the worker.

cache

LRU cache for suspended workflow states.

calendar

Calendar-aware schedule filtering: named exclusion sets, skip policies, and schedule preview generation (issue #337). Calendar-aware schedule filtering for business-day and holiday-skip jobs.

canary

Built-in synthetic liveness canary (issue #796).

cancellation_scope

Cancellation scopes and non-cancellable blocks (issue #1984). Cancellation scopes (issue #1984).

circuit_breaker

Per-activity circuit breaker that stops dispatch during downstream outages (issues #369, #1809). Per-activity circuit breaker that stops dispatch during downstream outages (issue #369).

codec_rotation

Payload-codec key rotation and the lazy re-encryption sweep (issue #948).

completion_callback

Durable completion callbacks (issue #605).

completion_trigger

concurrency

Per-key concurrency limits for tenant fair-share scheduling (issue #247). Per-key concurrency limits for tenant fair-share scheduling (issue #247).

context

Execution contexts passed to workflow and activity functions.

cost_hold

Cost-aware deferral of activities while a cost signal is high (autumn#1720). Cost-aware deferral of activities (autumn#1720).

critical_path

Critical Path Analyzer for DAG Definitions.

cross_shard_child

Cross-shard child workflow placement (issue #956).

dag

DAG definition primitives for Harvest.

dag_export

Export format types for Directed Acyclic Graphs (DAGs) representing workflows. Visualization exporters for DAG definitions.

dag_linter

DAG configuration analyzer and linter.

debounce

Debounced workflow starts — collapse trigger bursts into one run (issue #499). Debounced workflow starts — collapse trigger bursts into one run (issue #499).

decision_owner

The fenced owner lease of each decision partition (issue #2251). The fenced decision owner of a partition (issue #2251).

det_check

Deterministic workflow guardrails: static source-level check for replay-breaking patterns. Deterministic workflow guardrails.

diagnostic

Diagnostic reporting for simulated workflow executions.

dispatch

Task dispatch channel seam (issue #1312): Postgres stays the source of truth, a dispatch::TaskDispatch carries task references. Task dispatch channel seam (issue #1312).

dst

Deterministic simulation of the activity claim protocol (issue #1830), and of the real worker loop (issue #2002). Deterministic simulation testing (issue #1830).

durable_promise

Durable promises that any caller settles once (issue #1985). Durable promises (issue #1985).

effective_config

Effective runtime-configuration introspection (issue #695).

eligibility

entity

Keyed entity: serialized handlers over durable state for each key (issue #1975). Keyed entity: serialized handlers over durable state for each key (issue #1975).

entity_state

The keyed-entity state projection (issue #2259). The keyed-entity state projection (issue #2259).

erase

Targeted PII erasure for completed workflow executions (issue #495).

error

Error types for the harvest engine.

event

Event types for the workflow event-sourcing engine.

event_batch

Event-batched workflow starts — fold many triggers into one batched run (issue #518).

executor

Workflow executor – runs a single workflow function through replay + live execution.

external_target_location

Shard-placement-aware resolution for workflow_id-addressed external signal/cancel targets (issue #1146). Shard-placement-aware resolution for workflow_id-addressed external targets (issue #1146).

external_task

External activity task management — token-based async completion.

failure

Typed activity failure surface for structured error classification.

fairness_keys

Runtime weight overrides and state upkeep for fairness keys (issue #1976). Runtime weight overrides and state upkeep for fairness keys (issue #1976).

fan_out

Fan-out failure tolerance and result writer (issue #1986).

fork

Non-destructive fork of a workflow run (issue #2000). Non-destructive fork of a workflow run (issue #2000).

group_commit

Group commit of one decision partition (issue #2256). Group commit of the decisions of one decision partition (issue #2256).

guardrail

Deterministic workflow guardrail rule catalog (issue #173). Deterministic workflow guardrail rule catalog (issue #173).

handle

In-process workflow result handles for request/response embedders.

handle_typed

Type-safe client handle wrappers and start options for compile-time-safe workflows.

history_export

Export workflow event histories to replay fixtures and Mermaid diagrams.

info

Registration types returned by macro-generated companion functions.

interceptor

Activity execution interceptors (issue #680): an ordered middleware chain wrapping every activity execution on the worker (regular + local). Activity execution interceptors (issue #680).

lifecycle

Every persisted workflow execution state and every sanctioned transition. The workflow execution lifecycle, as one table.

llm_budget

LLM token and cost budgets per run and per tenant (issue #1997). LLM token and cost budgets per run and per tenant (issue #1997).

llm_ledger

Agent cost ledger: model, tokens, cost and latency per LLM step (issue #1996). Agent cost ledger: model, tokens, cost and latency per LLM step (issue #1996).

load_shed

Automatic load shedding driven by backlog age (issue #1794). Automatic load shedding driven by backlog age (issue #1794).

migrate

Migration applier for a dedicated Harvest database (issue #1240). Applying Harvest’s schema migrations to a dedicated Harvest database (issue #1240).

mutex

Durable mutual-exclusion locks for workflow code (ctx.mutex, issue #691). Durable mutual-exclusion locks for workflow code (issue #691).

overlay_log

The log of agent profile overlays (issue #2371). The log of agent profile overlays (issue #2371).

partition

Opt-in native Postgres declarative partitioning for harvest_events (issue #958).

partition_archive

Export of aged event partitions to object storage (issue #2009). Export of aged harvest_events partitions to object storage (issue #2009).

payload_codec

Interfaces for transforming event payloads before they are persisted.

payload_depth

The depth cap on payloads that Harvest keeps, shared by both backends (issues #2224, #2225). The depth cap on payloads that Harvest keeps (issues #2157, #2216, #2224, #2225).

payload_orphans

Sweep of payload blobs that no execution references (issue #2123). Sweep of payload blobs that no execution references (issue #2123).

payload_store

Large-payload offloading to external storage via claim-check (issue #524).

pg_tls

The connection transport a DSN’s sslmode selects, with TLS through rustls. The transport for a Postgres connection, chosen by the DSN’s sslmode.

poison_pill

Poison-pill task quarantine (Phase 4, issue #367).

policy

Retry policies, trigger rules, and scheduling types.

pool

Database pool configuration with separate pools and shared ceiling.

prelude

Convenient glob import for autumn-harvest users.

query

Types and definitions for querying workflow state and metadata. Query registry and dispatch for read-only workflow state inspection (issue #234).

queue_pause

Task-queue pause/resume — hold dispatch during a downstream outage (issue #619).

quota

Per-tenant resource quotas on executions, history, and DLQ (issue #946).

quota_reconcile

Registry-aware quota_key backfill for pre-upgrade executions (issue #1226).

ramp_guard

Metric-gated automatic abort of a build ramp (issue #1814). Metric-gated automatic abort of a build ramp (issue #1814).

rebalance_resume

Automatic resume of a shard rebalance stalled after its cutover (issue #1839). Automatic resume of a shard rebalance that stalls after its cutover (issue #1839).

remote_task

Durable outbound calls to a remote MCP or A2A task (issue #2006). Durable outbound calls to a remote MCP or A2A task (issue #2006).

replay

Replay engine for deterministic workflow re-execution.

replay_sample

Stratified in-flight history sampling for the replay-drift gate (issue #798).

replication

Cross-region DR fencing and replication-lag measurement (issue #954). Cross-region disaster recovery: write-authority fencing and replication-lag measurement (issue #954).

reset

Workflow reset and fork recovery primitives.

retention

Time-based retention janitor for completed workflow history.

retry_budget

Per-activity-type retry budget that bounds retry load (issue #1793). Per-activity-type retry budget (issue #1793).

run_chain

Continue-as-new run-chain assembly (issue #701). Continue-as-new run-chain assembly (issue #701).

run_defaults

Operator overrides for per-type sla and execution_timeout (issue #2387). Operator overrides for per-type run defaults (issue #2387).

saga

Saga compensation helper for workflow code.

scanner_health

Background control-loop liveness heartbeats (issue #797). Background control-loop liveness heartbeats (issue #797).

scanner_lease

One active background scanner per shard, elected by a lease (issue #1795). One active background scanner per shard (issue #1795).

schedule_decision

schedule_override

Operator overrides for code-declared schedules (issues #2385 and #2386). Operator overrides for code-declared schedules (issues #2385 and #2386).

schedule_patch

The partial update of a workflow schedule and its override rules (issues #771, #2386 and #2390). Shared by both backends. The partial update of a workflow schedule, and its override rules.

schedule_plan

Backend-neutral cron and interval slot arithmetic (issue #2031). Backend-neutral slot arithmetic for cron and interval schedules (issue #2031).

scheduler

DAG scheduler and runtime execution.

schema_contract

Workflow payload-schema contract baseline and replay-compatibility diffing (issue #794).

sessions

Worker session fleet-side registry and pure decision functions (issue #606). Worker sessions (issue #606): co-locate an activity pipeline on one worker.

shard

Shard routing and per-shard database pools.

shard_fence

A task-local fence on the shards one request may reach (issue #1803). A task-local fence on the shards one request may reach (issue #1803).

shard_rebalance

Shard rebalancing: migrating quiescent workflow executions across shards (issue #964). Shard rebalancing — migrating quiescent workflows across shards (issue #964).

shared_json

Shared, immutable JSON payload for the workflow start path (issue #1733). Shared, immutable JSON payload (issue #1733).

signal_handler

Signal handler registry for push-based reactive signal handling (issue #546). Signal handler registry for push-based reactive signal handling (issue #546).

simulator

Workflow simulator for local, determinism-safe testing.

slot_tuner

Adaptive worker dispatch-slot tuner (issue #548). Adaptive worker dispatch-slot tuner (issue #548).

stall_diagnosis

Per-execution stall diagnosis — the root-cause classifier (issue #809). Per-execution stall diagnosis — the root-cause classifier (issue #809).

start_idempotency

Request-scoped idempotency keys for plain workflow starts (issue #808). Request-scoped idempotency keys for plain workflow starts (issue #808).

table_split

One physical table over two diesel table! declarations (issue #2492). One physical table over two diesel table! declarations (issue #2492).

telemetry

OpenTelemetry integration: trace-context propagation and metrics. OpenTelemetry integration surface for autumn-harvest.

tenant

Tenant keys: validation shared by tokens, starts and retention (issue #1977). Tenant keys (issue #1977).

throttle

Workflow-start throttle — pace admissions, defer the excess (issue #607). Workflow-start throttle — pace admissions, defer the excess (issue #607).

timeline

Per-execution timeline read model (issue #739). Per-execution timeline read model (issue #739).

types

Core identity types for the workflow engine.

update

Update handler registry for the workflow Update primitive (issue #140).

usage

Read-only per-tenant/per-workflow usage aggregation (issue #596).

version_gate_retirement

Read-only retirement-check query for recorded workflow version-gate markers.

version_usage

Read-only inventory for recorded workflow version-gate markers.

webhook_trigger

Inbound HTTP webhook trigger descriptors (issue #344).

worker_outlier

Per-worker outlier (gray-failure) detection (issue #1815). Per-worker outlier (gray-failure) detection (issue #1815).

workers

Worker fleet registry — liveness tracking, heartbeat, and fleet queries.

Macros

always

A hard invariant of a workflow simulation run (issue #2033).

cfg_db

Embedded migrations for the harvest engine schema.

sometimes

A reachability target of a workflow simulation sweep (issue #2033).

split_insertable

Insert a flat struct through a core and an extension declaration.

split_queryable

Read a flat struct through a core and an extension declaration.

split_table

Bridge an extension declaration to its core declaration.

Structs

AuditRecord

A single management API audit record (issue #158).

CancelledWorkflowExecution

Result of a workflow cancellation request.

ConcurrencyKeyStats

Live stats for a single (concurrency_key, task_type) pair.

EventHistory

Loaded event history for a single workflow execution.

NewAuditRecord

Insert struct for recording a new audit event.

PausedWorkflowExecution

Result of a workflow pause request.

QueueScalingSignal

Live scaling signals for a task queue.

QueueTaskCounts

Helper struct for queue task counts.

ResolvedRun

A single candidate run resolved for a (workflow_name, workflow_id) pair on one shard (issue #805).

ResumedWorkflowExecution

Result of a workflow resume request.

ScheduleRunQuery

Filters + keyset cursor for list_schedule_runs (issue #534).

ScheduleRunRow

One row of the per-schedule run-history listing (issue #534).

ScheduleRunStateCount

A (state, count) pair from the per-schedule cadence summary (issue #534).

SignalWithStartOutcome

Result of a signal_with_start_workflow_execution call.

SignalWithStartParams

Parameters for the atomic signal_with_start primitive.

StartWorkflowParams

Parameters for starting a workflow execution.

StartedWorkflowExecution

Result of an idempotent workflow start attempt.

TriageFieldChange

A single triage-field mutation captured for the audit trail (issue #759, AC5).

TriageOutcome

Result of an annotate_workflow_execution call: the execution’s current triage view (issue #759, AC4/AC7) plus the set of fields this call actually changed.

TriagePatch

A partial, tri-state update to an execution’s operator-mutable triage metadata (issue #759): owner, severity, and a free-text note.

UpdateWithStartOutcome

Result of an update_with_start_workflow_execution call.

UpdateWithStartParams

Parameters for the atomic update_with_start primitive.

WorkflowCountQuery

Filters + grouping dimensions for the grouped workflow-count snapshot (issue #544).

WorkflowCountRow

One grouped count row, either raw from a single shard or already summed across shards (issue #544).

WorkflowTypeNonTerminalCount

Enums

AwaitMode

Whether a child workflow was spawned in await or detached mode.

IdempotentStartOutcome

Outcome of start_or_load_workflow_execution_idempotent (issue #808).

WorkflowCountDimension

Dimension to group GET /workflows/count results by (issue #544).

Constants

MIGRATIONS

ORIGIN_BACKFILL

Origin marker for a run created by a schedule backfill (issue #534).

ORIGIN_MANUAL_TRIGGER

Origin marker for an ad-hoc operator trigger-now fire of a schedule (issue #534).

ORIGIN_SCHEDULED

Origin marker for a normal scheduler-tick fire (issue #534).

RETRY_CHAIN_MAX_DEPTH

Upper bound on how far resolve_live_attempt walks the workflow-level retry chain (issue #523).

RETRY_CHAIN_MAX_REDRIVES

Bound on how many times a mutating operation is re-driven when the retry chain advanced underneath it (see redrive_target).

Functions

annotate_workflow_execution

Set, update, or clear an execution’s operator-mutable triage tags – owner, severity, and a free-text note – at any point in its life (issue #759).

auto_resume_expired_pauses

Auto-resume executions that have been paused longer than max_pause_duration (issue #383, bounded pause).

cancel_live_attempt

Cancel the live attempt of the logical run named by exec_id (#843).

cancel_workflow_execution

Cancel a running workflow execution.

count_workflow_executions_grouped

Count workflow executions grouped by the requested dimensions on one shard (issue #544).

list_schedule_runs

List the executions a schedule launched, newest-slot-first (issues #534, #762).

non_terminal_counts_by_workflow_name

Count non-terminal workflow executions grouped by workflow_name on one shard.

parse_byte_size

Parse a human-readable byte-size string like "2MiB", "256KiB", "4MB".

parse_instant

pause_live_attempt

Pause the live attempt of the logical run named by exec_id (#843).

pause_workflow_execution

Pause a running workflow execution (issue #383).

queue_task_counts

Return backlog, in-flight, and scheduled task counts per queue on this shard.

redrive_target

Pure decision helper for the mutating-operation re-drive loop (issue #843).

resolve_execution_id_by_workflow_id

Resolve the best “latest run” for (workflow_name, workflow_id) on ONE shard (issue #805).

resolve_live_attempt

Follow the workflow-level retry chain (issue #523) from exec_id to the live attempt and return it.

resolve_live_attempt_id

resolve_live_attempt, returning only the resolved ExecutionId and its shard.

resume_live_attempt

Resume the live attempt of the logical run named by exec_id (#843).

resume_workflow_execution

Resume a paused workflow execution (issue #383).

schedule_run_state_summary

Count a schedule’s scheduled-origin runs by terminal state (issue #534).

select_resolved_run

Pick the single best “latest run” from per-shard candidates (issue #805).

signal_with_start_workflow_execution

Errors

signal_with_start_workflow_execution_with_metrics

Errors

signal_with_start_workflow_execution_with_metrics_and_codecs

signal_with_start_workflow_execution_with_metrics, encoding WorkflowStarted.input / last_completion_result through codecs (issue #1243).

start_or_load_workflow_execution

Start a workflow execution or load the existing one, applying the caller’s WorkflowIdReusePolicy when a duplicate (workflow_name, workflow_id) collision occurs.

start_or_load_workflow_execution_idempotent

Start a workflow with request-scoped idempotency (issue #808).

start_or_load_workflow_execution_idempotent_with_codecs

start_or_load_workflow_execution_idempotent, encoding WorkflowStarted.input / last_completion_result through codecs (issue #1243).

start_or_load_workflow_execution_with_codecs

start_or_load_workflow_execution, encoding WorkflowStarted.input / last_completion_result through codecs (issue #1243).

start_or_load_workflow_execution_with_metrics

start_or_load_workflow_execution_with_metrics_and_codecs

start_or_load_workflow_execution_with_metrics, encoding WorkflowStarted.input / last_completion_result through codecs (issue #1243).

terminate_live_attempt

Terminate the live attempt of the logical run named by exec_id (#843).

terminate_workflow_execution

Hard-finalize a workflow execution to TERMINATED regardless of its current live state.

update_with_start_workflow_execution

Atomically start or attach to a workflow and admit one update.

update_with_start_workflow_execution_with_metrics

update_with_start_workflow_execution_with_metrics_and_codecs

update_with_start_workflow_execution_with_metrics, encoding WorkflowStarted.input / last_completion_result through codecs (issue #1243).