pub fn write_agent_completion(
pool: &Pool,
params: &AgentCompletionCreateParams,
sender_agent_instance_hierarchy: String,
) -> Result<(LogWriter<AgentCompletionChunk>, Receiver<String>), Error>pub fn write_agent_completion(
pool: &Pool,
params: &AgentCompletionCreateParams,
sender_agent_instance_hierarchy: String,
) -> Result<(LogWriter<AgentCompletionChunk>, Receiver<String>), Error>