[refactor] Simplify queue creation in AiProvider

- Replaced the manual queue setup process in the createQueue method with a call to createDefaultQueue for improved readability and maintainability.
- This change reduces complexity by leveraging a dedicated function for queue creation, streamlining the overall implementation.

Author: sroussey

packages/ai/src/provider/AiProvider.ts

@@ -7,6 +7,7 @@
 import { TaskInput, TaskOutput } from "@workglow/task-graph";
 import { globalServiceRegistry, WORKER_MANAGER, type WorkerServer } from "@workglow/util";
 import type { ModelConfig } from "../model/ModelSchema";
+import { createDefaultQueue } from "../queue/createDefaultQueue";
 import { type AiProviderRunFn, getAiProviderRegistry } from "./AiProviderRegistry";
 
 /**
@@ -183,31 +184,6 @@ export abstract class AiProvider<TModelConfig extends ModelConfig = ModelConfig>
    * Uses InMemoryQueueStorage with a ConcurrencyLimiter.
    */
   protected async createQueue(concurrency: number): Promise<void> {
-    // Lazy imports to avoid circular dependencies -- these packages
-    // are always available at runtime in any environment that uses AiProvider.
-    const { InMemoryQueueStorage } = await import("@workglow/storage");
-    const { ConcurrencyLimiter, JobQueueClient, JobQueueServer } =
-      await import("@workglow/job-queue");
-    const { getTaskQueueRegistry } = await import("@workglow/task-graph");
-    const { AiJob } = await import("../job/AiJob");
-
-    const storage = new InMemoryQueueStorage(this.name);
-    await storage.setupDatabase();
-
-    const server = new JobQueueServer(AiJob as any, {
-      storage,
-      queueName: this.name,
-      limiter: new ConcurrencyLimiter(concurrency, 100),
-    });
-
-    const client = new JobQueueClient({
-      storage,
-      queueName: this.name,
-    });
-
-    client.attach(server);
-
-    getTaskQueueRegistry().registerQueue({ server, client, storage });
-    await server.start();
+    await createDefaultQueue(this.name, concurrency);
   }
 }

packages/ai/src/queue/createDefaultQueue.ts

@@ -0,0 +1,45 @@
+/**
+ * @license
+ * Copyright 2025 Steven Roussey <sroussey@gmail.com>
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+import { ConcurrencyLimiter, JobQueueClient, JobQueueServer } from "@workglow/job-queue";
+import { getTaskQueueRegistry } from "@workglow/task-graph";
+import { InMemoryQueueStorage } from "@workglow/storage";
+
+import { AiJob } from "../job/AiJob";
+
+/**
+ * Create and register a default job queue for an AI provider.
+ * Uses InMemoryQueueStorage with a ConcurrencyLimiter.
+ *
+ * Extracted to a separate module to avoid circular dependencies between
+ * AiProvider, AiJob, and the storage/job-queue/task-graph packages.
+ *
+ * @param providerName - Unique provider identifier (used as queue name)
+ * @param concurrency - Maximum number of concurrent jobs
+ */
+export async function createDefaultQueue(
+  providerName: string,
+  concurrency: number
+): Promise<void> {
+  const storage = new InMemoryQueueStorage(providerName);
+  await storage.setupDatabase();
+
+  const server = new JobQueueServer(AiJob as any, {
+    storage,
+    queueName: providerName,
+    limiter: new ConcurrencyLimiter(concurrency, 100),
+  });
+
+  const client = new JobQueueClient({
+    storage,
+    queueName: providerName,
+  });
+
+  client.attach(server);
+
+  getTaskQueueRegistry().registerQueue({ server, client, storage });
+  await server.start();
+}