Concurrency limit

[michaelangeloio]

Is it possible to set a concurrency limit for a specific queue? Like limit concurrency per user ID?

[markuswustenberg]

@michaelangeloio the queue isn't really concerned with how you consume it, that's on the consumer side.

If you mean within the jobs package, you can set a global concurrent job limit: https://pkg.go.dev/github.com/maragudk/[email protected]/jobs#NewRunnerOpts . But it wouldn't be able to do it based on something like user ID, because there's no concept of user ID in the queue itself.

[michaelangeloio]

@michaelangeloio the queue isn't really concerned with how you consume it, that's on the consumer side.

If you mean within the jobs package, you can set a global concurrent job limit: https://pkg.go.dev/github.com/maragudk/[email protected]/jobs#NewRunnerOpts . But it wouldn't be able to do it based on something like user ID, because there's no concept of user ID in the queue itself.

@markuswustenberg awesome thank you for responding! Just to clarify, is there anything like a "retry" so that I can rate limit to one job per user at any given time? I have a requirement where only one job can be run for a given user at a time.

[markuswustenberg]

I guess you could give each user a queue and set the limit to 1. Otherwise, no.