Skip to content

Commit

Permalink
fix: support ExecContext cancel query (#127)
Browse files Browse the repository at this point in the history
* fix: support ExecContext cancel query

* fix
  • Loading branch information
hantmac authored Jun 13, 2024
1 parent 0e43f54 commit e0546ae
Showing 1 changed file with 6 additions and 0 deletions.
6 changes: 6 additions & 0 deletions restful.go
Original file line number Diff line number Diff line change
Expand Up @@ -377,6 +377,12 @@ func (c *APIClient) PollUntilQueryEnd(ctx context.Context, resp *QueryResponse)
data := resp.Data
resp, err = c.PollQuery(ctx, resp.NextURI)
if err != nil {
if errors.Is(err, context.Canceled) {
// context might be canceled due to timeout or canceled. if it's canceled, we need call
// the kill url to tell the backend it's killed.
fmt.Printf("query canceled, kill query:%s", resp.ID)
_ = c.KillQuery(context.Background(), resp)
}
return nil, err
}
if resp.Error != nil {
Expand Down

0 comments on commit e0546ae

Please sign in to comment.