File tree Expand file tree Collapse file tree 1 file changed +20
-0
lines changed
Expand file tree Collapse file tree 1 file changed +20
-0
lines changed Original file line number Diff line number Diff line change 540540 client . advance
541541
542542 sleep 1
543+
543544 stub_request ( :get , "localhost/v1/next_uri" ) .
544545 with ( headers : headers ) .
545546 to_return ( body : planning_response . to_json )
547+
548+ cancelled = false
549+ stub_request ( :delete , "localhost/v1/next_uri" ) .
550+ with ( headers : headers ) .
551+ to_return ( status : lambda { |req | cancelled = true ; 204 } ) # NoContent
552+
546553 expect do
547554 client . advance
548555 end . to raise_error ( Trino ::Client ::TrinoQueryTimeoutError , "Query queryid timed out" )
556+
557+ expect ( cancelled ) . to eq true
558+ expect ( client . client_error? ) . to eq true
549559 end
550560
551561 it "raises TrinoQueryTimeoutError if timeout during initial resuming" do
602612 client . advance
603613
604614 sleep 1
615+
605616 stub_request ( :get , "localhost/v1/next_uri" ) .
606617 with ( headers : headers ) .
607618 to_return ( body : late_running_response . to_json )
619+
620+ cancelled = false
621+ stub_request ( :delete , "localhost/v1/next_uri" ) .
622+ with ( headers : headers ) .
623+ to_return ( status : lambda { |req | cancelled = true ; 204 } ) # NoContent
624+
608625 expect do
609626 client . advance
610627 end . to raise_error ( Trino ::Client ::TrinoQueryTimeoutError , "Query queryid timed out" )
628+
629+ expect ( cancelled ) . to eq true
630+ expect ( client . client_error? ) . to eq true
611631 end
612632
613633 it "doesn't raise errors if query is done" do
You can’t perform that action at this time.
0 commit comments