From 4f736e8de00152e004fbe404294612fa54d03479 Mon Sep 17 00:00:00 2001 From: Ben Thomasson Date: Thu, 6 Jun 2019 18:26:35 -0400 Subject: [PATCH] Working on #summary --- ansible_kernel/kernel.py | 18 +++++++++++++++--- 1 file changed, 15 insertions(+), 3 deletions(-) diff --git a/ansible_kernel/kernel.py b/ansible_kernel/kernel.py index 03e8357..7527bc6 100644 --- a/ansible_kernel/kernel.py +++ b/ansible_kernel/kernel.py @@ -521,7 +521,7 @@ def do_execute(self, code, silent, store_history=True, try: if code.strip().startswith("#inventory"): - return self.do_inventory(code) + False return self.do_inventory(code) elif code.strip().startswith("#ansible.cfg"): return self.do_ansible_cfg(code) elif code.strip().startswith("#host_vars"): @@ -540,6 +540,8 @@ def do_execute(self, code, silent, store_history=True, return self.do_execute_python(code) elif code.strip().startswith("#vault_password"): return self.do_execute_vault_password(code) + elif code.strip().startswith("#summary"): + return self.do_execute_summary(code) else: return self.do_execute_task(code) @@ -931,6 +933,17 @@ def do_execute_vault_password(self, code): return {'status': 'ok', 'execution_count': self.execution_count, 'payload': [], 'user_expressions': {}} + def do_execute_summary(self, code): + + self.do_shutdown(False) + stream_content = dict(name='stdout', + text="summary ansible shutdown") + self.send_response(self.iopub_socket, 'stream', stream_content) + + + return {'status': 'ok', 'execution_count': self.execution_count, + 'payload': [], 'user_expressions': {}} + def do_complete(self, code, cursor_pos): code = code[:cursor_pos] default = {'matches': [], 'cursor_start': 0, @@ -1053,7 +1066,7 @@ def do_inspect(self, code, cursor_pos, detail_level=0): logger.debug("detail_level %s", detail_level) if code.strip().startswith("#inventory"): - logger.info("#inentory not supported") + logger.info("#inventory not supported") return {'status': 'ok', 'data': {}, 'metadata': {}, 'found': True} elif code.strip().startswith("#task"): return self.do_inspect_module(code, cursor_pos, detail_level) @@ -1103,7 +1116,6 @@ def get_galaxy_role(self, role_name): if role == role_name: return - p = Popen(command, cwd=self.temp_dir, stdout=PIPE, stderr=STDOUT, ) command = ['ansible-galaxy', 'install', '-p', 'project/roles', role_name] logger.debug("command %s", command) p = Popen(command, cwd=self.temp_dir, stdout=PIPE, stderr=STDOUT, )