diff --git a/api/src/shared/infrastructure/repositories/jobs/job-repository.js b/api/src/shared/infrastructure/repositories/jobs/job-repository.js index abf3c51d1ce..f4f2317dacd 100644 --- a/api/src/shared/infrastructure/repositories/jobs/job-repository.js +++ b/api/src/shared/infrastructure/repositories/jobs/job-repository.js @@ -59,7 +59,12 @@ export class JobRepository { async #send(jobs) { const knexConn = DomainTransaction.getConnection(); - return knexConn('pgboss.job').insert(jobs); + const results = await knexConn.batchInsert('pgboss.job', jobs); + + // Sum the inserted row counts from the batch insert results + const rowCount = results.reduce((total, batchResult) => total + (batchResult.rowCount || 0), 0); + + return { rowCount }; } async performAsync(...datas) {