mirror
/
changedetection.io
kopia lustrzana https://github.com/dgtlmoon/changedetection.io
1
0
Forkuj 0
Kod Zgłoszenia Packages Projekty Wydania Wiki Aktywność

Also check that the watch is not paused before putting it into the checking queuex

pull/33/head
dgtlmoon 2021-04-02 03:58:23 +02:00
rodzic ab6f4d11ed
commit f2b06c63bf
1 zmienionych plików z 4 dodań i 2 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

6
backend/__init__.py
Wyświetl plik

@ -598,9 +598,11 @@ def ticker_thread_check_time_launch_checks():
new_worker.start() new_worker.start()
while not app.config.exit.is_set(): while not app.config.exit.is_set():
running_uuids = [] running_uuids = []
for t in running_update_threads: for t in running_update_threads:
running_uuids.append(t.current_uuid) if t.current_uuid:
running_uuids.append(t.current_uuid)
# Look at the dataset, find a stale watch to process # Look at the dataset, find a stale watch to process
@ -609,7 +611,7 @@ def ticker_thread_check_time_launch_checks():
threshold = time.time() - (minutes * 60) threshold = time.time() - (minutes * 60)
for uuid, watch in datastore.data['watching'].items(): for uuid, watch in datastore.data['watching'].items():
if watch['last_checked'] <= threshold: if not watch['paused'] and watch['last_checked'] <= threshold:
if not uuid in running_uuids and uuid not in update_q.queue: if not uuid in running_uuids and uuid not in update_q.queue:
update_q.put(uuid) update_q.put(uuid)