disable river for now

target · Nov 12, 2024 · bc5a206 · bc5a206
1 parent 164e6b3
commit bc5a206
Showing 1 changed file with 10 additions and 9 deletions.
diff --git a/engine/engine.go b/engine/engine.go
@@ -284,9 +284,9 @@ func (p *Engine) Shutdown(ctx context.Context) error {
 
 func (p *Engine) _shutdown(ctx context.Context) (err error) {
 	close(p.shutdownCh)
-	if !p.cfg.DisableCycle {
-		err = p.cfg.River.Stop(ctx)
-	}
+	// if !p.cfg.DisableCycle {
+	// 	err = p.cfg.River.Stop(ctx)
+	// }
 	<-p.runLoopExit
 	return err
 }
@@ -549,12 +549,13 @@ func (p *Engine) _run(ctx context.Context) error {
 		}
 	}
 
-	go func() {
-		err := p.cfg.River.Start(ctx)
-		if err != nil {
-			log.Log(ctx, errors.Wrap(err, "start river"))
-		}
-	}()
+	// Disabled until we have our first worker (next PR)
+	// go func() {
+	// 	err := p.cfg.River.Start(ctx)
+	// 	if err != nil {
+	// 		log.Log(ctx, errors.Wrap(err, "start river"))
+	// 	}
+	// }()
 
 	dur := p.cfg.CycleTime
 	if dur == 0 {