fix: add back deprecated service names and fix webhook worker query (#…

…660)
hatchet-dev · Jun 27, 2024 · c2debe6 · c2debe6
1 parent 09499d2
commit c2debe6
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 3 deletions.
diff --git a/cmd/hatchet-engine/engine/run.go b/cmd/hatchet-engine/engine/run.go
@@ -176,7 +176,9 @@ func RunWithConfig(ctx context.Context, sc *server.ServerConfig) ([]Teardown, er
 		})
 	}
 
-	if sc.HasService("queue") {
+	// FIXME: jobscontroller and workflowscontroller are deprecated service names, but there's not a clear upgrade
+	// path for old config files.
+	if sc.HasService("queue") || sc.HasService("jobscontroller") || sc.HasService("workflowscontroller") {
 		partitionTeardown, partitionId, err := p.withControllers(ctx)
 
 		if err != nil {

diff --git a/pkg/repository/prisma/dbsqlc/webhook_workers.sql b/pkg/repository/prisma/dbsqlc/webhook_workers.sql
@@ -5,7 +5,8 @@ WITH tenants AS (
     FROM
         "Tenant"
     WHERE
-        "workerPartitionId" = sqlc.arg('workerPartitionId')::text
+        "workerPartitionId" = sqlc.arg('workerPartitionId')::text OR
+        "workerPartitionId" IS NULL
 ), update_partition AS (
     UPDATE
         "TenantWorkerPartition"

diff --git a/pkg/repository/prisma/dbsqlc/webhook_workers.sql.go b/pkg/repository/prisma/dbsqlc/webhook_workers.sql.go