srbee.py

from cts.srb import ServiceRequest, ServiceRequestList
from cts.client import get_http_client

http = get_http_client(endpoint=settings.CTS)
http.add_credentials(settings.CTS_USER, settings.CTS_PASSWORD)

try:
    task = ServiceRequest.accept_next_from_queue(queue="sampler",
                                                 serviceType="bag.QualityReviewBag.review",
                                                 http=http)
except:
    import pdb
    pdb.post_mortem()
    raise

print task