Skip to content

Commit 41d7de7

Browse files
Update reconsiler-dd-new.js
1 parent aebdea9 commit 41d7de7

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

src/reconsiler-dd-new.js

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -53,12 +53,14 @@ async function setupPgClient() {
5353
)).then(result => { if (typeof result.rows == "undefined")
5454
{
5555
console.log("terminating after posting to kafka")
56+
pgClient.end()
5657
process.exit(1)
5758
}
5859
})
5960
}
6061
else {
6162
console.log("terminate due to 0 rows")
63+
pgClient.end()
6264
process.exit(1)
6365
}
6466
}

0 commit comments

Comments
 (0)