heat.engine.worker 模块

class heat.engine.worker.WorkerService(host, topic, engine_id, thread_group_mgr)[source]

基类: object

在收敛中具有“worker”角色的服务。

此服务专用于处理收敛中“worker”（也称为“converger”）角色的内部消息。 此总线上的消息将使用“cast”方法而不是“call”方法将消息广播到将异步处理它的引擎。 它不会等待或期望这些消息的回复。

RPC_API_VERSION = '1.4'
cancel_check_resource(cnxt, stack_id)[source]

取消给定堆栈的 check_resource。

将取消为给定堆栈运行的所有 worker。

check_resource(cnxt, resource_id, current_traversal, data, is_update, adopt_stack_data, converge=False)[source]

处理依赖关系图中的一个节点。

该节点可能与相关资源的更新或清理相关联。

start()[source]
stop()[source]
stop_all_workers(stack)[source]

取消堆栈的所有现有 worker 线程。

线程将在下一次 yield 点停止运行，无论资源操作是否完成。

stop_traversal(stack)[source]

更新当前遍历以停止 worker 的传播。

将堆栈标记为由于取消而 FAILED，但是，允许所有正在进行的资源正常完成；不会突然停止任何 worker。

所有嵌套堆栈的任何正在进行的遍历也会停止，这些堆栈是传递堆栈的后代。

heat.engine.worker.log_exceptions(func)[source]