Skip to content

Commit 6003765

Browse files
committed
Remove deprecated usages
Signed-off-by: Matheus Cruz <[email protected]>
1 parent 5003630 commit 6003765

File tree

3 files changed

+10
-10
lines changed

3 files changed

+10
-10
lines changed

sdk-workflows/src/test/java/io/dapr/workflows/client/DaprWorkflowClientTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -199,7 +199,7 @@ public void waitForInstanceCompletion() throws TimeoutException {
199199
when(mockInnerClient.waitForInstanceCompletion(instanceId, timeout, true)).thenReturn(expectedMetadata);
200200

201201
// Act
202-
WorkflowInstanceStatus result = client.waitForInstanceCompletion(instanceId, timeout, true);
202+
WorkflowInstanceStatus result = client.waitForWorkflowCompletion(instanceId, timeout, true);
203203

204204
// Assert
205205
verify(mockInnerClient, times(1)).waitForInstanceCompletion(instanceId, timeout, true);

spring-boot-examples/workflows/multi-app/orchestrator/src/main/java/io/dapr/springboot/examples/orchestrator/CustomersRestController.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -84,7 +84,7 @@ public String getCustomerStatus(@RequestBody Customer customer) {
8484
if (workflowIdForCustomer == null || workflowIdForCustomer.isEmpty()) {
8585
return "N/A";
8686
}
87-
WorkflowInstanceStatus instanceState = daprWorkflowClient.getInstanceState(workflowIdForCustomer, true);
87+
WorkflowInstanceStatus instanceState = daprWorkflowClient.getWorkflowState(workflowIdForCustomer, true);
8888
assert instanceState != null;
8989
return "Workflow for Customer: " + customer.getCustomerName() + " is " + instanceState.getRuntimeStatus().name();
9090
}
@@ -101,7 +101,7 @@ public Customer getCustomerOutput(@RequestBody Customer customer) {
101101
if (workflowIdForCustomer == null || workflowIdForCustomer.isEmpty()) {
102102
return null;
103103
}
104-
WorkflowInstanceStatus instanceState = daprWorkflowClient.getInstanceState(workflowIdForCustomer, true);
104+
WorkflowInstanceStatus instanceState = daprWorkflowClient.getWorkflowState(workflowIdForCustomer, true);
105105
assert instanceState != null;
106106
return instanceState.readOutputAs(Customer.class);
107107
}

spring-boot-examples/workflows/patterns/src/main/java/io/dapr/springboot/examples/wfp/WorkflowPatternsRestController.java

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,7 @@ public String chain() throws TimeoutException {
6767
String instanceId = daprWorkflowClient.scheduleNewWorkflow(ChainWorkflow.class);
6868
logger.info("Workflow instance " + instanceId + " started");
6969
return daprWorkflowClient
70-
.waitForInstanceCompletion(instanceId, Duration.ofSeconds(10), true)
70+
.waitForWorkflowCompletion(instanceId, Duration.ofSeconds(10), true)
7171
.readOutputAs(String.class);
7272
}
7373

@@ -81,7 +81,7 @@ public String child() throws TimeoutException {
8181
String instanceId = daprWorkflowClient.scheduleNewWorkflow(ParentWorkflow.class);
8282
logger.info("Workflow instance " + instanceId + " started");
8383
return daprWorkflowClient
84-
.waitForInstanceCompletion(instanceId, Duration.ofSeconds(10), true)
84+
.waitForWorkflowCompletion(instanceId, Duration.ofSeconds(10), true)
8585
.readOutputAs(String.class);
8686
}
8787

@@ -97,7 +97,7 @@ public Result fanOutIn(@RequestBody List<String> listOfStrings) throws TimeoutEx
9797
logger.info("Workflow instance " + instanceId + " started");
9898

9999
// Block until the orchestration completes. Then print the final status, which includes the output.
100-
WorkflowInstanceStatus workflowInstanceStatus = daprWorkflowClient.waitForInstanceCompletion(
100+
WorkflowInstanceStatus workflowInstanceStatus = daprWorkflowClient.waitForWorkflowCompletion(
101101
instanceId,
102102
Duration.ofSeconds(30),
103103
true);
@@ -125,7 +125,7 @@ public Decision externalEventContinue(@RequestParam("orderId") String orderId, @
125125
logger.info("Workflow instance " + instanceId + " continue");
126126
daprWorkflowClient.raiseEvent(instanceId, "Approval", decision);
127127
WorkflowInstanceStatus workflowInstanceStatus = daprWorkflowClient
128-
.waitForInstanceCompletion(instanceId, null, true);
128+
.waitForWorkflowCompletion(instanceId, null, true);
129129
return workflowInstanceStatus.readOutputAs(Decision.class);
130130
}
131131

@@ -137,7 +137,7 @@ public CleanUpLog continueAsNew()
137137
String instanceId = daprWorkflowClient.scheduleNewWorkflow(ContinueAsNewWorkflow.class);
138138
logger.info("Workflow instance " + instanceId + " started");
139139

140-
WorkflowInstanceStatus workflowInstanceStatus = daprWorkflowClient.waitForInstanceCompletion(instanceId, null, true);
140+
WorkflowInstanceStatus workflowInstanceStatus = daprWorkflowClient.waitForWorkflowCompletion(instanceId, null, true);
141141
System.out.printf("workflow instance with ID: %s completed.", instanceId);
142142
return workflowInstanceStatus.readOutputAs(CleanUpLog.class);
143143
}
@@ -150,7 +150,7 @@ public Payload remoteEndpoint(@RequestBody Payload payload)
150150
logger.info("Workflow instance " + instanceId + " started");
151151

152152
WorkflowInstanceStatus workflowInstanceStatus = daprWorkflowClient
153-
.waitForInstanceCompletion(instanceId, null, true);
153+
.waitForWorkflowCompletion(instanceId, null, true);
154154
System.out.printf("workflow instance with ID: %s completed.", instanceId);
155155
return workflowInstanceStatus.readOutputAs(Payload.class);
156156
}
@@ -187,7 +187,7 @@ public Decision suspendResumeContinue(@RequestParam("orderId") String orderId, @
187187
logger.info("Workflow instance " + instanceId + " continue");
188188
daprWorkflowClient.raiseEvent(instanceId, "Approval", decision);
189189
WorkflowInstanceStatus workflowInstanceStatus = daprWorkflowClient
190-
.waitForInstanceCompletion(instanceId, null, true);
190+
.waitForWorkflowCompletion(instanceId, null, true);
191191
return workflowInstanceStatus.readOutputAs(Decision.class);
192192
}
193193

0 commit comments

Comments
 (0)