chore: added separate setup for api in degraded mode

rudderlabs · Aug 21, 2023 · f518596 · f518596
1 parent 09b9d6c
commit f518596
Showing 1 changed file with 11 additions and 7 deletions.
diff --git a/warehouse/warehouse.go b/warehouse/warehouse.go
@@ -411,13 +411,6 @@ func Start(ctx context.Context, app app.App) error {
 
 	RegisterAdmin(bcManager, pkgLogger)
 
-	api := NewApi(
-		mode,
-		config.Default, pkgLogger, stats.Default,
-		backendconfig.DefaultBackendConfig, wrappedDBHandle, &notifier, tenantManager,
-		bcManager, asyncWh,
-	)
-
 	runningMode := config.GetString("Warehouse.runningMode", "")
 	if runningMode == DegradedMode {
 		pkgLogger.Infof("WH: Running warehouse service in degraded mode...")
@@ -428,6 +421,12 @@ func Start(ctx context.Context, app app.App) error {
 				return err
 			}
 		}
+
+		api := NewApi(
+			mode, config.Default, pkgLogger, stats.Default,
+			backendconfig.DefaultBackendConfig, wrappedDBHandle, nil, tenantManager,
+			bcManager, nil,
+		)
 		return api.Start(ctx)
 	}
 	var err error
@@ -528,6 +527,11 @@ func Start(ctx context.Context, app app.App) error {
 	}
 
 	g.Go(func() error {
+		api := NewApi(
+			mode, config.Default, pkgLogger, stats.Default,
+			backendconfig.DefaultBackendConfig, wrappedDBHandle, &notifier, tenantManager,
+			bcManager, asyncWh,
+		)
 		return api.Start(gCtx)
 	})