diff options
| author | Timotheus Pokorra <tp@tbits.net> | 2015-05-29 14:52:56 +0200 |
|---|---|---|
| committer | Timotheus Pokorra <tp@tbits.net> | 2015-05-29 14:52:56 +0200 |
| commit | a6984e9e29a3cd6beca7f717ad3484e846358fbc (patch) | |
| tree | 826c847e0e9e0a31adafcc7483125f0c7a60446c /pykolab/cli/cmd_sync.py | |
| parent | e5925a3a56502be3e51571ea7db098d29638dfd3 (diff) | |
| download | pykolab-a6984e9e29a3cd6beca7f717ad3484e846358fbc.tar.gz | |
cli: kolab sync now properly creates mailboxes (#3975)
value of entry was not assigned properly.
and we need to wait for the creation to finish
Diffstat (limited to 'pykolab/cli/cmd_sync.py')
| -rw-r--r-- | pykolab/cli/cmd_sync.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/pykolab/cli/cmd_sync.py b/pykolab/cli/cmd_sync.py index 3e2191a..b9c6c9e 100644 --- a/pykolab/cli/cmd_sync.py +++ b/pykolab/cli/cmd_sync.py @@ -100,7 +100,8 @@ def queue_add(*args, **kw): global pool for dn, entry in kw['entry']: entry['dn'] = dn - pool.apply_async(_synchronize, (), dict(**entry)) + r = pool.apply_async(_synchronize, (), dict(**entry)) + r.wait() def worker_process(*args, **kw): pass @@ -108,7 +109,7 @@ def worker_process(*args, **kw): def _synchronize(*args, **kw): log.info(_("Worker process %s handling %s") % (multiprocessing.current_process().name, kw['dn'])) - entry = utils.normalize(entry) + entry = utils.normalize(kw) if not entry.has_key('mail'): return |