diff --git a/tests/test_stream_service.c b/tests/test_stream_service.c
index 74380f33..815cc24f 100644
--- a/tests/test_stream_service.c
+++ b/tests/test_stream_service.c
@@ -516,11 +516,16 @@ static void test_global_pressure(void) {
     for (unsigned i = 1; i < 3; i++) for (unsigned sub = 0; sub < 2; sub++)
         CHECK(stream_receive_open(subscribers[i], nodes[3]->node_id, sub, UINT64_MAX, &receives[i][sub]) == STREAM_OK);
     for (unsigned i = 1; i < 3; i++) run_until(&global_data[i], 1);
+    uint64_t previous_requests[3] = {0};
+    for (unsigned i = 1; i < 3; i++) {
+        struct stream_peer_load_info before; CHECK(stream_peer_get_load(nodes[3], nodes[i]->node_id, &before) == STREAM_OK);
+        previous_requests[i] = before.request_id;
+    }
     simulated_cpu = 1; test_clock_run_for(ua, 7000);
     struct stream_peer_load_info info[3];
     for (unsigned i = 1; i < 3; i++) {
         CHECK(stream_peer_get_load(nodes[3], nodes[i]->node_id, &info[i]) == STREAM_OK);
-        CHECK(info[i].cpu_percent == 95 && !info[i].request_id && !info[i].load.queued.bytes);
+        CHECK(info[i].cpu_percent == 95 && info[i].request_id == previous_requests[i] && !info[i].load.queued.bytes);
     }
     struct ll_queue *queues[3] = {0}; queue_callback_fn callbacks[3] = {0}; void *args[3] = {0};
     for (unsigned i = 1; i < 3; i++) {