Skip to content

Commit 3bd16db

Browse files
committed
fix new apis
1 parent c185195 commit 3bd16db

File tree

13 files changed

+84
-6652
lines changed

13 files changed

+84
-6652
lines changed
Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
package com.uber.cadence;
2+
3+
import lombok.Data;
4+
import lombok.experimental.Accessors;
5+
6+
@Data
7+
@Accessors(chain = true)
8+
public class DiagnoseWorkflowExecutionRequest {
9+
private String domain;
10+
private WorkflowExecution workflow_execution;
11+
private String identity;
12+
}
Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,11 @@
1+
package com.uber.cadence;
2+
3+
import lombok.Data;
4+
import lombok.experimental.Accessors;
5+
6+
@Data
7+
@Accessors(chain = true)
8+
public class DiagnoseWorkflowExecutionResponse {
9+
private String domain;
10+
private WorkflowExecution diagnosticWorkflowExecution;
11+
}

src/main/java/com/uber/cadence/internal/compatibility/Thrift2ProtoAdapter.java

Lines changed: 0 additions & 1323 deletions
This file was deleted.

src/main/java/com/uber/cadence/internal/compatibility/proto/mappers/ResponseMapper.java

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,11 @@
4848
import static com.uber.cadence.internal.compatibility.proto.mappers.TypeMapper.workflowQueryMap;
4949
import static com.uber.cadence.internal.compatibility.proto.mappers.TypeMapper.workflowType;
5050

51-
import com.uber.cadence.api.v1.*;
51+
import com.uber.cadence.*;
52+
import com.uber.cadence.api.v1.GetClusterInfoResponse;
53+
import com.uber.cadence.api.v1.RecordActivityTaskHeartbeatByIDResponse;
54+
import com.uber.cadence.api.v1.ScanWorkflowExecutionsResponse;
55+
import com.uber.cadence.api.v1.SignalWithStartWorkflowExecutionResponse;
5256
import java.util.Map;
5357
import java.util.stream.Collectors;
5458

@@ -77,7 +81,7 @@ public static com.uber.cadence.DescribeTaskListResponse describeTaskListResponse
7781
}
7882
com.uber.cadence.DescribeTaskListResponse describeTaskListResponse =
7983
new com.uber.cadence.DescribeTaskListResponse();
80-
describeTaskListResponse.setPollers(pollerInfoArray(t.getPollersList()));
84+
describeTaskListResponse.setPollers(pollerInfoArray(t.getPollers()));
8185
describeTaskListResponse.setTaskListStatus(taskListStatus(t.getTaskListStatus()));
8286
return describeTaskListResponse;
8387
}

src/main/java/com/uber/cadence/internal/compatibility/proto/mappers/TypeMapper.java

Lines changed: 40 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -36,6 +36,46 @@
3636

3737
import com.google.common.base.Strings;
3838
import com.uber.cadence.api.v1.*;
39+
import com.uber.cadence.api.v1.ActivityType;
40+
import com.uber.cadence.api.v1.BadBinaries;
41+
import com.uber.cadence.api.v1.BadBinaryInfo;
42+
import com.uber.cadence.api.v1.ClusterReplicationConfiguration;
43+
import com.uber.cadence.api.v1.DataBlob;
44+
import com.uber.cadence.api.v1.Domain;
45+
import com.uber.cadence.api.v1.ExternalExecutionInfo;
46+
import com.uber.cadence.api.v1.Failure;
47+
import com.uber.cadence.api.v1.Header;
48+
import com.uber.cadence.api.v1.IndexedValueType;
49+
import com.uber.cadence.api.v1.Memo;
50+
import com.uber.cadence.api.v1.ParentExecutionInfo;
51+
import com.uber.cadence.api.v1.Payload;
52+
import com.uber.cadence.api.v1.PendingActivityInfo;
53+
import com.uber.cadence.api.v1.PendingChildExecutionInfo;
54+
import com.uber.cadence.api.v1.PendingDecisionInfo;
55+
import com.uber.cadence.api.v1.PollerInfo;
56+
import com.uber.cadence.api.v1.QueryRejected;
57+
import com.uber.cadence.api.v1.ResetPointInfo;
58+
import com.uber.cadence.api.v1.ResetPoints;
59+
import com.uber.cadence.api.v1.RetryPolicy;
60+
import com.uber.cadence.api.v1.SearchAttributes;
61+
import com.uber.cadence.api.v1.StartTimeFilter;
62+
import com.uber.cadence.api.v1.StatusFilter;
63+
import com.uber.cadence.api.v1.StickyExecutionAttributes;
64+
import com.uber.cadence.api.v1.SupportedClientVersions;
65+
import com.uber.cadence.api.v1.TaskIDBlock;
66+
import com.uber.cadence.api.v1.TaskList;
67+
import com.uber.cadence.api.v1.TaskListMetadata;
68+
import com.uber.cadence.api.v1.TaskListPartitionMetadata;
69+
import com.uber.cadence.api.v1.TaskListStatus;
70+
import com.uber.cadence.api.v1.WorkerVersionInfo;
71+
import com.uber.cadence.api.v1.WorkflowExecution;
72+
import com.uber.cadence.api.v1.WorkflowExecutionConfiguration;
73+
import com.uber.cadence.api.v1.WorkflowExecutionFilter;
74+
import com.uber.cadence.api.v1.WorkflowExecutionInfo;
75+
import com.uber.cadence.api.v1.WorkflowQuery;
76+
import com.uber.cadence.api.v1.WorkflowQueryResult;
77+
import com.uber.cadence.api.v1.WorkflowType;
78+
import com.uber.cadence.api.v1.WorkflowTypeFilter;
3979
import java.util.ArrayList;
4080
import java.util.Collections;
4181
import java.util.HashMap;

src/main/java/com/uber/cadence/internal/compatibility/thrift/HistoryMapper.java

Lines changed: 0 additions & 1181 deletions
This file was deleted.

0 commit comments

Comments
 (0)