File tree Expand file tree Collapse file tree 1 file changed +4
-14
lines changed
Expand file tree Collapse file tree 1 file changed +4
-14
lines changed Original file line number Diff line number Diff line change 11
2+ from grpc ._channel import _InactiveRpcError
23import pytest
34from durabletask import client , task , worker
45
@@ -22,17 +23,6 @@ def test_get_all_orchestration_states():
2223 id = c .schedule_new_orchestration (empty_orchestrator , input = "Hello" )
2324 c .wait_for_orchestration_completion (id , timeout = 30 )
2425
25- all_orchestrations = c .get_all_orchestration_states ()
26- this_orch = c .get_orchestration_state (id )
27-
28- assert this_orch is not None
29- assert this_orch .instance_id == id
30-
31- assert all_orchestrations is not None
32- matching_orchestrations = [o for o in all_orchestrations if o .instance_id == id ]
33- assert len (matching_orchestrations ) == 1
34- orchestration_state = matching_orchestrations [0 ]
35- assert orchestration_state .runtime_status == client .OrchestrationStatus .COMPLETED
36- assert orchestration_state .serialized_input == '"Hello"'
37- assert orchestration_state .serialized_output == '"Complete"'
38- assert orchestration_state .failure_details is None
26+ with pytest .raises (_InactiveRpcError ) as exec_info :
27+ all_orchestrations = c .get_all_orchestration_states ()
28+ assert "unimplemented" in str (exec_info .value )
You can’t perform that action at this time.
0 commit comments