thorn.tasks

Tasks used by the Celery dispatcher.

(task)thorn.tasks.send_event(event, payload, sender, timeout, context={})

Task called by process dispatching the event.

Note

This will use the WorkerDispatcher to dispatch the individual HTTP requests in batches (dispatch_requests -> dispatch_request).

(task)thorn.tasks.dispatch_requests(reqs, app=None)

Process a batch of HTTP requests.

(task)thorn.tasks.dispatch_request(self, event, data, sender, subscriber, session=None, app=None, **kwargs)

Process a single HTTP request.