Skip to main content

RAG index construction and evaluation

Build a retrievable knowledge index and validate it before publication.

Import this workflow from AkôFlow Hub

Open the public README and measured execution results. The Hub includes the execution capture, activity metrics, logs and version history. Reading public results does not require an account.

In Desktop, choose Create workflow → Import from Hub and paste this version-specific URI:

akoflow://hub/publications/f04b2396-b1d7-4c6d-981d-5c9405992b42/versions/1

Download the exact workflow YAML (v1). Configure the runtime prerequisites below before planning and executing it.

Run this example locally

Clean and chunk a bundled document corpus, compute normalized TF-IDF vectors, build a portable JSON search index, and run retrieval and extractive-answer checks in parallel. This CPU profile uses lexical embeddings and source quotations, not a hosted embedding model or a generative LLM.

Install Go and Python 3.12 or newer.

git clone https://github.com/UFFeScience/akoflow-examples.git &&
cd akoflow-examples &&
git checkout --detach d890c3171e3661890305b763b8fc3ede48bb61b4 &&
cd generative-ai/rag-indexing &&
./prepare.sh &&
./run.sh

Run the block from the directory where you keep your repositories. If you already cloned the repository, enter this example's directory and run ./prepare.sh && ./run.sh.

Preparation downloads the Go module and any declared Python packages once. The workload then runs locally with offline input data. Every meaningful step is a separate process; independent activities run in parallel after their dependencies complete.

Read outputs/manifest.json for the generated artifacts, outputs/dag-validation.json for dependency waves, and outputs/stage-<activity>.json for each activity's observed result. A failed stage stops the run and prevents a successful final manifest.

Expected outputs: index.json, evaluation.json.

Run the same activities in Desktop

Start your local AkôFlow daemon with Docker available and configure AKOFLOW_API_TOKEN in your shell. From this example's directory, run:

go run ../../tools/daemon-local -root ../.. -example generative-ai/rag-indexing

This command validates the daemon connection, builds the declared image, registers the local environment and workflow, and submits a real run. The daemon owns execution and file transfers. Open the printed run ID in Desktop to inspect each activity.

RAG index construction and evaluation. Nodes in the same column can run in parallel once their dependencies complete.

Activity responsibilities

ActivityResponsibility
collect-documentsExecute the collect-documents stage and publish its declared outputs for downstream activities.
cleanExecute the clean stage and publish its declared outputs for downstream activities.
chunkExecute the chunk stage and publish its declared outputs for downstream activities.
embedExecute the embed stage and publish its declared outputs for downstream activities.
build-indexExecute the build-index stage and publish its declared outputs for downstream activities.
retrieval-testsExecute the retrieval-tests stage and publish its declared outputs for downstream activities.
answer-testsExecute the answer-tests stage and publish its declared outputs for downstream activities.
publishExecute the publish stage and publish its declared outputs for downstream activities.

Inputs

  • Source collection
  • Chunking policy
  • Model revisions

Outputs

  • index.json
  • evaluation.json

Provenance to preserve

  • Source revisions
  • Chunk identifiers
  • Prompts and models

Source bundle

The executable workflow and its implementation files are maintained in the separate AkôFlow examples repository. The documentation intentionally keeps code, container recipes, generators, and validation scripts out of the narrative page.

Open the complete source bundle ↗

Execution evidence

Verified on local Docker: 8/8 activities completed. These captures belong to run showcase-rag-indexing-local-51e75cdbe9-run-20261020t191344.209329000.

Read the daemon execution record · Local output manifest

Open full resolution ↗RAG index construction and evaluation: observed activity DAG
The observed activity graph. Click to see the complete capture.

Each stage also ran through the standalone local command. Read the dependency and artifact validation.

Execution considerations

Fan out document processing and embedding. Treat the vector database as a service while retaining immutable index evidence.

AkôFlow boundary: the engine schedules, deploys, executes, transfers data, and records evidence. The ML or agent framework remains an implementation choice inside each activity.