def get_entity(
self, entity_type, entity_id, history_index=-1, connected=True):
- """Return an object instance representing the entity created or
- updated by ``delta``
+ """Return an object instance for the given entity_type and id.
+
+ By default the object state matches the most recent state from
+ Juju. To get an instance of the object in an older state, pass
+ history_index, an index into the history deque for the entity.
- """
- """
- log.debug(
- 'Getting %s:%s at index %s',
- entity_type, entity_id, history_index)
"""
if history_index < 0 and history_index != -1:
This coroutine blocks until the new object appears in the model.
"""
- return await self._wait(entity_type, entity_id, predicate)
+ return await self._wait(entity_type, entity_id, 'add', predicate)
async def wait_for_action(self, action_id):
"""Given an action, wait for it to complete."""
action_id = action_id[7:]
def predicate(delta):
- return delta.data['status'] in ('completed', 'error')
+ return delta.data['status'] in ('completed', 'failed')
return await self._wait('action', action_id, 'change', predicate)