Skip to content

Commit 15a4893

Browse files
committed
updating dt to 1.5.10 and fixing conflicts
Signed-off-by: salaboy <[email protected]>
1 parent b826edc commit 15a4893

File tree

3 files changed

+44
-6
lines changed

3 files changed

+44
-6
lines changed

sdk-workflows/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@
4747
<dependency>
4848
<groupId>io.dapr</groupId>
4949
<artifactId>durabletask-client</artifactId>
50-
<version>1.5.6</version>
50+
<version>1.5.10</version>
5151
</dependency>
5252
<!--
5353
manually declare durabletask-client's jackson dependencies

sdk-workflows/src/main/java/io/dapr/workflows/WorkflowTaskOptions.java

Lines changed: 38 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -17,18 +17,48 @@ public class WorkflowTaskOptions {
1717

1818
private final WorkflowTaskRetryPolicy retryPolicy;
1919
private final WorkflowTaskRetryHandler retryHandler;
20+
private final String appId;
2021

2122
public WorkflowTaskOptions(WorkflowTaskRetryPolicy retryPolicy, WorkflowTaskRetryHandler retryHandler) {
23+
this(retryPolicy, retryHandler, null);
24+
}
25+
26+
public WorkflowTaskOptions(WorkflowTaskRetryHandler retryHandler) {
27+
this(null, retryHandler, null);
28+
}
29+
30+
public WorkflowTaskOptions(WorkflowTaskRetryPolicy retryPolicy) {
31+
this(retryPolicy, null, null);
32+
}
33+
34+
/**
35+
* Constructor for WorkflowTaskOptions with app ID for cross-app calls.
36+
*
37+
* @param appId the ID of the app to call the activity in
38+
*/
39+
public WorkflowTaskOptions(String appId) {
40+
this(null, null, appId);
41+
}
42+
43+
/**
44+
* Constructor for WorkflowTaskOptions with retry policy, retry handler, and app ID.
45+
*
46+
* @param retryPolicy the retry policy
47+
* @param retryHandler the retry handler
48+
* @param appId the app ID for cross-app activity calls
49+
*/
50+
public WorkflowTaskOptions(WorkflowTaskRetryPolicy retryPolicy, WorkflowTaskRetryHandler retryHandler, String appId) {
2251
this.retryPolicy = retryPolicy;
2352
this.retryHandler = retryHandler;
53+
this.appId = appId;
2454
}
2555

26-
public WorkflowTaskOptions(WorkflowTaskRetryPolicy retryPolicy) {
27-
this(retryPolicy, null);
56+
public WorkflowTaskOptions(WorkflowTaskRetryPolicy retryPolicy, String appId) {
57+
this(retryPolicy, null, appId);
2858
}
2959

30-
public WorkflowTaskOptions(WorkflowTaskRetryHandler retryHandler) {
31-
this(null, retryHandler);
60+
public WorkflowTaskOptions(WorkflowTaskRetryHandler retryHandler, String appId) {
61+
this(null, retryHandler, appId);
3262
}
3363

3464
public WorkflowTaskRetryPolicy getRetryPolicy() {
@@ -39,4 +69,8 @@ public WorkflowTaskRetryHandler getRetryHandler() {
3969
return retryHandler;
4070
}
4171

72+
public String getAppId() {
73+
return appId;
74+
}
75+
4276
}

sdk-workflows/src/main/java/io/dapr/workflows/runtime/DefaultWorkflowContext.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -245,7 +245,11 @@ private TaskOptions toTaskOptions(WorkflowTaskOptions options) {
245245
RetryPolicy retryPolicy = toRetryPolicy(options.getRetryPolicy());
246246
RetryHandler retryHandler = toRetryHandler(options.getRetryHandler());
247247

248-
return new TaskOptions(retryPolicy, retryHandler);
248+
return TaskOptions.builder()
249+
.retryPolicy(retryPolicy)
250+
.retryHandler(retryHandler)
251+
.appID(options.getAppId())
252+
.build();
249253
}
250254

251255
/**

0 commit comments

Comments
 (0)