Skip to content

Commit 8b27983

Browse files
authored
fix: fix TestAcquireJobWithCancel_Cancel flake (#18441)
1 parent b0fa327 commit 8b27983

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

coderd/provisionerdserver/provisionerdserver.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -368,7 +368,7 @@ func (s *server) AcquireJobWithCancel(stream proto.DRPCProvisionerDaemon_Acquire
368368
je = <-jec
369369
case je = <-jec:
370370
}
371-
if xerrors.Is(je.err, context.Canceled) {
371+
if database.IsQueryCanceledError(je.err) {
372372
s.Logger.Debug(streamCtx, "successful cancel")
373373
err := stream.Send(&proto.AcquiredJob{})
374374
if err != nil {

0 commit comments

Comments
 (0)