[apiserver/ingest] Use single EDGE_FUNC_INGEST_TASK_QUEUE worker queue

dilyevsky · dilyevsky · commit 05ae67f3df9c · 2025-02-10T12:07:14.000-08:00
diff --git a/pkg/apiserver/extensions/edgefunctionrevision.go b/pkg/apiserver/extensions/edgefunctionrevision.go
@@ -87,7 +87,7 @@ func (r *EdgeFunctionRevisionGCReconciler) Reconcile(ctx context.Context, req re
 				// Execute cleanup workflow.
 				wOpts := tclient.StartWorkflowOptions{
 					ID:                       revision.Name + "-cleanup",
-					TaskQueue:                ingest.EdgeFunctionCleanupQueue,
+					TaskQueue:                ingest.EdgeFunctionIngestQueue,
 					WorkflowExecutionTimeout: 10 * time.Minute,
 				}
 				in := &ingest.EdgeFunctionIngestParams{
diff --git a/pkg/apiserver/ingest/edgefunction.go b/pkg/apiserver/ingest/edgefunction.go
@@ -41,8 +41,7 @@ import (
 )
 
 const (
-	EdgeFunctionIngestQueue  = "EDGE_FUNC_INGEST_TASK_QUEUE"
-	EdgeFunctionCleanupQueue = "EDGE_FUNC_CLEANUP_TASK_QUEUE"
+	EdgeFunctionIngestQueue = "EDGE_FUNC_INGEST_TASK_QUEUE"
 )
 
 const (

Original file line number	Diff line number	Diff line change
`@@ -87,7 +87,7 @@ func (r *EdgeFunctionRevisionGCReconciler) Reconcile(ctx context.Context, req re`
`87`	`87`	`// Execute cleanup workflow.`
`88`	`88`	`wOpts := tclient.StartWorkflowOptions{`
`89`	`89`	`ID: revision.Name + "-cleanup",`
`90`		`- TaskQueue: ingest.EdgeFunctionCleanupQueue,`
	`90`	`+ TaskQueue: ingest.EdgeFunctionIngestQueue,`
`91`	`91`	`WorkflowExecutionTimeout: 10 * time.Minute,`
`92`	`92`	`}`
`93`	`93`	`in := &ingest.EdgeFunctionIngestParams{`
Original file line number	Diff line number	Diff line change
`@@ -41,8 +41,7 @@ import (`
`41`	`41`	`)`
`42`	`42`
`43`	`43`	`const (`
`44`		`- EdgeFunctionIngestQueue = "EDGE_FUNC_INGEST_TASK_QUEUE"`
`45`		`- EdgeFunctionCleanupQueue = "EDGE_FUNC_CLEANUP_TASK_QUEUE"`
	`44`	`+ EdgeFunctionIngestQueue = "EDGE_FUNC_INGEST_TASK_QUEUE"`
`46`	`45`	`)`
`47`	`46`
`48`	`47`	`const (`