Note

This documentation is for a development version of IPython. There may be significant differences from the latest stable release (1.2.1).

Module: parallel.controller.sqlitedb

A TaskRecord backend using sqlite3

Authors:

• Min RK

1 Class

class IPython.parallel.controller.sqlitedb.SQLiteDB(**kwargs)

Bases: IPython.parallel.controller.dictdb.BaseDB

SQLite3 TaskRecord backend.

__init__(**kwargs)

add_record(msg_id, rec)

Add a new Task Record, by msg_id.

drop_matching_records(check)

Remove a record from the DB.

drop_record(msg_id)

Remove a record from the DB.

find_records(check, keys=None)

Find records matching a query dict, optionally extracting subset of keys.

Returns list of matching records.

Parameters:

check: dict

mongodb-style query argument

keys: list of strs [optional]

if specified, the subset of keys to extract. msg_id will always be included.

get_history()

get all msg_ids, ordered by time submitted.

get_record(msg_id)

Get a specific Task Record, by msg_id.

update_record(msg_id, rec)

Update the data in an existing record.