prefect.server.events.models.automations
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
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]
Was this page helpful?