feat: write hash of actions to the worker

Author: mrkaye97

cmd/hatchet-migrate/migrate/migrations/20260428204451_v1_0_103.sql

@@ -0,0 +1,9 @@
+-- +goose Up
+-- +goose StatementBegin
+ALTER TABLE "Worker" ADD COLUMN "actionsHash" BYTEA;
+-- +goose StatementEnd
+
+-- +goose Down
+-- +goose StatementBegin
+ALTER TABLE "Worker" DROP COLUMN "actionsHash";
+-- +goose StatementEnd

pkg/repository/sqlcv1/models.go

@@ -434,7 +434,8 @@ INSERT INTO "Worker" (
     "language",
     "languageVersion",
     "os",
-    "runtimeExtra"
+    "runtimeExtra",
+    "actionsHash"
 ) VALUES (
     gen_random_uuid(),
     CURRENT_TIMESTAMP,
@@ -447,7 +448,8 @@ INSERT INTO "Worker" (
     sqlc.narg('language')::"WorkerSDKS",
     sqlc.narg('languageVersion')::text,
     sqlc.narg('os')::text,
-    sqlc.narg('runtimeExtra')::text
+    sqlc.narg('runtimeExtra')::text,
+    @actionsHash::bytea
 ) RETURNING *;
 
 -- name: LinkServicesToWorker :exec

pkg/repository/sqlcv1/workers.sql

@@ -2,6 +2,7 @@ package repository
 
 import (
 	"context"
+	"crypto/sha256"
 	"errors"
 	"fmt"
 	"time"
@@ -392,6 +393,16 @@ func (w *workerRepository) GetWorkerForEngine(ctx context.Context, tenantId uuid
 	})
 }
 
+func hashActions(actions []string) []byte {
+	h := sha256.New()
+
+	for _, action := range actions {
+		h.Write([]byte(action))
+	}
+
+	return h.Sum(nil)
+}
+
 func (w *workerRepository) CreateNewWorker(ctx context.Context, tenantId uuid.UUID, opts *CreateWorkerOpts) (*sqlcv1.Worker, error) {
 	preWorker, postWorker := w.m.Meter(ctx, sqlcv1.LimitResourceWORKER, tenantId, 1)
 
@@ -428,6 +439,7 @@ func (w *workerRepository) CreateNewWorker(ctx context.Context, tenantId uuid.UU
 		Tenantid:     tenantId,
 		Dispatcherid: opts.DispatcherId,
 		Name:         opts.Name,
+		Actionshash:  hashActions(opts.Actions),
 	}
 
 	// Default to self hosted

pkg/repository/sqlcv1/workers.sql.go

@@ -864,6 +864,7 @@ CREATE TABLE "Worker" (
     "runtimeExtra" TEXT,
     "sdkVersion" TEXT,
     "durableTaskDispatcherId" UUID,
+    "actionsHash" BYTEA,
 
     CONSTRAINT "Worker_pkey" PRIMARY KEY ("id")
 );