From 29f1631950a25058e2ab34c4f36a48fecccf8d54 Mon Sep 17 00:00:00 2001
From: Mauricio Siu <47042324+Siumauricio@users.noreply.github.com>
Date: Thu, 10 Oct 2024 23:34:56 -0600
Subject: [PATCH] refactor: add dynamic import queue

---
 apps/dokploy/server/server.ts | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git a/apps/dokploy/server/server.ts b/apps/dokploy/server/server.ts
index e501d8378..ec60d9a9c 100644
--- a/apps/dokploy/server/server.ts
+++ b/apps/dokploy/server/server.ts
@@ -15,7 +15,6 @@ import {
 } from "@dokploy/server";
 import { config } from "dotenv";
 import next from "next";
-import { deploymentWorker } from "./queues/deployments-queue";
 import { setupDockerContainerLogsWebSocketServer } from "./wss/docker-container-logs";
 import { setupDockerContainerTerminalWebSocketServer } from "./wss/docker-container-terminal";
 import { setupDockerStatsMonitoringSocketServer } from "./wss/docker-stats";
@@ -62,17 +61,16 @@ void app.prepare().then(async () => {
 			await sendDokployRestartNotifications();
 		}
 
-		console.log(process.env);
 		if (IS_CLOUD && process.env.NODE_ENV === "production") {
 			await migration();
 		}
 
 		server.listen(PORT);
 		console.log("Server Started:", PORT);
-		console.log(IS_CLOUD, process.env.IS_CLOUD);
 		if (!IS_CLOUD) {
 			console.log("Starting Deployment Worker");
-			deploymentWorker.run();
+			const { deploymentWorker } = await import("./queues/deployments-queue");
+			await deploymentWorker.run();
 		}
 	} catch (e) {
 		console.error("Main Server Error", e);