Skip to content
Open
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 5 additions & 3 deletions postgres_kernel/kernel.py
Original file line number Diff line number Diff line change
Expand Up @@ -188,10 +188,10 @@ def do_execute(self, code, silent, store_history=True,
self.send_response(self.iopub_socket, 'stream',
{'name': 'stderr', 'text': str(e)})
self._conn.rollback()
return {'status': 'error', 'execution_count': self.execution_count,
'ename': 'ProgrammingError', 'evalue': str(e),
'traceback': []}
return {'status': 'abort', 'execution_count': self.execution_count}

else:

if rows is not None:
self.send_response(
self.iopub_socket, 'stream', {
Expand All @@ -210,6 +210,8 @@ def do_execute(self, code, silent, store_history=True,
if header is not None and len(rows) > 0:
self.send_response(self.iopub_socket, 'display_data', display_data(header, rows))

self._conn.commit()

return {'status': 'ok', 'execution_count': self.execution_count,
'payload': [], 'user_expressions': {}}

Expand Down