topcoder-platform · Jun 23, 2020
diff --git a/‎src/reconsiler-dd.js
Lines changed: 3 additions & 2 deletions b/‎src/reconsiler-dd.js
Lines changed: 3 additions & 2 deletions
diff --git a/‎src/services/pushToDirectKafka-Reconsiler.js
Lines changed: 0 additions & 65 deletions b/‎src/services/pushToDirectKafka-Reconsiler.js
Lines changed: 0 additions & 65 deletions
@@ -5,7 +5,7 @@ const pg = require('pg')
 var AWS = require("aws-sdk");
 const logger = require('./common/logger')
 const pushToKafka = require('./services/pushToKafka')
-const kafkaService = require('./services/pushToDirectKafka-Reconsiler')
+const kafkaService = require('./services/pushToDirectKafka')
 const postMessage = require('./services/posttoslack')
 const auditTrail = require('./services/auditTrail');
 const pgOptions = config.get('POSTGRES')
@@ -77,8 +77,9 @@ async function onScan(err, data) {
         await docClient.scan(params, onScan);
       }
       else {
-        terminate()
+        //terminate()
         //return
+        logger.info("Need to terminate.")
       }
     }
     catch (err) {
Original file line number	Diff line number	Diff line change
`@@ -5,7 +5,7 @@ const pg = require('pg')`
`5`	`5`	`var AWS = require("aws-sdk");`
`6`	`6`	`const logger = require('./common/logger')`
`7`	`7`	`const pushToKafka = require('./services/pushToKafka')`
`8`		`-const kafkaService = require('./services/pushToDirectKafka-Reconsiler')`
	`8`	`+const kafkaService = require('./services/pushToDirectKafka')`
`9`	`9`	`const postMessage = require('./services/posttoslack')`
`10`	`10`	`const auditTrail = require('./services/auditTrail');`
`11`	`11`	`const pgOptions = config.get('POSTGRES')`
`@@ -77,8 +77,9 @@ async function onScan(err, data) {`
`77`	`77`	`await docClient.scan(params, onScan);`
`78`	`78`	`}`
`79`	`79`	`else {`
`80`		`- terminate()`
	`80`	`+ //terminate()`
`81`	`81`	`//return`
	`82`	`+ logger.info("Need to terminate.")`
`82`	`83`	`}`
`83`	`84`	`}`
`84`	`85`	`catch (err) {`