Skip to content

Commit 7b02c94

Browse files
review @sanderegg
1 parent 6a8401e commit 7b02c94

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

services/web/server/src/simcore_service_webserver/notifications/_rabbitmq_exclusive_queue_consumers.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -200,7 +200,7 @@ async def on_cleanup_ctx_rabbitmq_consumers(
200200
app[APP_WALLET_SUBSCRIPTIONS_KEY] = defaultdict(
201201
int
202202
) # wallet_id -> subscriber count
203-
app[APP_WALLET_SUBSCRIPTION_LOCK_KEY] = asyncio.Lock() # For thread-safe operations
203+
app[APP_WALLET_SUBSCRIPTION_LOCK_KEY] = asyncio.Lock() # Ensures exclusive access
204204

205205
yield
206206

0 commit comments

Comments
 (0)