Remove 1s buffer from cordon range (#226)

meatballhat · web-flow · commit 5f85c6958df6 · 2025-10-15T09:16:22.000-04:00
since it works so well that having the buffer actually results in early
cancelation.
diff --git a/queue/client.go b/queue/client.go
@@ -268,7 +268,7 @@ func (c *Client) CordonDeadlineExceeded(ctx context.Context, within time.Duratio
 	pipe := c.rdb.Pipeline()
 	zRangeOpts := &redis.ZRangeBy{
 		Min: strconv.Itoa(int(start.Add(-within).Unix())),
-		Max: strconv.Itoa(int(start.Add(1 * time.Second).Unix())),
+		Max: strconv.Itoa(int(start.Unix())),
 	}
 
 	zRangeCmd := c.rdb.ZRangeByScoreWithScores(

Original file line number	Diff line number	Diff line change
`@@ -268,7 +268,7 @@ func (c *Client) CordonDeadlineExceeded(ctx context.Context, within time.Duratio`
`268`	`268`	`pipe := c.rdb.Pipeline()`
`269`	`269`	`zRangeOpts := &redis.ZRangeBy{`
`270`	`270`	`Min: strconv.Itoa(int(start.Add(-within).Unix())),`
`271`		`- Max: strconv.Itoa(int(start.Add(1 * time.Second).Unix())),`
	`271`	`+ Max: strconv.Itoa(int(start.Unix())),`
`272`	`272`	`}`
`273`	`273`
`274`	`274`	`zRangeCmd := c.rdb.ZRangeByScoreWithScores(`