diff options
| author | Jenkins <jenkins@review.openstack.org> | 2014-08-12 04:03:19 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2014-08-12 04:03:19 +0000 |
| commit | ac4596b665ae3d63b17a2d500073a321456090d9 (patch) | |
| tree | 43271677655491b5d7b92ad351392a6be0375afd /taskflow/engines/worker_based/executor.py | |
| parent | 61dc87f9a4d4da83e57abb0505774ac7e6babdd0 (diff) | |
| parent | 0eb9fb90ab942eb6be648b002d4356f9c6fa5602 (diff) | |
| download | taskflow-ac4596b665ae3d63b17a2d500073a321456090d9.tar.gz | |
Merge "WBE response message validation"
Diffstat (limited to 'taskflow/engines/worker_based/executor.py')
| -rw-r--r-- | taskflow/engines/worker_based/executor.py | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/taskflow/engines/worker_based/executor.py b/taskflow/engines/worker_based/executor.py index 5622b8f..2b82f01 100644 --- a/taskflow/engines/worker_based/executor.py +++ b/taskflow/engines/worker_based/executor.py @@ -81,7 +81,10 @@ class WorkerTaskExecutor(executor.TaskExecutorBase): self._process_notify, functools.partial(pr.Notify.validate, response=True), ], - pr.RESPONSE: self._process_response, + pr.RESPONSE: [ + self._process_response, + pr.Response.validate, + ], } self._proxy = proxy.Proxy(uuid, exchange, handlers, self._on_wait, **kwargs) |