[GH-ISSUE #488] [FEATURE REQUEST] `RDB` and `Inspector` support Go contexts #221

New issue

Open

opened 2026-03-02 05:19:44 +03:00 by kerem · 1 comment

kerem commented

2026-03-02 05:19:44 +03:00

Owner

Originally created by @xuyang2 on GitHub (Jun 13, 2022).
Original GitHub issue: https://github.com/hibiken/asynq/issues/488

Originally assigned to: @hibiken on GitHub.

Is your feature request related to a problem? Please describe.
Is it acceptable to add a ctx context.Context parameter to some RDB and Inspector methods, for deadline, cancellation and observability(otel).

Describe the solution you'd like

Take Inspector.Queues() for example:

// QueuesContext returns a list of all queue names.
func (i *Inspector) QueuesContext(ctx context.Context) ([]string, error) {
	return i.rdb.AllQueuesContext(ctx)
}

// Queues returns a list of all queue names.
func (i *Inspector) Queues() ([]string, error) {
	return i.QueuesContext(context.Background())
}

// AllQueuesContext returns a list of all queue names.
func (r *RDB) AllQueuesContext(ctx context.Context) ([]string, error) {
	return r.client.SMembers(ctx, base.AllQueues).Result()
}

// AllQueues returns a list of all queue names.
func (r *RDB) AllQueues() ([]string, error) {
	return r.AllQueuesContext(context.Background())
}

I can make a PR if this is acceptable.

Originally created by @xuyang2 on GitHub (Jun 13, 2022). Original GitHub issue: https://github.com/hibiken/asynq/issues/488 Originally assigned to: @hibiken on GitHub. **Is your feature request related to a problem? Please describe.** Is it acceptable to add a `ctx context.Context` parameter to some `RDB` and `Inspector` methods, for deadline, cancellation and observability(otel). **Describe the solution you'd like** Take `Inspector.Queues()` for example: ```Go // QueuesContext returns a list of all queue names. func (i *Inspector) QueuesContext(ctx context.Context) ([]string, error) { return i.rdb.AllQueuesContext(ctx) } // Queues returns a list of all queue names. func (i *Inspector) Queues() ([]string, error) { return i.QueuesContext(context.Background()) } ``` ```Go // AllQueuesContext returns a list of all queue names. func (r *RDB) AllQueuesContext(ctx context.Context) ([]string, error) { return r.client.SMembers(ctx, base.AllQueues).Result() } // AllQueues returns a list of all queue names. func (r *RDB) AllQueues() ([]string, error) { return r.AllQueuesContext(context.Background()) } ``` I can make a PR if this is acceptable.

kerem added the

enhancement

good first issue

labels

2026-03-02 05:19:44 +03:00

kerem commented

2026-03-02 05:19:45 +03:00

Author

Owner

@hibiken commented on GitHub (Jun 18, 2022):

@xuyang2 Yes I think it makes sense to support context for all inspector operations. Please feel free to create a PR!

@hibiken commented on GitHub (Jun 18, 2022): @xuyang2 Yes I think it makes sense to support context for all inspector operations. Please feel free to create a PR!

kerem referenced this issue

2026-03-02 05:54:31 +03:00

[PR #226] [MERGED] Enhance/toolings #673

kerem referenced this issue

2026-03-07 22:05:37 +03:00

[GH-ISSUE #221] [FEATURE REQUEST] Allow handlers to fail a task permanently (no retry) #1095

kerem referenced this issue

2026-03-07 22:11:55 +03:00

[PR #226] [MERGED] Enhance/toolings #1685

kerem referenced this issue

2026-03-15 19:11:16 +03:00

[GH-ISSUE #221] [FEATURE REQUEST] Allow handlers to fail a task permanently (no retry) #2106