diff --git a/packages/tests/tests/filter/multiple_pubsub.node.spec.ts b/packages/tests/tests/filter/multiple_pubsub.node.spec.ts
index 03050db036..bd38430794 100644
--- a/packages/tests/tests/filter/multiple_pubsub.node.spec.ts
+++ b/packages/tests/tests/filter/multiple_pubsub.node.spec.ts
@@ -113,7 +113,7 @@ describe("Waku Filter V2: Multiple PubSubtopics", function () {
       DefaultPubSubTopic,
       await nwaku2.getPeerId()
     );
-    await nwaku.ensureSubscriptions([DefaultPubSubTopic]);
+    await nwaku2.ensureSubscriptions([DefaultPubSubTopic]);
 
     const messageCollector2 = new MessageCollector();
 
diff --git a/packages/tests/tests/filter/subscribe.node.spec.ts b/packages/tests/tests/filter/subscribe.node.spec.ts
index 22d63b1e3f..540c1391fa 100644
--- a/packages/tests/tests/filter/subscribe.node.spec.ts
+++ b/packages/tests/tests/filter/subscribe.node.spec.ts
@@ -327,6 +327,7 @@ describe("Waku Filter V2: Subscribe", function () {
       DefaultPubSubTopic,
       await nwaku2.getPeerId()
     );
+    await nwaku2.ensureSubscriptions([DefaultPubSubTopic]);
     // Send a message using the new subscription
     const newContentTopic = "/test/2/waku-filter";
     const newEncoder = createEncoder({ contentTopic: newContentTopic });
diff --git a/packages/tests/tests/light-push/multiple_pubsub.node.spec.ts b/packages/tests/tests/light-push/multiple_pubsub.node.spec.ts
index f942b654a6..87712ad431 100644
--- a/packages/tests/tests/light-push/multiple_pubsub.node.spec.ts
+++ b/packages/tests/tests/light-push/multiple_pubsub.node.spec.ts
@@ -112,6 +112,7 @@ describe("Waku Light Push : Multiple PubSubtopics", function () {
       relay: true,
       topic: [DefaultPubSubTopic]
     });
+    await nwaku2.ensureSubscriptions([DefaultPubSubTopic]);
     await waku.dial(await nwaku2.getMultiaddrWithId());
     await waitForRemotePeer(waku, [Protocols.LightPush]);