taskiq-faststream
taskiq-faststream copied to clipboard
FastStream - Taskiq integration to provide you with a great scheduling feature
Updates the requirements on [pytest](https://github.com/pytest-dev/pytest) and [ruff](https://github.com/astral-sh/ruff) to permit the latest version. Updates `pytest` to 9.0.0 Release notes Sourced from pytest's releases. 9.0.0 pytest 9.0.0 (2025-11-05) New features #1367: Support...
Is it possible to start the taskiq scheduler when the fast stream app starts? Like in the same program such that it is not needed to run 2 instances (scheduler...
I can only `schedule_by_time` with task when no additional params are configured. ```python @broker.subscriber( list="scheduled.task.delayed_bunny_media_status", ) @inject async def task_delayed_bunny_media_status( # msg: DelayedContentItemTranslationMediaStatusRequest, content_item_service: Annotated[ContentItemService, FromDishka()] ): pass # in...
When a generator raises an exception, currently, this is the TaskIq error I get: ``` Task exception was never retrieved future: ``` How to properly handle exception in this case,...