Skip to main content

protocol

Data-access seam for the activity domain.

Defines the ActivityRepository Protocol the activity routes depend on. The Prefect-backed implementation lives in repository.py.

Classes​

ActivityRepository​

class ActivityRepository(*args, **kwargs):

Read-facade over the Prefect task orchestrator's live state.

Ancestors​

Methods​

get_status​

async def get_status(self) ‑> ActivityStatus:

Return which eligibility runs are live now.

Returns The current ActivityStatus.

list_runs​

async def list_runs(    self, *, page: int = 1, page_size: int = 50,) ‑> RunList:

Return a page of recent runs across all known activity kinds.

Arguments

  • page: 1-indexed page number.
  • page_size: Items per page.

Returns The requested page of RunList.