Request dispatching module

Submit a request to one of the annotation / service providers through the distributed request system.

exception VestaService.request_process_mesg.WorkerExceptionWrapper(task_uuid, task_status, worker_exception, worker_exc_traceback)

Wrapper for worker exception

VestaService.request_process_mesg.cancel_request(uuid, app)

Cancel a processing request.

Parameters:
  • uuid – UUID of a given request
  • app – Handle to the Celery application.
VestaService.request_process_mesg.get_request_info(uuid, app)

Get information on a processing request.

Parameters:
  • uuid – UUID of a given request
  • app – Handle to the Celery application.
Returns:

dict with information on request processing.
VestaService.request_process_mesg.main()

Command line entry point.

VestaService.request_process_mesg.send_task_request(url, name, app, queue, misc={}, ann_srv_url=None)

Send a request for a process on URL.

Parameters:
  • url – URL of the file to process
  • name – Name of the process.
  • app – Handle to the Celery application.
  • queue – AMQP Queue to which the MSG will be sent.
  • misc – Optional data that can be passed to a celery worker.
  • ann_srv_url – URL to where the final annotations will be stored.
Returns:

Instance of celery.result.AsyncResult