Loading transfer_service/store_preprocessor.py +2 −2 Original line number Diff line number Diff line Loading @@ -81,7 +81,7 @@ class StorePreprocessor(TaskExecutor): def execute(self): try: self.logger.info("========== Start of preprocessing phase ==========") self.logger.info("++++++++++ Start of preprocessing phase ++++++++++") # First scan to find crowded dirs self.logger.info("Searching for 'crowded' dirs") Loading Loading @@ -217,7 +217,7 @@ class StorePreprocessor(TaskExecutor): sys.exit(1) self.logger.info("Overall data size calculation") self.jobObj.jobInfo["dataSize"] = self.systemUtils.getSize(self.path) self.logger.info("========== End of preprocessing phase ==========") self.logger.info("++++++++++ End of preprocessing phase ++++++++++") except Exception: self.logger.exception("FATAL: something went wrong during the preprocessing phase") self.update("ERROR") Loading Loading
transfer_service/store_preprocessor.py +2 −2 Original line number Diff line number Diff line Loading @@ -81,7 +81,7 @@ class StorePreprocessor(TaskExecutor): def execute(self): try: self.logger.info("========== Start of preprocessing phase ==========") self.logger.info("++++++++++ Start of preprocessing phase ++++++++++") # First scan to find crowded dirs self.logger.info("Searching for 'crowded' dirs") Loading Loading @@ -217,7 +217,7 @@ class StorePreprocessor(TaskExecutor): sys.exit(1) self.logger.info("Overall data size calculation") self.jobObj.jobInfo["dataSize"] = self.systemUtils.getSize(self.path) self.logger.info("========== End of preprocessing phase ==========") self.logger.info("++++++++++ End of preprocessing phase ++++++++++") except Exception: self.logger.exception("FATAL: something went wrong during the preprocessing phase") self.update("ERROR") Loading