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]¶