From: Tibor Frank Date: Tue, 30 Jul 2019 12:12:46 +0000 (+0200) Subject: Trending: Reduce input data X-Git-Url: https://gerrit.fd.io/r/gitweb?p=csit.git;a=commitdiff_plain;h=52ebb67e52800f4240001d117d56d08d78a84d6a Trending: Reduce input data Change-Id: Ifddbdc1f357a192af558079a92f4e4d1d2693efd Signed-off-by: Tibor Frank --- diff --git a/resources/tools/presentation/input_data_parser.py b/resources/tools/presentation/input_data_parser.py index 84245c429c..6da428e1bb 100644 --- a/resources/tools/presentation/input_data_parser.py +++ b/resources/tools/presentation/input_data_parser.py @@ -1337,30 +1337,41 @@ class InputData(object): logging.info("Done.") + logging.info("Collecting data:") + while not data_queue.empty(): - result = data_queue.get() - job = result["job"] - build_nr = result["build"]["build"] + try: + result = data_queue.get() + + job = result["job"] + build_nr = result["build"]["build"] + + logging.info(" {job}-{build}".format(job=job, build=build_nr)) + + if result["data"]: + data = result["data"] + build_data = pd.Series({ + "metadata": pd.Series(data["metadata"].values(), + index=data["metadata"].keys()), + "suites": pd.Series(data["suites"].values(), + index=data["suites"].keys()), + "tests": pd.Series(data["tests"].values(), + index=data["tests"].keys())}) + + if self._input_data.get(job, None) is None: + self._input_data[job] = pd.Series() + self._input_data[job][str(build_nr)] = build_data - if result["data"]: - data = result["data"] - build_data = pd.Series({ - "metadata": pd.Series(data["metadata"].values(), - index=data["metadata"].keys()), - "suites": pd.Series(data["suites"].values(), - index=data["suites"].keys()), - "tests": pd.Series(data["tests"].values(), - index=data["tests"].keys())}) + self._cfg.set_input_file_name(job, build_nr, + result["build"]["file-name"]) - if self._input_data.get(job, None) is None: - self._input_data[job] = pd.Series() - self._input_data[job][str(build_nr)] = build_data + self._cfg.set_input_state(job, build_nr, result["state"]) - self._cfg.set_input_file_name(job, build_nr, - result["build"]["file-name"]) + except (MemoryError, EOFError) as err: + logging.error(repr(err)) + raise - self._cfg.set_input_state(job, build_nr, result["state"]) del data_queue diff --git a/resources/tools/presentation/specification_CPTA.yaml b/resources/tools/presentation/specification_CPTA.yaml index 5a3c7d69c9..a387645403 100644 --- a/resources/tools/presentation/specification_CPTA.yaml +++ b/resources/tools/presentation/specification_CPTA.yaml @@ -169,23 +169,23 @@ # 3n-hsw plot-performance-trending-all-3n-hsw: csit-vpp-perf-mrr-daily-master: - start: 670 + start: 700 end: "lastCompletedBuild" skip: - - 672 - - 673 - - 674 - - 675 - - 676 - - 677 - - 678 - - 679 - - 680 - - 688 - - 689 - - 690 - - 694 - - 695 +# - 672 +# - 673 +# - 674 +# - 675 +# - 676 +# - 677 +# - 678 +# - 679 +# - 680 +# - 688 +# - 689 +# - 690 +# - 694 +# - 695 - 726 - 749 - 750 @@ -202,6 +202,10 @@ - 782 - 783 - 784 + - 786 + - 787 + - 788 + - 789 - 791 # - 793 - 795 @@ -221,23 +225,23 @@ plot-performance-trending-vpp-3n-hsw: csit-vpp-perf-mrr-daily-master: - start: 670 + start: 700 end: "lastCompletedBuild" skip: - - 672 - - 673 - - 674 - - 675 - - 676 - - 677 - - 678 - - 679 - - 680 - - 688 - - 689 - - 690 - - 694 - - 695 +# - 672 +# - 673 +# - 674 +# - 675 +# - 676 +# - 677 +# - 678 +# - 679 +# - 680 +# - 688 +# - 689 +# - 690 +# - 694 +# - 695 - 726 - 749 - 750 @@ -254,6 +258,10 @@ - 782 - 783 - 784 + - 786 + - 787 + - 788 + - 789 - 791 # - 793 - 795 @@ -574,23 +582,23 @@ # 3n-hsw csit-vpp-perf-mrr-daily-master: - start: 670 + start: 700 end: "lastCompletedBuild" skip: - - 672 - - 673 - - 674 - - 675 - - 676 - - 677 - - 678 - - 679 - - 680 - - 688 - - 689 - - 690 - - 694 - - 695 +# - 672 +# - 673 +# - 674 +# - 675 +# - 676 +# - 677 +# - 678 +# - 679 +# - 680 +# - 688 +# - 689 +# - 690 +# - 694 +# - 695 - 726 - 749 - 750 @@ -607,6 +615,10 @@ - 782 - 783 - 784 + - 786 + - 787 + - 788 + - 789 - 791 # - 793 - 795 @@ -658,6 +670,10 @@ - 532 - 533 - 534 + - 536 + - 537 + - 538 + - 539 - 541 # - 543 # - 545