File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 4040import prestodb .logging
4141import prestodb .redirect
4242import requests
43+ from six .moves .urllib .parse import urlparse
4344from prestodb import constants , exceptions
4445from prestodb .transaction import NO_TRANSACTION
4546
@@ -337,7 +338,8 @@ def statement_url(self):
337338 @property
338339 def next_uri (self ):
339340 # type: () -> Text
340- return self ._next_uri
341+ next_uri_path = urlparse (self ._next_uri ).path
342+ return self .get_url (next_uri_path )
341343
342344 def post (self , sql ):
343345 data = sql .encode ("utf-8" )
@@ -431,7 +433,7 @@ def process(self, http_response):
431433 stats = response ["stats" ],
432434 warnings = response .get ("warnings" , []),
433435 info_uri = response ["infoUri" ],
434- next_uri = self ._next_uri ,
436+ next_uri = self .next_uri () ,
435437 rows = response .get ("data" , []),
436438 columns = response .get ("columns" ),
437439 )
You can’t perform that action at this time.
0 commit comments