store it
Project description
simple worker
Note: this package is still in alpha. Use with caution !
Quickstart
Install worker:
pip install worker
Use worker:
data = [ {'hello': 'world'}, ] * 40 info = { 'worker': 'xxx.yyy.worker_do_sth' } worker = Worker(mode='thread') resp = worker.work(data, info) print(resp)
def worker_do_sth(data, info): print(data) return data def callback(results): print('final') print(results) def test_celery(): data = [ 'u11', 'u22', 'u33', 'u44', 'u21', 'u22', 'u23', 'u24', 'u31', 'u32', 'u33', 'u34', 'u41', 'u42', 'u43', 'u44', 'u51', 'u52', 'u53', 'u54', ]*8 info={ 'celery_worker': 'test.functional.test_celery.simple', 'worker': 'test.functional.test_celery.worker_do_sth', 'celery_max_workers': 4, 'celery_chunk_size': 80, 'chunk_size': 20, 'final_callback': 'test.functional.test_celery.callback', 'queue': '123' } worker = Worker(mode='celery') resp = worker.work(data, info) return resp
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.
Built Distribution
worker-2018.4.1-py3-none-any.whl
(11.3 kB
view hashes)
Close
Hashes for worker-2018.4.1-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 7a9d1b390801c869e081df1fd6a289da396b0d1b1493eff47be870128c886252 |
|
MD5 | 326d1f35186064f802791659d39403c3 |
|
BLAKE2-256 | 3dc5bef2cd6d128cb328e8190b2c81716aad3da1d69e4b737e7ebff53f76f483 |