ft-orchestration jq.py use jq with --round-robin

Author: pascal260303

tools/ft-orchestration/src/collector/jq.py

@@ -121,7 +121,7 @@ def __init__(self, executor: Executor, file: str):
 EOF
 
 ipfixcol2 -c {Path(self._conf_dir, self.CONFIG_FILE)} |
-parallel --pipe --recend '\n' --line-buffer --memfree 6G -L 200K --retries 0 -j 100% -- jq -r -f "$file"
+parallel --pipe --round-robin --recend '\n' --line-buffer -j 100% -- jq -r -f "$file"
 """
         # Reads fds file and outputs json with ipfixcol2, then converts json with jq to csv.
         # In the csv output the IPv4/IPv6 addresses are merged to source/destinationIPAddress.
@@ -343,7 +343,11 @@ def save_csv(csv_file: str):
         with open(csv_file, mode="w") as f:
             f.write(",".join(header) + "\n")
 
-        Tool(ssh_cmd).run()
+        cmd = Tool(ssh_cmd)
+        cmd.run()
+
+        if cmd.returncode() > 0:
+            raise CollectorOutputReaderException(cmd)
 
         end = time.time()
         try: