sjs/vdirsyncer
1
0
Fork 0
mirror of https://github.com/samsonjs/vdirsyncer.git synced 2026-03-29 09:35:50 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Remove silly handled_jobs

Browse source
This commit is contained in:
Markus Unterwaditzer 2015-07-05 23:06:44 +02:00
parent cad938d023
commit a446307d44
2 changed files with 0 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
vdirsyncer/cli/__init__.py
View file

@ -116,7 +116,6 @@ def sync(pairs, force_delete, max_workers):
general, all_pairs, all_storages = ctx.obj['config']
wq = WorkerQueue(max_workers)
wq.handled_jobs = set()
for pair_name, collections in parse_pairs_args(pairs, all_pairs):
wq.spawn_worker()

12
vdirsyncer/cli/tasks.py
View file

@ -12,12 +12,6 @@ from ..sync import sync
def sync_pair(wq, pair_name, collections_to_sync, general, all_pairs,
all_storages, force_delete):
key = ('prepare', pair_name)
if key in wq.handled_jobs:
cli_logger.warning('Already prepared {}, skipping'.format(pair_name))
return
wq.handled_jobs.add(key)
a_name, b_name, pair_options = all_pairs[pair_name]
try:
@ -56,12 +50,6 @@ def sync_collection(wq, pair_name, collection, config_a, config_b,
pair_options, general, force_delete):
status_name = get_status_name(pair_name, collection)
key = ('sync', pair_name, collection)
if key in wq.handled_jobs:
cli_logger.warning('Already syncing {}, skipping'.format(status_name))
return
wq.handled_jobs.add(key)
try:
cli_logger.info('Syncing {}'.format(status_name))