When returning an exception as the result of an orchestration, the orchestration will never complete:
Example:
def test_orchestrator(ctx: task.OrchestrationContext, _):
entity_id = EntityInstanceId("FailingEntity", "testEntity")
try:
yield ctx.call_entity(entity_id, "fail")
except task.TaskFailedError as e:
return e
This orchestration will never complete.