crate.operator.utils.notifications module

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

Bases: StateBasedSubHandler

Ensures any previously registered and pending notification is sent.

Parameters

• namespace (str) –

• name (str) –

• ref (str) –

• context (dict) –

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) –