'Wait for a workflow invocation to completely schedule and then history
to be complete.'

def wait_for_workflow(self, workflow_id, invocation_id, history_id, assert_ok=True, timeout=DEFAULT_TIMEOUT):

    self.wait_for_invocation(workflow_id, invocation_id, timeout=timeout)
    self.dataset_populator.wait_for_history(history_id, assert_ok=assert_ok, timeout=timeout)
