crate.operator.rollback module

class crate.operator.rollback.FinalRollbackSubHandler(namespace, name, ref, context, depends_on=None, run_on_dep_failures=False, operation=None)

Bases: StateBasedSubHandler

Parameters:

• namespace (str)

• name (str)

• ref (str)

• context (dict)

• operation (Optional[OperationType])

async handle(**kwargs)

Parameters:

kwargs (Any)

async perform_rollback(**kwargs)

class crate.operator.rollback.RollbackHandler(namespace, name, body, patch, logger, ref=None, context=None)

Bases: object

Parameters:

• namespace (str)

• name (str)

• body (Body)

• patch (Patch)

• logger (Logger)

• ref (Optional[str])

• context (Optional[dict])

annotation_key()

Return type:

str

static annotation_key_for(op)

Parameters:

op (OperationType)

Return type:

str

clear_rollback()

get_operation_type()

Return type:

OperationType

is_in_rollback()

Return type:

bool

mark_rollback()

async rollback()

class crate.operator.rollback.RollbackUpgradeSubHandler(namespace, name, body, patch, logger, ref=None, context=None)

Bases: RollbackHandler

Parameters:

• namespace (str)

• name (str)

• body (Body)

• patch (Patch)

• logger (Logger)

• ref (Optional[str])

• context (Optional[dict])

get_operation_type()

Return type:

OperationType

async rollback(**kwargs)