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.get(context, entity_id, traversal_id, is_update)[source]¶
Retrieves a sync point entry from DB.
- heat.engine.sync_point.sync(cnxt, entity_id, current_traversal, is_update, propagate, predecessors, new_data, new_resource_failures=None, is_skip=False)[source]¶
Synchronize resource state and propagate when all predecessors done.
This function updates the sync point with new data and resource failures, and calls the propagate callback when all predecessors have reported.
- heat.engine.sync_point.update_input_data(context, entity_id, current_traversal, is_update, atomic_key, input_data=None, extra_data=None)[source]¶
- heat.engine.sync_point.update_sync_point(cnxt, entity_id, current_traversal, is_update, predecessors, new_data, new_resource_failures=None, is_skip=False)[source]¶
Update a sync point atomically with new data and failures.
Retry waits up to 60 seconds at most, with exponentially increasing amounts of jitter per resource still outstanding.
