make sure in run mode we write status to stderr
added more debug messages
catch the appropriate cluster exception on lookup
renamed name paramter to avoid conflicts
fixed issue with fan_out streams
fixed issue with streams on fan in
changed failure states for pipes/groups so that all jobs are makred failed and cleanup is performed
added ocaml example
typo fixes
Ocaml example and documentation