Skip to main content

repository

Prefect-backed implementation of the activity domain's repository.

Classes​

PrefectActivityRepository​

class PrefectActivityRepository():

Prefect-backed implementation of ActivityRepository.

Methods​

get_status​

async def get_status(self) ‑> ActivityStatus:

Return which eligibility runs are live now.

list_runs​

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

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

Arguments

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

Returns The requested page, most recent first, and the total match count.