RAG index pipeline, from raw data clean to index. each step communicate via message queue.
-
Updated
Sep 17, 2026 - Python
RAG index pipeline, from raw data clean to index. each step communicate via message queue.
This repo contains a simple in memory publish subscribe message queue in Python which delivers messages based on the priority of the subscribers and handles them in different thread pool.
To associate your repository with the messagequeue topic, visit your repo's landing page and select "manage topics."