thorn.tasks
Tasks used by the Celery dispatcher.
-
(task)
thorn.tasks.
send_event
(event, payload, sender, timeout, context={})[source]
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)[source]
Process a batch of HTTP requests.
-
(task)
thorn.tasks.
dispatch_request
(event, data, sender, subscriber, session=None, app=None, **kwargs)[source]
Process a single HTTP request.