ContextQMD
Back to Prefect

events

docs/v3/api-ref/python/prefect-server-models-events.mdx

3.7.5.dev15.4 KB
Original Source

prefect.server.models.events

Functions

flow_run_state_change_event <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/models/events.py#L42" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
flow_run_state_change_event(session: AsyncSession, occurred: datetime, flow_run: ORMFlowRun, initial_state_id: Optional[UUID], initial_state: Optional[schemas.states.State], validated_state_id: Optional[UUID], validated_state: schemas.states.State) -> Event

state_payload <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/models/events.py#L262" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
state_payload(state: Optional[schemas.states.State]) -> Optional[Dict[str, str]]

Given a State, return the essential string parts of it for use in an event payload

deployment_status_event <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/models/events.py#L379" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
deployment_status_event(session: AsyncSession, deployment_id: UUID, status: DeploymentStatus, occurred: DateTime) -> Event

deployment_created_event <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/models/events.py#L402" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
deployment_created_event(session: AsyncSession, deployment: ORMDeployment, occurred: DateTime) -> Event

Create an event for deployment creation.

deployment_updated_event <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/models/events.py#L420" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
deployment_updated_event(session: AsyncSession, deployment: ORMDeployment, changed_fields: Dict[str, Dict[str, Any]], occurred: DateTime) -> Event

Create an event for deployment field updates.

deployment_deleted_event <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/models/events.py#L443" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
deployment_deleted_event(session: AsyncSession, deployment: ORMDeployment, occurred: DateTime) -> Event

Create an event for deployment deletion.

work_queue_status_event <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/models/events.py#L461" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
work_queue_status_event(session: AsyncSession, work_queue: 'ORMWorkQueue', occurred: DateTime) -> Event

work_pool_status_event <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/models/events.py#L497" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
work_pool_status_event(event_id: UUID, occurred: DateTime, pre_update_work_pool: Optional['ORMWorkPool'], work_pool: 'ORMWorkPool') -> Event

work_pool_updated_event <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/models/events.py#L518" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
work_pool_updated_event(session: AsyncSession, work_pool: 'ORMWorkPool', changed_fields: Dict[str, Dict[str, Any]], occurred: DateTime) -> Event

Create an event for work pool field updates (non-status).

work_queue_updated_event <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/models/events.py#L544" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
work_queue_updated_event(session: AsyncSession, work_queue: 'ORMWorkQueue', changed_fields: Dict[str, Dict[str, Any]], occurred: DateTime) -> Event

Create an event for work queue field updates (non-status).

work_pool_created_event <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/models/events.py#L626" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
work_pool_created_event(work_pool: 'ORMWorkPool', occurred: DateTime) -> Event

Create an event for work pool creation.

work_pool_deleted_event <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/models/events.py#L640" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
work_pool_deleted_event(work_pool: 'ORMWorkPool', occurred: DateTime) -> Event

Create an event for work pool deletion.

work_queue_created_event <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/models/events.py#L676" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
work_queue_created_event(session: AsyncSession, work_queue: 'ORMWorkQueue', occurred: DateTime) -> Event

Create an event for work queue creation.

work_queue_deleted_event <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/server/models/events.py#L695" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
work_queue_deleted_event(session: AsyncSession, work_queue: 'ORMWorkQueue', occurred: DateTime) -> Event

Create an event for work queue deletion.