Remove the delete_timeseries part of Repo deletion (#1278)

Author: Swatinem

core/commands/repository/interactors/erase_repository.py

@@ -11,5 +11,4 @@ def execute(self, owner_username: str, repo_name: str) -> None:
             owner_username, repo_name, ensure_is_admin=True
         )
 
-        TaskService().delete_timeseries(repository_id=repo.repoid)
         TaskService().flush_repo(repository_id=repo.repoid)

services/task/task.py

@@ -299,16 +299,6 @@ def backfill_dataset(
             ),
         ).apply_async()
 
-    def delete_timeseries(self, repository_id: int):
-        log.info(
-            "Delete repository timeseries data",
-            extra=dict(repository_id=repository_id),
-        )
-        self._create_signature(
-            celery_config.timeseries_delete_task_name,
-            kwargs=dict(repository_id=repository_id),
-        ).apply_async()
-
     def transplant_report(self, repo_id: int, from_sha: str, to_sha: str) -> None:
         self._create_signature(
             "app.tasks.reports.transplant_report",

services/tests/test_task.py

@@ -202,31 +202,6 @@ def test_backfill_dataset(mocker):
     signature.apply_async.assert_called_once_with()
 
 
-@freeze_time("2023-06-13T10:01:01.000123")
-def test_timeseries_delete(mocker):
-    signature_mock = mocker.patch("services.task.task.signature")
-    mock_route_task = mocker.patch(
-        "services.task.task.route_task", return_value={"queue": "celery"}
-    )
-    TaskService().delete_timeseries(repository_id=12345)
-    mock_route_task.assert_called_with(
-        celery_config.timeseries_delete_task_name,
-        args=None,
-        kwargs=dict(repository_id=12345),
-    )
-    signature_mock.assert_called_with(
-        celery_config.timeseries_delete_task_name,
-        args=None,
-        kwargs=dict(repository_id=12345),
-        app=celery_app,
-        queue="celery",
-        soft_time_limit=None,
-        time_limit=None,
-        headers=dict(created_timestamp="2023-06-13T10:01:01.000123"),
-        immutable=False,
-    )
-
-
 @freeze_time("2023-06-13T10:01:01.000123")
 def test_flush_repo(mocker):
     signature_mock = mocker.patch("services.task.task.signature")