CODEWITHSUNDEEP
pythonmessage-queuegearman
daniyalzade
daniyalzade

Reputation: 991

Is it possible to empty a job queue on a Gearman server

Is it possible to empty a job queue on a Gearman server? I am using the python driver for Gearman, and the documentation does not have any information about emptying queues. I would imagine that this functionality should exist, possibly, with a direct connection to the Gearman server.

Upvotes: 11

Views: 12914

Answers (3)

Gary Richardson
Gary Richardson

Reputation: 16441

I came across this method:

/usr/bin/gearman -t 1000 -n -w -f function_name > /dev/null

which basically dumps all the jobs into /dev/null.

Upvotes: 15

d5ve
d5ve

Reputation: 1160

The telnetable administrative protocol (search for "Administrative Protocol") doesn't have a command to empty a queue either, there is only a shutdown command.

If you wish to avoid downtime, you could write a generic "job consumer" worker and use that to empty the queues. I've set one up as a script which takes a list of job names, and just sits there accepting jobs and consuming them.

Something like:

# generic_consumer.py job1 job2 job3

You can use the administrative protocol's status command to get a list of the function names and counts on the queue. The administrative protocol docs tell you the format of the response.

# (echo status ; sleep 0.1) | netcat 127.0.0.1 4730

Upvotes: 6

user336242
user336242

Reputation:

As far as i have been able to tell from the docs and using gearman with PHP, the only way to clear the job queue is to restart to the gearmand job server. If you are using persistent job queues, you will also need to empty whatever you are using as the persistent storage, if this is DB storage, you will need to empty the appropriate tables of all the rows.

stop gearmand --> empty table rows --> start gearmand

Hope this is clear enough.

Upvotes: 5

Related Questions