Cron Scheduler

import requests, base64, json

application = "my-app"

payload = {"cron_expression": "0 * * * *"}  # Every hour

# Optional: pass input data to each invocation
input_data = json.dumps({"report_type": "daily"}).encode()
payload["input_base64"] = base64.b64encode(input_data).decode()

response = requests.post(
    f"https://api.tensorlake.ai/applications/{application}/cron-schedules",
    json=payload,
    headers={"Authorization": "Bearer TENSORLAKE_API_KEY"},
)
response.raise_for_status()

schedule_id = response.json()["schedule_id"]
print(f"Created schedule: {schedule_id}")

async function createCronSchedule(
  application: string,
  cronExpression: string,
  inputBytes?: Uint8Array,
) {
  const body: Record<string, string> = { cron_expression: cronExpression };
  if (inputBytes) {
    body.input_base64 = btoa(String.fromCharCode(...inputBytes));
  }

  const res = await fetch(
    `/applications/${application}/cron-schedules`,
    {
      method: "POST",
      headers: { "Content-Type": "application/json" },
      body: JSON.stringify(body),
    },
  );

  if (!res.ok) {
    const err = await res.json();
    throw new Error(err.error ?? `HTTP ${res.status}`);
  }

  const { schedule_id } = await res.json();
  return schedule_id as string;
}

response = requests.get(
    f"https://api.tensorlake.ai/applications/{application}/cron-schedules",
    headers={"Authorization": "Bearer TENSORLAKE_API_KEY"},
)
response.raise_for_status()

for schedule in response.json()["schedules"]:
    print(schedule["id"], schedule["cron_expression"], schedule["next_fire_time_ms"])

interface CronSchedule {
  id: string;
  application_name: string;
  cron_expression: string;
  next_fire_time_ms: number;
  last_fired_at_ms: number | null;
  created_at: number;
  enabled: boolean;
}

async function listCronSchedules(application: string) {
  const res = await fetch(
    `/applications/${application}/cron-schedules`,
  );
  if (!res.ok) throw new Error(`HTTP ${res.status}`);
  const { schedules } = await res.json();
  return schedules as CronSchedule[];
}

response = requests.delete(
    f"https://api.tensorlake.ai/applications/{application}/cron-schedules/{schedule_id}",
    headers={"Authorization": "Bearer TENSORLAKE_API_KEY"},
)
response.raise_for_status()

async function deleteCronSchedule(
  application: string,
  scheduleId: string,
) {
  const res = await fetch(
    `/applications/${application}/cron-schedules/${scheduleId}`,
    { method: "DELETE" },
  );
  if (!res.ok) throw new Error(`HTTP ${res.status}`);
}