Minor cleanups of AgentContext

LangStream · Nov 14, 2023 · dc41cd7 · dc41cd7
1 parent b16e58d
commit dc41cd7
Show file tree

Hide file tree

Showing 4 changed files with 16 additions and 15 deletions.
diff --git a/langstream-runtime/langstream-runtime-impl/src/main/python/langstream/api.py b/langstream-runtime/langstream-runtime-impl/src/main/python/langstream/api.py
@@ -67,7 +67,7 @@ class AgentContext(ABC):
     """The Agent context interface"""
 
     @abstractmethod
-    def get_persistent_state_directory(self):
+    def get_persistent_state_directory(self) -> Optional[str]:
         """Return the path of the agent disk. Return None if not configured."""
         pass
 

diff --git a/langstream-runtime/langstream-runtime-impl/src/main/python/langstream_grpc/api.py b/langstream-runtime/langstream-runtime-impl/src/main/python/langstream_grpc/api.py
@@ -67,9 +67,9 @@ class AgentContext(ABC):
     """The Agent context interface"""
 
     @abstractmethod
-    def get_persistent_state_directory(self):
+    def get_persistent_state_directory(self) -> Optional[str]:
         """Return the path of the agent disk. Return None if not configured."""
-        return None
+        pass
 
 
 class Agent(ABC):

diff --git a/langstream-runtime/langstream-runtime-impl/src/main/python/langstream_grpc/grpc_service.py b/langstream-runtime/langstream-runtime-impl/src/main/python/langstream_grpc/grpc_service.py
@@ -383,13 +383,10 @@ def __init__(self, configuration: dict, context: dict):
         self.configuration = configuration
         self.context = context
 
-    def get_persistent_state_directory(self) -> str:
-        dir = self.context.get("persistentStateDirectory", "")
-        if not dir:
-            return None
-        return dir
-
+    def get_persistent_state_directory(self) -> Optional[str]:
+        return self.context.get("persistentStateDirectory")
 
+agen
 class AgentServer(object):
     def __init__(self, target: str, config: str, context: str):
         self.thread_pool = concurrent.futures.ThreadPoolExecutor(max_workers=10)

diff --git a/...time/langstream-runtime-impl/src/main/python/langstream_grpc/tests/test_grpc_processor.py b/...time/langstream-runtime-impl/src/main/python/langstream_grpc/tests/test_grpc_processor.py
@@ -281,23 +281,27 @@ def process(self, record: Record) -> Future[List[RecordType]]:
         return self.executor.submit(lambda r: [r], record)
 
 
-class ProcessorInitOneParameter(Processor):
+class ProcessorInitOneParameter:
+    def __init__(self):
+        self.myparam = None
+
     def init(self, agent_config):
         self.myparam = agent_config["my-param"]
 
-    def process(self, record: Record) -> List[RecordType]:
+    def process(self, _) -> List[RecordType]:
         return [{"value": self.myparam}]
 
 
 class ProcessorUseContext(Processor):
+    def __init__(self):
+        self.myparam = None
+        self.context = None
+
     def init(self, agent_config, context: AgentContext):
         self.myparam = agent_config["my-param"]
         self.context = context
 
     def process(self, record: Record) -> List[RecordType]:
         return [
-            {
-                "value": "directory is "
-                + str(self.context.get_persistent_state_directory())
-            }
+            {"value": f"directory is {self.context.get_persistent_state_directory()}"}
         ]