The heat.engine.sync_point Module¶

heat.engine.sync_point.create(context, entity_id, traversal_id, is_update, stack_id)[source]¶

Creates a sync point entry in DB.

heat.engine.sync_point.delete_all(context, stack_id, traversal_id)[source]¶

Deletes all sync points of a stack associated with a traversal_id.

heat.engine.sync_point.deserialize_input_data(db_input_data)[source]¶

heat.engine.sync_point.get(context, entity_id, traversal_id, is_update)[source]¶

Retrieves a sync point entry from DB.

heat.engine.sync_point.make_key(*components)[source]¶

heat.engine.sync_point.serialize_input_data(input_data)[source]¶

heat.engine.sync_point.str_pack_tuple(t)[source]¶

heat.engine.sync_point.sync(cnxt, entity_id, current_traversal, is_update, propagate, predecessors, new_data)[source]¶

heat.engine.sync_point.update_input_data(context, entity_id, current_traversal, is_update, atomic_key, input_data)[source]¶

class heat.engine.sync_point.wait_random_exponential(min=0, multiplier=1, max=4611686018427387903, exp_base=2)[source]¶

Bases: tenacity.wait.wait_exponential

Random wait strategy with a geometrically increasing amount of jitter.

Implements the truncated binary exponential backoff algorithm as used in e.g. CSMA media access control. The retry occurs at a random time in a (geometrically) expanding interval constrained by minimum and maximum limits.