removed AgentStateActor as it was not used

agent_state_actor.py

@@ -1,34 +0,0 @@
-from datetime import datetime
-import ray
-from copy import deepcopy
-
-class AgentState:
-    def __init__(self):
-        self.timestamp = datetime.utcnow()
-        self.input_stt_preview = ''
-        self.prompts = []
-        self.video_input = None
-
-@ray.remote
-class AgentStateActor:
-    def __init__(self):
-        self.begin_step()
-
-    def begin_step(self):
-        self.state = AgentState()
-        # self.state = deepcopy(self.state)
-        # self.state.timestamp = datetime.utcnow()
-
-    def set_input_stt_preview(self, input_stt_preview):
-        self.state.input_stt_preview = input_stt_preview
-
-    def add_input_stt_prompt(self, prompt):
-        self.state.prompts.append(prompt)
-
-    def add_video_input(self, video_input):
-        self.state.video_input = video_input
-
-    def get_state(self):
-        return self.state
-
-

charles_actor.py

@@ -5,7 +5,6 @@ import asyncio
 import os
 from clip_transform import CLIPTransform
 from environment_state_actor import EnvironmentStateActor, EnvironmentState
-from agent_state_actor import AgentStateActor
 import asyncio
 import subprocess
 
@@ -39,7 +38,6 @@ class CharlesActor:
         self._state = "001 - creating RespondToPromptActor"
         from respond_to_prompt_actor import RespondToPromptActor
         self._environment_state_actor = EnvironmentStateActor.remote()
-        self._agent_state_actor = AgentStateActor.remote()
         self._respond_to_prompt_actor = RespondToPromptActor.remote(self._environment_state_actor, self._audio_output_queue)
 
         print("002 - create SpeechToTextVoskActor")
@@ -112,7 +110,6 @@ class CharlesActor:
             
             env_state = await self._environment_state_actor.begin_next_step.remote()
             self._environment_state = env_state
-            self._agent_state_actor.begin_step.remote()
             audio_frames = await self._app_interface_actor.dequeue_audio_input_frames_async.remote()    
             video_frames = await self._app_interface_actor.dequeue_video_input_frames_async.remote()
 

environment_state_actor.py

@@ -1,12 +1,8 @@
 import ray
 from datetime import datetime
 
-from agent_state_actor import AgentState
-
 class EnvironmentState:
     def __init__(self, episode, step):
-
-        self.agent_state = None
         self.timestamp = datetime.utcnow()
         self.episode = episode
         self.step = step
@@ -53,8 +49,5 @@ class EnvironmentStateActor:
     def add_tts_raw_chunk_id(self, chunk_id):
         self.state.tts_raw_chunk_ids.append(chunk_id)
 
-    def add_agent_state(self, agent_state:AgentState):
-        self.state.agent_state = agent_state
-
     def get_state(self)->EnvironmentState:
         return self.state

respond_to_prompt_actor.py

@@ -9,8 +9,6 @@ import asyncio
 from ffmpeg_converter_actor import FFMpegConverterActor
 from agent_response import AgentResponse
 from environment_state_actor import EnvironmentStateActor
-from agent_state_actor import AgentStateActor
-from agent_state_actor import AgentState
 import json
 
 @ray.remote