diff options
Diffstat (limited to 'packages/meshbay-node/src/meshbay_node/ops.py')
| -rw-r--r-- | packages/meshbay-node/src/meshbay_node/ops.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/packages/meshbay-node/src/meshbay_node/ops.py b/packages/meshbay-node/src/meshbay_node/ops.py index 4d3422d..91a922a 100644 --- a/packages/meshbay-node/src/meshbay_node/ops.py +++ b/packages/meshbay-node/src/meshbay_node/ops.py @@ -30,6 +30,7 @@ from dataclasses import asdict from pathlib import Path from typing import Any +from meshbay_common.background import spawn from meshbay_common.chatbox import new_epoch_key from meshbay_common.crypto import ( generate_gek, @@ -1673,7 +1674,7 @@ async def set_app_directories(state: dict, group_id: str, app_key: str, enrich = (state.get("enrich_app_dirs_fns") or {}).get(app_key) if enrich: - asyncio.ensure_future(enrich(group_id)) + spawn(enrich(group_id)) return {"app": app_key, "directories": clean, "group_id": group_id} @@ -1881,5 +1882,5 @@ async def start_reload(state: dict) -> dict: reload_fn = state.get("reload_fn") if not reload_fn: raise OpError("Reload not available", status=503) - asyncio.ensure_future(reload_fn()) + spawn(reload_fn()) return {"status": "reloading"} |