Sergey Khadkvevich

``` 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) ```...

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) ```...