diff options
Diffstat (limited to 'packages/meshbay-hub/src/meshbay_hub/api/revocation.py')
| -rw-r--r-- | packages/meshbay-hub/src/meshbay_hub/api/revocation.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/packages/meshbay-hub/src/meshbay_hub/api/revocation.py b/packages/meshbay-hub/src/meshbay_hub/api/revocation.py index 0e274f9..60b0c88 100644 --- a/packages/meshbay-hub/src/meshbay_hub/api/revocation.py +++ b/packages/meshbay-hub/src/meshbay_hub/api/revocation.py @@ -40,6 +40,7 @@ from sqlalchemy import select, update from sqlalchemy.ext.asyncio import AsyncSession import jwt +from meshbay_common.background import spawn from meshbay_hub.auth import hub_public_key_pem, decode_access_token from meshbay_hub.api.deps import get_current_user, require_admin from meshbay_hub.db.engine import get_db @@ -397,7 +398,7 @@ async def node_websocket(ws: WebSocket): if not _notify_budget(node_id): log.warning("Node %s exceeded its chat_notify rate", node_id[:8]) continue - asyncio.ensure_future(_handle_chat_notify( + spawn(_handle_chat_notify( msg.get("group_id", ""), msg.get("sender_name", ""), # The author, as the node authenticated them — not |