more info in heratbeat

seamapi · Aug 27, 2023 · 12efa21 · 12efa21
1 parent 0d16135
commit 12efa21
Show file tree

Hide file tree

Showing 5 changed files with 20 additions and 4 deletions.
diff --git a/dist/worker-wrapper.js b/dist/worker-wrapper.js
diff --git a/dist/worker-wrapper.js.map b/dist/worker-wrapper.js.map
diff --git a/dist/worker-wrapper.mjs b/dist/worker-wrapper.mjs
@@ -236,7 +236,8 @@ var Worker = class {
  output
  });
  const postgresClient = new pg.Pool({
- connectionString
+ connectionString,
+ query_timeout: 5e3
  });
  postgresClient.on("error", (err) => {
  parentPort.postMessage({
@@ -248,6 +249,10 @@ var Worker = class {
  });
  const heartbeat = async () => {
  try {
+ parentPort.postMessage({
+ type: "ava-postgres",
+ message: "running postgres heartbeat..."
+ });
  const { rows } = await postgresClient.query("SELECT 1");
  parentPort.postMessage({
  type: "ava-postgres",

diff --git a/dist/worker-wrapper.mjs.map b/dist/worker-wrapper.mjs.map
diff --git a/src/worker.ts b/src/worker.ts
@@ -324,6 +324,7 @@ export class Worker {
 
  const postgresClient = new pg.Pool({
  connectionString,
+ query_timeout: 5000,
  })
 
  postgresClient.on("error", (err) => {
@@ -337,6 +338,11 @@ export class Worker {
 
  const heartbeat = async () => {
  try {
+ parentPort!.postMessage({
+ type: "ava-postgres",
+ message: "running postgres heartbeat...",
+ })
+
  const { rows } = await postgresClient.query("SELECT 1")
 
  parentPort!.postMessage({