Installation Guide

How to install Taskiq-Flow and set up your environment

---

Prerequisites

• Python ≥3.10
• pip (Python package installer)
• Optional: Redis (for distributed tracking/storage)

---

Basic Installation

Install Taskiq-Flow from PyPI:

pip install taskiq taskiq-flow

That’s it! You’re ready to start building pipelines.

---

Optional Dependencies

Taskiq-Flow supports additional features via optional extras:

# Everything
pip install "taskiq-flow[all]"

# Brokers support (Kafka + RabbitMQ + Redis)
pip install "taskiq-flow[brokers]"

# Scheduling capabilities (APScheduler + SQLAlchemy)
pip install "taskiq-flow[scheduler]"

# Scientific data types (numpy, xarray, zarr)
pip install "taskiq-flow[scientific]"

Extra	Installs
all	Every optional feature
brokers	taskiq-aio-kafka, taskiq-aio-pika, taskiq-redis
scheduler	apscheduler[sqlalchemy] (DB-backed job persistence)
scientific	numpy, xarray, zarr

Note: fastapi and uvicorn are included in the core install and are always available.

---

Verify Installation

Create a simple test file test_install.py:

from taskiq import InMemoryBroker
from taskiq_flow import Pipeline, PipelineMiddleware

broker = InMemoryBroker()
broker.add_middlewares(PipelineMiddleware())

@broker.task
def hello(name: str) -> str:
    return f"Hello, {name}!"

async def main():
    pipeline = Pipeline(broker).call_next(hello)
    task = await pipeline.kiq("World")
    result = await task.wait_result()
    print(result.return_value)  # Should print: Hello, World!

if __name__ == "__main__":
    import asyncio
    asyncio.run(main())

Run:

python test_install.py

Expected output:

Hello, World!

---

Next Steps

Once installed, continue with:

• Quick Start Guide — Build your first pipeline
• Core Concepts — Understand fundamental ideas

---

Installation completed successfully? Proceed to Quick Start.