The heat.engine.worker Module

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

Bases: oslo_service.service.Service

Service that has ‘worker’ actor in convergence.

This service is dedicated to handle internal messages to the ‘worker’ (a.k.a. ‘converger’) actor in convergence. Messages on this bus will use the ‘cast’ rather than ‘call’ method to anycast the message to an engine that will handle it asynchronously. It won’t wait for or expect replies from these messages.

RPC_API_VERSION = '1.3'
cancel_check_resource(*args, **kwargs)[source]

Cancel check_resource for given stack.

All the workers running for the given stack will be cancelled.

check_resource(*args, **kwargs)[source]

Process a node in the dependency graph.

The node may be associated with either an update or a cleanup of its associated resource.

reset(*args, **kwargs)

Reset a service in case it received a SIGHUP.

start(*args, **kwargs)[source]
stop(*args, **kwargs)[source]
stop_all_workers(*args, **kwargs)[source]
stop_traversal(*args, **kwargs)[source]

Update current traversal to stop workers from propagating.

Marks the stack as FAILED due to cancellation, but, allows all in_progress resources to complete normally; no worker is stopped abruptly.

wait(*args, **kwargs)

Wait for a service to shut down.

Previous topic

The heat.engine.watchrule Module

Next topic

The heat.hacking.checks Module

Project Source

This Page