mirror of
https://github.com/amir20/dozzle.git
synced 2026-06-23 04:10:12 +00:00
chore: debug logs
Push container / Push branches and PRs (push) Has been cancelled
Deploy VitePress site to Pages / build (push) Has been cancelled
Deploy VitePress site to Pages / Deploy (push) Has been cancelled
Test / Typecheck (push) Has been cancelled
Test / JavaScript Tests (push) Has been cancelled
Test / Go Tests (push) Has been cancelled
Test / Go Staticcheck (push) Has been cancelled
Test / Integration Tests (push) Has been cancelled
Push container / Push branches and PRs (push) Has been cancelled
Deploy VitePress site to Pages / build (push) Has been cancelled
Deploy VitePress site to Pages / Deploy (push) Has been cancelled
Test / Typecheck (push) Has been cancelled
Test / JavaScript Tests (push) Has been cancelled
Test / Go Tests (push) Has been cancelled
Test / Go Staticcheck (push) Has been cancelled
Test / Integration Tests (push) Has been cancelled
This commit is contained in:
@@ -236,8 +236,11 @@ func (c *Client) connect(ctx context.Context, apiKey string) (wasConnected bool,
|
||||
streamReqID := cancelReq.CancelStream.StreamRequestId
|
||||
if cancel, loaded := c.activeStreams.LoadAndDelete(streamReqID); loaded {
|
||||
if cancelFn, ok := cancel.(context.CancelFunc); ok {
|
||||
log.Debug().Str("request_id", streamReqID).Msg("cancelling active stream")
|
||||
cancelFn()
|
||||
}
|
||||
} else {
|
||||
log.Warn().Str("request_id", streamReqID).Msg("cancel_stream: no active stream found")
|
||||
}
|
||||
continue
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user