defer deadlockCancel()
for _, cr := range allcrs {
if strings.Contains(cr.Command[2], " j ") && !strings.Contains(cr.Command[2], " k ") {
+ cr := cr
wg.Add(1)
go func() {
defer wg.Done()
"state": "Cancelled",
},
})
+ if errors.Is(err, context.Canceled) {
+ break
+ }
c.Assert(err, IsNil)
}
time.Sleep(time.Second / 10)