Triplehx3/contentdb
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add dedicated celery task for codeberg

Browse Source
This commit is contained in:
rubenwardy
2025-08-26 20:50:05 +01:00
parent 0adf02bf99
commit 704c6be1c4
1 changed files with 15 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
app/tasks/importtasks.py
View File

@@ -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()