diff options
author | Jeroen van Meeuwen (Kolab Systems) <vanmeeuwen@kolabsys.com> | 2014-03-04 13:25:01 +0100 |
---|---|---|
committer | Jeroen van Meeuwen (Kolab Systems) <vanmeeuwen@kolabsys.com> | 2014-03-04 13:25:01 +0100 |
commit | 8fcd6441ed755f5ae81a6d9e5b6ec6ef3fab8393 (patch) | |
tree | c16182432e1a84f6e943f2ef69af197b3b7fd3c6 | |
parent | 49a35d7e3710bb47ba8fdab9ec81bfc1ebf37a6b (diff) | |
download | pykolab-8fcd6441ed755f5ae81a6d9e5b6ec6ef3fab8393.tar.gz |
Take a result from modules being executed seriously
-rw-r--r-- | wallace/__init__.py | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/wallace/__init__.py b/wallace/__init__.py index 084425e..be23ffa 100644 --- a/wallace/__init__.py +++ b/wallace/__init__.py @@ -48,6 +48,8 @@ def pickup_message(filepath, *args, **kw): # Cause the previous modules to be skipped wallace_modules = wallace_modules[(wallace_modules.index(kw['module'])+1):] + log.debug(_("Wallace modules: %r") % (wallace_modules), level=8) + # Execute the module if kw.has_key('stage'): modules.execute(kw['module'], filepath, stage=kw['stage']) @@ -55,7 +57,9 @@ def pickup_message(filepath, *args, **kw): modules.execute(kw['module'], filepath) for module in wallace_modules: - filepath = modules.execute(module, filepath) + result_filepath = modules.execute(module, filepath) + if not result_filepath == None and not result_filepath == False: + filepath = result_filepath def worker_process(*args, **kw): log.debug(_("Worker process %s initializing") % (multiprocessing.current_process().name), level=1) |