final fix

sanderegg · sanderegg · commit 5327ba73754f · 2025-07-31T18:07:42.000+02:00
diff --git a/services/web/server/tests/integration/02/notifications/test_rabbitmq_consumers.py b/services/web/server/tests/integration/02/notifications/test_rabbitmq_consumers.py
@@ -420,7 +420,7 @@ async def test_progress_computational_workflow(
     )
     await rabbitmq_publisher.publish(progress_message.channel_name, progress_message)
 
-    call_expected = subscribe_to_logs
+    call_expected = sender_same_user_id and subscribe_to_logs
     if call_expected:
         expected_call = jsonable_encoder(
             progress_message, include={"node_id", "project_id"}

Original file line number	Diff line number	Diff line change
`@@ -420,7 +420,7 @@ async def test_progress_computational_workflow(`
`420`	`420`	`)`
`421`	`421`	`await rabbitmq_publisher.publish(progress_message.channel_name, progress_message)`
`422`	`422`
`423`		`- call_expected = subscribe_to_logs`
	`423`	`+ call_expected = sender_same_user_id and subscribe_to_logs`
`424`	`424`	`if call_expected:`
`425`	`425`	`expected_call = jsonable_encoder(`
`426`	`426`	`progress_message, include={"node_id", "project_id"}`