From e4a0790c664268f08e7f08ab5e4708385d80419d Mon Sep 17 00:00:00 2001 From: bigeagle Date: Sat, 18 Oct 2014 11:22:59 +0800 Subject: [PATCH] bug fix --- tunasync/jobs.py | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) diff --git a/tunasync/jobs.py b/tunasync/jobs.py index 6668611..fd16940 100644 --- a/tunasync/jobs.py +++ b/tunasync/jobs.py @@ -1,7 +1,6 @@ #!/usr/bin/env python2 # -*- coding:utf-8 -*- import sys -import time import signal @@ -36,18 +35,18 @@ def run_job(sema, child_q, manager_q, provider): sema.release() aquired = False + + print("syncing {} finished, sleep {} minutes for the next turn".format( + provider.name, provider.interval + )) + try: - msg = child_q.get(timeout=1) + msg = child_q.get(timeout=provider.interval * 60) if msg == "terminate": manager_q.put((provider.name, "QUIT")) break except: pass - print("syncing {} finished, sleep {} minutes for the next turn".format( - provider.name, provider.interval - )) - time.sleep(provider.interval * 60) - # vim: ts=4 sw=4 sts=4 expandtab