Fix tests for execute_together

Author: penguinolog

test/test_ssh_client_execute.py

@@ -450,12 +450,28 @@ def test_009_execute_together(ssh, ssh2, execute_async, exec_result, run_paramet
 
     if 0 == run_parameters["ec"]:
         results = exec_helpers.SSHClient.execute_together(
-            remotes=remotes, command=command, stdin=run_parameters.get("stdin", None)
+            remotes=remotes,
+            command=command,
+            stdin=run_parameters["stdin"],
+            open_stdout=run_parameters["open_stdout"],
+            open_stderr=run_parameters["open_stderr"],
         )
         execute_async.assert_has_calls(
             (
-                mock.call(command, stdin=run_parameters.get("stdin", None), log_mask_re=None),
-                mock.call(command, stdin=run_parameters.get("stdin", None), log_mask_re=None),
+                mock.call(
+                    command,
+                    stdin=run_parameters["stdin"],
+                    log_mask_re=None,
+                    open_stdout=run_parameters["open_stdout"],
+                    open_stderr=run_parameters["open_stderr"],
+                ),
+                mock.call(
+                    command,
+                    stdin=run_parameters["stdin"],
+                    log_mask_re=None,
+                    open_stdout=run_parameters["open_stdout"],
+                    open_stderr=run_parameters["open_stderr"],
+                ),
             )
         )
         assert results == {(host, port): exec_result, (host2, port): exec_result}
@@ -472,12 +488,29 @@ def test_010_execute_together_expected(ssh, ssh2, execute_async, exec_result, ru
     remotes = [ssh, ssh2]
 
     results = exec_helpers.SSHClient.execute_together(
-        remotes=remotes, command=command, stdin=run_parameters.get("stdin", None), expected=[run_parameters["ec"]]
+        remotes=remotes,
+        command=command,
+        stdin=run_parameters["stdin"],
+        open_stdout=run_parameters["open_stdout"],
+        open_stderr=run_parameters["open_stderr"],
+        expected=[run_parameters["ec"]],
     )
     execute_async.assert_has_calls(
         (
-            mock.call(command, stdin=run_parameters.get("stdin", None), log_mask_re=None),
-            mock.call(command, stdin=run_parameters.get("stdin", None), log_mask_re=None),
+            mock.call(
+                command,
+                stdin=run_parameters.get("stdin", None),
+                log_mask_re=None,
+                open_stdout=run_parameters["open_stdout"],
+                open_stderr=run_parameters["open_stderr"],
+            ),
+            mock.call(
+                command,
+                stdin=run_parameters.get("stdin", None),
+                log_mask_re=None,
+                open_stdout=run_parameters["open_stdout"],
+                open_stderr=run_parameters["open_stderr"],
+            ),
         )
     )
     assert results == {(host, port): exec_result, (host2, port): exec_result}