Updating redis to v4.2.2 (#343)

Author: filipecosta90

poetry.lock

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "redisbench-admin"
-version = "0.8.0"
+version = "0.8.1"
 description = "Redis benchmark run helper. A wrapper around Redis and Redis Modules benchmark tools ( ftsb_redisearch, memtier_benchmark, redis-benchmark, aibench, etc... )."
 authors = ["filipecosta90 <[email protected]>","Redis Performance Group <[email protected]>"]
 readme = "README.md"
@@ -43,7 +43,7 @@ scipy = "^1.3.3"
 scikit-learn = "^0.22.2"
 Jinja2 = "^3.0.3"
 watchdog = "^2.1.6"
-redis = "4.2.0rc3"
+redis = "4.2.2"
 
 [tool.poetry.dev-dependencies]
 pytest = "^4.6"

pyproject.toml

@@ -202,8 +202,8 @@ def stop_profile(self, **kwargs):
         result = False
         self.profile_end_time = time.time()
         if not self._is_alive(self.profiler_process):
-            self.logger.error(
-                "Profiler process is not alive, might have crash during test execution.  Exit code: {}".format(
+            self.logger.warning(
+                "Profiler process is not alive. might have crash during test execution.  Exit code: {}".format(
                     self.profiler_process_exit_code
                 )
             )
@@ -288,8 +288,11 @@ def generate_trace_file_from_profile(self, filename=None):
                     try:
                         subprocess.Popen(args=args, stdout=outfile).wait()
                     except OSError as e:
+                        args_str = " ".join([str(x) for x in args])
                         self.logger.error(
-                            "Unable to run {} script {}".format(self.perf, e.__str__())
+                            "Unable to run {} script with args {}. Error: {}".format(
+                                self.perf, args_str, e.__str__()
+                            )
                         )
                 if self.pid is not None:
                     filename_main_thread = filename + ".mainthread"
@@ -302,19 +305,20 @@ def generate_trace_file_from_profile(self, filename=None):
                             "-i",
                             self.output,
                         ]
+                        args_str = " ".join([str(x) for x in args])
                         try:
                             subprocess.Popen(args=args, stdout=outfile).wait()
                             self.trace_file_main_thread = filename_main_thread
                         except OSError as e:
                             self.logger.error(
-                                "Unable to run {} script {}".format(
-                                    self.perf, e.__str__()
+                                "Unable to run {} script args {}. Error: {}".format(
+                                    self.perf, args_str, e.__str__()
                                 )
                             )
                         except Exception as e:
                             self.logger.error(
-                                "Unable to run {} script {}".format(
-                                    self.perf, e.__str__()
+                                "Unable to run {} script args {}. Error: {}".format(
+                                    self.perf, args_str, e.__str__()
                                 )
                             )
                 else:

redisbench_admin/profilers/perf.py

@@ -101,8 +101,20 @@ def profilers_stop_if_required(
                                 ",".join(tabular_data_map.keys()),
                             )
                         )
-                        overall_artifacts_map.update(profile_res_artifacts_map)
-                        overall_tabular_data_map.update(tabular_data_map)
+                    else:
+                        logging.error(
+                            "One or more steps within Profiler {} for pid {} exited with ERROR!".format(
+                                profiler_name,
+                                profiler_obj.pid,
+                            )
+                        )
+                    logging.info(
+                        "There are a total of {} artifacts".format(
+                            len(profile_res_artifacts_map.values())
+                        )
+                    )
+                    overall_artifacts_map.update(profile_res_artifacts_map)
+                    overall_tabular_data_map.update(tabular_data_map)
 
         for (
             artifact_name,