diff options
Diffstat (limited to 'Omni/Agent/Worker.hs')
| -rw-r--r-- | Omni/Agent/Worker.hs | 38 |
1 files changed, 20 insertions, 18 deletions
diff --git a/Omni/Agent/Worker.hs b/Omni/Agent/Worker.hs index 1c69b15..79cf3c8 100644 --- a/Omni/Agent/Worker.hs +++ b/Omni/Agent/Worker.hs @@ -93,7 +93,7 @@ processTask worker task = do activityId <- TaskCore.logActivityWithMetrics tid TaskCore.Running Nothing Nothing (Just startTime) Nothing Nothing Nothing say "[worker] Starting engine..." - (exitCode, output, costCents) <- runWithEngine repo task + (exitCode, output, costCents) <- runWithEngine worker repo task endTime <- Data.Time.getCurrentTime say ("[worker] Agent exited with: " <> tshow exitCode) @@ -199,8 +199,8 @@ tryCommit repo msg = do -- | Run task using native Engine -- Returns (ExitCode, output text, cost in cents) -runWithEngine :: FilePath -> TaskCore.Task -> IO (Exit.ExitCode, Text, Int) -runWithEngine repo task = do +runWithEngine :: Core.Worker -> FilePath -> TaskCore.Task -> IO (Exit.ExitCode, Text, Int) +runWithEngine worker repo task = do -- Read API key from environment maybeApiKey <- Env.lookupEnv "OPENROUTER_API_KEY" case maybeApiKey of @@ -254,7 +254,9 @@ runWithEngine repo task = do -- Build Engine config with callbacks totalCostRef <- newIORef (0 :: Int) - let engineCfg = + let quiet = Core.workerQuiet worker + sayLog msg = if quiet then putText msg else AgentLog.log msg + engineCfg = Engine.EngineConfig { Engine.engineLLM = Engine.defaultLLM @@ -262,26 +264,26 @@ runWithEngine repo task = do }, Engine.engineOnCost = \tokens cost -> do modifyIORef' totalCostRef (+ cost) - AgentLog.log <| "Cost: " <> tshow cost <> " cents (" <> tshow tokens <> " tokens)" - logEvent "cost" (Aeson.object [("tokens", Aeson.toJSON tokens), ("cents", Aeson.toJSON cost)]), + sayLog <| "Cost: " <> tshow cost <> " cents (" <> tshow tokens <> " tokens)" + logEvent "Cost" (Aeson.object [("tokens", Aeson.toJSON tokens), ("cents", Aeson.toJSON cost)]), Engine.engineOnActivity = \activity -> do - AgentLog.log <| "[engine] " <> activity, + sayLog <| "[engine] " <> activity, Engine.engineOnToolCall = \toolName args -> do - AgentLog.log <| "[tool] " <> toolName - logEvent "tool_call" (Aeson.object [("tool", Aeson.toJSON toolName), ("args", Aeson.toJSON args)]), + sayLog <| "[tool] " <> toolName + logEvent "ToolCall" (Aeson.String (toolName <> ": " <> args)), Engine.engineOnAssistant = \msg -> do - AgentLog.log <| "[assistant] " <> Text.take 200 msg - logEvent "assistant" (Aeson.String msg), + sayLog <| "[assistant] " <> Text.take 200 msg + logEvent "Assistant" (Aeson.String msg), Engine.engineOnToolResult = \toolName success output -> do let statusStr = if success then "ok" else "failed" - AgentLog.log <| "[result] " <> toolName <> " (" <> statusStr <> "): " <> Text.take 100 output - logEvent "tool_result" (Aeson.object [("tool", Aeson.toJSON toolName), ("success", Aeson.toJSON success), ("output", Aeson.toJSON output)]), + sayLog <| "[result] " <> toolName <> " (" <> statusStr <> "): " <> Text.take 100 output + logEvent "ToolResult" (Aeson.String output), Engine.engineOnComplete = do - AgentLog.log "[engine] Complete" - logEvent "complete" Aeson.Null, + sayLog "[engine] Complete" + logEvent "Complete" Aeson.Null, Engine.engineOnError = \err -> do - AgentLog.log <| "[error] " <> err - logEvent "error" (Aeson.String err) + sayLog <| "[error] " <> err + logEvent "Error" (Aeson.String err) } -- Build Agent config @@ -290,7 +292,7 @@ runWithEngine repo task = do { Engine.agentModel = model, Engine.agentTools = Tools.allTools, Engine.agentSystemPrompt = systemPrompt, - Engine.agentMaxIterations = 20 + Engine.agentMaxIterations = 100 } -- Run the agent |