RETRY loop BUG when status report is corrupt

This commit is contained in:
Luis Fernando Molina committed 2018-03-30 17:29:55 +02:00
1 parent d8ea2d9eae
commit af883be0ff
2 files changed
+21

No files matched your search

Binary file not shown.
+21
View File
@@ -188,6 +188,13 @@ What is the lastFile pointer?
reportKey = "AAMasters" + "-" + "AACharly" + "-" + "Poloniex-Live-Trades" + "-" + "dataSet.V1";
if (FULL_LOG === true) { logger.write("[INFO] start -> getContextVariables -> reportKey = " + reportKey); }
if (dependencies.statusReports.get(reportKey).status === "Status Report is corrupt.") {
logger.write("[ERROR] start -> getContextVariables -> Can not continue because dependecy Status Report is corrupt. ");
callBackFunction(global.DEFAULT_RETRY_RESPONSE);
return;
}
thisReport = dependencies.statusReports.get(reportKey).file;
if (thisReport.lastFile === undefined) {
@@ -206,6 +213,13 @@ What is the lastFile pointer?
reportKey = "AAMasters" + "-" + "AACharly" + "-" + "Poloniex-Historic-Trades" + "-" + "dataSet.V1";
if (FULL_LOG === true) { logger.write("[INFO] start -> getContextVariables -> reportKey = " + reportKey); }
if (dependencies.statusReports.get(reportKey).status === "Status Report is corrupt.") {
logger.write("[ERROR] start -> getContextVariables -> Can not continue because dependecy Status Report is corrupt. ");
callBackFunction(global.DEFAULT_RETRY_RESPONSE);
return;
}
thisReport = dependencies.statusReports.get(reportKey).file;
if (thisReport.lastFile === undefined) {
@@ -256,6 +270,13 @@ What is the lastFile pointer?
reportKey = "AAMasters" + "-" + "AACharly" + "-" + "Poloniex-Hole-Fixing" + "-" + "dataSet.V1" + "-" + year + "-" + month;
if (FULL_LOG === true) { logger.write("[INFO] start -> getContextVariables -> reportKey = " + reportKey); }
if (dependencies.statusReports.get(reportKey).status === "Status Report is corrupt.") {
logger.write("[ERROR] start -> getContextVariables -> Can not continue because self dependecy Status Report is corrupt. Aborting Process.");
callBackFunction(global.DEFAULT_FAIL_RESPONSE);
return;
}
holeFixingStatusReport = dependencies.statusReports.get(reportKey).file;
if (holeFixingStatusReport.lastFile === undefined) {