<s> import json <EOL> import time <EOL> import logging <EOL> logging . basicConfig ( level = logging . DEBUG ) <EOL> from pydisque . client import Client <EOL> c = Client ( [ '<STR_LIT>' , '<STR_LIT>' ] ) <EOL> c . connect ( ) <EOL> while True : <EOL> jobs = c . get_job ( [ '<STR_LIT:test>' ] ) <EOL> for queue_name , job_id , job in jobs : <EOL> job = json . loads ( job ) <EOL> print "<STR_LIT>" , job <EOL> c . ack_job ( job_id ) </s>
