test

ConduitIO · Aug 21, 2024 · d3fe994 · d3fe994
1 parent ac28fab
commit d3fe994
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/pipeline/lifecycle_test.go b/pkg/pipeline/lifecycle_test.go
@@ -414,7 +414,7 @@ func TestServiceLifecycle_StopAll_Recovering(t *testing.T) {
 		// wait for pipeline to finish consuming records from the source
 		time.Sleep(100 * time.Millisecond)
 
-		pl.Status = StatusRecovering
+		pl.SetStatus(StatusRecovering)
 		tc.stopFn(ctx, is, ps, pl.ID)
 
 		// wait for pipeline to finish
@@ -426,7 +426,7 @@ func TestServiceLifecycle_StopAll_Recovering(t *testing.T) {
 			is.Equal("", pl.Error)
 		}
 
-		is.Equal(tc.want, pl.Status)
+		is.Equal(tc.want, pl.GetStatus())
 	}
 
 	testCases := []testCase{