From b32ca3b11ae609b40f6c7f118f343f7830414a7d Mon Sep 17 00:00:00 2001
From: Houkime <>
Date: Fri, 21 Apr 2023 12:19:59 +0000
Subject: [PATCH] test(backups): assure that jobs are created and not
 duplicated

---
 tests/test_graphql/test_backup.py | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/tests/test_graphql/test_backup.py b/tests/test_graphql/test_backup.py
index 5e064fa..420e14e 100644
--- a/tests/test_graphql/test_backup.py
+++ b/tests/test_graphql/test_backup.py
@@ -9,6 +9,7 @@ import selfprivacy_api.services as services
 from selfprivacy_api.services import get_service_by_id
 from selfprivacy_api.services.test_service import DummyService
 from selfprivacy_api.graphql.queries.providers import BackupProvider
+from selfprivacy_api.jobs import Jobs, JobStatus
 
 from selfprivacy_api.backup import Backups
 import selfprivacy_api.backup.providers as providers
@@ -16,6 +17,7 @@ from selfprivacy_api.backup.providers import AbstractBackupProvider
 from selfprivacy_api.backup.providers.backblaze import Backblaze
 from selfprivacy_api.backup.tasks import start_backup, restore_snapshot
 from selfprivacy_api.backup.storage import Storage
+from selfprivacy_api.backup.jobs import get_backup_job
 
 
 TESTFILE_BODY = "testytest!"
@@ -30,6 +32,8 @@ def backups(tmpdir):
     test_repo_path = path.join(tmpdir, "totallyunrelated")
     Backups.set_localfile_repo(test_repo_path)
 
+    Jobs.reset()
+
 
 @pytest.fixture()
 def backups_backblaze(generic_userdata):
@@ -219,6 +223,11 @@ def test_backup_service_task(backups, dummy_service):
     snaps = Backups.get_snapshots(dummy_service)
     assert len(snaps) == 1
 
+    id = dummy_service.get_id()
+    finished_jobs = [job for job in Jobs.get_jobs() if job.status is JobStatus.FINISHED]
+    finished_types = [job.type_id for job in finished_jobs]
+    assert finished_types.count(f"services.{id}.backup") == 1
+
 
 def test_restore_snapshot_task(backups, dummy_service):
     Backups.back_up(dummy_service)