Skip to content
@bubustack

BubuStack

Kubernetes-native workflow runtime for batch DAGs and streaming pipelines.
BubuStack

Kubernetes-native workflow runtime for batch DAGs and streaming pipelines.

LicenseKubernetesGoArtifact Hub


BubuStack is an open-source toolkit for declarative, composable workflows on Kubernetes. Define workflows as CRDs, review and promote them through pull requests, and run them with durable execution semantics for batch automation and streaming workloads.

Why BubuStack

  • GitOps-native - Workflows are CRDs. Version, review, and promote them through pull requests like any other infrastructure.
  • Durable execution - StoryRun and StepRun resources give you retries, timeouts, status, and observability at the workflow level.
  • Composable building blocks - Reusable Engrams (tasks) and Impulses (triggers) let you package common behavior without coupling everything into one controller.
  • Batch + streaming in one model - Use the same Story abstraction for DAG-style batch jobs and transport-backed streaming pipelines.

Quickstart

For fresh cluster setup, cert-manager, storage, Helm installation, and the first example, start with the website quickstart:

Repositories

RepositoryDescription
bobrapetStory, StoryRun, Engram, and Impulse controllers — the core operator
coreShared contracts, templating engine, transport runtime, and identity helpers
bobravoz-grpcTransport operator for streaming workloads with hub and peer-to-peer topologies
bubu-sdk-goGo SDK for building Engrams and Impulses with streaming, retries, and observability
tractatusCanonical protobuf definitions and multi-language transport artifacts
examplesRunnable examples for batch and streaming workflows
websitePublic documentation site and product pages
bubuilderUI and API work for browsing runs, stories, and engrams
bubu-registryRegistry and packaging work for sharing Engrams and Impulses
helm-chartsHelm charts for bobrapet, bobravoz-grpc, and bubuilder
engrams/*First-party Engrams — HTTP, OpenAI, LiveKit Bridge, MCP, VAD, Map-Reduce, and more
impulses/*First-party Impulses — Cron, GitHub webhooks, Kubernetes events, LiveKit webhooks

Examples

ExamplePatternWhat it shows
Hello WorldBatchZero-dependency quickstart - parallel steps, DAG dependencies, template expressions
Scheduled Health CheckBatchCron triggers, parallel fan-out, allowFailure, AI-powered summarization
Map-Reduce SummarizerBatchDynamic parallelism with sub-stories, map-reduce adapter, result aggregation
Content Digest (Simple)BatchRSS to AI extraction to newsletter to Discord via MCP adapter
Content Digest (Advanced)BatchMulti-feed fan-out with map-reduce, combined digest, Discord notification
Multi-Model ConsensusBatchSame template with different configs, fan-in judge pattern, structured output
GitHub PR ReviewBatchAI-powered PR review - GitHub webhooks, diff analysis, automated comments
Materialize DemoBatchOffloaded data handling - storage refs, materialization, controller-mode resolution
Pod Crash NotifierBatchKubernetes event watch, AI crash analysis, Discord alerts
LiveKit Text ChatStreamingText-only chat assistant via LiveKit data channels
LiveKit Live TranslationStreamingEnglish-to-French speech translation with VAD, STT, LLM, and TTS
LiveKit Voice AssistantStreamingVoice and chat dual-mode - VAD, STT, LLM, TTS with a parallel chat path

Watch the LiveKit realtime examples demo: YouTube.

Contributing

We welcome contributions of all kinds — bug fixes, new Engrams, documentation, and feature proposals.

Read the full Contributing Guide to get started.

Community


Apache 2.0 Licensed. Built for platform engineers, AI/ML teams, and anyone who believes workflows belong in Git.

Pinned Loading

  1. bobrapetbobrapetPublic

    Kubernetes operator for declarative AI workflows. Model pipelines as CRDs (Stories, Engrams, Impulses) with real‑time streaming and batch execution.

    Go 5 1

  2. bubu-sdk-gobubu-sdk-goPublic

    Official Go SDK for building Engrams & Impulses for bobrapet — type‑safe config/inputs, streaming via gRPC, retries, and OpenTelemetry.

    Go 3

  3. bobravoz-grpcbobravoz-grpcPublic

    Pluggable gRPC transport hub for bobrapet. Auto‑wires real‑time streaming topologies (P2P or Hub‑and‑Spoke) and executes in‑flight Story primitives.

    Go 3

  4. helm-chartshelm-chartsPublic

    Helm charts for BubuStack — bobrapet operator and bobravoz-grpc transport hub. Auto-synced from source repos on release.

    Go Template

  5. examplesexamplesPublic

    Runnable BubuStack example workflows and walkthroughs, from simple batch Stories to full realtime LiveKit voice pipelines.

Repositories

Showing 10 of 26 repositories

People

This organization has no public members. You must be a member to see who’s a part of this organization.

Top languages

Loading…

Most used topics

Loading…