Struct TestRun 

pub struct TestRun {

    pub id: Uuid,
    pub suite_id: Uuid,
    pub org_id: Uuid,
    pub kind: String,
    pub triggered_by: String,
    pub triggered_by_user: Option<Uuid>,
    pub status: String,
    pub queued_at: DateTime<Utc>,
    pub started_at: Option<DateTime<Utc>>,
    pub finished_at: Option<DateTime<Utc>>,
    pub runner_seconds: Option<i32>,
    pub summary: Option<Value>,
    pub git_ref: Option<String>,
    pub git_sha: Option<String>,
}

Fields

id: Uuid

suite_id: Uuid

Owning resource id. For suite runs this is test_suites.id; for chaos / flow / snapshot / contract / replay / clone runs it points at the matching domain table — kind says which.

org_id: Uuid

kind: String

What sort of run this is. Mirrors the kind vocabulary in test_suites plus the cross-task additions documented in migration 20250101000059_test_execution.sql.

triggered_by: String

triggered_by_user: Option<Uuid>

status: String

queued_at: DateTime<Utc>

started_at: Option<DateTime<Utc>>

finished_at: Option<DateTime<Utc>>

runner_seconds: Option<i32>

summary: Option<Value>

git_ref: Option<String>

git_sha: Option<String>

Implementations

impl TestRun

pub async fn enqueue( pool: &Pool<Postgres>, input: EnqueueTestRun<'_>, ) -> Result<TestRun, Error>

Insert a new run in queued status.

pub async fn find_by_id( pool: &Pool<Postgres>, id: Uuid, ) -> Result<Option<TestRun>, Error>

pub async fn list_by_suite( pool: &Pool<Postgres>, suite_id: Uuid, limit: i64, ) -> Result<Vec<TestRun>, Error>

Recent runs of a suite, newest first.

pub async fn list_by_org( pool: &Pool<Postgres>, org_id: Uuid, status_filter: Option<&str>, limit: i64, ) -> Result<Vec<TestRun>, Error>

Cross-suite list for an org. Used by the global “all runs” dashboard.

pub async fn count_inflight( pool: &Pool<Postgres>, org_id: Uuid, ) -> Result<InflightRuns, Error>

How many runs are queued + running for this org? Used by the concurrency-cap check (max_concurrent_runs plan limit) before admitting a new run.

pub async fn mark_running( pool: &Pool<Postgres>, id: Uuid, ) -> Result<Option<TestRun>, Error>

Worker-callback transition to running. Idempotent: only transitions when current status is queued, otherwise no-op.

pub async fn mark_finished( pool: &Pool<Postgres>, id: Uuid, status: &str, runner_seconds: i32, summary: Option<&Value>, ) -> Result<Option<TestRun>, Error>

Worker-callback transition to a terminal status. Idempotent on the terminal: a row already in passed/failed/cancelled/errored is not changed.

pub async fn cancel( pool: &Pool<Postgres>, id: Uuid, ) -> Result<Option<TestRun>, Error>

User-initiated abort. Allowed from queued or running.

Trait Implementations

impl Clone for TestRun

fn clone(&self) -> TestRun

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TestRun

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TestRun

fn deserialize<__D>( __deserializer: __D, ) -> Result<TestRun, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<'a, R> FromRow<'a, R> for TestRun

where R: Row, &'a str: ColumnIndex<R>, Uuid: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>, String: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>, Option<Uuid>: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>, DateTime<Utc>: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>, Option<DateTime<Utc>>: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>, Option<i32>: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>, Option<Value>: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>, Option<String>: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>,

fn from_row(__row: &'a R) -> Result<TestRun, Error>

impl Serialize for TestRun

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.