Cron

from agentfield import Agent, on_schedule

app = Agent(node_id="scheduler")

@app.reasoner()
@on_schedule("*/15 * * * *")
async def run_every_fifteen_minutes(_input, trigger=None):
    return {"fired_at": trigger.received_at.isoformat() if trigger else None}

app.run()

import { Agent } from '@agentfield/sdk';

const agent = new Agent({ nodeId: 'scheduler' });

// The cron source dispatches the schedule metadata as ctx.input.event.
// The TypeScript SDK has no declarative schedule binding — connect the
// `cron` source to this reasoner from the UI (or via the trigger REST API).
agent.reasoner('runEveryFifteenMinutes', async (ctx) => {
  const { event } = ctx.input;
  return { firedAt: event?.fired_at ?? null };
});

agent.serve();

a, _ := agent.New(agent.Config{NodeID: "scheduler", Version: "1.0.0"})

// The cron schedule binding is declared in code via WithScheduleTrigger.
// The control plane runs the schedule and dispatches a synthetic "tick"
// event; the schedule metadata arrives as input["event"].
a.RegisterReasoner("run_every_fifteen_minutes", func(ctx context.Context, input map[string]any) (any, error) {
    event, _ := input["event"].(map[string]any)
    return map[string]any{"fired_at": event["fired_at"]}, nil
},
    agent.WithScheduleTrigger("*/15 * * * *"),
)

a.Serve(context.Background())