new line

Codebucket-Solutions · Apr 8, 2024 · 2cd7557 · 2cd7557
1 parent b0c682b
commit 2cd7557
Showing 1 changed file with 9 additions and 7 deletions.
diff --git a/src/utils/queue-batch-processor.ts b/src/utils/queue-batch-processor.ts
@@ -3,13 +3,15 @@ import Logstash from "./logstash";
 
 export default async (queue: Queue, logstash: Logstash) => {
   const jobs = await queue.getJobs(undefined, 0, -1, true);
-  let jobData = [];
+  let jobData = "";
   for (let job of jobs) {
-    jobData.push(job.data);
+    jobData = jobData + JSON.stringify(job.data) + "\r\n";
+  }
+  if (jobData.length > 0) {
+    logstash.log(jobData, async () => {
+      for (let job of jobs) {
+        await job.remove();
+      }
+    });
   }
-  logstash.log(JSON.stringify(jobData), async () => {
-    for (let job of jobs) {
-      await job.remove();
-    }
-  });
 };