fix: save_commit_measurements (#1057)

tasks/save_commit_measurements.py

@@ -13,6 +13,7 @@
 from services.timeseries import (
     maybe_upsert_coverage_measurement,
     maybe_upsert_flag_measurements,
+    repository_datasets_query,
     upsert_components_measurements,
 )
 from services.yaml import get_repo_yaml
@@ -83,7 +84,7 @@ def run_impl(
         db_session: Session,
         commitid: str,
         repoid: int,
-        dataset_names: Sequence[str],
+        dataset_names: Sequence[str] | None,
         *args,
         **kwargs,
     ):
@@ -106,6 +107,13 @@ def run_impl(
         if commit is None:
             return {"successful": False, "error": "no_commit_in_db"}
 
+        if dataset_names is None:
+            dataset_names = [
+                dataset.name for dataset in repository_datasets_query(commit.repository)
+            ]
+        if len(dataset_names) == 0:
+            return
+
         try:
             # TODO: We should improve on the error handling/logs inside this fn
             save_commit_measurements(commit=commit, dataset_names=dataset_names)

tasks/upsert_component.py

@@ -1,6 +1,7 @@
 import logging
 
 from shared.reports.readonly import ReadOnlyReport
+from shared.utils.enums import TaskConfigGroup
 from sqlalchemy.orm import Session
 
 from app import celery_app
@@ -12,8 +13,10 @@
 
 log = logging.getLogger(__name__)
 
+task_name = f"app.tasks.{TaskConfigGroup.timeseries.value}.UpsertComponentTask"
 
-class UpsertComponentTask(BaseCodecovTask):
+
+class UpsertComponentTask(BaseCodecovTask, name=task_name):
     def run_impl(
         self,
         db_session: Session,