The karbor.services.operationengine.engine.executors.base Module¶

Executor which receives operations and run them.

class karbor.services.operationengine.engine.executors.base.BaseExecutor(operation_manager)¶

Bases: object

cancel_operation(operation_id)¶

Cancel the execution of operation.

There is no effective for the operations which are running, but for operations which are in waiting, they will not be executed.

Parameters:	operation_id – ID of operation

execute_operation(operation_id, triggered_time, expect_start_time, window_time, **kwargs)¶

Execute an operation.

Parameters:	operation_id – ID of operation triggered_time – time when the operation is triggered expect_start_time – expect time when to run the operation window_time – time how long to wait to run the operation after expect_start_time

resume_operation(operation_id, **kwargs)¶

Resume operations.

Get operations which are not finished from DB by operation_id, and execute them again.

Parameters:	operation_id – ID of operation

shutdown()¶

Shutdown the executor