diff --git a/packages/cli/src/Db.ts b/packages/cli/src/Db.ts
index 2b5432a23f..daebfa031d 100644
--- a/packages/cli/src/Db.ts
+++ b/packages/cli/src/Db.ts
@@ -41,7 +41,6 @@ import {
 	WorkflowStatisticsRepository,
 	WorkflowTagMappingRepository,
 } from '@db/repositories';
-import { PruningService } from '@/services/pruning.service';
 
 export const collections = {} as IDatabaseCollections;
 
@@ -192,10 +191,6 @@ export async function init(testConnectionOptions?: ConnectionOptions): Promise<v
 	collections.Settings = Container.get(SettingsRepository);
 	collections.Credentials = Container.get(CredentialsRepository);
 	collections.Workflow = Container.get(WorkflowRepository);
-
-	const pruningService = Container.get(PruningService);
-
-	if (await pruningService.isPruningEnabled()) pruningService.startPruning();
 }
 
 export async function migrate() {
diff --git a/packages/cli/src/commands/start.ts b/packages/cli/src/commands/start.ts
index 432135f8fe..676e91cc81 100644
--- a/packages/cli/src/commands/start.ts
+++ b/packages/cli/src/commands/start.ts
@@ -65,6 +65,8 @@ export class Start extends BaseCommand {
 
 	protected server = new Server();
 
+	private pruningService: PruningService;
+
 	constructor(argv: string[], cmdConfig: IConfig) {
 		super(argv, cmdConfig);
 		this.setInstanceType('main');
@@ -110,9 +112,9 @@ export class Start extends BaseCommand {
 			// Note: While this saves a new license cert to DB, the previous entitlements are still kept in memory so that the shutdown process can complete
 			await Container.get(License).shutdown();
 
-			const pruningService = Container.get(PruningService);
-
-			if (await pruningService.isPruningEnabled()) await pruningService.stopPruning();
+			if (await this.pruningService.isPruningEnabled()) {
+				await this.pruningService.stopPruning();
+			}
 
 			if (config.getEnv('leaderSelection.enabled')) {
 				const { MultiMainInstancePublisher } = await import(
@@ -342,6 +344,11 @@ export class Start extends BaseCommand {
 
 		await this.server.start();
 
+		this.pruningService = Container.get(PruningService);
+		if (await this.pruningService.isPruningEnabled()) {
+			this.pruningService.startPruning();
+		}
+
 		// Start to get active workflows and run their triggers
 		await this.activeWorkflowRunner.init();
 
diff --git a/packages/cli/src/services/pruning.service.ts b/packages/cli/src/services/pruning.service.ts
index c5435e6371..96bed63927 100644
--- a/packages/cli/src/services/pruning.service.ts
+++ b/packages/cli/src/services/pruning.service.ts
@@ -56,6 +56,9 @@ export class PruningService {
 		return true;
 	}
 
+	/**
+	 * @important Call only after DB connection is established and migrations have completed.
+	 */
 	startPruning() {
 		this.setSoftDeletionInterval();
 		this.scheduleHardDeletion();