Instructs the worker to respond with processing statistics.
Instructs the worker to exit with signal 0.
Instructs the worker to exit with signal -1.
Client for the Gearman task farm.
Size of a map request (in number of input elements).
Apply a function to a list.
Resubmit a job up to three times.
Wait one minute for each job to complete.
Logic for process that handles command messages.
A quit or restart command is handled by setting the worker’s finish flag to True, setting the exit status, and returning. The exit status is 0 on quit, or -1 on restart.
Indicates that an error occurred while reading the cluster configuration.
Gearman task ID for the map task.
A data encoder that reads and writes using the Pickle format.
By default, a GearmanClient can only send byte-strings. If we want to be able to send Python objects, we must specify a data encoder. This will automatically convert byte strings to Python objects (and vice versa) for all commands that have the ‘data’ field. See http://gearman.org/index.php?id=protocol for client commands that send/receive ‘opaque data’.
Launch a Gearman worker and wait for it to complete.
This worker processes batch requests using a MulticorePool.
Exit status of the worker processes.
A Gearman worker that tracks exit status.
Returns True unless the finish flag is set.
This method is called by the gearman.GearmanWorker to decide when to quit.
Exit status of the worker.
Indicates whether the worker has received a quit or restart command.