release

Author: Luca

fluid/scheduler/broker.py

@@ -49,6 +49,9 @@ class TaskInfo:
     priority: str
     schedule: Optional[str] = None
     enabled: bool = True
+    last_run_end: Optional[int] = None
+    last_run_duration: Optional[int] = None
+    last_run_state: Optional[str] = None
 
 
 class TaskRegistry(Dict[str, Task]):
@@ -246,6 +249,9 @@ def _decode_task(self, task: Task, data: dict):
             schedule=str(task.schedule) if task.schedule else None,
             priority=task.priority.name,
             enabled=info.get("enabled", True),
+            last_run_duration=info.get("last_run_duration"),
+            last_run_end=info.get("last_run_end"),
+            last_run_state=info.get("last_run_state"),
         )
 
 

fluid/scheduler/task.py

@@ -4,6 +4,8 @@
 from typing import TYPE_CHECKING, Any, Callable, Dict, NamedTuple, Optional, Union
 from uuid import uuid4
 
+from openapi.spec.utils import trim_docstring
+
 from fluid import log
 from fluid.node import WorkerApplication
 from fluid.utils import microseconds
@@ -148,7 +150,7 @@ def __init__(self, **kwargs):
     def __call__(self, executor: TaskExecutor) -> Task:
         kwargs = {
             "name": executor.__name__,
-            "description": executor.__doc__,
+            "description": trim_docstring(executor.__doc__ or ""),
             **self.kwargs,
             "executor": executor,
         }

poetry.lock

@@ -34,7 +34,7 @@ classifiers = [
 
 [tool.poetry.dependencies]
 python = ">=3.8,<4"
-aio-openapi = "^2.7.1"
+aio-openapi = "^2.7.2"
 aioredis = "^2.0.0"
 ujson = "^5.1.0"
 inflection = "^0.5.1"

pyproject.toml

@@ -27,5 +27,5 @@ Async utility for executing commands in sub-processes
 packages for AWS interaction are installed via
 
 - [aiobotocore](https://github.com/aio-libs/aiobotocore)
-- [s3fs](https://github.com/fsspec/s3fs)(which depends on aiobotocore and therefore versions must be compatible)
+- [s3fs](https://github.com/fsspec/s3fs) (which depends on aiobotocore and therefore versions must be compatible)
 - [boto3](https://boto3.amazonaws.com/v1/documentation/api/latest/guide/quickstart.html) is installed as extra dependency of aiobotocore so versioning is compatible