Clepsydra is a mini framework for task scheduling
All parts are designed to be replaceable.
Main ideas are:
- No pickle! Tasks are stored in readable format, so can be used outside of framework
- Task creator doesn't need to know how tasks are implemented or executed
- Persistence may be implemented
- All workers must follow same async style: be either sync or async functions
Currently project is in the design stage and any APIs are to be changed
Create scheduler (this step will be customizable).
If your task functions as synchronous, pass param sync_executor=True
from clepsydra import create_scheduler
scheduler = create_scheduler() Register functions that can be scheduled (custom name can be provided for compatibility)
scheduler.task(some_func)Add some job using function name. For example single run:
from clepsydra import SingleRun
job_id = await scheduler.add_job("some_func", rule=SingleRun(when=datetime.now()))Run scheduler:
await scheduler.run()