Run inline callbacks from Twisted as Invoke tasks
Project description
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.
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
txinvoke-0.1.0.tar.gz
(3.9 kB
view hashes)