diff --git a/dpc-attribution/src/main/java/gov/cms/dpc/attribution/jobs/ExpireAttributions.java b/dpc-attribution/src/main/java/gov/cms/dpc/attribution/jobs/ExpireAttributions.java index 9ce43d0ef7..54bbdc4cd2 100644 --- a/dpc-attribution/src/main/java/gov/cms/dpc/attribution/jobs/ExpireAttributions.java +++ b/dpc-attribution/src/main/java/gov/cms/dpc/attribution/jobs/ExpireAttributions.java @@ -43,6 +43,8 @@ public void doJob(JobExecutionContext jobContext) { logger.debug("Expiring active attribution relationships before {}.", expirationTemporal.format(DateTimeFormatter.ISO_DATE_TIME)); try (final Connection connection = this.dataSource.getConnection(); final DSLContext context = DSL.using(connection, this.settings)) { + connection.setAutoCommit(false); + final int updated = context .update(Attributions.ATTRIBUTIONS) .set(Attributions.ATTRIBUTIONS.INACTIVE, true)