Skip to content

Commit 3d7d244

Browse files
committed
Bind task for proper retrying
1 parent ac0c154 commit 3d7d244

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

website/preprints/tasks.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -65,8 +65,8 @@ def update_or_enqueue_on_preprint_updated(preprint_id, saved_fields=None):
6565
)
6666

6767

68-
@celery_app.task(ignore_results=True, max_retries=5, default_retry_delay=CROSSREF_FAIL_RETRY_DELAY)
69-
def mint_doi_on_crossref_fail(preprint_id):
68+
@celery_app.task(bind=True, acks_late=True, max_retries=5, default_retry_delay=CROSSREF_FAIL_RETRY_DELAY)
69+
def mint_doi_on_crossref_fail(self, preprint_id):
7070
from osf.models import Preprint
7171
preprint = Preprint.load(preprint_id)
7272
existing_versions_without_minted_doi = Preprint.objects.filter(
@@ -79,7 +79,7 @@ def mint_doi_on_crossref_fail(preprint_id):
7979
f'There are existing preprint versions for preprint with guid {preprint._id} that are missing DOIs. Versions: '
8080
f'{list(existing_versions_without_minted_doi.values_list('versioned_guids__version', flat=True))}'
8181
)
82-
mint_doi_on_crossref_fail.retry(countdown=CROSSREF_FAIL_RETRY_DELAY)
82+
self.retry()
8383
else:
8484
crossref_client = preprint.get_doi_client()
8585
if crossref_client:

0 commit comments

Comments
 (0)