Run inline callbacks from Twisted as Invoke tasks.
Installation
pip install txinvokeExample
# -*- 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.
1 maintainer
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 details)
File details
Details for the file txinvoke-0.1.0.tar.gz.
File metadata
- Download URL: txinvoke-0.1.0.tar.gz
- Upload date:
- Size: 3.9 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
cb75f294a8f3a9febfd2dc917c9966d9e326313a538a2ceded6bbea71be5013f
|
|
| MD5 |
1e3094c646108896340da4898afca5fc
|
|
| BLAKE2b-256 |
f0a089bf19694704a9604f52bb15df8959fceaf80a446a2fa43db1080e1b86d7
|
