summaryrefslogtreecommitdiff
path: root/taskflow/engines/worker_based/engine.py
diff options
context:
space:
mode:
authorJoshua Harlow <harlowja@yahoo-inc.com>2014-04-28 15:05:27 -0700
committerJoshua Harlow <harlowja@gmail.com>2014-05-03 10:15:34 -0700
commitbb64df0b1533f293ad939c14234e9fb00b8f83de (patch)
tree566730e9e4d016150e653d2137343d53f44e04de /taskflow/engines/worker_based/engine.py
parentef72c4dcdeaf02fe4d5787f9ac650e75d1827dfb (diff)
downloadtaskflow-bb64df0b1533f293ad939c14234e9fb00b8f83de.tar.gz
Add docs for the worker based engine (WBE)
Begin to rework the twiki docs into a developer doc, moving items from the twiki to rst and adjusting examples to make a unified place where the worker model can be documented. Change-Id: I43ed828be33351b9fb6606317011e7204f61a136
Diffstat (limited to 'taskflow/engines/worker_based/engine.py')
-rw-r--r--taskflow/engines/worker_based/engine.py14
1 files changed, 14 insertions, 0 deletions
diff --git a/taskflow/engines/worker_based/engine.py b/taskflow/engines/worker_based/engine.py
index af178cb..0c7702e 100644
--- a/taskflow/engines/worker_based/engine.py
+++ b/taskflow/engines/worker_based/engine.py
@@ -20,6 +20,20 @@ from taskflow import storage as t_storage
class WorkerBasedActionEngine(engine.ActionEngine):
+ """Worker based action engine.
+
+ Specific backend configuration:
+
+ :param exchange: broker exchange exchange name in which executor / worker
+ communication is performed
+ :param url: broker connection url (see format in kombu documentation)
+ :param topics: list of workers topics to communicate with (this will also
+ be learned by listening to the notifications that workers
+ emit).
+ :keyword transport: transport to be used (e.g. amqp, memory, etc.)
+ :keyword transport_options: transport specific options
+ """
+
_storage_cls = t_storage.SingleThreadedStorage
def _task_executor_cls(self):