cohort | Kitaru Reference

Client-side cohort selection for batch replay experiments.

CohortQuery

CohortResult

funccoerce_exec_ids(executions) -> list[str]

Return exec IDs from a resolved cohort or plain sequence.

paramexecutionsCohortResult | Sequence[str]

Returns

list[str]

funccohort

(*, flow, at, deployment=None, deployment_version=None, order_by='-started_at', limit=50, originals_only=True, status='completed', since=None, until=None, client=None) -> CohortQuery

Build a cohort selection query for resolve().

paramflowstr

paramatstr

paramdeploymentstr | None

= None

paramdeployment_versionint | None

= None

paramorder_bystr

= '-started_at'

paramlimitint

= 50

paramoriginals_onlybool

= True

paramstatusstr | Sequence[str]

= 'completed'

paramsincedatetime | str | None

= None

paramuntildatetime | str | None

= None

paramclientKitaruClient | None

= None

Returns

kitaru.cohort.CohortQuery

funcexecution_replay_at_status(*, execution, at) -> Literal['present', 'missing', 'ambiguous', 'no_checkpoints']

Return whether at resolves on a hydrated Execution.

paramexecutionExecution

paramatstr

Returns

typing.Literal['present', 'missing', 'ambiguous', 'no_checkpoints']