Skip to content

Commit 08863e0

Browse files
committed
Fix job pk to id
1 parent 315b977 commit 08863e0

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

plain-jobs/plain/jobs/models.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -308,7 +308,7 @@ def defer(self, *, job: Job, defer_exception: DeferJob) -> JobResult:
308308

309309
with transaction.atomic():
310310
# 1. Save JobProcess state and delete (releases concurrency slot)
311-
saved_pk = self.pk
311+
saved_id = self.id
312312
job_process_uuid = self.uuid
313313
job_request_uuid = self.job_request_uuid
314314
started_at = self.started_at
@@ -326,8 +326,8 @@ def defer(self, *, job: Job, defer_exception: DeferJob) -> JobResult:
326326

327327
# Check if re-enqueue failed
328328
if new_job_request is None:
329-
# Restore pk since transaction will roll back and object still exists
330-
self.pk = saved_pk
329+
# Restore id since transaction will roll back and object still exists
330+
self.id = saved_id
331331
raise DeferError(
332332
f"Failed to re-enqueue deferred job {self.job_class}: "
333333
f"concurrency limit reached for key '{self.concurrency_key}'"

0 commit comments

Comments
 (0)