exit early if maxTasks <= 0

maxdml · maxdml · commit c89baea31c3d · 2025-08-29T17:23:14.000-07:00
diff --git a/dbos/system_database.go b/dbos/system_database.go
@@ -2079,6 +2079,10 @@ func (s *sysDB) dequeueWorkflows(ctx context.Context, input dequeueWorkflowsInpu
 		}
 	}
 
+	if maxTasks <= 0 {
+		return nil, nil
+	}
+
 	// Build the query to select workflows for dequeueing
 	// Use SKIP LOCKED when no global concurrency is set to avoid blocking,
 	// otherwise use NOWAIT to ensure consistent view across processes

Original file line number	Diff line number	Diff line change
`@@ -2079,6 +2079,10 @@ func (s *sysDB) dequeueWorkflows(ctx context.Context, input dequeueWorkflowsInpu`
`2079`	`2079`	`}`
`2080`	`2080`	`}`
`2081`	`2081`
	`2082`	`+ if maxTasks <= 0 {`
	`2083`	`+ return nil, nil`
	`2084`	`+ }`
	`2085`	`+`
`2082`	`2086`	`// Build the query to select workflows for dequeueing`
`2083`	`2087`	`// Use SKIP LOCKED when no global concurrency is set to avoid blocking,`
`2084`	`2088`	`// otherwise use NOWAIT to ensure consistent view across processes`