Author SHA1 Message Date
Francesco Renzi 6fcfe31040 log connection 2026-02-02 10:44:31 +01:00
Francesco Renzi bc6c5ed3e8 do not delete 2026-01-31 12:37:25 +01:00
Francesco Renzi c250298318 gging 2026-01-31 12:35:56 +01:00
Francesco Renzi 14887afcce no labels 2026-01-31 12:32:30 +01:00
2 changed files with 22 additions and 14 deletions
+3
View File
@@ -7,6 +7,7 @@ import (
"encoding/json" "encoding/json"
"fmt" "fmt"
"io" "io"
"log/slog"
"maps" "maps"
"net/http" "net/http"
"net/url" "net/url"
@@ -835,6 +836,8 @@ func (c *Client) getActionsServiceAdminConnection(ctx context.Context, rt *regis
return nil, fmt.Errorf("failed to get actions service admin connection: %w", err) return nil, fmt.Errorf("failed to get actions service admin connection: %w", err)
} }
slog.Info("got admin connection", *adminConnection.ActionsServiceURL)
return adminConnection, nil return adminConnection, nil
} }
+19 -14
View File
@@ -74,35 +74,40 @@ func run(ctx context.Context, c Config) error {
runnerGroupID = runnerGroup.ID runnerGroupID = runnerGroup.ID
} }
slog.Info("creating scale set")
// Create the runner scale set // Create the runner scale set
scaleSet, err := scalesetClient.CreateRunnerScaleSet(ctx, &scaleset.RunnerScaleSet{ scaleSet, err := scalesetClient.CreateRunnerScaleSet(ctx, &scaleset.RunnerScaleSet{
Name: c.ScaleSetName, Name: c.ScaleSetName,
RunnerGroupID: runnerGroupID, RunnerGroupID: runnerGroupID,
Labels: c.BuildLabels(), Labels: []scaleset.Label{},
RunnerSetting: scaleset.RunnerSetting{ RunnerSetting: scaleset.RunnerSetting{
DisableUpdate: true, DisableUpdate: true,
}, },
}) })
if err != nil { if err != nil {
slog.Error("failed to create", err)
return fmt.Errorf("failed to create runner scale set: %w", err) return fmt.Errorf("failed to create runner scale set: %w", err)
} }
slog.Info("created")
// Set the user agent for the scaleset client now that we have the scale set ID // Set the user agent for the scaleset client now that we have the scale set ID
scalesetClient.SetSystemInfo(systemInfo(scaleSet.ID)) scalesetClient.SetSystemInfo(systemInfo(scaleSet.ID))
defer func() { // defer func() {
logger.Info( // logger.Info(
"Deleting runner scale set", // "Deleting runner scale set",
slog.Int("scaleSetID", scaleSet.ID), // slog.Int("scaleSetID", scaleSet.ID),
) // )
if err := scalesetClient.DeleteRunnerScaleSet(context.WithoutCancel(ctx), scaleSet.ID); err != nil { // if err := scalesetClient.DeleteRunnerScaleSet(context.WithoutCancel(ctx), scaleSet.ID); err != nil {
slog.Error( // slog.Error(
"Failed to delete runner scale set", // "Failed to delete runner scale set",
slog.Int("scaleSetID", scaleSet.ID), // slog.Int("scaleSetID", scaleSet.ID),
slog.String("error", err.Error()), // slog.String("error", err.Error()),
) // )
} // }
}() // }()
dockerClient, err := dockerclient.NewClientWithOpts(dockerclient.FromEnv, dockerclient.WithAPIVersionNegotiation()) dockerClient, err := dockerclient.NewClientWithOpts(dockerclient.FromEnv, dockerclient.WithAPIVersionNegotiation())
if err != nil { if err != nil {