[dev] Printing active builds (#1597)

toolkit/tools/scheduler/scheduler.go

@@ -322,12 +322,16 @@ func buildAllNodes(stopOnFailure, isGraphOptimized, canUseCache bool, packagesTo
 			stopBuilding = true
 		}
 
+		activeSRPMs := buildState.ActiveSRPMs()
+		activeSRPMsCount := len(activeSRPMs)
 		if stopBuilding {
-			outstandingBuilds := len(buildState.ActiveBuilds())
-			if outstandingBuilds == 0 {
+			if activeSRPMsCount == 0 {
 				break
 			}
-			logger.Log.Infof("Waiting for %d outstanding builds to complete", outstandingBuilds)
+		}
+
+		if res.Node.Type == pkggraph.TypeBuild {
+			logger.Log.Infof("%d currently active build(s): %v.", activeSRPMsCount, activeSRPMs)
 		}
 	}
 

toolkit/tools/scheduler/schedulerutils/graphbuildstate.go

@@ -4,6 +4,8 @@
 package schedulerutils
 
 import (
+	"path/filepath"
+
 	"microsoft.com/pkggen/internal/logger"
 	"microsoft.com/pkggen/internal/pkggraph"
 )
@@ -57,6 +59,17 @@ func (g *GraphBuildState) ActiveBuilds() map[int64]*BuildRequest {
 	return g.activeBuilds
 }
 
+// ActiveSRPMs returns a list of all SRPMs, which are currently being built.
+func (g *GraphBuildState) ActiveSRPMs() (builtSRPMs []string) {
+	for _, buildRequest := range g.activeBuilds {
+		if buildRequest.Node.Type == pkggraph.TypeBuild {
+			builtSRPMs = append(builtSRPMs, filepath.Base(buildRequest.Node.SrpmPath))
+		}
+	}
+
+	return
+}
+
 // BuildFailures returns a slice of all failed builds.
 func (g *GraphBuildState) BuildFailures() []*BuildResult {
 	return g.failures