fix(ta): pass right arg to cache rollup task

services/test_analytics/ta_finish_upload.py

@@ -110,7 +110,6 @@ def queue_followup_tasks(
             process_flakes_task_name,
             kwargs={
                 "repo_id": repo.repoid,
-                "commit_id": commit.commitid,
                 "impl_type": impl_type,
             },
         )
@@ -119,7 +118,7 @@ def queue_followup_tasks(
         celery_app.send_task(
             cache_test_rollups_task_name,
             kwargs={
-                "repoid": repo.repoid,
+                "repo_id": repo.repoid,
                 "branch": commit.branch,
                 "impl_type": impl_type,
             },

services/test_analytics/tests/test_ta_finish_upload.py

@@ -16,10 +16,7 @@
 from shared.django_apps.test_analytics.models import Flake
 
 from database.enums import ReportType
-from database.tests.factories import (
-    PullFactory,
-    UploadFactory,
-)
+from database.tests.factories import PullFactory, UploadFactory
 from services.test_analytics.ta_finish_upload import FinisherResult, new_impl
 from services.yaml import UserYaml
 from tests.helpers import mock_all_plans_and_tiers
@@ -147,7 +144,7 @@ def assert_tasks(tasks: list[Literal["flakes", "cache_rollup"]]):
             "cache_rollup": call(
                 "app.tasks.cache_rollup.CacheTestRollupsTask",
                 kwargs={
-                    "repoid": repo.repoid,
+                    "repo_id": repo.repoid,
                     "branch": commit.branch,
                     "impl_type": "new",
                 },

tasks/cache_rollup_cron_task.py

@@ -25,7 +25,7 @@ def run_cron_task(self, _db_session: Session, *args, **kwargs):
                 repo_branch.delete()
             else:
                 self.app.tasks[cache_test_rollups_task_name].s(
-                    repoid=repo.repoid,
+                    repo_id=repo.repoid,
                     branch=branch,
                     update_date=False,
                 ).apply_async()

tasks/tests/unit/test_cache_rollup_cron_task.py

@@ -25,7 +25,7 @@ def test_cache_rollup_cron_task(mock_storage, transactional_db, mocker):
     )
 
     mocked_app.tasks[cache_test_rollups_task_name].s.assert_called_once_with(
-        repoid=rollup_date.repository_id,
+        repo_id=rollup_date.repository_id,
         branch=rollup_date.branch,
         update_date=False,
     )