Marius
Light weight job scheduling tool with more performance and scalability.
Name come from Gaius Marius
Installation
pip install marius
Usage Example
import time
from marius import Task, TimeLine
def func(num):
print('task-{0}'.format(num))
if __name__ == '__main__':
tl = TimeLine()
now = time.time()
tl.add(Task(iter([now + i for i in [2, 3, 5]]), func, 3))
while tl.has_tasks():
tl.wait_next()
tl.run()
else:
print("all job run over")
TODO
add automatic test supportadd more helper function- add doc
Welcome to contribute
Feel free to open a issue or start a pull request.
You are welcome.