Fixed run stream tests

triggerdotdev · Dec 19, 2024 · 203d7a0 · 203d7a0
1 parent 85b3605
commit 203d7a0
Showing 1 changed file with 3 additions and 11 deletions.
diff --git a/packages/core/test/runStream.test.ts b/packages/core/test/runStream.test.ts
@@ -31,11 +31,7 @@ class TestStreamSubscriptionFactory implements StreamSubscriptionFactory {
     this.streams.set(`${runId}:${streamKey}`, chunks);
   }
 
-  createSubscription(
-    metadata: Record<string, unknown>,
-    runId: string,
-    streamKey: string
-  ): StreamSubscription {
+  createSubscription(runId: string, streamKey: string): StreamSubscription {
     const chunks = this.streams.get(`${runId}:${streamKey}`) ?? [];
     return new TestStreamSubscription(chunks);
   }
@@ -285,13 +281,9 @@ describe("RunSubscription", () => {
 
     // Override createSubscription to count calls
     const originalCreate = streamFactory.createSubscription.bind(streamFactory);
-    streamFactory.createSubscription = (
-      metadata: Record<string, unknown>,
-      runId: string,
-      streamKey: string
-    ) => {
+    streamFactory.createSubscription = (runId: string, streamKey: string) => {
       streamCreationCount++;
-      return originalCreate(metadata, runId, streamKey);
+      return originalCreate(runId, streamKey);
     };
 
     // Set up test chunks