Skip to content

Commit f0177d7

Browse files
committed
spotless
1 parent dee7b87 commit f0177d7

3 files changed

Lines changed: 7 additions & 6 deletions

File tree

transact/src/main/java/dev/dbos/transact/database/dao/WorkflowDAO.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -377,8 +377,8 @@ public static void recordWorkflowError(DbContext ctx, String workflowId, String
377377
/**
378378
* Insert a workflow_status row and immediately mark it ERROR, for a workflow that was never
379379
* actually started. Used when an internal workflow that is responsible for starting a user
380-
* workflow fails before it can do so: without a status row, any handle awaiting the user
381-
* workflow would poll {@link #awaitWorkflowResult} forever.
380+
* workflow fails before it can do so: without a status row, any handle awaiting the user workflow
381+
* would poll {@link #awaitWorkflowResult} forever.
382382
*
383383
* @param initStatus metadata for the workflow that will be recorded as failed
384384
* @param error the error serialized as json

transact/src/main/java/dev/dbos/transact/internal/DBOSIntegration.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -196,9 +196,9 @@ public RegisteredWorkflow registerInternalWorkflow(
196196
}
197197

198198
/**
199-
* Record a terminal ERROR for a workflow that was never started, so handles awaiting it fail
200-
* fast instead of polling forever. Used by the built-in debouncer workflow when it cannot start
201-
* the user workflow it is responsible for.
199+
* Record a terminal ERROR for a workflow that was never started, so handles awaiting it fail fast
200+
* instead of polling forever. Used by the built-in debouncer workflow when it cannot start the
201+
* user workflow it is responsible for.
202202
*/
203203
public void recordErrorForUnstartedWorkflow(
204204
String workflowId,

transact/src/test/java/dev/dbos/transact/workflow/DebouncerTest.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -385,7 +385,8 @@ public void recoveryDoesNotRestartUserWorkflow() throws Exception {
385385
dbos.launch();
386386

387387
var handle =
388-
dbos.<String>debouncer().debounce("rec-key", Duration.ofMillis(300), () -> svc.process("v1"));
388+
dbos.<String>debouncer()
389+
.debounce("rec-key", Duration.ofMillis(300), () -> svc.process("v1"));
389390
String userWorkflowId = handle.workflowId();
390391
assertEquals("result:v1", handle.getResult());
391392
assertEquals(1, serviceImpl.callCount());

0 commit comments

Comments
 (0)