Skip to content

Commit 5091f9a

Browse files
authored
feat: remove suspended state from numaproj crds (#23359)
Signed-off-by: Dillen Padhiar <[email protected]>
1 parent c7a0fa3 commit 5091f9a

File tree

11 files changed

+14
-10
lines changed

11 files changed

+14
-10
lines changed

resource_customizations/numaflow.numaproj.io/MonoVertex/health.lua

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ if obj.status ~= nil then
2020
end
2121
return hs
2222
elseif obj.status.phase == "Paused" then
23-
hs.status = "Suspended"
23+
hs.status = "Healthy"
2424
hs.message = "MonoVertex is paused"
2525
return hs
2626
elseif obj.status.phase == "Running" then

resource_customizations/numaflow.numaproj.io/MonoVertex/health_test.yaml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,6 @@ tests:
1212
message: "Subresources are unhealthy"
1313
inputPath: testdata/degraded.yaml
1414
- healthStatus:
15-
status: Suspended
15+
status: Healthy
1616
message: "MonoVertex is paused"
17-
inputPath: testdata/suspended.yaml
17+
inputPath: testdata/paused.yaml

resource_customizations/numaflow.numaproj.io/Pipeline/health.lua

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ if obj.status ~= nil then
2020
end
2121
return hs
2222
elseif obj.status.phase == "Paused" or obj.status.phase == "Pausing" then
23-
hs.status = "Suspended"
23+
hs.status = "Healthy"
2424
hs.message = "Pipeline is paused"
2525
return hs
2626
elseif obj.status.phase == "Running" then

resource_customizations/numaflow.numaproj.io/Pipeline/health_test.yaml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,6 @@ tests:
1212
message: "Subresources are unhealthy"
1313
inputPath: testdata/degraded.yaml
1414
- healthStatus:
15-
status: Suspended
15+
status: Healthy
1616
message: "Pipeline is paused"
17-
inputPath: testdata/suspended.yaml
17+
inputPath: testdata/paused.yaml

resource_customizations/numaflow.numaproj.io/Vertex/health.lua

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,10 @@ if obj.status ~= nil then
2020
hs.message = healthy.message
2121
end
2222
return hs
23+
elseif obj.status.phase == "Paused" then
24+
hs.status = "Healthy"
25+
hs.message = "Vertex is paused"
26+
return hs
2327
elseif obj.status.phase == "Running" then
2428
hs.status = "Healthy"
2529
hs.message = "Vertex is healthy"

resource_customizations/numaplane.numaproj.io/MonoVertexRollout/health.lua

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -111,7 +111,7 @@ end
111111

112112
paused, reason = isPaused(obj)
113113
if paused then
114-
hs.status = "Suspended"
114+
hs.status = "Healthy"
115115
hs.message = reason
116116
return hs
117117
end

resource_customizations/numaplane.numaproj.io/MonoVertexRollout/health_test.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ tests:
88
message: "Healthy"
99
inputPath: testdata/MonoVertexRollout/healthy.yaml
1010
- healthStatus:
11-
status: Suspended
11+
status: Healthy
1212
message: "MonoVertex paused"
1313
inputPath: testdata/MonoVertexRollout/paused.yaml
1414
- healthStatus:

resource_customizations/numaplane.numaproj.io/PipelineRollout/health.lua

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,7 @@ end
110110

111111
paused, reason = isPaused(obj)
112112
if paused then
113-
hs.status = "Suspended"
113+
hs.status = "Healthy"
114114
hs.message = reason
115115
return hs
116116
end

0 commit comments

Comments
 (0)