From 8f235ad03a31be828affb203a43ae605f17b5782 Mon Sep 17 00:00:00 2001
From: akumar <arun.kumar@n-fuse.co>
Date: Wed, 11 Dec 2024 13:38:47 +0100
Subject: [PATCH] fix: fileimport

---
 src/worker.ts | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/src/worker.ts b/src/worker.ts
index 0b3349f..8c6aa3a 100644
--- a/src/worker.ts
+++ b/src/worker.ts
@@ -354,9 +354,13 @@ export class Worker {
             const fileImport = await import(require_dir + externalFile);
             // check for double default
             if (fileImport?.default?.default) {
-              await fileImport.default.default(cfg, logger, events, runWorker);
+              (async () => (await import(require_dir + externalFile)).default.default(cfg, logger, events, runWorker))().catch(err => {
+                this.logger.error(`Error scheduling external job ${externalFile}`, { err: err.message });
+              });
             } else {
-              await fileImport.default(cfg, logger, events, runWorker);
+              (async () => (await import(require_dir + externalFile)).default(cfg, logger, events, runWorker))().catch(err => {
+                this.logger.error(`Error scheduling external job ${externalFile}`, { err: err.message });
+              });
             }
           }
           catch (err: any) {