Billy D. a8b5d9153d
Some checks failed
CI / Lint (push) Successful in 2m55s
CI / Release (push) Successful in 1m46s
CI / Test (push) Successful in 2m57s
CI / Notify (push) Has been cancelled
CI / Docker Build & Push (push) Has been cancelled
fix: use docker login CLI instead of login-action for Gitea compat
docker/login-action@v3 fails with 'Username and password required' on
Gitea Actions — secrets not passed to action with: inputs. Switch to
direct docker login CLI which reliably interpolates secrets in run: steps.
2026-02-21 19:34:28 -05:00
2026-02-20 07:11:03 -05:00
2026-02-19 17:52:31 -05:00
2026-02-02 11:08:05 +00:00
2026-02-19 17:52:31 -05:00

pipeline-bridge

Bridges NATS events to Argo Workflows and Kubeflow Pipelines. Subscribes to ai.pipeline.trigger and submits workflow runs to the appropriate engine, publishing status updates to ai.pipeline.status.{request_id}.

Supported Pipelines

Name Engine Template / Pipeline ID
document-ingestion Argo document-ingestion
batch-inference Argo batch-inference
model-evaluation Argo model-evaluation
rag-query Kubeflow rag-pipeline
voice-pipeline Kubeflow voice-pipeline

Configuration

Variable Default Description
KUBEFLOW_HOST http://ml-pipeline.kubeflow.svc.cluster.local:8888 Kubeflow Pipelines API
ARGO_HOST http://argo-server.argo.svc.cluster.local:2746 Argo Server API
ARGO_NAMESPACE ai-ml Namespace for Argo workflows

Plus all standard handler-base settings (NATS_URL, OTEL_*, HEALTH_PORT, etc.).

Build

go build -o pipeline-bridge .

Test

go test -v -race ./...

Docker

docker build -t pipeline-bridge .
Description
No description provided
Readme MIT 315 KiB
Languages
Go 96%
Dockerfile 4%