add vcjob

Author: dekaihu

pkg/resourceinterpreter/default/thirdparty/resourcecustomizations/batch.volcano.sh/v1alpha1/Job/customizations.yaml

@@ -110,10 +110,29 @@ spec:
             return nil
           end
         end
+
         function AggregateStatus(desiredObj, statusItems)
           if statusItems == nil then return desiredObj end
           if desiredObj.status == nil then desiredObj.status = {} end
-
+          
+          if #statusItems == 1 then
+            desiredObj.status = statusItems[1].status
+            return desiredObj
+          end
+          
+          local failedClusters = {}
+          local completedClusters = 0
+          local latestTransition = {}
+          local successfulClusters = 0
+          local hasFailed = false
+          local failedConditions = {}
+          local failedPhases = {
+            Failed = true,
+            Aborted = true,
+            Aborting = true,
+            Terminated = true,
+            Terminating = true,
+          }
           local status = {
             state = {},
             minAvailable = 0,
@@ -129,7 +148,6 @@ spec:
             controlledResources = {},
             conditions = {},
             runningDuration = "0s",
-            state = {}
           }
 
           for i = 1, #statusItems do
@@ -144,7 +162,6 @@ spec:
               status.unknown = status.unknown + (s.unknown or 0)
               status.version = math.max(status.version, s.version or 0)
               status.retryCount = status.retryCount + (s.retryCount or 0)
-              status.state = s.state
               if durationVal(s.runningDuration) > durationVal(status.runningDuration) then
                 status.runningDuration = s.runningDuration
               end
@@ -161,17 +178,62 @@ spec:
                   end
                 end
               end
+
               if s.controlledResources then
                 for k, v in pairs(s.controlledResources) do
                   status.controlledResources[k] = v
                 end
               end
               
-              if s.conditions ~= nil then
+              if s.conditions then
+                local clusterHasFailed = false
                 for _, c in ipairs(s.conditions) do
-                  table.insert(status.conditions, c)
+                  if failedPhases[c.status] then
+                    clusterHasFailed = true
+                    hasFailed = true
+                  end
+                  if not clusterHasFailed then
+                    local exist = latestTransition[c.status]
+                    if exist == nil or c.lastTransitionTime > exist.lastTransitionTime then
+                      latestTransition[c.status] = c
+                    end
+                  end
+                end
+                if clusterHasFailed and #failedConditions == 0 then
+                  failedConditions = s.conditions
                 end
               end
+
+              if s.state ~= nil then
+                local st = s.state
+                if st.phase == "Completed" then
+                  successfulClusters = successfulClusters + 1
+                elseif st.phase == "Failed" or st.phase == "Aborted" then
+                  table.insert(failedClusters, statusItems[i].clusterName)
+                end
+              end
+            end
+          end
+
+          if #failedClusters > 0 then
+            status.state.phase = "Failed"
+            status.state.reason = "VolcanoJobFailed"
+            status.state.message = "Job failed in clusters: " .. table.concat(failedClusters, ",")
+            status.state.lastTransitionTime =  os.date("!%Y-%m-%dT%H:%M:%SZ")
+          end
+
+          if successfulClusters == #statusItems and successfulClusters > 0 then
+            status.state.phase = "Completed"
+            status.state.reason = "Completed"
+            status.state.message = "Job completed successfully"
+            status.state.lastTransitionTime = os.date("!%Y-%m-%dT%H:%M:%SZ")   
+          end
+
+          if hasFailed then
+            status.conditions = failedConditions
+          else
+            for _, v in pairs(latestTransition) do
+              table.insert(status.conditions, v)
             end
           end