diff --git a/ts/deploy/docker-compose.yml b/ts/deploy/docker-compose.yml
index 9d8d3b55..57971e78 100644
--- a/ts/deploy/docker-compose.yml
+++ b/ts/deploy/docker-compose.yml
@@ -322,3 +322,150 @@ services:
     networks:
       - trustgraph
     restart: unless-stopped
+
+  # ---------------------------------------------------------------------------
+  # Document Processing Pipeline
+  # ---------------------------------------------------------------------------
+
+  pdf-decoder:
+    image: trustgraph-ts:local
+    command: ["node", "entrypoints/pdf-decoder.mjs"]
+    environment:
+      - NATS_URL=nats://nats:4222
+    depends_on:
+      nats:
+        condition: service_healthy
+    networks:
+      - trustgraph
+    restart: unless-stopped
+
+  chunker:
+    image: trustgraph-ts:local
+    command: ["node", "entrypoints/chunker.mjs"]
+    environment:
+      - NATS_URL=nats://nats:4222
+    depends_on:
+      nats:
+        condition: service_healthy
+    networks:
+      - trustgraph
+    restart: unless-stopped
+
+  extractor:
+    image: trustgraph-ts:local
+    command: ["node", "entrypoints/extractor.mjs"]
+    environment:
+      - NATS_URL=nats://nats:4222
+    depends_on:
+      nats:
+        condition: service_healthy
+    networks:
+      - trustgraph
+    restart: unless-stopped
+
+  triples-store:
+    image: trustgraph-ts:local
+    command: ["node", "entrypoints/triples-store.mjs"]
+    environment:
+      - NATS_URL=nats://nats:4222
+      - FALKORDB_URL=redis://falkordb:6379
+    depends_on:
+      nats:
+        condition: service_healthy
+      falkordb:
+        condition: service_healthy
+    networks:
+      - trustgraph
+    restart: unless-stopped
+
+  graph-embeddings-store:
+    image: trustgraph-ts:local
+    command: ["node", "entrypoints/graph-embeddings-store.mjs"]
+    environment:
+      - NATS_URL=nats://nats:4222
+      - QDRANT_URL=http://qdrant:6333
+    depends_on:
+      nats:
+        condition: service_healthy
+      qdrant:
+        condition: service_healthy
+    networks:
+      - trustgraph
+    restart: unless-stopped
+
+  # ---------------------------------------------------------------------------
+  # Query Services
+  # ---------------------------------------------------------------------------
+
+  triples-query:
+    image: trustgraph-ts:local
+    command: ["node", "entrypoints/triples-query.mjs"]
+    environment:
+      - NATS_URL=nats://nats:4222
+      - FALKORDB_URL=redis://falkordb:6379
+    depends_on:
+      nats:
+        condition: service_healthy
+      falkordb:
+        condition: service_healthy
+    networks:
+      - trustgraph
+    restart: unless-stopped
+
+  graph-embeddings-query:
+    image: trustgraph-ts:local
+    command: ["node", "entrypoints/graph-embeddings-query.mjs"]
+    environment:
+      - NATS_URL=nats://nats:4222
+      - QDRANT_URL=http://qdrant:6333
+    depends_on:
+      nats:
+        condition: service_healthy
+      qdrant:
+        condition: service_healthy
+    networks:
+      - trustgraph
+    restart: unless-stopped
+
+  doc-embeddings-query:
+    image: trustgraph-ts:local
+    command: ["node", "entrypoints/doc-embeddings-query.mjs"]
+    environment:
+      - NATS_URL=nats://nats:4222
+      - QDRANT_URL=http://qdrant:6333
+    depends_on:
+      nats:
+        condition: service_healthy
+      qdrant:
+        condition: service_healthy
+    networks:
+      - trustgraph
+    restart: unless-stopped
+
+  # ---------------------------------------------------------------------------
+  # Retrieval Services
+  # ---------------------------------------------------------------------------
+
+  graph-rag:
+    image: trustgraph-ts:local
+    command: ["node", "entrypoints/graph-rag.mjs"]
+    environment:
+      - NATS_URL=nats://nats:4222
+    depends_on:
+      nats:
+        condition: service_healthy
+    networks:
+      - trustgraph
+    restart: unless-stopped
+
+  document-rag:
+    image: trustgraph-ts:local
+    command: ["node", "entrypoints/document-rag.mjs"]
+    environment:
+      - NATS_URL=nats://nats:4222
+    depends_on:
+      nats:
+        condition: service_healthy
+    networks:
+      - trustgraph
+    restart: unless-stopped
diff --git a/ts/package.json b/ts/package.json
index de081e85..707f50dc 100644
--- a/ts/package.json
+++ b/ts/package.json
@@ -21,7 +21,15 @@
     "llm:ollama": "tsx scripts/run-ollama.ts",
     "pdf-decoder": "tsx scripts/run-pdf-decoder.ts",
     "triples-store": "tsx scripts/run-triples-store.ts",
-    "graph-embeddings-store": "tsx scripts/run-graph-embeddings-store.ts"
+    "graph-embeddings-store": "tsx scripts/run-graph-embeddings-store.ts",
+    "chunker": "tsx scripts/run-chunker.ts",
+    "extractor": "tsx scripts/run-extractor.ts",
+    "embeddings": "tsx scripts/run-embeddings.ts",
+    "triples-query": "tsx scripts/run-triples-query.ts",
+    "graph-embeddings-query": "tsx scripts/run-graph-embeddings-query.ts",
+    "doc-embeddings-query": "tsx scripts/run-doc-embeddings-query.ts",
+    "graph-rag": "tsx scripts/run-graph-rag.ts",
+    "document-rag": "tsx scripts/run-document-rag.ts"
   },
   "devDependencies": {
     "nats": "^2.29.0",
diff --git a/ts/packages/base/src/schema/messages.ts b/ts/packages/base/src/schema/messages.ts
index dbcef0c5..0cf5fbc3 100644
--- a/ts/packages/base/src/schema/messages.ts
+++ b/ts/packages/base/src/schema/messages.ts
@@ -113,6 +113,18 @@ export interface GraphEmbeddingsResponse {
   error?: TgError;
 }
 
+// Document embeddings query
+export interface DocumentEmbeddingsRequest {
+  vectors: number[][];
+  limit?: number;
+  collection?: string;
+}
+
+export interface DocumentEmbeddingsResponse {
+  chunks: Array<{ chunkId: string; score: number }>;
+  error?: TgError;
+}
+
 // Config
 export type ConfigOperation = "get" | "list" | "delete" | "put" | "config";
 
diff --git a/ts/packages/flow/src/flow-manager/service.ts b/ts/packages/flow/src/flow-manager/service.ts
index 7354ffe2..5aeb2198 100644
--- a/ts/packages/flow/src/flow-manager/service.ts
+++ b/ts/packages/flow/src/flow-manager/service.ts
@@ -82,6 +82,12 @@ const DEFAULT_BLUEPRINT: Blueprint = {
     // Embeddings
     "embeddings-request": "tg.flow.embeddings-request",
     "embeddings-response": "tg.flow.embeddings-response",
+    // Graph embeddings query
+    "graph-embeddings-request": "tg.flow.graph-embeddings-request",
+    "graph-embeddings-response": "tg.flow.graph-embeddings-response",
+    // Document embeddings query
+    "document-embeddings-request": "tg.flow.document-embeddings-request",
+    "document-embeddings-response": "tg.flow.document-embeddings-response",
     // Librarian RPC (for PDF decoder)
     "librarian-request": "tg.flow.librarian-request",
     "librarian-response": "tg.flow.librarian-response",
diff --git a/ts/packages/flow/src/index.ts b/ts/packages/flow/src/index.ts
index 585ddab8..51e255cd 100644
--- a/ts/packages/flow/src/index.ts
+++ b/ts/packages/flow/src/index.ts
@@ -68,5 +68,14 @@ export { OllamaProcessor } from "./model/text-completion/ollama.js";
 // PDF decoder
 export { PdfDecoderService } from "./decoding/pdf-decoder.js";
 
+// Query services (FlowProcessor wrappers)
+export { TriplesQueryService } from "./query/triples/falkordb-service.js";
+export { GraphEmbeddingsQueryService } from "./query/embeddings/qdrant-graph-service.js";
+export { DocEmbeddingsQueryService } from "./query/embeddings/qdrant-doc-service.js";
+
+// Retrieval services (FlowProcessor wrappers)
+export { GraphRagService } from "./retrieval/graph-rag-service.js";
+export { DocumentRagService } from "./retrieval/document-rag-service.js";
+
 // Flow manager service
 export { FlowManagerService } from "./flow-manager/service.js";
diff --git a/ts/packages/flow/src/query/embeddings/qdrant-doc-service.ts b/ts/packages/flow/src/query/embeddings/qdrant-doc-service.ts
new file mode 100644
index 00000000..59e2e5e4
--- /dev/null
+++ b/ts/packages/flow/src/query/embeddings/qdrant-doc-service.ts
@@ -0,0 +1,81 @@
+/**
+ * Document embeddings query service — finds similar document chunks in Qdrant.
+ *
+ * Wraps QdrantDocEmbeddingsQuery as a NATS consumer so Document RAG can look up
+ * chunks by vector similarity over the message bus.
+ *
+ * Python reference: trustgraph-flow/trustgraph/query/doc_embeddings/qdrant/service.py
+ */
+
+import {
+  FlowProcessor,
+  ConsumerSpec,
+  ProducerSpec,
+  type ProcessorConfig,
+  type FlowContext,
+  type DocumentEmbeddingsRequest,
+  type DocumentEmbeddingsResponse,
+} from "@trustgraph/base";
+import { QdrantDocEmbeddingsQuery } from "./qdrant-doc.js";
+
+export class DocEmbeddingsQueryService extends FlowProcessor {
+  private query: QdrantDocEmbeddingsQuery;
+
+  constructor(config: ProcessorConfig) {
+    super(config);
+    this.query = new QdrantDocEmbeddingsQuery();
+
+    this.registerSpecification(
+      new ConsumerSpec<DocumentEmbeddingsRequest>(
+        "document-embeddings-request",
+        this.onMessage.bind(this),
+      ),
+    );
+    this.registerSpecification(
+      new ProducerSpec<DocumentEmbeddingsResponse>("document-embeddings-response"),
+    );
+
+    console.log("[DocEmbeddingsQuery] Service initialized");
+  }
+
+  private async onMessage(
+    msg: DocumentEmbeddingsRequest,
+    properties: Record<string, string>,
+    flowCtx: FlowContext,
+  ): Promise<void> {
+    const requestId = properties.id;
+    if (!requestId) return;
+
+    const producer = flowCtx.flow.producer<DocumentEmbeddingsResponse>("document-embeddings-response");
+    const collection = msg.collection ?? "default";
+
+    try {
+      const allChunks: DocumentEmbeddingsResponse["chunks"] = [];
+
+      for (const vector of msg.vectors ?? []) {
+        const matches = await this.query.query({
+          vector,
+          user: "default",
+          collection,
+          limit: msg.limit ?? 10,
+        });
+
+        for (const match of matches) {
+          allChunks.push({ chunkId: match.chunkId, score: match.score });
+        }
+      }
+
+      await producer.send(requestId, { chunks: allChunks });
+    } catch (err) {
+      console.error("[DocEmbeddingsQuery] Query failed:", err);
+      await producer.send(requestId, {
+        chunks: [],
+        error: { type: "query-error", message: String(err) },
+      });
+    }
+  }
+}
+
+export async function run(): Promise<void> {
+  await DocEmbeddingsQueryService.launch("doc-embeddings-query");
+}
diff --git a/ts/packages/flow/src/query/embeddings/qdrant-graph-service.ts b/ts/packages/flow/src/query/embeddings/qdrant-graph-service.ts
new file mode 100644
index 00000000..b02cdff0
--- /dev/null
+++ b/ts/packages/flow/src/query/embeddings/qdrant-graph-service.ts
@@ -0,0 +1,83 @@
+/**
+ * Graph embeddings query service — finds similar entities in Qdrant via FlowProcessor.
+ *
+ * Wraps QdrantGraphEmbeddingsQuery as a NATS consumer so Graph RAG can look up
+ * entities by vector similarity over the message bus.
+ *
+ * Python reference: trustgraph-flow/trustgraph/query/graph_embeddings/qdrant/service.py
+ */
+
+import {
+  FlowProcessor,
+  ConsumerSpec,
+  ProducerSpec,
+  type ProcessorConfig,
+  type FlowContext,
+  type GraphEmbeddingsRequest,
+  type GraphEmbeddingsResponse,
+} from "@trustgraph/base";
+import { QdrantGraphEmbeddingsQuery } from "./qdrant-graph.js";
+
+export class GraphEmbeddingsQueryService extends FlowProcessor {
+  private query: QdrantGraphEmbeddingsQuery;
+
+  constructor(config: ProcessorConfig) {
+    super(config);
+    this.query = new QdrantGraphEmbeddingsQuery();
+
+    this.registerSpecification(
+      new ConsumerSpec<GraphEmbeddingsRequest>(
+        "graph-embeddings-request",
+        this.onMessage.bind(this),
+      ),
+    );
+    this.registerSpecification(
+      new ProducerSpec<GraphEmbeddingsResponse>("graph-embeddings-response"),
+    );
+
+    console.log("[GraphEmbeddingsQuery] Service initialized");
+  }
+
+  private async onMessage(
+    msg: GraphEmbeddingsRequest,
+    properties: Record<string, string>,
+    flowCtx: FlowContext,
+  ): Promise<void> {
+    const requestId = properties.id;
+    if (!requestId) return;
+
+    const producer = flowCtx.flow.producer<GraphEmbeddingsResponse>("graph-embeddings-response");
+    const user = msg.collection ?? "default";
+    const collection = msg.collection ?? "default";
+
+    try {
+      // Query for each vector and aggregate results
+      const allEntities: GraphEmbeddingsResponse["entities"] = [];
+
+      for (const vector of msg.vectors ?? []) {
+        const matches = await this.query.query({
+          vector,
+          user,
+          collection,
+          limit: msg.limit ?? 50,
+        });
+
+        for (const match of matches) {
+          allEntities.push(match.entity);
+        }
+      }
+
+      await producer.send(requestId, { entities: allEntities });
+    } catch (err) {
+      console.error("[GraphEmbeddingsQuery] Query failed:", err);
+      await producer.send(requestId, {
+        entities: [],
+        error: { type: "query-error", message: String(err) },
+      });
+    }
+  }
+}
+
+export async function run(): Promise<void> {
+  await GraphEmbeddingsQueryService.launch("graph-embeddings-query");
+}
diff --git a/ts/packages/flow/src/query/triples/falkordb-service.ts b/ts/packages/flow/src/query/triples/falkordb-service.ts
new file mode 100644
index 00000000..f5f6a931
--- /dev/null
+++ b/ts/packages/flow/src/query/triples/falkordb-service.ts
@@ -0,0 +1,67 @@
+/**
+ * Triples query service — queries RDF triples from FalkorDB via FlowProcessor.
+ *
+ * Wraps FalkorDBTriplesQuery as a NATS consumer so the agent and Graph RAG
+ * can query the knowledge graph over the message bus.
+ *
+ * Python reference: trustgraph-flow/trustgraph/query/triples/falkordb/service.py
+ */
+
+import {
+  FlowProcessor,
+  ConsumerSpec,
+  ProducerSpec,
+  type ProcessorConfig,
+  type FlowContext,
+  type TriplesQueryRequest,
+  type TriplesQueryResponse,
+} from "@trustgraph/base";
+import { FalkorDBTriplesQuery } from "./falkordb.js";
+
+export class TriplesQueryService extends FlowProcessor {
+  private query: FalkorDBTriplesQuery;
+
+  constructor(config: ProcessorConfig) {
+    super(config);
+    this.query = new FalkorDBTriplesQuery();
+
+    this.registerSpecification(
+      new ConsumerSpec<TriplesQueryRequest>("triples-request", this.onMessage.bind(this)),
+    );
+    this.registerSpecification(new ProducerSpec<TriplesQueryResponse>("triples-response"));
+
+    console.log("[TriplesQuery] Service initialized");
+  }
+
+  private async onMessage(
+    msg: TriplesQueryRequest,
+    properties: Record<string, string>,
+    flowCtx: FlowContext,
+  ): Promise<void> {
+    const requestId = properties.id;
+    if (!requestId) return;
+
+    const producer = flowCtx.flow.producer<TriplesQueryResponse>("triples-response");
+
+    try {
+      const triples = await this.query.queryTriples(
+        msg.s,
+        msg.p,
+        msg.o,
+        msg.limit ?? 100,
+      );
+
+      await producer.send(requestId, { triples });
+    } catch (err) {
+      console.error("[TriplesQuery] Query failed:", err);
+      await producer.send(requestId, {
+        triples: [],
+        error: { type: "query-error", message: String(err) },
+      });
+    }
+  }
+}
+
+export async function run(): Promise<void> {
+  await TriplesQueryService.launch("triples-query");
+}
diff --git a/ts/packages/flow/src/retrieval/document-rag-service.ts b/ts/packages/flow/src/retrieval/document-rag-service.ts
new file mode 100644
index 00000000..51972b0a
--- /dev/null
+++ b/ts/packages/flow/src/retrieval/document-rag-service.ts
@@ -0,0 +1,112 @@
+/**
+ * Document RAG service — FlowProcessor wrapper around the DocumentRag class.
+ *
+ * Consumes DocumentRagRequest messages, runs the document retrieval pipeline
+ * (embed query → find similar chunks → synthesize answer), emits DocumentRagResponse.
+ *
+ * Each request gets its own DocumentRag instance for security isolation.
+ *
+ * Python reference: trustgraph-flow/trustgraph/retrieval/document_rag/
+ */
+
+import {
+  FlowProcessor,
+  ConsumerSpec,
+  ProducerSpec,
+  RequestResponseSpec,
+  type ProcessorConfig,
+  type FlowContext,
+  type DocumentRagRequest,
+  type DocumentRagResponse,
+  type TextCompletionRequest,
+  type TextCompletionResponse,
+  type EmbeddingsRequest,
+  type EmbeddingsResponse,
+  type DocumentEmbeddingsRequest,
+  type DocumentEmbeddingsResponse,
+  type PromptRequest,
+  type PromptResponse,
+} from "@trustgraph/base";
+import { DocumentRag } from "./document-rag.js";
+
+export class DocumentRagService extends FlowProcessor {
+  constructor(config: ProcessorConfig) {
+    super(config);
+
+    // Consumer: document RAG requests
+    this.registerSpecification(
+      new ConsumerSpec<DocumentRagRequest>("document-rag-request", this.onRequest.bind(this)),
+    );
+
+    // Producer: document RAG responses
+    this.registerSpecification(new ProducerSpec<DocumentRagResponse>("document-rag-response"));
+
+    // Request-response clients
+    this.registerSpecification(
+      new RequestResponseSpec<TextCompletionRequest, TextCompletionResponse>(
+        "llm",
+        "text-completion-request",
+        "text-completion-response",
+      ),
+    );
+    this.registerSpecification(
+      new RequestResponseSpec<EmbeddingsRequest, EmbeddingsResponse>(
+        "embeddings",
+        "embeddings-request",
+        "embeddings-response",
+      ),
+    );
+    this.registerSpecification(
+      new RequestResponseSpec<DocumentEmbeddingsRequest, DocumentEmbeddingsResponse>(
+        "doc-embeddings",
+        "document-embeddings-request",
+        "document-embeddings-response",
+      ),
+    );
+    this.registerSpecification(
+      new RequestResponseSpec<PromptRequest, PromptResponse>(
+        "prompt",
+        "prompt-request",
+        "prompt-response",
+      ),
+    );
+
+    console.log("[DocumentRag] Service initialized");
+  }
+
+  private async onRequest(
+    msg: DocumentRagRequest,
+    properties: Record<string, string>,
+    flowCtx: FlowContext,
+  ): Promise<void> {
+    const requestId = properties.id;
+    if (!requestId) return;
+
+    const producer = flowCtx.flow.producer<DocumentRagResponse>("document-rag-response");
+
+    try {
+      const documentRag = new DocumentRag({
+        llm: flowCtx.flow.requestor<TextCompletionRequest, TextCompletionResponse>("llm"),
+        embeddings: flowCtx.flow.requestor<EmbeddingsRequest, EmbeddingsResponse>("embeddings"),
+        docEmbeddings: flowCtx.flow.requestor<DocumentEmbeddingsRequest, DocumentEmbeddingsResponse>("doc-embeddings"),
+        prompt: flowCtx.flow.requestor<PromptRequest, PromptResponse>("prompt"),
+      });
+
+      const response = await documentRag.query(msg.query, {
+        collection: msg.collection,
+      });
+
+      await producer.send(requestId, { response });
+    } catch (err) {
+      console.error("[DocumentRag] Query failed:", err);
+      await producer.send(requestId, {
+        response: "",
+        error: { type: "rag-error", message: String(err) },
+      });
+    }
+  }
+}
+
+export async function run(): Promise<void> {
+  await DocumentRagService.launch("document-rag");
+}
diff --git a/ts/packages/flow/src/retrieval/graph-rag-service.ts b/ts/packages/flow/src/retrieval/graph-rag-service.ts
new file mode 100644
index 00000000..3fd2f9df
--- /dev/null
+++ b/ts/packages/flow/src/retrieval/graph-rag-service.ts
@@ -0,0 +1,133 @@
+/**
+ * Graph RAG service — FlowProcessor wrapper around the GraphRag class.
+ *
+ * Consumes GraphRagRequest messages from the agent/gateway, runs the full
+ * Graph RAG pipeline (concept extraction → entity lookup → graph traversal →
+ * edge scoring → answer synthesis), and emits GraphRagResponse.
+ *
+ * Each request gets its own GraphRag instance to prevent data leakage
+ * across requests (security requirement from the Python implementation).
+ *
+ * Python reference: trustgraph-flow/trustgraph/retrieval/graph_rag/rag.py
+ */
+
+import {
+  FlowProcessor,
+  ConsumerSpec,
+  ProducerSpec,
+  RequestResponseSpec,
+  type ProcessorConfig,
+  type FlowContext,
+  type GraphRagRequest,
+  type GraphRagResponse,
+  type TextCompletionRequest,
+  type TextCompletionResponse,
+  type EmbeddingsRequest,
+  type EmbeddingsResponse,
+  type GraphEmbeddingsRequest,
+  type GraphEmbeddingsResponse,
+  type TriplesQueryRequest,
+  type TriplesQueryResponse,
+  type PromptRequest,
+  type PromptResponse,
+} from "@trustgraph/base";
+import { GraphRag } from "./graph-rag.js";
+
+export class GraphRagService extends FlowProcessor {
+  constructor(config: ProcessorConfig) {
+    super(config);
+
+    // Consumer: graph RAG requests
+    this.registerSpecification(
+      new ConsumerSpec<GraphRagRequest>("graph-rag-request", this.onRequest.bind(this)),
+    );
+
+    // Producer: graph RAG responses
+    this.registerSpecification(new ProducerSpec<GraphRagResponse>("graph-rag-response"));
+
+    // Request-response clients for the pipeline
+    this.registerSpecification(
+      new RequestResponseSpec<TextCompletionRequest, TextCompletionResponse>(
+        "llm",
+        "text-completion-request",
+        "text-completion-response",
+      ),
+    );
+    this.registerSpecification(
+      new RequestResponseSpec<EmbeddingsRequest, EmbeddingsResponse>(
+        "embeddings",
+        "embeddings-request",
+        "embeddings-response",
+      ),
+    );
+    this.registerSpecification(
+      new RequestResponseSpec<GraphEmbeddingsRequest, GraphEmbeddingsResponse>(
+        "graph-embeddings",
+        "graph-embeddings-request",
+        "graph-embeddings-response",
+      ),
+    );
+    this.registerSpecification(
+      new RequestResponseSpec<TriplesQueryRequest, TriplesQueryResponse>(
+        "triples",
+        "triples-request",
+        "triples-response",
+      ),
+    );
+    this.registerSpecification(
+      new RequestResponseSpec<PromptRequest, PromptResponse>(
+        "prompt",
+        "prompt-request",
+        "prompt-response",
+      ),
+    );
+
+    console.log("[GraphRag] Service initialized");
+  }
+
+  private async onRequest(
+    msg: GraphRagRequest,
+    properties: Record<string, string>,
+    flowCtx: FlowContext,
+  ): Promise<void> {
+    const requestId = properties.id;
+    if (!requestId) return;
+
+    const producer = flowCtx.flow.producer<GraphRagResponse>("graph-rag-response");
+
+    try {
+      // Create a per-request GraphRag instance with flow clients
+      const graphRag = new GraphRag(
+        {
+          llm: flowCtx.flow.requestor<TextCompletionRequest, TextCompletionResponse>("llm"),
+          embeddings: flowCtx.flow.requestor<EmbeddingsRequest, EmbeddingsResponse>("embeddings"),
+          graphEmbeddings: flowCtx.flow.requestor<GraphEmbeddingsRequest, GraphEmbeddingsResponse>("graph-embeddings"),
+          triples: flowCtx.flow.requestor<TriplesQueryRequest, TriplesQueryResponse>("triples"),
+          prompt: flowCtx.flow.requestor<PromptRequest, PromptResponse>("prompt"),
+        },
+        {
+          entityLimit: msg.entityLimit,
+          tripleLimit: msg.tripleLimit,
+          maxSubgraphSize: msg.maxSubgraphSize,
+          maxPathLength: msg.maxPathLength,
+        },
+      );
+
+      const response = await graphRag.query(msg.query, {
+        collection: msg.collection,
+      });
+
+      await producer.send(requestId, { response });
+    } catch (err) {
+      console.error("[GraphRag] Query failed:", err);
+      await producer.send(requestId, {
+        response: "",
+        error: { type: "rag-error", message: String(err) },
+      });
+    }
+  }
+}
+
+export async function run(): Promise<void> {
+  await GraphRagService.launch("graph-rag");
+}
diff --git a/ts/scripts/run-chunker.ts b/ts/scripts/run-chunker.ts
new file mode 100644
index 00000000..12c2be0c
--- /dev/null
+++ b/ts/scripts/run-chunker.ts
@@ -0,0 +1,6 @@
+import { run } from "../packages/flow/src/chunking/service.js";
+
+run().catch((err) => {
+  console.error("Chunking service failed:", err);
+  process.exit(1);
+});
diff --git a/ts/scripts/run-doc-embeddings-query.ts b/ts/scripts/run-doc-embeddings-query.ts
new file mode 100644
index 00000000..85b4ab0f
--- /dev/null
+++ b/ts/scripts/run-doc-embeddings-query.ts
@@ -0,0 +1,6 @@
+import { run } from "../packages/flow/src/query/embeddings/qdrant-doc-service.js";
+
+run().catch((err) => {
+  console.error("Document embeddings query service failed:", err);
+  process.exit(1);
+});
diff --git a/ts/scripts/run-document-rag.ts b/ts/scripts/run-document-rag.ts
new file mode 100644
index 00000000..fc430d3a
--- /dev/null
+++ b/ts/scripts/run-document-rag.ts
@@ -0,0 +1,6 @@
+import { run } from "../packages/flow/src/retrieval/document-rag-service.js";
+
+run().catch((err) => {
+  console.error("Document RAG service failed:", err);
+  process.exit(1);
+});
diff --git a/ts/scripts/run-embeddings.ts b/ts/scripts/run-embeddings.ts
new file mode 100644
index 00000000..174aa77f
--- /dev/null
+++ b/ts/scripts/run-embeddings.ts
@@ -0,0 +1,6 @@
+import { run } from "../packages/flow/src/embeddings/ollama.js";
+
+run().catch((err) => {
+  console.error("Embeddings service failed:", err);
+  process.exit(1);
+});
diff --git a/ts/scripts/run-extractor.ts b/ts/scripts/run-extractor.ts
new file mode 100644
index 00000000..a549ed71
--- /dev/null
+++ b/ts/scripts/run-extractor.ts
@@ -0,0 +1,6 @@
+import { run } from "../packages/flow/src/extract/knowledge-extract.js";
+
+run().catch((err) => {
+  console.error("Knowledge extract service failed:", err);
+  process.exit(1);
+});
diff --git a/ts/scripts/run-graph-embeddings-query.ts b/ts/scripts/run-graph-embeddings-query.ts
new file mode 100644
index 00000000..06bc8a03
--- /dev/null
+++ b/ts/scripts/run-graph-embeddings-query.ts
@@ -0,0 +1,6 @@
+import { run } from "../packages/flow/src/query/embeddings/qdrant-graph-service.js";
+
+run().catch((err) => {
+  console.error("Graph embeddings query service failed:", err);
+  process.exit(1);
+});
diff --git a/ts/scripts/run-graph-rag.ts b/ts/scripts/run-graph-rag.ts
new file mode 100644
index 00000000..a35d93db
--- /dev/null
+++ b/ts/scripts/run-graph-rag.ts
@@ -0,0 +1,6 @@
+import { run } from "../packages/flow/src/retrieval/graph-rag-service.js";
+
+run().catch((err) => {
+  console.error("Graph RAG service failed:", err);
+  process.exit(1);
+});
diff --git a/ts/scripts/run-triples-query.ts b/ts/scripts/run-triples-query.ts
new file mode 100644
index 00000000..76d9f4ec
--- /dev/null
+++ b/ts/scripts/run-triples-query.ts
@@ -0,0 +1,6 @@
+import { run } from "../packages/flow/src/query/triples/falkordb-service.js";
+
+run().catch((err) => {
+  console.error("Triples query service failed:", err);
+  process.exit(1);
+});
diff --git a/ts/scripts/seed-config.ts b/ts/scripts/seed-config.ts
index 08bd8fe5..685d6fd8 100644
--- a/ts/scripts/seed-config.ts
+++ b/ts/scripts/seed-config.ts
@@ -88,6 +88,56 @@ async function main(): Promise<void> {
         "Question: {query}",
       ].join("\n"),
     },
+    "extract-concepts": {
+      system: "You extract key concepts and entities from questions.",
+      prompt: [
+        "Extract the key concepts and entities from the following question.",
+        "Return one concept per line, no numbering or bullets.",
+        "",
+        "Question: {query}",
+      ].join("\n"),
+    },
+    "kg-edge-scoring": {
+      system: "You are a knowledge graph expert that scores the relevance of graph edges to a query.",
+      prompt: [
+        "Given the following question and a list of knowledge graph edges,",
+        "score each edge for relevance to answering the question.",
+        "Return a JSON array of objects with 'id' and 'score' (0.0 to 1.0).",
+        "",
+        "Question: {query}",
+        "",
+        "Edges:",
+        "{knowledge}",
+        "",
+        "Requirements:",
+        "- Respond only with a valid JSON array.",
+        "- Example: [{\"id\": \"0\", \"score\": 0.9}, {\"id\": \"1\", \"score\": 0.2}]",
+      ].join("\n"),
+    },
+    "graph-rag-synthesize": {
+      system: "You are a helpful assistant that answers questions using knowledge graph data. Only use the provided context.",
+      prompt: [
+        "Use the following knowledge graph relationships to answer the question.",
+        "Do not speculate if the answer is not found in the context.",
+        "",
+        "Knowledge:",
+        "{context}",
+        "",
+        "Question: {query}",
+      ].join("\n"),
+    },
+    "document-rag-synthesize": {
+      system: "You are a helpful assistant. Use only the provided document context to answer questions.",
+      prompt: [
+        "Use the following document excerpts to answer the question.",
+        "Do not speculate if the answer is not found in the context.",
+        "",
+        "Documents:",
+        "{context}",
+        "",
+        "Question: {query}",
+      ].join("\n"),
+    },
   });
 
   // 2. Flow definitions (default flow with all topic mappings)
@@ -129,6 +179,12 @@ async function main(): Promise<void> {
         // Embeddings
         "embeddings-request": "tg.flow.embeddings-request",
         "embeddings-response": "tg.flow.embeddings-response",
+        // Graph embeddings query
+        "graph-embeddings-request": "tg.flow.graph-embeddings-request",
+        "graph-embeddings-response": "tg.flow.graph-embeddings-response",
+        // Document embeddings query
+        "document-embeddings-request": "tg.flow.document-embeddings-request",
+        "document-embeddings-response": "tg.flow.document-embeddings-response",
         // Librarian RPC (for PDF decoder)
         "librarian-request": "tg.flow.librarian-request",
         "librarian-response": "tg.flow.librarian-response",