Damien Krotkine

add state to the group consumer

9

I need that for work. I've added an init_handler() function to define a state, which is passed around when handle_messages() is called. Of course it's not backward compatible so this...

[Question] dynamically registering new topics

6

Hi, I haven't found in the doc and at a first glance of the code if it was possible and how easy, to register to new topics dynamically, without having...

For upstream/avoid useless cleanup

7

It's impacting performance, and it's redundant with the workers' maintenance task that already calls `cleanup`

Fix maintenance task issues raised in #2005

5

- share 'last_cleaned_at' between workers and set it at maintenance task start time - release maintenance lock when maintenance task is finished

strange interactions between last_cleaned_at, maintenance_interval and rq:clean_registries lock key

1

Hi, `run_maintenance_tasks` runs if `should_run_maintenance_tasks` returns `True`. `should_run_maintenance_tasks` uses the `last_cleaned_at` attribute of the worker instance and compare it with `maintenance_interval`. However if the worker just started, `last_cleaned_at` is None...

We use RQ with a lot of jobs, and registry' `count` and `get_job_ids` get called very often. In addition to simply returning the number of elements or the job ids,...