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)

task = ServiceRequest.accept_next_from_queue(queue="sampler",
                                             serviceType="bag.QualityReviewBag.review",
                                             http=http)
print task