We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent dd8161e commit 6f50f1bCopy full SHA for 6f50f1b
services/web/server/src/simcore_service_webserver/conversations/_socketio.py
@@ -14,7 +14,7 @@
14
from pydantic.alias_generators import to_camel
15
from servicelib.utils import limited_as_completed
16
17
-from ..socketio.messages import send_message_to_standard_group
+from ..socketio.messages import send_message_to_user
18
19
_MAX_CONCURRENT_SENDS: Final[int] = 3
20
@@ -62,7 +62,9 @@ async def _send_message_to_recipients(
62
):
63
async for _ in limited_as_completed(
64
(
65
- send_message_to_standard_group(app, recipient, notification_message)
+ send_message_to_user(
66
+ app, recipient, notification_message, ignore_queue=True
67
+ )
68
for recipient in recipients
69
),
70
limit=_MAX_CONCURRENT_SENDS,
0 commit comments