upstream/ipython Files · IPython/html/services/config/handlers.py

Handle kernel messages synchronously...

Handle kernel messages synchronously A problem can happen when two messages come in for different comms, where the second depends on the first (for example, the first might be a message setting the state of a widget, and the second triggering a view creation for the widget). Since comm message queues are independent of each other, the second message could be executed before the first message. This exposes a more fundamental assumption users are likely to have that messages from python are processed synchronously. Thanks to @dmadeka for reporting an error that led to discovering this issue.

Thomas Kluyver - - Load All Authors

File last commit:

r19083:3afade56


                r20621:f936f880

Download file

             handlers.py
        
                    44 lines
            
             | 1.2 KiB
            
                | text/x-python
            
             |
                PythonLexer
            
             / IPython / html / services / config / handlers.py
          
                    History
                
                 |
                  Annotation
                 | Raw
                 |Copy content
                 |Copy permalink

      """Tornado handlers for frontend config storage."""

      # Copyright (c) IPython Development Team.

      # Distributed under the terms of the Modified BSD License.

      import json

      import os

      import io

      import errno

      from tornado import web

      from IPython.utils.py3compat import PY3

      from ...base.handlers import IPythonHandler, json_errors

      class ConfigHandler(IPythonHandler):

          SUPPORTED_METHODS = ('GET', 'PUT', 'PATCH')

          @web.authenticated

          @json_errors

          def get(self, section_name):

              self.set_header("Content-Type", 'application/json')

              self.finish(json.dumps(self.config_manager.get(section_name)))

          @web.authenticated

          @json_errors

          def put(self, section_name):

              data = self.get_json_body()  # Will raise 400 if content is not valid JSON

              self.config_manager.set(section_name, data)

              self.set_status(204)

          @web.authenticated

          @json_errors

          def patch(self, section_name):

              new_data = self.get_json_body()

              section = self.config_manager.update(section_name, new_data)

              self.finish(json.dumps(section))

      # URL to handler mappings

      section_name_regex = r"(?P<section_name>\w+)"

      default_handlers = [

          (r"/api/config/%s" % section_name_regex, ConfigHandler),

      ]

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages

				"""Tornado handlers for frontend config storage."""

				# Copyright (c) IPython Development Team.
				# Distributed under the terms of the Modified BSD License.
				import json
				import os
				import io
				import errno
				from tornado import web

				from IPython.utils.py3compat import PY3
				from ...base.handlers import IPythonHandler, json_errors

				class ConfigHandler(IPythonHandler):
				SUPPORTED_METHODS = ('GET', 'PUT', 'PATCH')

				@web.authenticated
				@json_errors
				def get(self, section_name):
				self.set_header("Content-Type", 'application/json')
				self.finish(json.dumps(self.config_manager.get(section_name)))

				@web.authenticated
				@json_errors
				def put(self, section_name):
				data = self.get_json_body() # Will raise 400 if content is not valid JSON
				self.config_manager.set(section_name, data)
				self.set_status(204)

				@web.authenticated
				@json_errors
				def patch(self, section_name):
				new_data = self.get_json_body()
				section = self.config_manager.update(section_name, new_data)
				self.finish(json.dumps(section))


				# URL to handler mappings

				section_name_regex = r"(?P<section_name>\w+)"

				default_handlers = [
				(r"/api/config/%s" % section_name_regex, ConfigHandler),
				]