[perf] Remove unused perf-upload-worker perf/go/perfresults/workflows/worker never registers any Temporal workflows or activities, so the perf-upload-worker WorkerDeployment in skia-infra-public-dev was stuck in WaitingForPollers / NotRegistered since 2026-07-06 and fired RunningK8sAppNotCheckedIn. The WorkerDeployment was deleted from skia-infra-public-dev and never existed in skia-infra-public or skia-infra-corp. Remove the binary and its perf_upload_worker image target. Nothing else depends on this package. Bug: b/581001062 Change-Id: I016cd6bf6d9a947ef5c5b8fb064dd11f5c92aa70 Reviewed-on: https://skia-review.googlesource.com/c/buildbot/+/1416358 Reviewed-by: German Garcia <ggj@google.com> Reviewed-by: Eric Boren <borenet@google.com> Commit-Queue: Marco Esau Garcia Martinez <gmarcoesau@google.com>
diff --git a/perf/go/perfresults/workflows/worker/BUILD.bazel b/perf/go/perfresults/workflows/worker/BUILD.bazel deleted file mode 100644 index 87e6377..0000000 --- a/perf/go/perfresults/workflows/worker/BUILD.bazel +++ /dev/null
@@ -1,37 +0,0 @@ -load("@rules_go//go:def.bzl", "go_binary", "go_library") -load("//bazel:skia_app_container.bzl", "skia_app_container") - -go_library( - name = "worker_lib", - srcs = ["main.go"], - importpath = "go.skia.org/infra/perf/go/perfresults/workflows/worker", - visibility = ["//visibility:private"], - deps = [ - "//go/common", - "//go/sklog", - "//temporal/go/metrics", - "@io_temporal_go_sdk//client", - "@io_temporal_go_sdk//worker", - ], -) - -go_binary( - name = "worker", - embed = [":worker_lib"], - visibility = ["//visibility:public"], -) - -skia_app_container( - name = "perf_upload_worker", - base_image = "@basealpine", - dirs = { - "/usr/local/bin": [ - [ - ":worker", - "0755", - ], - ], - }, - entrypoint = "/usr/local/bin/worker", - repository = "skia-public/perf_upload_worker", -)
diff --git a/perf/go/perfresults/workflows/worker/main.go b/perf/go/perfresults/workflows/worker/main.go deleted file mode 100644 index 1069c7e..0000000 --- a/perf/go/perfresults/workflows/worker/main.go +++ /dev/null
@@ -1,63 +0,0 @@ -package main - -import ( - "flag" - "fmt" - "os" - "os/user" - - "go.skia.org/infra/go/common" - "go.skia.org/infra/go/sklog" - "go.skia.org/infra/temporal/go/metrics" - "go.temporal.io/sdk/client" - "go.temporal.io/sdk/worker" -) - -const appName = "perf-upload-worker" - -var ( - hostPort = flag.String("host_port", "localhost:7233", "Host the worker connects to.") - promPort = flag.String("prom_port", ":8000", "Prometheus port that it listens on.") - namespace = flag.String("namespace", "default", "The namespace the worker registered to.") - taskQueue = flag.String("task_queue", "", "Task queue name registered to worker services.") -) - -func main() { - flag.Parse() - - common.InitWithMust( - appName, - common.PrometheusOpt(promPort), - ) - - if *taskQueue == "" { - if u, err := user.Current(); err != nil { - sklog.Fatalf("Unable to get the current user: %s", err) - } else { - *taskQueue = fmt.Sprintf("localhost.%s", u.Username) - } - } - - // The client and worker are heavyweight objects that should be created once per process. - c, err := client.Dial(client.Options{ - MetricsHandler: metrics.NewMetricsHandler(map[string]string{}, nil), - HostPort: *hostPort, - Namespace: *namespace, - }) - if err != nil { - sklog.Fatalf("Unable to create client: %s", err) - } - defer c.Close() - - workerOpts := worker.Options{} - if buildID := os.Getenv("TEMPORAL_WORKER_BUILD_ID"); buildID != "" { - workerOpts.BuildID = buildID - workerOpts.UseBuildIDForVersioning = true - } - w := worker.New(c, *taskQueue, workerOpts) - - err = w.Run(worker.InterruptCh()) - if err != nil { - sklog.Fatalf("Unable to start worker: %s", err) - } -}