Skip to main content

model

Pydantic record for the runs cache table (v1).

Classes​

RunRecord​

class RunRecord(**data: Any):

Record of a single flow execution.

Attributes

  • task_hash: Pipeline task hash.
  • run_id: UUID uniquely identifying this run attempt.
  • type: Free-form run-kind discriminator used as the dedup key (e.g. a DAG name, a "<dag>:interactive" suffix, a node name, or "file_metadata"). NOT a closed set.
  • status: Current lifecycle state (RunStatus).
  • started_at: When the run started.
  • completed_at: When the run finished (None if still running).
  • files_processed: Number of files processed in this run.
  • error: Error message if the run failed.
  • tags: Arbitrary flat metadata.

Create a new model by parsing and validating input data from keyword arguments.

Raises [ValidationError][pydantic_core.ValidationError] if the input data cannot be validated to form a valid model.

self is explicitly positional-only to allow self as a field name.

Variables​

  • static error : str | None
  • static files_processed : int
  • static model_config
  • static parent_run_id : str | None
  • static project_id : str | None
  • static run_id : str
  • static task_hash : str
  • static type : str

BackgroundRunRecord​

class BackgroundRunRecord(**data: Any):

Record of a single flow execution.

Attributes

  • task_hash: Pipeline task hash.
  • run_id: UUID uniquely identifying this run attempt.
  • type: Free-form run-kind discriminator used as the dedup key (e.g. a DAG name, a "<dag>:interactive" suffix, a node name, or "file_metadata"). NOT a closed set.
  • status: Current lifecycle state (RunStatus).
  • started_at: When the run started.
  • completed_at: When the run finished (None if still running).
  • files_processed: Number of files processed in this run.
  • error: Error message if the run failed.
  • tags: Arbitrary flat metadata.

Create a new model by parsing and validating input data from keyword arguments.

Raises [ValidationError][pydantic_core.ValidationError] if the input data cannot be validated to form a valid model.

self is explicitly positional-only to allow self as a field name.

Variables​

  • static error : str | None
  • static files_processed : int
  • static model_config
  • static parent_run_id : str | None
  • static project_id : str | None
  • static run_id : str
  • static task_hash : str
  • static type : str

RunStatus​

class RunStatus(*args, **kwds):

Lifecycle state of a Run row.

A closed set: a run is opened RUNNING, then closed out exactly once as COMPLETE, PARTIAL or FAILED. Values are the strings persisted in the runs table's status column (SQLite has no native enum type).

PARTIAL is a run that finished without error but could not cover all of its input because the source became unreachable part-way through. It is not a completion: queries for the last complete run skip it.

Ancestors​

Variables​

  • static COMPLETE
  • static FAILED
  • static PARTIAL
  • static RUNNING