m3resp.WorkflowResult#

class m3resp.WorkflowResult(name, context, outputs=<factory>, processing_run_id=None, run_id=None, status='pending', started_at=None, finished_at=None, duration_seconds=None, compiled_workflow=None, step_records=(), diagnostics=(), warnings=(), execution_context=None, resolved_output_dir=None, manifest_path=None)[source]#

Results, timing and execution records for one workflow run.

Variables:

name (str) – Workflow name.
context (WorkflowContext) – Shared values and the session used by the steps.
outputs (dict[str, Any]) – Produced context values and externally supplied values, excluding the session and keys named in spec.inputs.
processing_run_id (str | None) – Stored ProcessingRun identifier when a data-model recorder is attached, otherwise None.
run_id (str | None) – Identifier used in execution records and progress events.
status (WorkflowStatus) – Run state; completed executions are succeeded or cancelled.
started_at (str | None) – Run start time as an ISO 8601 UTC string, or None.
finished_at (str | None) – Run finish time as an ISO 8601 UTC string, or None.
duration_seconds (float | None) – Elapsed execution time in seconds, or None.
compiled_workflow (CompiledWorkflow | None) – Ordered description of the steps and resolved settings.
step_records (tuple[StepExecutionRecord, ...]) – Records of steps that executed, in execution order.
diagnostics (tuple[Diagnostic, ...]) – Structural diagnostics collected before execution.
warnings (tuple[CapturedWarning, ...]) – Python warnings captured during executed steps, in order.
execution_context (ExecutionContext | None) – Recorded software versions and seed information.
resolved_output_dir (Path | None) – Shared output directory, when supplied in context.
manifest_path (Path | None) – Run-manifest path when written by run_spec.

Parameters:

name (str)
context (WorkflowContext)
outputs (dict[str, Any])
processing_run_id (str | None)
run_id (str | None)
status (WorkflowStatus)
started_at (str | None)
finished_at (str | None)
duration_seconds (float | None)
compiled_workflow (CompiledWorkflow | None)
step_records (tuple[StepExecutionRecord, ...])
diagnostics (tuple[Diagnostic, ...])
warnings (tuple[CapturedWarning, ...])
execution_context (ExecutionContext | None)
resolved_output_dir (Path | None)
manifest_path (Path | None)

Methods

value

Return a context value by key.

Attributes

`compiled_workflow`
`diagnostics`
`duration_seconds`
`execution_context`
`finished_at`
`manifest_path`
`processing_run_id`	The ProcessingRun id record_workflow_result created for this run, when a DataModelRecorder is attached to the session.
`resolved_output_dir`
`run_id`
`session`	Return the session used by this workflow's context.
`started_at`
`status`
`step_records`
`warnings`
`name`
`context`
`outputs`

compiled_workflow: CompiledWorkflow | None = None#

context: WorkflowContext#

diagnostics: tuple[Diagnostic, ...] = ()#

duration_seconds: float | None = None#

execution_context: ExecutionContext | None = None#

finished_at: str | None = None#

manifest_path: Path | None = None#

name: str#

outputs: dict[str, Any]#

processing_run_id: str | None = None#: The ProcessingRun id record_workflow_result created for this run, when a DataModelRecorder is attached to the session. None otherwise (including for a session without a recorder).

resolved_output_dir: Path | None = None#

run_id: str | None = None#

property session: M3Session#: Return the session used by this workflow’s context.

started_at: str | None = None#

status: WorkflowStatus = 'pending'#

step_records: tuple[StepExecutionRecord, ...] = ()#

value(key)[source]#

Return a context value by key.

Raises WorkflowSpecError if the key is unavailable.

Parameters:: key (str)
Return type:: Any

warnings: tuple[CapturedWarning, ...] = ()#