Skip to main content

routes

HTTP routes for the activity domain.

Module

Functions

get_status

async def get_status(    repository: ActivityRepository = Depends(dependency=<function get_activity_repository>, use_cache=True, scope=None),    user: AuthenticatedUser = Depends(dependency=<function verify_jwt>, use_cache=True, scope=None),)> ActivityStatus:

Return live Prefect task-orchestrator state.

Arguments

  • repository: The activity repository.
  • user: The authenticated caller.

Returns Which eligibility runs are live now.

list_runs

async def list_runs(    page: Annotated[int, Query(ge=1)] = 1,    page_size: Annotated[int, Query(ge=1, le=200)] = 50,    repository: ActivityRepository = Depends(dependency=<function get_activity_repository>, use_cache=True, scope=None),    user: AuthenticatedUser = Depends(dependency=<function verify_jwt>, use_cache=True, scope=None),)> RunList:

Return a page of recent Prefect runs, most recent first.

Arguments

  • page: 1-indexed page number.
  • page_size: Items per page (1-200, default 50).
  • repository: The activity repository.
  • user: The authenticated caller.

Returns The requested page in items, and the count of all matching runs (before pagination) in total.