Oban worker for recurring/scheduled agent runs via Oban cron.

A thin convenience wrapper around ADK.Oban.AgentWorker that defaults to the :scheduled queue and is designed for use with the Oban cron plugin.

One-Shot Delayed Scheduling

# Schedule an agent to run in 60 seconds
ADK.Oban.ScheduledJob.schedule(MyApp.Agents.Cleanup, schedule_in: 60)

# Schedule with inline agent config
ADK.Oban.ScheduledJob.schedule(
  %{
    "agent_name" => "cleanup",
    "model" => "gemini-flash-latest",
    "instruction" => "You are a cleanup agent.",
    "message" => "Run cleanup now",
    "user_id" => "system"
  },
  schedule_in: 3600
)

Recurring via Oban Cron Plugin

# config/config.exs
config :my_app, Oban,
  repo: MyApp.Repo,
  queues: [scheduled: 5],
  plugins: [
    {Oban.Plugins.Cron,
     crontab: [
       # Run cleanup agent every day at midnight
       {"0 0 * * *", ADK.Oban.ScheduledJob,
        args: %{
          "agent_module" => "MyApp.Agents.Cleanup",
          "app_name" => "my_app",
          "user_id" => "system",
          "message" => "Run daily cleanup"
        }},
       # Run monitoring agent every hour
       {"0 * * * *", ADK.Oban.ScheduledJob,
        args: %{
          "agent_module" => "MyApp.Agents.Monitor",
          "app_name" => "my_app",
          "user_id" => "system",
          "message" => "Run hourly monitoring check"
        }}
     ]}
  ]

Agent Module

Define an agent module that exports agent/0:

defmodule MyApp.Agents.Cleanup do
  def agent do
    ADK.Agent.LlmAgent.new(
      name: "cleanup",
      model: "gemini-flash-latest",
      instruction: "You are a cleanup agent. Remove stale data and free resources."
    )
  end
end

Inline Agent Config

Alternatively, pass agent config directly in args:

%{
  "agent_name" => "monitor",
  "model" => "gemini-flash-latest",
  "instruction" => "You are a monitoring agent.",
  "message" => "Run health check",
  "user_id" => "system"
}
|> ADK.Oban.ScheduledJob.new()
|> Oban.insert()

Telemetry

Emits the following events on job execution:

• [:adk, :scheduled_job, :start] — before agent run, metadata includes args
• [:adk, :scheduled_job, :stop] — after agent run, measurements include duration