Loading nixos/tests/temporal.nix +8 −8 Original line number Diff line number Diff line Loading @@ -274,32 +274,32 @@ ) import json cluster_list_json = json.loads(temporal.wait_until_succeeds("temporal operator cluster list --output json")) cluster_list_json = json.loads(temporal.wait_until_succeeds("temporal operator cluster list --output json", timeout=60)) assert cluster_list_json[0]['clusterName'] == "active" cluster_describe_json = json.loads(temporal.wait_until_succeeds("temporal operator cluster describe --output json")) cluster_describe_json = json.loads(temporal.wait_until_succeeds("temporal operator cluster describe --output json", timeout=60)) assert cluster_describe_json['serverVersion'] in "${pkgs.temporal.version}" temporal.log(temporal.wait_until_succeeds("temporal operator namespace create --namespace default")) temporal.log(temporal.wait_until_succeeds("temporal operator namespace create --namespace default", timeout=60)) temporal.wait_until_succeeds( "journalctl -o cat -u temporal.service | grep 'Register namespace succeeded'" ) namespace_list_json = json.loads(temporal.wait_until_succeeds("temporal operator namespace list --output json")) namespace_list_json = json.loads(temporal.wait_until_succeeds("temporal operator namespace list --output json", timeout=60)) assert len(namespace_list_json) == 2 namespace_describe_json = json.loads(temporal.wait_until_succeeds("temporal operator namespace describe --output json --namespace default")) namespace_describe_json = json.loads(temporal.wait_until_succeeds("temporal operator namespace describe --output json --namespace default", timeout=60)) assert namespace_describe_json['namespaceInfo']['name'] == "default" assert namespace_describe_json['namespaceInfo']['state'] == "NAMESPACE_STATE_REGISTERED" workflow_json = json.loads(temporal.wait_until_succeeds("temporal workflow list --output json")) workflow_json = json.loads(temporal.wait_until_succeeds("temporal workflow list --output json", timeout=60)) assert len(workflow_json) == 0 out = temporal.wait_until_succeeds("temporal-hello-workflow.py") out = temporal.wait_until_succeeds("temporal-hello-workflow.py", timeout=60) assert "Result: Hello, World!" in out workflow_json = json.loads(temporal.wait_until_succeeds("temporal workflow list --output json")) workflow_json = json.loads(temporal.wait_until_succeeds("temporal workflow list --output json", timeout=60)) assert workflow_json[0]['execution']['workflowId'] == "hello-activity-workflow-id" assert workflow_json[0]['status'] == "WORKFLOW_EXECUTION_STATUS_COMPLETED" Loading Loading
nixos/tests/temporal.nix +8 −8 Original line number Diff line number Diff line Loading @@ -274,32 +274,32 @@ ) import json cluster_list_json = json.loads(temporal.wait_until_succeeds("temporal operator cluster list --output json")) cluster_list_json = json.loads(temporal.wait_until_succeeds("temporal operator cluster list --output json", timeout=60)) assert cluster_list_json[0]['clusterName'] == "active" cluster_describe_json = json.loads(temporal.wait_until_succeeds("temporal operator cluster describe --output json")) cluster_describe_json = json.loads(temporal.wait_until_succeeds("temporal operator cluster describe --output json", timeout=60)) assert cluster_describe_json['serverVersion'] in "${pkgs.temporal.version}" temporal.log(temporal.wait_until_succeeds("temporal operator namespace create --namespace default")) temporal.log(temporal.wait_until_succeeds("temporal operator namespace create --namespace default", timeout=60)) temporal.wait_until_succeeds( "journalctl -o cat -u temporal.service | grep 'Register namespace succeeded'" ) namespace_list_json = json.loads(temporal.wait_until_succeeds("temporal operator namespace list --output json")) namespace_list_json = json.loads(temporal.wait_until_succeeds("temporal operator namespace list --output json", timeout=60)) assert len(namespace_list_json) == 2 namespace_describe_json = json.loads(temporal.wait_until_succeeds("temporal operator namespace describe --output json --namespace default")) namespace_describe_json = json.loads(temporal.wait_until_succeeds("temporal operator namespace describe --output json --namespace default", timeout=60)) assert namespace_describe_json['namespaceInfo']['name'] == "default" assert namespace_describe_json['namespaceInfo']['state'] == "NAMESPACE_STATE_REGISTERED" workflow_json = json.loads(temporal.wait_until_succeeds("temporal workflow list --output json")) workflow_json = json.loads(temporal.wait_until_succeeds("temporal workflow list --output json", timeout=60)) assert len(workflow_json) == 0 out = temporal.wait_until_succeeds("temporal-hello-workflow.py") out = temporal.wait_until_succeeds("temporal-hello-workflow.py", timeout=60) assert "Result: Hello, World!" in out workflow_json = json.loads(temporal.wait_until_succeeds("temporal workflow list --output json")) workflow_json = json.loads(temporal.wait_until_succeeds("temporal workflow list --output json", timeout=60)) assert workflow_json[0]['execution']['workflowId'] == "hello-activity-workflow-id" assert workflow_json[0]['status'] == "WORKFLOW_EXECUTION_STATUS_COMPLETED" Loading