taskiq-faststream

taskiq-faststream copied to clipboard

Bumps [ruff](https://github.com/astral-sh/ruff) from 0.4.1 to 0.4.4. Release notes Sourced from ruff's releases. v0.4.4 Changes Preview features [pycodestyle] Ignore end-of-line comments when determining blank line rules (#11342) [pylint] Detect pathlib.Path.open calls...

dependabot[bot]

Updates the requirements on [mypy](https://github.com/python/mypy) to permit the latest version. Changelog Sourced from mypy's changelog. Mypy Release Notes Next release Mypy 1.10 We’ve just uploaded mypy 1.10 to the Python...

dependabot[bot]

Bumps [ruff](https://github.com/astral-sh/ruff) from 0.4.1 to 0.5.4. Release notes Sourced from ruff's releases. 0.5.4 Release Notes Rule changes [ruff] Rename RUF007 to zip-instead-of-pairwise (#12399) Bug fixes [flake8-builtins] Avoid shadowing diagnostics for...

dependabot[bot]

Updates the requirements on [mypy](https://github.com/python/mypy) to permit the latest version. Changelog Sourced from mypy's changelog. Mypy Release Notes Next release Mypy 1.11 We’ve just uploaded mypy 1.11 to the Python...

dependabot[bot]

faststream = {extras = ["rabbit"], version = "^0.5.12"} taskiq-faststream = {extras = ["rabbit"], version = "^0.1.8"} ```python from faststream.rabbit import RabbitQueue, RabbitExchange from taskiq.schedule_sources import LabelScheduleSource from taskiq_faststream import BrokerWrapper,...

maxim-f1

Bumps [pypa/gh-action-pypi-publish](https://github.com/pypa/gh-action-pypi-publish) from 1.8.14 to 1.9.0. Release notes Sourced from pypa/gh-action-pypi-publish's releases. v1.9.0 💅 Cosmetic Output Improvements @​woodruffw💰 updated the tense on password nudge in #234 @​shenxianpeng💰 helped us disable...

dependabot[bot]

Fixed an issue where multiple scheduled messages could be lost. Added a test to verify correct task scheduling with cron using StreamScheduler

w4terlaw

TypeError: BrokerWrapper.task.<locals>.<lambda>__taskiq_original() takes 0 positional arguments but 1 was given

1

```python kafka_router = KafkaRouter( settings.kafka.KAFKA_BROKER, include_in_schema=True, ) taskiq_broker = BrokerWrapper(kafka_router.broker) taskiq_scheduler = TaskiqScheduler( broker=taskiq_broker, sources=[LabelScheduleSource(taskiq_broker)], ) @taskiq_broker.task async def sync_last_bets() -> None: td = timedelta(minutes=10, seconds=30) await sync_service.sync_bets(batch_size=100, time_delta=td) ```...

glambary

Dynamic scheduling task

1

Hey guys. Is it possible to use Redis to dynamically add tasks? Like in this part of the [documentation](https://taskiq-python.github.io/guide/scheduling-tasks.html#dynamic-scheduling)?

nontxt