pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2025-10-26 11:16:12 +08:00
Code Issues Projects Releases Wiki Activity

rename ctx2 to ctx

Browse Source
This commit is contained in:
strobus
2021-08-26 19:23:13 -04:00
parent 626e626058
commit 39a9689336
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
internal/asynqtest/asynqtest.go
View File

@@ -170,8 +170,8 @@ func FlushDB(tb testing.TB, r redis.UniversalClient) {
tb.Fatal(err)
}
case *redis.ClusterClient:
err := r.ForEachMaster(context.Background(), func(ctx2 context.Context, c *redis.Client) error {
if err := c.FlushAll(ctx2).Err(); err != nil {
err := r.ForEachMaster(context.Background(), func(ctx context.Context, c *redis.Client) error {
if err := c.FlushAll(ctx).Err(); err != nil {
return err
}
return nil