taskiq

taskiq copied to clipboard

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

There is no way of sending a task with arbitrary types

4

So I tried to use PickleSerializer. But it raises SendTaskError without message, which is not quite informative, by the way, so I needed to debug. And turned out formatter tries...

Suoslex

Sending a task by it's name

10

I'm looking for a way to send a task by it's name (something similar to [send_task](https://docs.celeryq.dev/en/stable/reference/celery.html#celery.Celery.send_task) in Celery). I've tried to find something in docs, but didn't get anywhere. The...

Suoslex

Added task-creators.

1

s3rius

Unhandled KeyboardInterruptError from interrupt_handler

2

### Description When running a taskiq worker that spawns subprocesses, KeyboardInterrupt exceptions are not being caught and handled as expected. This results in an unhandled exception traceback being printed when...

rtnpro

Worker embedded scheduler

1

Is it possible to embed the scheduler as a part of the worker node (like celery ```celery -A tasks worker --beat```), this would be convenient for development so I don't...

brandongillett

No longer able to register methods in TaskIQ 0.11.16

19

After updating to `0.11.16`, registering a method as a task produces an `AttributeError`: ``` bbot_server/applets/_base.py:234: in register_watchdog_tasks task = broker.register_task(method, **kwargs) ../../../.cache/pypoetry/virtualenvs/bbot-server-DmHQwTaK-py3.13/lib/python3.13/site-packages/taskiq/abc/broker.py:377: in register_task return self.task(task_name=task_name, **labels)(func) ../../../.cache/pypoetry/virtualenvs/bbot-server-DmHQwTaK-py3.13/lib/python3.13/site-packages/taskiq/abc/broker.py:331: in inner...

TheTechromancer

Add max_attempts_at_message

3

This addresses the issue https://github.com/taskiq-python/taskiq-aio-pika/issues/35.

Arseniy-Popov

Warn people of unset result backend

3

> @s3rius Thank you for the quick answer, and it was exactly this. Maybe we should emphasize this in the documentation or put a warning when we use a `.wait_for`...

s3rius

Add intervals for scheduled task

2

#290 #348 Hi! First, thank you for the project! In this PR, I want to add intervals for scheduled tasks. I am attaching one commit as a draft to coordinate...

so-saf