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

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

Creative Commons Attribution 3.0 License

Except where otherwise noted, this document is licensed under Creative Commons Attribution 3.0 License. See all OpenStack Legal Documents.