From 19005158a8635884fba4ddfa1139ca139b67bda7 Mon Sep 17 00:00:00 2001
From: dettlaff <dettlaff@riseup.net>
Date: Mon, 26 Jun 2023 23:33:41 +0400
Subject: [PATCH] fix: add timewait

---
 selfprivacy_api/jobs/nix_collect_garbage.py | 21 ++++++++++-----------
 1 file changed, 10 insertions(+), 11 deletions(-)

diff --git a/selfprivacy_api/jobs/nix_collect_garbage.py b/selfprivacy_api/jobs/nix_collect_garbage.py
index 8cc3e66..b9401b2 100644
--- a/selfprivacy_api/jobs/nix_collect_garbage.py
+++ b/selfprivacy_api/jobs/nix_collect_garbage.py
@@ -47,12 +47,9 @@ def parse_line(line):
         )
 
 
-def stream_process(
-    job,
-    stream,
-    total_dead_packages,
-):
+def stream_process(job, stream, total_dead_packages):
     completed_packages = 0
+    prev_progress = 0
 
     for line in stream:
         line = line.decode("utf-8")
@@ -61,12 +58,14 @@ def stream_process(
             completed_packages += 1
             percent = int((completed_packages / total_dead_packages) * 100)
 
-            Jobs.update(
-                job=job,
-                status=JobStatus.RUNNING,
-                progress=percent,
-                status_text="Cleaning...",
-            )
+            if percent - prev_progress >= 5:
+                Jobs.update(
+                    job=job,
+                    status=JobStatus.RUNNING,
+                    progress=percent,
+                    status_text="Cleaning...",
+                )
+                prev_progress = percent
 
         elif "store paths deleted," in line:
             status = parse_line(line)