{"repo":"taskiq-python/taskiq","free":true,"listed":false,"github":"https://github.com/taskiq-python/taskiq","clone":"git clone https://github.com/taskiq-python/taskiq.git","description":"Distributed task queue with full async support","language":"Python","stars":2291,"topics":["asyncio","python","python3","task-executor","task-manager","celery-like","hacktoberfest"],"license":"MIT","category":"productivity","readme_excerpt":"Documentation: https://taskiq-python.github.io/ What is taskiq? Taskiq is an asynchronous distributed task queue for python. This project takes inspiration from big projects such as Celery and Dramatiq. But taskiq can send and run both the sync and async functions, has integration with popular async frameworks, such as FastAPI and AioHTTP. Also, we use PEP-612 to provide the best autosuggestions possible. All code is type-hinted. Installation This project can be installed using pip: Or it can be installed directly from git: Usage At first you need to create a broker. Broker is an object that can communicate to workers using distributed queues. We have different brokers for different queue backends. For example, we have a broker for NATS, Redis, RabbitMQ, Kafka and even more. Choose the one that fits you and create an instance. Declaring tasks is as easy as declaring a function. Just add a decorator to your function and you are ready to go. The message is going to be sent to the broker and then to the worker. The worker will execute the function. To start worker processes, just run the following command: Where path.to.the.module is the path to the module where the broker is defined and broker is the name of the broker variable. If you have tasks in different modules, you can ask taskiq to automatically import them by passing the --fs-discover flag: It will import all modules called tasks.py in the current directory and all subdirectories. Also, we support hot reload for worker","default_branch":null,"files":null,"tree":[],"storefront":"/r/taskiq-python","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/taskiq-python/taskiq/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}