Skip to content

Commit 91d8e90

Browse files
committed
comment
1 parent f7df447 commit 91d8e90

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

dbos/workflow.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -240,7 +240,7 @@ func registerWorkflow(ctx DBOSContext, workflowFQN string, fn WrappedWorkflowFun
240240
maxRetries: maxRetries,
241241
name: customName,
242242
}
243-
243+
244244
if _, exists := c.workflowRegistry.LoadOrStore(workflowFQN, entry); exists {
245245
c.logger.Error("workflow function already registered", "fqn", workflowFQN)
246246
panic(newConflictingRegistrationError(workflowFQN))
@@ -667,7 +667,7 @@ func (c *dbosContext) RunAsWorkflow(_ DBOSContext, fn WorkflowFunc, input any, o
667667
}
668668
// When enqueuing, we do not set a deadline. It'll be computed with the timeout during dequeue.
669669
if status == WorkflowStatusEnqueued {
670-
deadline = time.Time{} // No deadline for enqueued workflows
670+
deadline = time.Time{}
671671
}
672672

673673
if params.priority > uint(math.MaxInt) {

0 commit comments

Comments
 (0)