IPython Documentation

Table Of Contents

Previous topic

parallel.engine.kernelstarter

Next topic

parallel.error

This Page

parallel.engine.streamkernel

Module: parallel.engine.streamkernel

Inheritance diagram for IPython.parallel.engine.streamkernel:

Kernel adapted from kernel.py to use ZMQ Streams

Authors:

  • Min RK
  • Brian Granger
  • Fernando Perez
  • Evan Patterson

Kernel

class IPython.parallel.engine.streamkernel.Kernel(**kwargs)

Bases: IPython.zmq.session.SessionFactory

__init__(**kwargs)
abort_queue(stream)
abort_queues()
abort_request(stream, ident, parent)

abort a specifig msg by id

aborted

An instance of a Python set.

apply_request(stream, ident, parent)
bident

A casting version of the byte string trait.

check_aborted(msg_id)
check_dependencies(dependencies)
classmethod class_config_section()

Get the config class config section

classmethod class_get_help(inst=None)

Get the help string for this class in ReST format.

If inst is given, it’s current trait values will be used in place of class defaults.

classmethod class_get_trait_help(trait, inst=None)

Get the help string for a single trait.

If inst is given, it’s current trait values will be used in place of the class default.

classmethod class_print_help(inst=None)

Get the help string for a single trait and print it.

classmethod class_trait_names(**metadata)

Get a list of all the names of this classes traits.

This method is just like the trait_names() method, but is unbound.

classmethod class_traits(**metadata)

Get a list of all the traits of this class.

This method is just like the traits() method, but is unbound.

The TraitTypes returned don’t know anything about the values that the various HasTrait’s instances are holding.

This follows the same algorithm as traits does and does not allow for any simple way of specifying merely that a metadata name exists, but has any value. This is because get_metadata returns None if a metadata key doesn’t exist.

clear_request(stream, idents, parent)

Clear our namespace.

client

A trait whose value must be an instance of a specified class.

The value can also be an instance of a subclass of the specified class.

compiler

A trait whose value must be an instance of a specified class.

The value can also be an instance of a subclass of the specified class.

complete(msg)
complete_request(stream, ident, parent)
completer

A trait whose value must be an instance of a specified class.

The value can also be an instance of a subclass of the specified class.

config

A trait whose value must be an instance of a specified class.

The value can also be an instance of a subclass of the specified class.

context

A trait whose value must be an instance of a specified class.

The value can also be an instance of a subclass of the specified class.

control_handlers

An instance of a Python dict.

control_stream

A trait whose value must be an instance of a specified class.

The value can also be an instance of a subclass of the specified class.

dispatch_control(msg)
dispatch_queue(stream, msg)
exec_lines

An instance of a Python list.

execute_request(stream, ident, parent)
ident

A trait for unicode strings.

int_id

An integer trait.

Longs that are unnecessary (<= sys.maxint) are cast to ints.

iopub_stream

A trait whose value must be an instance of a specified class.

The value can also be an instance of a subclass of the specified class.

log

A trait whose value must be an instance of a specified class.

The value can also be an instance of a subclass of the specified class.

logname

A trait for unicode strings.

loop

A trait whose value must be an instance of a specified class.

The value can also be an instance of a subclass of the specified class.

on_trait_change(handler, name=None, remove=False)

Setup a handler to be called when a trait changes.

This is used to setup dynamic notifications of trait changes.

Static handlers can be created by creating methods on a HasTraits subclass with the naming convention ‘_[traitname]_changed’. Thus, to create static handler for the trait ‘a’, create the method _a_changed(self, name, old, new) (fewer arguments can be used, see below).

Parameters :

handler : callable

A callable that is called when a trait changes. Its signature can be handler(), handler(name), handler(name, new) or handler(name, old, new).

name : list, str, None

If None, the handler will apply to all traits. If a list of str, handler will apply to all names in the list. If a str, the handler will apply just to that name.

remove : bool

If False (the default), then install the handler. If True then unintall it.

session

A trait whose value must be an instance of a specified class.

The value can also be an instance of a subclass of the specified class.

shell_handlers

An instance of a Python dict.

shell_streams

An instance of a Python list.

shutdown_request(stream, ident, parent)

kill ourself. This should really be handled in an external process

start()
task_stream

A trait whose value must be an instance of a specified class.

The value can also be an instance of a subclass of the specified class.

trait_metadata(traitname, key)

Get metadata values for trait by key.

trait_names(**metadata)

Get a list of all the names of this classes traits.

traits(**metadata)

Get a list of all the traits of this class.

The TraitTypes returned don’t know anything about the values that the various HasTrait’s instances are holding.

This follows the same algorithm as traits does and does not allow for any simple way of specifying merely that a metadata name exists, but has any value. This is because get_metadata returns None if a metadata key doesn’t exist.

update_config(config)

Fire the traits events when the config is updated.

user_ns

An instance of a Python dict.

IPython.parallel.engine.streamkernel.printer(*args)