Joshua Harlow 6520b9c35e Add a basic map/reduce example to show how this can be done ...

Since we can create tasks, run them in a parallel then direct
there result into a result task we can create a workflow that
can define how this can be accomplished and have the map ops
run in parallel (with the reduction op happening after all the
map ops have finished).

Part of blueprint more-examples

Change-Id: I7c04f5508b35b945c49e5798ece0e298d2e1b979

2014-12-17 19:13:45 +00:00

..

conductors

Merge "Use and verify event and latch wait() return using timeouts"

2014-10-19 02:53:47 +00:00

engines

Add a futures type that can unify our future functionality

2014-10-18 20:21:48 -07:00

examples

Add a basic map/reduce example to show how this can be done

2014-12-17 19:13:45 +00:00

jobs

Jobboard example that show jobs + workers + producers

2014-09-27 14:51:38 -07:00

listeners

Merge "Add a timing listener that also prints the results"

2014-10-18 20:23:10 +00:00

openstack

Switch to using oslo.utils and oslo.serialization

2014-09-20 09:03:11 -07:00

patterns

Relax the graph flow symbol constraints

2014-09-08 20:55:45 +00:00

persistence

Add a futures type that can unify our future functionality

2014-10-18 20:21:48 -07:00

tests

Merge "Use the mock that finds a working implementation"

2014-10-21 21:18:29 +00:00

types

Add a futures type that can unify our future functionality

2014-10-18 20:21:48 -07:00

utils

Add a futures type that can unify our future functionality

2014-10-18 20:21:48 -07:00

__init__.py

Removed copyright from empty files

2014-02-22 17:16:29 +08:00

atom.py

Document more function/class/method params

2014-09-26 11:43:45 -07:00

exceptions.py

Merge "Document more function/class/method params"

2014-10-18 19:27:57 +00:00

flow.py

Be smarter about required flow symbols

2014-09-08 19:14:51 +00:00

retry.py

Document more function/class/method params

2014-09-26 11:43:45 -07:00

states.py

Merge "Make intentions a tuple (to denote immutability)"

2014-06-19 17:28:08 +00:00

storage.py

Merge "Expose only ensure_atom from storage"

2014-10-18 20:16:40 +00:00

task.py

Merge "Use constants for revert automatically provided kwargs"

2014-10-18 19:38:17 +00:00

test.py

Use the mock that finds a working implementation

2014-10-18 20:26:00 -07:00

version.py

Make version.py handle pbr not being installed

2014-09-01 20:09:59 +00:00