From 704c6be1c43b0da7e3f96747346752f3ec039dec Mon Sep 17 00:00:00 2001 From: rubenwardy Date: Tue, 26 Aug 2025 20:50:05 +0100 Subject: [PATCH] Add dedicated celery task for codeberg --- app/tasks/importtasks.py | 18 +++++++++++++++--- 1 file changed, 15 insertions(+), 3 deletions(-) diff --git a/app/tasks/importtasks.py b/app/tasks/importtasks.py index 9b71d8a2..05eff165 100644 --- a/app/tasks/importtasks.py +++ b/app/tasks/importtasks.py @@ -533,8 +533,6 @@ def check_update_config_impl(package): config.last_tag = tag db.session.commit() - -@celery.task(bind=True, rate_limit="7/m") def check_update_config(self, package_id): package: Package = Package.query.get(package_id) if package is None: @@ -567,6 +565,17 @@ def check_update_config(self, package_id): return +@celery.task(bind=True, rate_limit="60/m") +def check_update_config_default(self, package_id): + check_update_config(self, package_id) + + +@celery.task(bind=True, rate_limit="400/h") +def check_update_config_codeberg(self, package_id): + check_update_config(self, package_id) + + + @celery.task def check_for_updates(): for update_config in PackageUpdateConfig.query.all(): @@ -579,6 +588,9 @@ def check_for_updates(): db.session.delete(update_config) continue - check_update_config.delay(update_config.package_id) + if "codeberg.org" in update_config.package.repo: + check_update_config_codeberg.delay(update_config.package_id) + else: + check_update_config_default.delay(update_config.package_id) db.session.commit()