What's changed
- Added task scheduler
About scheduler
The task scheduler is needed to run certain tasks once in a given period of time.
The period in which the task needs to be started is described using a cron template.
An example of a message that will be added to the scheduler:
@consumer.message(name='test.scheduler', schedule='*/5 * * * *')
async def scheduler_test_message(username: Optional[str] = None) -> None:
print(f'Hello, world! My name is {username or "scheduler"}')Full Changelog: v1.0.7...1.1.0