Warning

This documentation is for an old version of IPython. You can find docs for newer versions here.

Module: parallel.controller.mongodb

A TaskRecord backend using mongodb

Authors:

• Min RK

1 Class

class IPython.parallel.controller.mongodb.MongoDB(**kwargs)

Bases: IPython.parallel.controller.dictdb.BaseDB

MongoDB 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.