Light weight job scheduling tool with more performance and scalability.
Name come from Gaius Marius
pip install marius
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")
add automatic test supportadd more helper function- add doc
Feel free to open a issue or start a pull request.
You are welcome.