Skip to main content

An asynchronous Python Jupyter kernel

Project description

Build Status Code style: black Binder

akernel

A Python Jupyter kernel, with different flavors:

  • concurrent cell execution,
  • reactive programming,
  • cell execution caching,
  • multi-kernel emulation.

Install

pip install akernel
# pip install akernel[react]  # if you want to be able to use reactive programming
# pip install akernel[cache]  # if you want to be able to use cell execution caching

You can parameterize akernel's execution mode:

akernel install  # default (chained cell execution mode)
akernel install concurrent  # concurrent cell execution mode
akernel install react  # reactive programming mode
akernel install cache  # cell execution caching  mode
akernel install multi  # multi-kernel emulation mode
akernel install cache-multi-react-concurrent  # you can combine several modes

Motivation

ipykernel offers the ability to run asynchronous code from the REPL. This means you can await at the top-level, outside of an async function. Unfortunately, this will still block the kernel.

akernel changes this behavior by launching each cell in a task. By default, cell tasks are chained, which means that a cell will start executing after the previous one is done. You might wonder, is it not the same as ipykernel then? Well, not quite. In ipykernel, when an async cell is executing, it also blocks the processing of Comm messages, which prevents the kernel from interacting with e.g. JupyterLab widgets (see here and there). In akernel, it will not be the case.

If you want to go all the way and have cells execute concurrently, you can also do so (see below).

Features

Asynchronous execution

First, set the concurrent execution mode in order to have async cells execute concurrently (you could also do that at install-time with akernel install concurrent):

__unchain_execution__()
# __chain_execution__()

akernel allows for asynchronous code execution. What this means is that when used in a Jupyter notebook, you can run cells concurrently if the code is cooperative. For instance, you can run a cell with the following code:

# cell 1
for i in range(10):
    print("cell 1:", i)
    await asyncio.sleep(1)

Since this cell is async (it has an await), it will not block the execution of other cells. So you can run another cell concurrently, provided that this cell is also cooperative:

# cell 2
for j in range(10):
    print("cell 2:", j)
    await asyncio.sleep(1)

If cell 2 was blocking, cell 1 would pause until cell 2 was finished. You can see that by changing await asyncio.sleep(1) into time.sleep(1) in cell 2.

You can make a cell wait for the previous one to be finished with:

# cell 3
await __task__()  # wait for cell 2 to be finished
print("cell 2 has run")

Reactive programming

One feature other notebooks offer is the ability to have variables react to other variables' changes. Observable notebooks are a good example of this, and it can give a whole new user experience. For instance, you can run cells out of order:

# cell 1
a = b + 1  # "b" is not defined yet
a

Executing cell 1 won't result in an "undefined variable" error. Instead, the result of the operation is undefined, and the output of cell 1 is None. You can then continue with the definition of b:

# cell 2
b = 2  # triggers the computation of "a" in cell 1

Now a, which depends on b, is automatically updated, and the output of cell 1 is 3.

You can of course define much more complex data flows, by defining variables on top of other ones.

screencast

Cell execution caching

With this mode, cell execution is cached so that the next time a cell is run, its outputs are retrieved from cache (if its inputs didn't change). Inputs and outputs are inferred from the cell code.

Multi-kernel emulation mode

This mode emulates multiple kernels inside the same kernel. Kernel isolation is achieved by using the session ID of execution requests. You can thus connect multiple notebooks to the same kernel, and they won't share execution state.

This is particularly useful if cells are async, because they won't block the kernel. The same kernel can thus be "shared" and used by potentially a lot of notebooks, greatly reducing resource usage.

Limitations

It is still a work in progress, in particular:

  • stdout/stderr redirection to the cell output is only supported through the print function.
  • No rich representation for now, only the standard __repr__ is supported. This means no matplotlib figure yet :-( But since ipywidgets work, why not using ipympl? :-)

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

akernel-0.2.0.tar.gz (19.4 kB view details)

Uploaded Source

Built Distribution

akernel-0.2.0-py3-none-any.whl (24.4 kB view details)

Uploaded Python 3

File details

Details for the file akernel-0.2.0.tar.gz.

File metadata

  • Download URL: akernel-0.2.0.tar.gz
  • Upload date:
  • Size: 19.4 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: python-httpx/0.24.1

File hashes

Hashes for akernel-0.2.0.tar.gz
Algorithm Hash digest
SHA256 f8616167ea4ae99ffdde85a83c0670126e00887a4a28878279bbe1177d4288af
MD5 f4a8a3a2143e05619c090d4631fdacbc
BLAKE2b-256 02417f068d93c35c1073371300496a446510a2ee0490ec744a4a380c6fa0d41c

See more details on using hashes here.

Provenance

File details

Details for the file akernel-0.2.0-py3-none-any.whl.

File metadata

  • Download URL: akernel-0.2.0-py3-none-any.whl
  • Upload date:
  • Size: 24.4 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: python-httpx/0.24.1

File hashes

Hashes for akernel-0.2.0-py3-none-any.whl
Algorithm Hash digest
SHA256 865aef8aaf7ce2a00cd832f6976bad2316775706263cf25c96eb2b3883ee9366
MD5 d04d017192c0612e036db5b5c98cae4e
BLAKE2b-256 4a577d620e83156b08b015702299a754c7d3ef63980b0641ce71d7b497c07b45

See more details on using hashes here.

Provenance

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page