txinvoke 0.1.0

Run inline callbacks from Twisted as Invoke tasks

Run inline callbacks from Twisted as Invoke tasks.

Installation

pip install txinvoke

Example

# -*- coding: utf-8 -*-
# tasks.py

import time
import txmongo

from txinvoke import task_on_callbacks


@task_on_callbacks(name='test_task')
def example(verbose=False):
    connection = yield txmongo.MongoConnection()
    test_collection = connection.db.test

    for x in range(10000):
        data = x * time.time()
        doc = {'something': data}
        yield test_collection.insert(doc, safe=True)

        if verbose:
            print("Test data '{data}' was inserted".format(data=data))

Caveats

Sorry, but tasks chaining will NOT work currently.