A tool for creating external worker processes
This package provides a wrapper to create standalone worker processes.
Workers are created by extending the BaseWorker class and implementing a tick method to execute then calling .main() on the class. This will start an infinite loop calling that function.
The worker can be rate limited with max_ticks_per_second.
The worker can be stopped gracefully by sending a SIGTERM to the process.
>>> import time ... ... from workerprocess import BaseWorker ... ... ... class ExampleWorker(BaseWorker): ... ... max_ticks_per_second = 10 ... ... def tick(self): ... print 'Tick!' ... time.sleep(1) ... ... ExampleWorker.main()
A sighup method on the function will be called if the process receives a SIGHUP
Running the Worker
The easiest way to be able to run the worker is by adding a console_script entry point in your setup.py:
entry_points=”“” [console_scripts] example_worker_process = yourpackage.yourmodule:ExampleWorker.main “”“,
After installing your package you will be able to run the command example_worker_process from the command line.
|Filename, size||File type||Python version||Upload date||Hashes|
|Filename, size workerprocess-0.1.2.tar.gz (3.0 kB)||File type Source||Python version None||Upload date||Hashes View hashes|