Skip to main content

​
prefect.server.events.models.automations

​
Functions

​
emit_automation_created_event 

emit_automation_created_event(automation: Automation) -> None
Emit an event when an automation is created.

​
emit_automation_updated_event 

emit_automation_updated_event(automation: Automation) -> None
Emit an event when an automation is updated.

​
emit_automation_deleted_event 

emit_automation_deleted_event(automation: Automation) -> None
Emit an event when an automation is deleted.

​
automations_session 

automations_session(db: PrefectDBInterface, begin_transaction: bool = False) -> AsyncGenerator[AsyncSession, None]

​
read_automations_for_workspace 

read_automations_for_workspace(db: PrefectDBInterface, session: AsyncSession, sort: AutomationSort = AutomationSort.NAME_ASC, limit: Optional[int] = None, offset: Optional[int] = None, automation_filter: Optional[filters.AutomationFilter] = None) -> Sequence[Automation]

​
count_automations_for_workspace 

count_automations_for_workspace(db: PrefectDBInterface, session: AsyncSession) -> int

​
read_automation 

read_automation(db: PrefectDBInterface, session: AsyncSession, automation_id: UUID) -> Optional[Automation]

​
read_automation_by_id 

read_automation_by_id(db: PrefectDBInterface, session: AsyncSession, automation_id: UUID) -> Optional[Automation]

​
create_automation 

create_automation(db: PrefectDBInterface, session: AsyncSession, automation: Automation) -> Automation

​
update_automation 

update_automation(db: PrefectDBInterface, session: AsyncSession, automation_update: Union[AutomationUpdate, AutomationPartialUpdate], automation_id: UUID) -> bool

​
delete_automation 

delete_automation(db: PrefectDBInterface, session: AsyncSession, automation_id: UUID) -> bool

​
delete_automations_for_workspace 

delete_automations_for_workspace(db: PrefectDBInterface, session: AsyncSession) -> bool

​
disable_automations_for_workspace 

disable_automations_for_workspace(db: PrefectDBInterface, session: AsyncSession) -> bool

​
disable_automation 

disable_automation(db: PrefectDBInterface, session: AsyncSession, automation_id: UUID) -> bool

​
relate_automation_to_resource 

relate_automation_to_resource(db: PrefectDBInterface, session: AsyncSession, automation_id: UUID, resource_id: str, owned_by_resource: bool) -> None

read_automations_related_to_resource(db: PrefectDBInterface, session: AsyncSession, resource_id: str, owned_by_resource: Optional[bool] = None, automation_filter: Optional[filters.AutomationFilter] = None) -> Sequence[Automation]

​
delete_automations_owned_by_resource 

delete_automations_owned_by_resource(db: PrefectDBInterface, session: AsyncSession, resource_id: str, automation_filter: Optional[filters.AutomationFilter] = None) -> Sequence[UUID]