diff options
| author | Joshua Harlow <harlowja@yahoo-inc.com> | 2013-07-30 10:39:40 -0700 |
|---|---|---|
| committer | Joshua Harlow <harlowja@yahoo-inc.com> | 2013-08-01 18:46:21 -0700 |
| commit | 324ea453aee7ad6432e60360441fdc018d143d9c (patch) | |
| tree | fae53f49f2431c25c97b7f12a14862e84fa4e0e9 /taskflow/patterns/distributed_flow.py | |
| parent | 3e5d91584a69b2118bb2178b728be13fe230ab18 (diff) | |
| download | taskflow-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.py | 10 |
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 |
