crate.operator.utils.notifications module

class crate.operator.utils.notifications.FlushNotificationsSubHandler(namespace, name, ref, context, depends_on=None, run_on_dep_failures=False, operation=None)

Bases: StateBasedSubHandler

Ensures any previously registered and pending notification is sent.

Parameters:

• namespace (str)

• name (str)

• ref (str)

• context (dict)

• operation (Optional[OperationType])

async handle(namespace, name, body, old, logger, status, **kwargs)

Parameters:

• namespace (str)

• name (str)

• body (Body)

• old (Body)

• logger (Logger)

• status (Status)

• kwargs (Any)

async crate.operator.utils.notifications.send_operation_progress_notification(*, namespace, name, message, logger, status, operation, action)

Parameters:

• namespace (str)

• name (str)

• message (str)

• logger (Logger)

• status (WebhookStatus)

• operation (WebhookOperation)

• action (WebhookAction)