Repository: incubator-ariatosca Updated Branches: refs/heads/ARIA-185-NullPool-logging-messages-appear-during-execution 8ce1dddd1 -> 75ab5edac
minor fixes Project: http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/commit/75ab5eda Tree: http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/tree/75ab5eda Diff: http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/diff/75ab5eda Branch: refs/heads/ARIA-185-NullPool-logging-messages-appear-during-execution Commit: 75ab5edac1dc833e0cbe092af8e4b11c4bdcace4 Parents: 8ce1ddd Author: max-orlov <[email protected]> Authored: Tue May 23 18:49:19 2017 +0300 Committer: max-orlov <[email protected]> Committed: Tue May 23 18:57:30 2017 +0300 ---------------------------------------------------------------------- aria/orchestrator/execution_plugin/ctx_proxy/client.py | 12 ++++++------ .../execution_plugin/test_ctx_proxy_server.py | 1 + 2 files changed, 7 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/blob/75ab5eda/aria/orchestrator/execution_plugin/ctx_proxy/client.py ---------------------------------------------------------------------- diff --git a/aria/orchestrator/execution_plugin/ctx_proxy/client.py b/aria/orchestrator/execution_plugin/ctx_proxy/client.py index f58c727..fbfff57 100644 --- a/aria/orchestrator/execution_plugin/ctx_proxy/client.py +++ b/aria/orchestrator/execution_plugin/ctx_proxy/client.py @@ -45,7 +45,7 @@ def _http_request(socket_url, request, method, timeout): return json.loads(response.read()) -def _client_request(socket_url, args, method, timeout): +def _client_request(socket_url, args, timeout, method='POST'): response = _http_request( socket_url=socket_url, request={'args': args}, @@ -90,15 +90,15 @@ def _process_args(json_prefix, args): def _close_session(socket_url, timeout): - return _client_request(socket_url, [], 'DELETE', timeout) + return _client_request(socket_url, [], timeout, 'DELETE') def main(args=None): try: args = _parse_args(args) - response = _client_request(args.socket_url, + response = _client_request( + args.socket_url, args=_process_args(args.json_arg_prefix, args.args), - method='POST', timeout=args.timeout) if args.json_output: response = json.dumps(response) @@ -107,11 +107,11 @@ def main(args=None): response = '' response = str(response) sys.stdout.write(response) - except BaseException: + except BaseException as origial_e: try: _close_session(args.socket_url, args.timeout) except BaseException: - pass + raise origial_e if __name__ == '__main__': main() http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/blob/75ab5eda/tests/orchestrator/execution_plugin/test_ctx_proxy_server.py ---------------------------------------------------------------------- diff --git a/tests/orchestrator/execution_plugin/test_ctx_proxy_server.py b/tests/orchestrator/execution_plugin/test_ctx_proxy_server.py index 98ceff9..c94bae7 100644 --- a/tests/orchestrator/execution_plugin/test_ctx_proxy_server.py +++ b/tests/orchestrator/execution_plugin/test_ctx_proxy_server.py @@ -165,6 +165,7 @@ class TestCtxProxy(object): @pytest.fixture def server(self, ctx): result = ctx_proxy.server.CtxProxy(ctx) + result._close_session = lambda *args, **kwargs: {} yield result result.close()
