Skip to content
This repository was archived by the owner on Sep 16, 2025. It is now read-only.

Commit a87e595

Browse files
committed
add preferredQueryEngine to run the query on Upsolver instead of the default Athena
1 parent 9d3497f commit a87e595

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

upsolver/client/query.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,10 @@
55

66
ExecutionResult = list
77

8+
preferredQueryEngine = {"displayName": "Upsolver",
9+
"engine": {
10+
"clazz": "GetAvailableQueryEnginesUseCase$QueryEngine"}}
11+
812
class RestQueryApi():
913
def __init__(self, requester: Requester, poller_builder: ResponsePollerBuilder):
1014
self.requester = requester
@@ -19,7 +23,7 @@ def execute(self, query: str, timeout_sec: float) -> Iterator[ExecutionResult]:
1923

2024
(data, next_path) = poller(
2125
self.requester,
22-
self.requester.post('query', json={'sql': query})
26+
self.requester.post('query', json={'sql': query, 'preferredQueryEngine': preferredQueryEngine})
2327
)
2428
yield data
2529

0 commit comments

Comments
 (0)