gearman client multiple worker

client

import json
import gearman
import time
import sys
def check_request_status(job_request):
    if job_request.complete:
        #print len(job_request.result)
        #data = json.loads(job_request.result)
        print "Job %s finished!  Result: %s - %s" % (job_request.job.unique, job_request.state, job_request.result)
    elif job_request.timed_out:
        print "Job %s timed out!"
    elif job_request.state == JOB_UNKNOWN:
        print "Job %s connection failed!"

gm_client = gearman.GearmanClient(['localhost:4730'])
print sys.argv[1]
tasks = [{'task': 'load_lexicon', 'data': 'This is testing sentence'}, {'task': 'load_db', 'data': sys.argv[1]}]

#@submitted_requests = gm_client.submit_multiple_jobs(tasks, background=False, wait_until_complete=False)

#completed_requests = gm_client.wait_until_jobs_completed(submitted_requests)
completed_job_request = gm_client.submit_job("reverse", "Hello World!")
#print completed_requests[1].result
for completed_job_request in completed_requests:
    check_request_status(completed_job_request)