nit

maxdml · maxdml · commit 293deac23b8b · 2025-08-12T16:13:02.000-07:00
diff --git a/dbos/queue.go b/dbos/queue.go
@@ -209,6 +209,7 @@ func (qr *queueRunner) run(ctx *dbosContext) {
 				registeredWorkflow, exists := ctx.workflowRegistry[wfName.(string)]
 				if !exists {
 					ctx.logger.Error("workflow function not found in registry", "workflow_name", workflow.name)
+					continue
 				}
 
 				// Deserialize input

Original file line number	Diff line number	Diff line change
`@@ -209,6 +209,7 @@ func (qr queueRunner) run(ctx dbosContext) {`
`209`	`209`	`registeredWorkflow, exists := ctx.workflowRegistry[wfName.(string)]`
`210`	`210`	`if !exists {`
`211`	`211`	`ctx.logger.Error("workflow function not found in registry", "workflow_name", workflow.name)`
	`212`	`+ continue`
`212`	`213`	`}`
`213`	`214`
`214`	`215`	`// Deserialize input`