Set explicit Celery priorities on post-processing, grading, and JIRA tasks

- post_process_finding_save: priority=3 (user-triggered, regular task)
- post_process_findings_batch: priority=4 (background batch processing)
- calculate_grade: priority=4 (background processing)
- All JIRA tasks (push_finding_to_jira, push_finding_group_to_jira,
  push_engagement_to_jira, close_epic, update_epic, add_epic): priority=4
  (integrations tier, should not compete with imports for worker slots)

Author: valentijnscholten

dojo/finding/helper.py

@@ -396,7 +396,7 @@ def add_findings_to_auto_group(name, findings, group_by, *, create_finding_group
                     finding_group.findings.add(*findings)
 
 
-@app.task
+@app.task(priority=3)
 def post_process_finding_save(finding_id, dedupe_option=True, rules_option=True, product_grading_option=True,  # noqa: FBT002
              issue_updater_option=True, push_to_jira=False, user=None, *args, **kwargs):  # noqa: FBT002 - this is bit hard to fix nice have this universally fixed
     finding = get_object_or_none(Finding, id=finding_id)
@@ -459,7 +459,7 @@ def post_process_finding_save_internal(finding, dedupe_option=True, rules_option
             jira_helper.push_to_jira(finding.finding_group)
 
 
-@app.task
+@app.task(priority=4)
 def post_process_findings_batch(
     finding_ids,
     *args,

dojo/jira_link/helper.py

@@ -778,7 +778,7 @@ def push_to_jira(obj, *args, **kwargs):
 
 
 # we need thre separate celery tasks due to the decorators we're using to map to/from ids
-@app.task(priority=3)
+@app.task(priority=4)
 def push_finding_to_jira(finding_id, *args, **kwargs):
     finding = get_object_or_none(Finding, id=finding_id)
     if not finding:
@@ -790,7 +790,7 @@ def push_finding_to_jira(finding_id, *args, **kwargs):
     return add_jira_issue(finding, *args, **kwargs)
 
 
-@app.task(priority=3)
+@app.task(priority=4)
 def push_finding_group_to_jira(finding_group_id, *args, **kwargs):
     finding_group = get_object_or_none(Finding_Group, id=finding_group_id)
     if not finding_group:
@@ -806,7 +806,7 @@ def push_finding_group_to_jira(finding_group_id, *args, **kwargs):
     return add_jira_issue(finding_group, *args, **kwargs)
 
 
-@app.task(priority=3)
+@app.task(priority=4)
 def push_engagement_to_jira(engagement_id, *args, **kwargs):
     engagement = get_object_or_none(Engagement, id=engagement_id)
     if not engagement:
@@ -1395,7 +1395,7 @@ def jira_check_attachment(issue, source_file_name):
     return file_exists
 
 
-@app.task(priority=3)
+@app.task(priority=4)
 def close_epic(engagement_id, push_to_jira, **kwargs):
     engagement = get_object_or_none(Engagement, id=engagement_id)
     if not engagement:
@@ -1443,7 +1443,7 @@ def close_epic(engagement_id, push_to_jira, **kwargs):
     return False
 
 
-@app.task(priority=3)
+@app.task(priority=4)
 def update_epic(engagement_id, **kwargs):
     engagement = get_object_or_none(Engagement, id=engagement_id)
     if not engagement:
@@ -1489,7 +1489,7 @@ def update_epic(engagement_id, **kwargs):
     return False
 
 
-@app.task(priority=3)
+@app.task(priority=4)
 def add_epic(engagement_id, **kwargs):
     engagement = get_object_or_none(Engagement, id=engagement_id)
     if not engagement:

dojo/utils.py

@@ -1254,7 +1254,7 @@ def grade_product(crit, high, med, low):
     return max(health, 5)
 
 
-@app.task
+@app.task(priority=4)
 def calculate_grade(product_id, *args, **kwargs):
     product = get_object_or_none(Product, id=product_id)
     if not product: