AWPThreadInfo

def __init__(self, run_agent_input: RunAgentInput, workflow_id: str) -> None:
    """Represent AWP thread.

    Args:
        run_agent_input (RunAgentInput): run agent input from the request
        workflow_id (str): The workflow id.
    """
    self.run_agent_input = run_agent_input
    self.awp_id = run_agent_input.thread_id
    self.run_id = run_agent_input.run_id
    self.workflow_id = workflow_id
    self.out_queue: Queue[BaseMessage] = Queue()
    self.input_queue: Queue[str] = Queue()
    self.active = True
    self.encoder = EventEncoder()
    # all messages that have been attempted to send in one run
    self.sent_messages: list[BaseMessage] = []