Fix: actually wait for realtime streams to finished (#1520)

* Realtime streams fix waiting for streams to finished

* Add changeset

Author: ericallam

.changeset/thirty-moose-jam.md

@@ -0,0 +1,5 @@
+---
+"@trigger.dev/sdk": patch
+---
+
+Fix for waiting for realtime streams to finish

packages/core/src/v3/runMetadata/manager.ts

@@ -250,7 +250,7 @@ export class StandardMetadataManager implements RunMetadataManager {
       return streamInstance;
     } catch (error) {
       // Clean up metadata key if stream creation fails
-      this.deleteKey(`$$stream.${key}`);
+      this.removeFromKey(`$$streams`, key);
       throw error;
     }
   }
@@ -265,7 +265,7 @@ export class StandardMetadataManager implements RunMetadataManager {
       return;
     }
 
-    const promises = Array.from(this.activeStreams.values());
+    const promises = Array.from(this.activeStreams.values()).map((stream) => stream.wait());
 
     try {
       await Promise.race([