Skip to content

Commit 54b316a

Browse files
committed
Switch to last-return exception checking
1 parent 8f0c04f commit 54b316a

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

redisgraph/query_result.py

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
from .node import Node
22
from .edge import Edge
33
from prettytable import PrettyTable
4+
from redis import ResponseError
45

56
class ResultSetColumnTypes(object):
67
COLUMN_UNKNOWN = 0
@@ -15,7 +16,6 @@ class ResultSetScalarTypes(object):
1516
PROPERTY_INTEGER = 3
1617
PROPERTY_BOOLEAN = 4
1718
PROPERTY_DOUBLE = 5
18-
PROPERTY_ERROR = 6
1919

2020
class QueryResult(object):
2121
LABELS_ADDED = 'Labels added'
@@ -31,6 +31,10 @@ def __init__(self, graph, response):
3131
self.header = []
3232
self.result_set = []
3333

34+
# If we encountered a run-time error, the last response element will be an exception.
35+
if isinstance(response[-1], ResponseError):
36+
raise response[-1]
37+
3438
if len(response) is 1:
3539
self.parse_statistics(response[0])
3640
else:
@@ -140,9 +144,6 @@ def parse_scalar(self, cell):
140144
elif scalar_type == ResultSetScalarTypes.PROPERTY_DOUBLE:
141145
scalar = float(value)
142146

143-
elif scalar_type == ResultSetScalarTypes.PROPERTY_ERROR:
144-
raise value
145-
146147
elif scalar_type == ResultSetScalarTypes.PROPERTY_UNKNOWN:
147148
print("Unknown scalar type\n")
148149

0 commit comments

Comments
 (0)