c4d653ee7275f364b82d539bc58a9793248374eb,lib/streamlit/ScriptRunner.py,ScriptRunner,maybe_handle_execution_control_request,#ScriptRunner#,255

Before Change

    // This method gets called from inside the script"s execution context.
    def maybe_handle_execution_control_request(self):
        if self._state_change_requested:
            LOGGER.debug("Received execution control request: %s", self._state)

            if self._state == State.STOP_REQUESTED:
                raise StopException()
            elif self._state == State.RERUN_REQUESTED:

After Change

        self._event_queue.enqueue(ScriptEvent.SHUTDOWN)

    def maybe_handle_execution_control_request(self):
        if self._run_loop_thread != threading.current_thread():
            // We can only handle execution_control_request if we"re on the
            // script execution thread. However, it"s possible for deltas to
            // be enqueued (and, therefore, for this function to be called)
            // in separate threads, so we check for that here.
            return

        // Pop the next event from our queue. Don"t block if there"s no event
        event, event_data = self._event_queue.dequeue_nowait()
        if event is None:
            return

Instances