AgentSessionManager.WorkflowBridge (AgentSessionManager v0.8.0)

Thin integration layer for calling ASM from workflow/DAG engines.

WorkflowBridge adapts AgentSessionManager's API into workflow-friendly primitives: step execution, normalized results, error classification, and multi-run session lifecycle management.

This module does NOT depend on any external workflow library. It produces data shapes that any workflow engine (Jido, Broadway, custom) can consume.

Summary

Types

adapter()

step_params()

store()

Functions

classify_error(error)

Classify an ASM error for workflow routing decisions.

complete_workflow_session(store, session_id, opts \\ [])

Complete or fail a shared workflow session.

setup_workflow_session(store, adapter, attrs)

Create and activate a shared session for a multi-step workflow.

step_execute(store, adapter, params)

Execute a single workflow step via ASM.

step_result(raw_result, opts \\ [])

Normalize a raw ASM result map into a StepResult struct.

Types

adapter()

@type adapter() :: AgentSessionManager.SessionManager.adapter()

step_params()

@type step_params() :: %{
  :input => map(),
  optional(:session_id) => String.t(),
  optional(:agent_id) => String.t(),
  optional(:context) => map(),
  optional(:metadata) => map(),
  optional(:tags) => [String.t()],
  optional(:continuation) => :auto | :replay | false,
  optional(:continuation_opts) => keyword(),
  optional(:adapter_opts) => keyword(),
  optional(:policy) => map(),
  optional(:workspace) => keyword(),
  optional(:event_callback) => (map() -> any())
}

store()

@type store() :: AgentSessionManager.SessionManager.store()

Functions

classify_error(error)

@spec classify_error(AgentSessionManager.Core.Error.t()) ::
  AgentSessionManager.WorkflowBridge.ErrorClassification.t()

Classify an ASM error for workflow routing decisions.

Returns an ErrorClassification struct with:

retryable - whether the error is retryable
category - error category atom
recommended_action - :retry, :failover, :wait_and_retry, :abort, or :cancel

complete_workflow_session(store, session_id, opts \\ [])

@spec complete_workflow_session(store(), String.t(), keyword()) ::
  :ok | {:error, AgentSessionManager.Core.Error.t()}

Complete or fail a shared workflow session.

With default opts, completes the session. Pass status: :failed and optionally error: %Error{} to fail it.

Returns :ok or {:error, Error.t()}.

setup_workflow_session(store, adapter, attrs)

@spec setup_workflow_session(store(), adapter(), map()) ::
  {:ok, String.t()} | {:error, AgentSessionManager.Core.Error.t()}

Create and activate a shared session for a multi-step workflow.

Returns {:ok, session_id} or {:error, Error.t()}.

step_execute(store, adapter, params)

@spec step_execute(store(), adapter(), step_params()) ::
  {:ok, AgentSessionManager.WorkflowBridge.StepResult.t()}
  | {:error, AgentSessionManager.Core.Error.t()}

Execute a single workflow step via ASM.

When params.session_id is provided, executes within an existing session (multi-run mode). Otherwise, creates a standalone one-shot session.

Returns {:ok, StepResult.t()} or {:error, Error.t()}.

step_result(raw_result, opts \\ [])

@spec step_result(
  map(),
  keyword()
) :: AgentSessionManager.WorkflowBridge.StepResult.t()

Normalize a raw ASM result map into a StepResult struct.

Accepts either a run_once result (has session_id, run_id) or an execute_run result (no session_id/run_id) plus optional session_id and run_id overrides.