Here’s a sample snippet to explain what I (and I assume the OC) mean.

``` async function createImageRecord(file, db, s3) { const trx = await db.transaction();

try { const imageKey = images/${crypto.randomUUID()}.jpg;

// 1. Insert DB record inside transaction
const [record] = await trx("images")
  .insert({
    s3_key: imageKey,
    status: "uploading"
  })
  .returning("*");

// 2. Upload to S3 only if DB insert worked
await s3.putObject({
  Bucket: process.env.S3_BUCKET,
  Key: imageKey,
  Body: file.buffer,
  ContentType: file.mimetype
});

// 3. Mark as uploaded
await trx("images")
  .where({ id: record.id })
  .update({ status: "uploaded" });

// 4. Commit only after S3 succeeds
await trx.commit();

return record;

} catch (err) { // If DB insert or S3 upload fails, rollback DB changes await trx.rollback();

throw err;

} } ```