taran.worker
Worker([configuration]) |
A template for all decision processors. |
This module provides worker/actor specific methods to all child classes.
-
class
taran.worker.Worker(configuration=None)[source]
A template for all decision processors.
-
configuration
module
The configuration a worker needs in order to participate in the workflow.
-
activity_task_failed(reason=None, details=None)[source]
Signal that activity task failed.
-
complete_activity_task(result=u'Undefined')[source]
Signal activity task as complete.
-
get_activity_results(activity=None)[source]
Get a list of all results (when activity completed)
-
poll_for_activity_task()[source]
Poll for an activity task from SWF and return if a task token has been provided.
| Returns: | task –
Details of the assigned task. |
|---|
| Return type: | dict |
|---|