mirror of
https://github.com/tiqi-group/pydase.git
synced 2026-02-14 06:18:41 +01:00
updates task serialization
This commit is contained in:
@@ -7,6 +7,7 @@ from typing import Any, TypedDict
|
|||||||
|
|
||||||
import pydase.units as u
|
import pydase.units as u
|
||||||
from pydase.data_service.abstract_data_service import AbstractDataService
|
from pydase.data_service.abstract_data_service import AbstractDataService
|
||||||
|
from pydase.data_service.task_manager import TaskStatus
|
||||||
from pydase.utils.helpers import (
|
from pydase.utils.helpers import (
|
||||||
function_has_arguments,
|
function_has_arguments,
|
||||||
get_attribute_doc,
|
get_attribute_doc,
|
||||||
@@ -244,8 +245,7 @@ class Serializer:
|
|||||||
|
|
||||||
# If there's a running task for this method
|
# If there's a running task for this method
|
||||||
if key in obj._task_manager.tasks:
|
if key in obj._task_manager.tasks:
|
||||||
task_info = obj._task_manager.tasks[key]
|
value[key]["value"] = TaskStatus.RUNNING.name
|
||||||
value[key]["value"] = task_info["kwargs"]
|
|
||||||
|
|
||||||
# If the DataService attribute is a property
|
# If the DataService attribute is a property
|
||||||
if isinstance(getattr(obj.__class__, key, None), property):
|
if isinstance(getattr(obj.__class__, key, None), property):
|
||||||
|
|||||||
Reference in New Issue
Block a user