Schedules

import { pi } from "@rivet-dev/pi";
import { e2bProvider } from "@rivet-dev/sandbox-adapter/e2b";
import { setup } from "rivetkit";

const agent = pi({
	model: "anthropic/claude-sonnet-5-5",
	sandbox: e2bProvider(),
	onCreate: async (c) => {
		const [repo] = c.key;
		await c.cron.set({
			name: "morning-triage",
			expression: "0 9 * * *",
			action: "prompt",
			args: [`Clone https://github.com/${repo}, run its test suite, and summarize any failures.`],
		});
	},
});

export const registry = setup({ use: { agent } });

registry.start();

import { createClient } from "rivetkit/client";
import type { registry } from "./server";

const client = createClient<typeof registry>();
const agent = client.agent.getOrCreate(["acme/app", "morning-triage"]);

// The first call creates the agent, and onCreate sets its cron.
await agent.resolve();

// Any time after a run, read the latest summary.
const summary = await agent.getLastAssistantText();
console.log(summary ?? "No run yet. The first one starts at 9:00 UTC.");