import { pool } from "./db";

export async function log(jobId: number, stream: "stdout" | "stderr" | "system", message: string) {
  await pool.query(
    "INSERT INTO job_logs (job_id, stream, message) VALUES (?, ?, ?)",
    [jobId, stream, message]
  );
}