File tree 1 file changed +3
-2
lines changed
1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -47,7 +47,7 @@ async function setupPgClient() {
47
47
Promise . all ( result . rows . map ( async ( row ) => {
48
48
console . log ( row . payloadseqid )
49
49
const x = await calldynamodb ( row . payloadseqid )
50
- console . log ( "val of x" , x )
50
+ console . log ( "val of x " , x )
51
51
}
52
52
//))
53
53
) ) . then ( result => { if ( typeof result . rows == "undefined" )
@@ -90,9 +90,10 @@ async function calldynamodb(payloadseqid)
90
90
else {
91
91
var s_payload = ( data . Items [ 0 ] . pl_document )
92
92
// console.log("s_payload",s_payload)
93
+ logger . info ( `Reconsiler2 Before Posting Payload : ${ JSON . stringify ( s_payload ) } ` )
93
94
await kafkaService . pushToKafka ( s_payload )
94
95
await audit ( s_payload , 1 )
95
- logger . info ( `Reconsiler2 Posted Payload : ${ s_payload } ` )
96
+ logger . info ( `Reconsiler2 Payload posted ` )
96
97
} ;
97
98
resolve ( "done" ) ;
98
99
} ) ;
You can’t perform that action at this time.
0 commit comments