diff --git a/src/lib/core/streamr/index.ts b/src/lib/core/streamr/index.ts
index 6bf7b42..4a4856a 100644
--- a/src/lib/core/streamr/index.ts
+++ b/src/lib/core/streamr/index.ts
@@ -29,12 +29,12 @@ export default class implements Hooks {
             await retry(
               () => this.publishPendingTransactionsToStreamr(STREAMR_STREAM_ID, pendingTransactions),
               3,
-              2000
+              2000,
             );
           }
         }
       },
-      { name: "streamr-publish-pending-transactions", noOverlap: true }
+      { name: "streamr-publish-pending-transactions", noOverlap: true },
     );
 
     console.log("Streamr cron job registered.");
@@ -53,14 +53,10 @@ export default class implements Hooks {
     });
 
     try {
-      const stream = await retry(
-        () => streamrClient.getStream(STREAMR_STREAM_ID!),
-        3,
-        2000
-      );
+      const stream = await retry(() => streamrClient.getStream(STREAMR_STREAM_ID!), 3, 2000);
 
       await new Promise((resolve) => setTimeout(resolve, 2000));
-      
+
       const batchPayload = buildBatchPayload(pendingTransactions);
       await stream.publish(batchPayload);
 
diff --git a/src/lib/core/streamr/ui.ts b/src/lib/core/streamr/ui.ts
index 9ceaa00..6204318 100644
--- a/src/lib/core/streamr/ui.ts
+++ b/src/lib/core/streamr/ui.ts
@@ -140,8 +140,9 @@ export default class implements UIHooks {
     });
 
     try {
-      const stream = await streamrClient.getStream(streamId);
+      const stream = await retry(() => streamrClient.getStream(streamId), 3, 2000);
       const batchPayload = buildBatchPayload(pendingTransactions);
+      await new Promise((resolve) => setTimeout(resolve, 2000));
       await stream.publish(batchPayload);
     } finally {
       await streamrClient.destroy();