|
@@ -99,8 +99,7 @@ class DataProcessor:
|
|
|
self.logger.info(f"analysis type execute result : dataFrame = {dataFram}")
|
|
|
return dataFram
|
|
|
except Exception as exception:
|
|
|
- self.logger.info(f"analysis type execute error : {exception.message}")
|
|
|
- traceback.format_exc()
|
|
|
+ self.logger.info(f"analysis type execute error : {traceback.format_exc()}")
|
|
|
raise exception
|
|
|
|
|
|
def notifyOfTurbines(self, conf: Contract,turbineCodes) -> pd.DataFrame:
|
|
@@ -118,8 +117,7 @@ class DataProcessor:
|
|
|
result = future.result()
|
|
|
results.append(result)
|
|
|
except Exception as exc:
|
|
|
- self.logger.info(f"future deal error. future : {future} , error is {exc.message}")
|
|
|
- traceback.format_exc()
|
|
|
+ self.logger.info(f"future deal error. future : {future} , error is {traceback.format_exc()}")
|
|
|
raise exc
|
|
|
|
|
|
returnResult = pd.concat(results, ignore_index=True)
|
|
@@ -233,8 +231,7 @@ class DataProcessor:
|
|
|
self.logger.info(
|
|
|
f"批次:{conf.dataContract.dataFilter.dataBatchNum} 完成请求发电性能分析、输出及更新状态")
|
|
|
except (CustomError, Exception) as e:
|
|
|
- self.logger.info(f" executeAnalysis error: {e.message}")
|
|
|
- traceback.format_exc()
|
|
|
+ self.logger.info(f" executeAnalysis error: {traceback.format_exc()}")
|
|
|
try:
|
|
|
dbUtil = GetBusinessFoundationDbUtil()
|
|
|
ex = e if isinstance(e, CustomError) else CustomError(-1)
|