mirror of
https://github.com/samsonjs/vdirsyncer.git
synced 2026-04-27 14:57:41 +00:00
Deduplicate debug msg
This commit is contained in:
parent
7ef30202d6
commit
4f16f9c64e
1 changed files with 3 additions and 3 deletions
|
|
@ -77,7 +77,9 @@ main = app
|
||||||
|
|
||||||
def max_workers_callback(ctx, param, value):
|
def max_workers_callback(ctx, param, value):
|
||||||
if value == 0 and ctx.obj['verbosity'] == log.logging.DEBUG:
|
if value == 0 and ctx.obj['verbosity'] == log.logging.DEBUG:
|
||||||
return 1
|
value = 1
|
||||||
|
|
||||||
|
cli_logger.debug('Using {} maximal workers.'.format(value))
|
||||||
return value
|
return value
|
||||||
|
|
||||||
|
|
||||||
|
|
@ -113,7 +115,6 @@ def sync(pairs, force_delete, max_workers):
|
||||||
from .utils import parse_pairs_args, WorkerQueue
|
from .utils import parse_pairs_args, WorkerQueue
|
||||||
general, all_pairs, all_storages = ctx.obj['config']
|
general, all_pairs, all_storages = ctx.obj['config']
|
||||||
|
|
||||||
cli_logger.debug('Using {} maximal workers.'.format(max_workers))
|
|
||||||
wq = WorkerQueue(max_workers)
|
wq = WorkerQueue(max_workers)
|
||||||
wq.handled_jobs = set()
|
wq.handled_jobs = set()
|
||||||
|
|
||||||
|
|
@ -139,7 +140,6 @@ def discover(pairs, max_workers):
|
||||||
from .tasks import discover_collections
|
from .tasks import discover_collections
|
||||||
from .utils import WorkerQueue
|
from .utils import WorkerQueue
|
||||||
general, all_pairs, all_storages = ctx.obj['config']
|
general, all_pairs, all_storages = ctx.obj['config']
|
||||||
cli_logger.debug('Using {} maximal workers.'.format(max_workers))
|
|
||||||
wq = WorkerQueue(max_workers)
|
wq = WorkerQueue(max_workers)
|
||||||
|
|
||||||
for pair in (pairs or all_pairs):
|
for pair in (pairs or all_pairs):
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue