Pass workflow id into SchemaManager when using it inside workflow

pilsy · Sep 12, 2024 · 71ac039 · 71ac039
1 parent 34f8fe4
commit 71ac039
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/SchemaManager.ts b/src/SchemaManager.ts
@@ -39,9 +39,9 @@ export class SchemaManager extends EventEmitter {
    * Returns the singleton instance of SchemaManager.
    * @returns The SchemaManager instance.
    */
-  public static getInstance(): SchemaManager {
+  public static getInstance(workflowId?: string): SchemaManager {
     if (!this.instance) {
-      this.instance = new SchemaManager();
+      this.instance = new SchemaManager(workflowId);
     }
     return this.instance;
   }
@@ -66,7 +66,7 @@ export class SchemaManager extends EventEmitter {
   /**
    * Private constructor to enforce singleton pattern.
    */
-  private constructor() {
+  private constructor(protected workflowId?: string) {
     super();
   }
 

diff --git a/src/workflows/StatefulWorkflow.ts b/src/workflows/StatefulWorkflow.ts
@@ -84,7 +84,7 @@ export type PendingChange = {
 };
 
 export abstract class StatefulWorkflow extends Workflow {
-  private schemaManager = SchemaManager.getInstance();
+  private schemaManager = SchemaManager.getInstance(workflow.workflowInfo().workflowId);
   private schema: Schema;
 
   protected async condition(): Promise<any> {