diff --git a/pragma-sdk/pragma_sdk/onchain/mixins/randomness.py b/pragma-sdk/pragma_sdk/onchain/mixins/randomness.py
index abfdb277..e6458e76 100644
--- a/pragma-sdk/pragma_sdk/onchain/mixins/randomness.py
+++ b/pragma-sdk/pragma_sdk/onchain/mixins/randomness.py
@@ -172,6 +172,7 @@ async def process_request(request):
         invocation = await self.account.execute_v1(  # type: ignore[union-attr]
             calls=all_calls, max_fee=self.execution_config.max_fee
         )
+        await self.full_node_client.wait_for_tx(invocation.transaction_hash)
         return invocation
 
     async def estimate_gas_submit_random_op(
diff --git a/vrf-listener/vrf_listener/main.py b/vrf-listener/vrf_listener/main.py
index 8f64c67b..91c9dc8c 100644
--- a/vrf-listener/vrf_listener/main.py
+++ b/vrf-listener/vrf_listener/main.py
@@ -57,7 +57,6 @@ async def main(
     while True:
         if index_with_apibara:
             events = await _consume_full_queue(requests_queue)
-            logger.info(events)
         try:
             await client.handle_random(
                 private_key=int(private_key, 16),
@@ -165,8 +164,7 @@ async def _consume_full_queue(requests_queue: asyncio.Queue) -> List[RandomnessR
     while not requests_queue.empty():
         try:
             e = requests_queue.get_nowait()
-            if e not in events:
-                events.append(e)
+            events.append(e)
         except asyncio.QueueEmpty:
             break
     return events