From 705fdefc508d8b3ed1936981db6f17e167b4b5bb Mon Sep 17 00:00:00 2001
From: Paul Hinze <paul@miren.dev>
Date: Thu, 23 Jul 2026 14:58:25 -0500
Subject: [PATCH] Enable distributed runners by default

Distributed runners have baked long enough to graduate from the labs
opt-in. Flip the distributedrunners feature default to on, so every
cluster gets the distributed scheduler path (plus the runner command
tree and etcd mTLS) without --labs distributedrunners.

The labs flag stays as an escape hatch: an operator who sees badness can
force the old path back with MIREN_LABS=-distributedrunners. The parser
already handles the "-" disable prefix, so this is just a default flip
plus a regression guard so it can't silently revert.
---
 pkg/labs/features.yaml |  2 +-
 pkg/labs/labs.gen.go   |  2 +-
 pkg/labs/labs_test.go  | 11 +++++++++++
 3 files changed, 13 insertions(+), 2 deletions(-)

diff --git a/pkg/labs/features.yaml b/pkg/labs/features.yaml
index 466f0042d..694668600 100644
--- a/pkg/labs/features.yaml
+++ b/pkg/labs/features.yaml
@@ -2,7 +2,7 @@ features:
   - name: distributedrunners
     predicate: DistributedRunners
     description: Schedule jobs across multiple runner nodes
-    default: false
+    default: true
 
   - name: sagas
     predicate: Sagas
diff --git a/pkg/labs/labs.gen.go b/pkg/labs/labs.gen.go
index 4feaed4bf..f3413163e 100644
--- a/pkg/labs/labs.gen.go
+++ b/pkg/labs/labs.gen.go
@@ -37,7 +37,7 @@ var (
 
 // featureDefaults holds the default state for each feature
 var featureDefaults = map[string]bool{
-	FeatureDistributedRunners: false,
+	FeatureDistributedRunners: true,
 	FeatureSagas:              false,
 }
 
diff --git a/pkg/labs/labs_test.go b/pkg/labs/labs_test.go
index d27536399..c347664e5 100644
--- a/pkg/labs/labs_test.go
+++ b/pkg/labs/labs_test.go
@@ -18,6 +18,17 @@ func TestDisableFeatureWithPrefix(t *testing.T) {
 	}
 }
 
+func TestDistributedRunnersEnabledByDefault(t *testing.T) {
+	Reset()
+
+	// GA: distributed runners are on by default with no flags set.
+	Init(nil, nil)
+
+	if !DistributedRunners() {
+		t.Error("DistributedRunners should be enabled by default")
+	}
+}
+
 func TestCaseInsensitiveFeatureNames(t *testing.T) {
 	Reset()