1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
|
from azure.kusto.data.exceptions import OneApiError
def test_parse_one_api_error():
result = OneApiError.from_dict(
{
"code": "LimitsExceeded",
"message": "Request is invalid and cannot be executed.",
"@type": "Kusto.Data.Exceptions.KustoServicePartialQueryFailureLimitsExceededException",
"@message": "Query execution has exceeded the allowed limits (80DA0003): .",
"@context": {
"timestamp": "2018-12-10T15:10:48.8352222Z",
"machineName": "RD0003FFBEDEB9",
"processName": "Kusto.Azure.Svc",
"processId": 4328,
"threadId": 7284,
"appDomainName": "RdRuntime",
"clientRequestId": "KPC.execute;d3a43e37-0d7f-47a9-b6cd-a889b2aee3d3",
"activityId": "a57ec272-8846-49e6-b458-460b841ed47d",
"subActivityId": "a57ec272-8846-49e6-b458-460b841ed47d",
"activityType": "PO-OWIN-CallContext",
"parentActivityId": "a57ec272-8846-49e6-b458-460b841ed47d",
"activityStack": "(Activity stack: CRID=KPC.execute;d3a43e37-0d7f-47a9-b6cd-a889b2aee3d3 ARID=a57ec272-8846-49e6-b458-460b841ed47d > PO-OWIN-CallContext/a57ec272-8846-49e6-b458-460b841ed47d)",
},
"@permanent": False,
}
)
assert result.code == "LimitsExceeded"
assert result.type == "Kusto.Data.Exceptions.KustoServicePartialQueryFailureLimitsExceededException"
assert result.message == "Request is invalid and cannot be executed."
assert result.description == "Query execution has exceeded the allowed limits (80DA0003): ."
assert not result.permanent
assert result.context["timestamp"] == "2018-12-10T15:10:48.8352222Z"
assert result.context["machineName"] == "RD0003FFBEDEB9"
assert result.context["processName"] == "Kusto.Azure.Svc"
assert result.context["processId"] == 4328
assert result.context["threadId"] == 7284
assert result.context["appDomainName"] == "RdRuntime"
assert result.context["clientRequestId"] == "KPC.execute;d3a43e37-0d7f-47a9-b6cd-a889b2aee3d3"
assert result.context["activityId"] == "a57ec272-8846-49e6-b458-460b841ed47d"
assert result.context["subActivityId"] == "a57ec272-8846-49e6-b458-460b841ed47d"
assert result.context["activityType"] == "PO-OWIN-CallContext"
assert result.context["parentActivityId"] == "a57ec272-8846-49e6-b458-460b841ed47d"
assert (
result.context["activityStack"] == "(Activity stack: CRID=KPC.execute;d3a43e37-0d7f-47a9-b6cd-a889b2aee3d3 ARID=a57ec272-8846-49e6-b458-460b841ed47d "
"> PO-OWIN-CallContext/a57ec272-8846-49e6-b458-460b841ed47d)"
)
def test_one_api_error_no_type_success():
result = OneApiError.from_dict(
{
"code": "LimitsExceeded",
"message": "Request is invalid and cannot be executed.",
"@message": "Query execution has exceeded the allowed limits (80DA0003): .",
"@context": {
"timestamp": "2018-12-10T15:10:48.8352222Z",
"machineName": "RD0003FFBEDEB9",
"processName": "Kusto.Azure.Svc",
"processId": 4328,
"threadId": 7284,
"appDomainName": "RdRuntime",
"clientRequestId": "KPC.execute;d3a43e37-0d7f-47a9-b6cd-a889b2aee3d3",
"activityId": "a57ec272-8846-49e6-b458-460b841ed47d",
"subActivityId": "a57ec272-8846-49e6-b458-460b841ed47d",
"activityType": "PO-OWIN-CallContext",
"parentActivityId": "a57ec272-8846-49e6-b458-460b841ed47d",
"activityStack": "(Activity stack: CRID=KPC.execute;d3a43e37-0d7f-47a9-b6cd-a889b2aee3d3 ARID=a57ec272-8846-49e6-b458-460b841ed47d > PO-OWIN-CallContext/a57ec272-8846-49e6-b458-460b841ed47d)",
},
}
)
assert result.code == "LimitsExceeded"
assert not result.permanent
def test_one_api_error_no_code_fail():
result = OneApiError.from_dict(
{
"message": "Request is invalid and cannot be executed.",
"@message": "Query execution has exceeded the allowed limits (80DA0003): .",
"@context": {
"timestamp": "2018-12-10T15:10:48.8352222Z",
"machineName": "RD0003FFBEDEB9",
"processName": "Kusto.Azure.Svc",
"processId": 4328,
"threadId": 7284,
"appDomainName": "RdRuntime",
"clientRequestId": "KPC.execute;d3a43e37-0d7f-47a9-b6cd-a889b2aee3d3",
"activityId": "a57ec272-8846-49e6-b458-460b841ed47d",
"subActivityId": "a57ec272-8846-49e6-b458-460b841ed47d",
"activityType": "PO-OWIN-CallContext",
"parentActivityId": "a57ec272-8846-49e6-b458-460b841ed47d",
"activityStack": "(Activity stack: CRID=KPC.execute;d3a43e37-0d7f-47a9-b6cd-a889b2aee3d3 ARID=a57ec272-8846-49e6-b458-460b841ed47d > PO-OWIN-CallContext/a57ec272-8846-49e6-b458-460b841ed47d)",
},
"@permanent": False,
}
)
assert result.code == "FailedToParse"
assert result.type == "FailedToParseOneApiError"
assert not result.permanent
|
