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

function call cleanup

Browse source
This commit is contained in:
Markus Unterwaditzer 2014-12-20 02:54:31 +01:00
parent 14699d3195
commit a19838327d
1 changed files with 10 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
vdirsyncer/cli/__init__.py
View file

@ -105,12 +105,11 @@ def sync(ctx, pairs, force_delete, max_workers):
for pair_name, collections in parse_pairs_args(pairs, all_pairs):
wq.spawn_worker()
wq.put(
functools.partial(sync_pair, pair_name=pair_name,
collections_to_sync=collections,
general=general, all_pairs=all_pairs,
all_storages=all_storages,
force_delete=force_delete))
wq.put(lambda wq: sync_pair(wq, pair_name=pair_name,
collections_to_sync=collections,
general=general, all_pairs=all_pairs,
all_storages=all_storages,
force_delete=force_delete))
wq.join()
@ -137,11 +136,11 @@ def discover(ctx, pairs, max_workers):
.format(pair, list(all_pairs)))
wq.spawn_worker()
wq.put(functools.partial(
(lambda wq, **kwargs: collections_for_pair(**kwargs)),
status_path=general['status_path'], name_a=name_a,
name_b=name_b, pair_name=pair, config_a=all_storages[name_a],
wq.put(lambda wq: collections_for_pair(
status_path=general['status_path'], name_a=name_a, name_b=name_b,
pair_name=pair, config_a=all_storages[name_a],
config_b=all_storages[name_b], pair_options=pair_options,
skip_cache=True))
skip_cache=True)
)
wq.join()