aboutsummaryrefslogtreecommitdiffstats
path: root/packages/meshbay-node/src/meshbay_node/ops.py
diff options
context:
space:
mode:
Diffstat (limited to 'packages/meshbay-node/src/meshbay_node/ops.py')
-rw-r--r--packages/meshbay-node/src/meshbay_node/ops.py5
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"}