Send a kernel_info_request to the kernel.
A object containing the kernel channels
The reply from the server
Gets information about newly launched kernel.
An epic that emits comm actions from the backend kernel
Action Observable from redux-observable
Comm actions
Converts a Notebook content to the Jupyter Content
type expected in Bookstore.
Notebook
the execute cell epic processes execute requests for all cells, creating inner observable streams of the running execution responses
Observe all the reactions to running code for cell with id.
The standard channels specified in the Jupyter specification.
Universally Unique Identifier of cell to be executed.
updatedOutputs - It returns an observable with a stream of events that need to happen after a cell has been executed.
Listen for comm_open messages from the kernel that are associated with models that will not be rendered on the page.
Note: this is not an ideal solution but we need to do this so that we can keep the WidgetManager contextualized to the WidgetDisplay as opposed to at the top-level.
NOTE: This function is exactly the same as the desktop loading.js version
with one strong exception -- extractNewKernel
Can they be combined without incurring a penalty on the web app?
The native functions used are path.dirname, path.resolve, and process.cwd()
We could always inject those dependencies separately...
First step in publishing notebooks to bookstore.
Saves notebook using the content API. Then,
kicks off an action that saves the notebook
to Bookstore.
Action type.
Application state.
Last step in publishing notebooks to bookstore.
Saves notebook to Bookstore.
Action type.
Application state.
Restarts a Jupyter kernel in the local scenario, where a restart requires killing the existing kernel process and starting an ew one.
Sets the execution state after a kernel has been launched.
Generated using TypeDoc
@nteract/epics
This package contains a set of Redux-Observable epics for use in nteract applications.
Installation
$ yarn add @nteract/epics$ npm install --save @nteract/epicsUsage
The example below shows how we can use the
watchExecutionStateEpicto monitor the state of a recently launched kernel.import { watchExecutionStateEpic } from "@nteract/epics";export default () => { // Create a Observable for the successful launch of a // kernel. const action$ = ActionsObservable.of({ type: actionTypes.LAUNCH_KERNEL_SUCCESSFUL, payload: { kernel: { channels: of({ header: { msg_type: "status" }, content: { execution_state: "idle" } }) } } }); // Monitor the Observable and update the // state of the kernel on our client appropriately. const obs = watchExecutionStateEpic(action$); obs.pipe(toArray()).subscribe( actions => { const types = actions.map(({ type }) => type); expect(types).toEqual([actionTypes.SET_EXECUTION_STATE]); }, err => done.fail(err), // It should not error in the stream () => done() ); }); }
Documentation
We're working on adding more documentation for this component. Stay tuned by watching this repository!
Support
If you experience an issue while using this package or have a feature request, please file an issue on the issue board and add the
pkg:epicslabel.License
BSD-3-Clause