Added finished function. Updated join to not consume stdout. Updated …

…docs. Updated example
ParallelSSH · Aug 25, 2016 · f457d80 · f457d80
1 parent 7b7f6c4
commit f457d80
Show file tree

Hide file tree

Showing 4 changed files with 207 additions and 118 deletions.
diff --git a/examples/parallel_commands.py b/examples/parallel_commands.py
@@ -12,11 +12,10 @@
 for cmd in cmds:
     output.append(client.run_command(cmd, stop_on_errors=False))
 end = datetime.datetime.now()
-print "Started %s commands on %s host(s) in %s" % (
-    len(cmds), len(hosts), end-start,)
+print("Started %s commands on %s host(s) in %s" % (
+    len(cmds), len(hosts), end-start,))
 start = datetime.datetime.now()
 for _output in output:
-    for line in _output[host]['stdout']:
-        print line
+    client.join(_output)
 end = datetime.datetime.now()
-print "All commands finished in %s" % (end-start,)
+print("All commands finished in %s" % (end-start,))