summaryrefslogtreecommitdiff
path: root/taskflow/patterns/distributed_flow.py
diff options
context:
space:
mode:
authorJoshua Harlow <harlowja@yahoo-inc.com>2013-07-30 10:39:40 -0700
committerJoshua Harlow <harlowja@yahoo-inc.com>2013-08-01 18:46:21 -0700
commit324ea453aee7ad6432e60360441fdc018d143d9c (patch)
treefae53f49f2431c25c97b7f12a14862e84fa4e0e9 /taskflow/patterns/distributed_flow.py
parent3e5d91584a69b2118bb2178b728be13fe230ab18 (diff)
downloadtaskflow-324ea453aee7ad6432e60360441fdc018d143d9c.tar.gz
Adjust a bunch of hacking violations.
- Fix new hacking violations! - Add more comments! Change-Id: Ida0c1b6c98a8f45a15985b33529a1f479e595db5
Diffstat (limited to 'taskflow/patterns/distributed_flow.py')
-rw-r--r--taskflow/patterns/distributed_flow.py10
1 files changed, 8 insertions, 2 deletions
diff --git a/taskflow/patterns/distributed_flow.py b/taskflow/patterns/distributed_flow.py
index 90b3f25..5b4268b 100644
--- a/taskflow/patterns/distributed_flow.py
+++ b/taskflow/patterns/distributed_flow.py
@@ -27,8 +27,14 @@ LOG = logging.getLogger(__name__)
class Flow(object):
- """A linear chain of independent tasks that can be applied as one unit or
- rolled back as one unit."""
+ """A flow that can paralleize task running by using celery.
+
+ This flow backs running tasks (and associated dependencies) by using celery
+ as the runtime framework to accomplish execution (and status reporting) of
+ said tasks that compose the flow. It allows for parallel execution where
+ possible (data/task dependency dependent) without having to worry about how
+ this is accomplished in celery.
+ """
def __init__(self, name, parents=None):
self.name = name