update

main.py

@@ -115,10 +115,8 @@ def main():
         key = porter_task_file.stem
         value = environment.get(key=key, default=False, dtype=bool)
         logger.info(f"{key}: {value}")
-
         if value is True:
             task_manager.add_tasks_by_task_file(tasks_file=porter_task_file.as_posix())
-
     task_thread = threading.Thread(
         target=async_thread_wrapper,
         args=(task_manager.run(),),

tabs/space_manage_tab.py

@@ -92,7 +92,7 @@ def get_space_manage_tab():
                 key="rebuild_switch",
                 value=value
             )
-            runtime = api.get_space_runtime(repo_id=space_name)
+            runtime = api.restart_space(repo_id=space_name)
             result = {
                 "stage": runtime.stage,
             }

toolbox/space_manager/cyclic/cyclic.py

@@ -5,7 +5,10 @@ from datetime import datetime, timedelta
 import logging
 import json
 import os
-from typing import Coroutine, Dict, List, Tuple, Union, Iterable
+from typing import List, Callable, Awaitable, TypeVar
+
+T = TypeVar('T')
+
 
 logger = logging.getLogger("toolbox")
 
@@ -15,21 +18,20 @@ from project_settings import environment, project_path, time_zone_info
 
 
 class AsyncDelayTask(object):
-    def __init__(self, delay: float, coro_or_future: Union[Coroutine, asyncio.Future]):
+    def __init__(self,
+                 delay: float,
+                 fn: Callable[..., Awaitable[T]],
+                 *args, **kwargs
+                 ):
         self.delay = delay
-        self.coro_or_future = coro_or_future
+        self.fn = fn
+        self.args = args
+        self.kwargs = kwargs
 
     async def run(self):
         await asyncio.sleep(self.delay)
-        return await self.coro_or_future
-
-
-async def remove_file(filename: str):
-    try:
-        logger.info(f"删除文件：{filename}")
-        os.remove(filename)
-    except FileNotFoundError:
-        logger.info(f"文件不存在，跳过删除：{filename}")
+        result = await self.fn(*self.args, **self.kwargs)
+        return result
 
 
 class CyclicSpaceManager(object):
@@ -130,7 +132,7 @@ class CyclicSpaceManager(object):
         task = asyncio.ensure_future(
             AsyncDelayTask(
                 delay=delay_time,
-                coro_or_future=rebuild_space()
+                fn=rebuild_space
             ).run()
         )
         # await task