2490

Committed 13 Aug 2024 05:39PM CUT coverage: 61.99% (-0.03%) from 62.021%

Build # 2490

Build Type

push

buildkite

Committed by

web-flow

Commit Message

Removing fossa as it is migrated to snyk (#919)

Run Details

12090 of 19503 relevant lines covered (61.99%)

0.62 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/main/java/com/uber/cadence/internal/compatibility/proto/DecisionMapper.java

/*
 *  Modifications Copyright (c) 2017-2021 Uber Technologies Inc.
 *  Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
 *
 *  Licensed under the Apache License, Version 2.0 (the "License"). You may not
 *  use this file except in compliance with the License. A copy of the License is
 *  located at
 *
 *  http://aws.amazon.com/apache2.0
 *
 *  or in the "license" file accompanying this file. This file is distributed on
 *  an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
 *  express or implied. See the License for the specific language governing
 *  permissions and limitations under the License.
 */
package com.uber.cadence.internal.compatibility.proto;

import static com.uber.cadence.internal.compatibility.proto.EnumMapper.continueAsNewInitiator;
import static com.uber.cadence.internal.compatibility.proto.EnumMapper.parentClosePolicy;
import static com.uber.cadence.internal.compatibility.proto.EnumMapper.workflowIdReusePolicy;
import static com.uber.cadence.internal.compatibility.proto.Helpers.arrayToByteString;
import static com.uber.cadence.internal.compatibility.proto.Helpers.longToInt;
import static com.uber.cadence.internal.compatibility.proto.Helpers.secondsToDuration;
import static com.uber.cadence.internal.compatibility.proto.TypeMapper.activityType;
import static com.uber.cadence.internal.compatibility.proto.TypeMapper.failure;
import static com.uber.cadence.internal.compatibility.proto.TypeMapper.header;
import static com.uber.cadence.internal.compatibility.proto.TypeMapper.memo;
import static com.uber.cadence.internal.compatibility.proto.TypeMapper.payload;
import static com.uber.cadence.internal.compatibility.proto.TypeMapper.retryPolicy;
import static com.uber.cadence.internal.compatibility.proto.TypeMapper.searchAttributes;
import static com.uber.cadence.internal.compatibility.proto.TypeMapper.taskList;
import static com.uber.cadence.internal.compatibility.proto.TypeMapper.workflowExecution;
import static com.uber.cadence.internal.compatibility.proto.TypeMapper.workflowRunPair;
import static com.uber.cadence.internal.compatibility.proto.TypeMapper.workflowType;

import com.uber.cadence.api.v1.CancelTimerDecisionAttributes;
import com.uber.cadence.api.v1.CancelWorkflowExecutionDecisionAttributes;
import com.uber.cadence.api.v1.CompleteWorkflowExecutionDecisionAttributes;
import com.uber.cadence.api.v1.ContinueAsNewWorkflowExecutionDecisionAttributes;
import com.uber.cadence.api.v1.Decision;
import com.uber.cadence.api.v1.Decision.Builder;
import com.uber.cadence.api.v1.FailWorkflowExecutionDecisionAttributes;
import com.uber.cadence.api.v1.RecordMarkerDecisionAttributes;
import com.uber.cadence.api.v1.RequestCancelActivityTaskDecisionAttributes;
import com.uber.cadence.api.v1.RequestCancelExternalWorkflowExecutionDecisionAttributes;
import com.uber.cadence.api.v1.ScheduleActivityTaskDecisionAttributes;
import com.uber.cadence.api.v1.SignalExternalWorkflowExecutionDecisionAttributes;
import com.uber.cadence.api.v1.StartChildWorkflowExecutionDecisionAttributes;
import com.uber.cadence.api.v1.StartTimerDecisionAttributes;
import com.uber.cadence.api.v1.UpsertWorkflowSearchAttributesDecisionAttributes;
import java.util.ArrayList;
import java.util.List;

class DecisionMapper {

  static List<Decision> decisionArray(List<com.uber.cadence.Decision> t) {
    if (t == null) {
      return null;
    }

    List<Decision> v = new ArrayList<>();
    for (int i = 0; i < t.size(); i++) {
      v.add(decision(t.get(i)));
    }
    return v;
  }

  static Decision decision(com.uber.cadence.Decision d) {
    if (d == null) {
      return null;
    }
    Builder decision = Decision.newBuilder();
    switch (d.getDecisionType()) {
      case ScheduleActivityTask:
        {
          com.uber.cadence.ScheduleActivityTaskDecisionAttributes attr =
              d.getScheduleActivityTaskDecisionAttributes();
          ScheduleActivityTaskDecisionAttributes.Builder builder =
              ScheduleActivityTaskDecisionAttributes.newBuilder()
                  .setActivityId(attr.getActivityId())
                  .setActivityType(activityType(attr.getActivityType()))
                  .setTaskList(taskList(attr.getTaskList()))
                  .setInput(payload(attr.getInput()))
                  .setScheduleToCloseTimeout(
                      secondsToDuration(attr.getScheduleToCloseTimeoutSeconds()))
                  .setScheduleToStartTimeout(
                      secondsToDuration(attr.getScheduleToStartTimeoutSeconds()))
                  .setStartToCloseTimeout(secondsToDuration(attr.getStartToCloseTimeoutSeconds()))
                  .setHeartbeatTimeout(secondsToDuration(attr.getHeartbeatTimeoutSeconds()))
                  .setHeader(header(attr.getHeader()))
                  .setRequestLocalDispatch(attr.isRequestLocalDispatch());
          if (attr.getRetryPolicy() != null) {
            builder.setRetryPolicy(retryPolicy(attr.getRetryPolicy()));
          }
          if (attr.getDomain() != null) {
            builder.setDomain(attr.getDomain());
          }
          decision.setScheduleActivityTaskDecisionAttributes(builder);
        }
        break;
      case RequestCancelActivityTask:
        {
          com.uber.cadence.RequestCancelActivityTaskDecisionAttributes attr =
              d.getRequestCancelActivityTaskDecisionAttributes();
          decision.setRequestCancelActivityTaskDecisionAttributes(
              RequestCancelActivityTaskDecisionAttributes.newBuilder()
                  .setActivityId(attr.getActivityId()));
        }
        break;
      case StartTimer:
        {
          com.uber.cadence.StartTimerDecisionAttributes attr = d.getStartTimerDecisionAttributes();
          decision.setStartTimerDecisionAttributes(
              StartTimerDecisionAttributes.newBuilder()
                  .setTimerId(attr.getTimerId())
                  .setStartToFireTimeout(
                      secondsToDuration(longToInt(attr.getStartToFireTimeoutSeconds()))));
        }
        break;
      case CompleteWorkflowExecution:
        {
          com.uber.cadence.CompleteWorkflowExecutionDecisionAttributes attr =
              d.getCompleteWorkflowExecutionDecisionAttributes();
          decision.setCompleteWorkflowExecutionDecisionAttributes(
              CompleteWorkflowExecutionDecisionAttributes.newBuilder()
                  .setResult(payload(attr.getResult())));
        }
        break;
      case FailWorkflowExecution:
        {
          com.uber.cadence.FailWorkflowExecutionDecisionAttributes attr =
              d.getFailWorkflowExecutionDecisionAttributes();
          decision.setFailWorkflowExecutionDecisionAttributes(
              FailWorkflowExecutionDecisionAttributes.newBuilder()
                  .setFailure(failure(attr.getReason(), attr.getDetails())));
        }
        break;
      case CancelTimer:
        {
          com.uber.cadence.CancelTimerDecisionAttributes attr =
              d.getCancelTimerDecisionAttributes();
          decision.setCancelTimerDecisionAttributes(
              CancelTimerDecisionAttributes.newBuilder().setTimerId(attr.getTimerId()));
        }
        break;
      case CancelWorkflowExecution:
        {
          com.uber.cadence.CancelWorkflowExecutionDecisionAttributes attr =
              d.getCancelWorkflowExecutionDecisionAttributes();
          decision.setCancelWorkflowExecutionDecisionAttributes(
              CancelWorkflowExecutionDecisionAttributes.newBuilder()
                  .setDetails(payload(attr.getDetails())));
        }
        break;
      case RequestCancelExternalWorkflowExecution:
        {
          com.uber.cadence.RequestCancelExternalWorkflowExecutionDecisionAttributes attr =
              d.getRequestCancelExternalWorkflowExecutionDecisionAttributes();
          RequestCancelExternalWorkflowExecutionDecisionAttributes.Builder builder =
              RequestCancelExternalWorkflowExecutionDecisionAttributes.newBuilder()
                  .setDomain(attr.getDomain())
                  .setWorkflowExecution(workflowRunPair(attr.getWorkflowId(), attr.getRunId()))
                  .setChildWorkflowOnly(attr.isChildWorkflowOnly());
          if (attr.getControl() != null) {
            builder.setControl(arrayToByteString(attr.getControl()));
          }
          decision.setRequestCancelExternalWorkflowExecutionDecisionAttributes(builder);
        }
        break;
      case ContinueAsNewWorkflowExecution:
        {
          com.uber.cadence.ContinueAsNewWorkflowExecutionDecisionAttributes attr =
              d.getContinueAsNewWorkflowExecutionDecisionAttributes();
          ContinueAsNewWorkflowExecutionDecisionAttributes.Builder builder =
              ContinueAsNewWorkflowExecutionDecisionAttributes.newBuilder()
                  .setWorkflowType(workflowType(attr.getWorkflowType()))
                  .setTaskList(taskList(attr.getTaskList()))
                  .setInput(payload(attr.getInput()))
                  .setExecutionStartToCloseTimeout(
                      secondsToDuration(attr.getExecutionStartToCloseTimeoutSeconds()))
                  .setTaskStartToCloseTimeout(
                      secondsToDuration(attr.getTaskStartToCloseTimeoutSeconds()))
                  .setBackoffStartInterval(
                      secondsToDuration(attr.getBackoffStartIntervalInSeconds()))
                  .setInitiator(continueAsNewInitiator(attr.getInitiator()))
                  .setFailure(failure(attr.getFailureReason(), attr.getFailureDetails()))
                  .setLastCompletionResult(payload(attr.getLastCompletionResult()))
                  .setHeader(header(attr.getHeader()))
                  .setMemo(memo(attr.getMemo()))
                  .setSearchAttributes(searchAttributes(attr.getSearchAttributes()));
          if (attr.getRetryPolicy() != null) {
            builder.setRetryPolicy(retryPolicy(attr.getRetryPolicy()));
          }
          if (attr.getCronSchedule() != null) {
            builder.setCronSchedule(attr.getCronSchedule());
          }
          decision.setContinueAsNewWorkflowExecutionDecisionAttributes(builder);
        }
        break;
      case StartChildWorkflowExecution:
        {
          com.uber.cadence.StartChildWorkflowExecutionDecisionAttributes attr =
              d.getStartChildWorkflowExecutionDecisionAttributes();
          StartChildWorkflowExecutionDecisionAttributes.Builder builder =
              StartChildWorkflowExecutionDecisionAttributes.newBuilder()
                  .setDomain(attr.getDomain())
                  .setWorkflowId(attr.getWorkflowId())
                  .setWorkflowType(workflowType(attr.getWorkflowType()))
                  .setTaskList(taskList(attr.getTaskList()))
                  .setInput(payload(attr.getInput()))
                  .setExecutionStartToCloseTimeout(
                      secondsToDuration(attr.getExecutionStartToCloseTimeoutSeconds()))
                  .setTaskStartToCloseTimeout(
                      secondsToDuration(attr.getTaskStartToCloseTimeoutSeconds()))
                  .setParentClosePolicy(parentClosePolicy(attr.getParentClosePolicy()))
                  .setWorkflowIdReusePolicy(workflowIdReusePolicy(attr.getWorkflowIdReusePolicy()))
                  .setHeader(header(attr.getHeader()))
                  .setMemo(memo(attr.getMemo()))
                  .setSearchAttributes(searchAttributes(attr.getSearchAttributes()));
          if (attr.getRetryPolicy() != null) {
            builder.setRetryPolicy(retryPolicy(attr.getRetryPolicy()));
          }
          if (attr.getControl() != null) {
            builder.setControl(arrayToByteString(attr.getControl()));
          }
          if (attr.getCronSchedule() != null) {
            builder.setCronSchedule(attr.getCronSchedule());
          }
          decision.setStartChildWorkflowExecutionDecisionAttributes(builder);
        }
        break;
      case SignalExternalWorkflowExecution:
        {
          com.uber.cadence.SignalExternalWorkflowExecutionDecisionAttributes attr =
              d.getSignalExternalWorkflowExecutionDecisionAttributes();
          SignalExternalWorkflowExecutionDecisionAttributes.Builder builder =
              SignalExternalWorkflowExecutionDecisionAttributes.newBuilder()
                  .setDomain(attr.getDomain())
                  .setWorkflowExecution(workflowExecution(attr.getExecution()))
                  .setSignalName(attr.getSignalName())
                  .setInput(payload(attr.getInput()))
                  .setChildWorkflowOnly(attr.isChildWorkflowOnly());
          if (attr.getControl() != null) {
            builder.setControl(arrayToByteString(attr.getControl()));
          }
          decision.setSignalExternalWorkflowExecutionDecisionAttributes(builder);
        }
        break;
      case UpsertWorkflowSearchAttributes:
        {
          com.uber.cadence.UpsertWorkflowSearchAttributesDecisionAttributes attr =
              d.getUpsertWorkflowSearchAttributesDecisionAttributes();
          decision.setUpsertWorkflowSearchAttributesDecisionAttributes(
              UpsertWorkflowSearchAttributesDecisionAttributes.newBuilder()
                  .setSearchAttributes(searchAttributes(attr.getSearchAttributes())));
        }
        break;
      case RecordMarker:
        {
          com.uber.cadence.RecordMarkerDecisionAttributes attr =
              d.getRecordMarkerDecisionAttributes();
          decision.setRecordMarkerDecisionAttributes(
              RecordMarkerDecisionAttributes.newBuilder()
                  .setMarkerName(attr.getMarkerName())
                  .setDetails(payload(attr.getDetails()))
                  .setHeader(header(attr.getHeader())));
        }
        break;
      default:
        throw new IllegalArgumentException("unknown decision type");
    }
    return decision.build();
  }
}

1	/*
2	* Modifications Copyright (c) 2017-2021 Uber Technologies Inc.
3	* Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
4	*
5	* Licensed under the Apache License, Version 2.0 (the "License"). You may not
6	* use this file except in compliance with the License. A copy of the License is
7	* located at
8	*
9	* http://aws.amazon.com/apache2.0
10	*
11	* or in the "license" file accompanying this file. This file is distributed on
12	* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
13	* express or implied. See the License for the specific language governing
14	* permissions and limitations under the License.
15	*/
16	package com.uber.cadence.internal.compatibility.proto;
17
18	import static com.uber.cadence.internal.compatibility.proto.EnumMapper.continueAsNewInitiator;
19	import static com.uber.cadence.internal.compatibility.proto.EnumMapper.parentClosePolicy;
20	import static com.uber.cadence.internal.compatibility.proto.EnumMapper.workflowIdReusePolicy;
21	import static com.uber.cadence.internal.compatibility.proto.Helpers.arrayToByteString;
22	import static com.uber.cadence.internal.compatibility.proto.Helpers.longToInt;
23	import static com.uber.cadence.internal.compatibility.proto.Helpers.secondsToDuration;
24	import static com.uber.cadence.internal.compatibility.proto.TypeMapper.activityType;
25	import static com.uber.cadence.internal.compatibility.proto.TypeMapper.failure;
26	import static com.uber.cadence.internal.compatibility.proto.TypeMapper.header;
27	import static com.uber.cadence.internal.compatibility.proto.TypeMapper.memo;
28	import static com.uber.cadence.internal.compatibility.proto.TypeMapper.payload;
29	import static com.uber.cadence.internal.compatibility.proto.TypeMapper.retryPolicy;
30	import static com.uber.cadence.internal.compatibility.proto.TypeMapper.searchAttributes;
31	import static com.uber.cadence.internal.compatibility.proto.TypeMapper.taskList;
32	import static com.uber.cadence.internal.compatibility.proto.TypeMapper.workflowExecution;
33	import static com.uber.cadence.internal.compatibility.proto.TypeMapper.workflowRunPair;
34	import static com.uber.cadence.internal.compatibility.proto.TypeMapper.workflowType;
35
36	import com.uber.cadence.api.v1.CancelTimerDecisionAttributes;
37	import com.uber.cadence.api.v1.CancelWorkflowExecutionDecisionAttributes;
38	import com.uber.cadence.api.v1.CompleteWorkflowExecutionDecisionAttributes;
39	import com.uber.cadence.api.v1.ContinueAsNewWorkflowExecutionDecisionAttributes;
40	import com.uber.cadence.api.v1.Decision;
41	import com.uber.cadence.api.v1.Decision.Builder;
42	import com.uber.cadence.api.v1.FailWorkflowExecutionDecisionAttributes;
43	import com.uber.cadence.api.v1.RecordMarkerDecisionAttributes;
44	import com.uber.cadence.api.v1.RequestCancelActivityTaskDecisionAttributes;
45	import com.uber.cadence.api.v1.RequestCancelExternalWorkflowExecutionDecisionAttributes;
46	import com.uber.cadence.api.v1.ScheduleActivityTaskDecisionAttributes;
47	import com.uber.cadence.api.v1.SignalExternalWorkflowExecutionDecisionAttributes;
48	import com.uber.cadence.api.v1.StartChildWorkflowExecutionDecisionAttributes;
49	import com.uber.cadence.api.v1.StartTimerDecisionAttributes;
50	import com.uber.cadence.api.v1.UpsertWorkflowSearchAttributesDecisionAttributes;
51	import java.util.ArrayList;
52	import java.util.List;
53
54	class DecisionMapper {	×
55
56	static List<Decision> decisionArray(List<com.uber.cadence.Decision> t) {
57	if (t == null) {	×
58	return null;	×
59	}
60
61	List<Decision> v = new ArrayList<>();	×
62	for (int i = 0; i < t.size(); i++) {	×
63	v.add(decision(t.get(i)));	×
64	}
65	return v;	×
66	}
67
68	static Decision decision(com.uber.cadence.Decision d) {
69	if (d == null) {	×
70	return null;	×
71	}
72	Builder decision = Decision.newBuilder();	×
73	switch (d.getDecisionType()) {	×
74	case ScheduleActivityTask:
75	{
76	com.uber.cadence.ScheduleActivityTaskDecisionAttributes attr =	×
77	d.getScheduleActivityTaskDecisionAttributes();	×
78	ScheduleActivityTaskDecisionAttributes.Builder builder =
79	ScheduleActivityTaskDecisionAttributes.newBuilder()	×
80	.setActivityId(attr.getActivityId())	×
81	.setActivityType(activityType(attr.getActivityType()))	×
82	.setTaskList(taskList(attr.getTaskList()))	×
83	.setInput(payload(attr.getInput()))	×
84	.setScheduleToCloseTimeout(	×
85	secondsToDuration(attr.getScheduleToCloseTimeoutSeconds()))	×
86	.setScheduleToStartTimeout(	×
87	secondsToDuration(attr.getScheduleToStartTimeoutSeconds()))	×
88	.setStartToCloseTimeout(secondsToDuration(attr.getStartToCloseTimeoutSeconds()))	×
89	.setHeartbeatTimeout(secondsToDuration(attr.getHeartbeatTimeoutSeconds()))	×
90	.setHeader(header(attr.getHeader()))	×
91	.setRequestLocalDispatch(attr.isRequestLocalDispatch());	×
92	if (attr.getRetryPolicy() != null) {	×
93	builder.setRetryPolicy(retryPolicy(attr.getRetryPolicy()));	×
94	}
95	if (attr.getDomain() != null) {	×
96	builder.setDomain(attr.getDomain());	×
97	}
98	decision.setScheduleActivityTaskDecisionAttributes(builder);	×
99	}
100	break;	×
101	case RequestCancelActivityTask:
102	{
103	com.uber.cadence.RequestCancelActivityTaskDecisionAttributes attr =	×
104	d.getRequestCancelActivityTaskDecisionAttributes();	×
105	decision.setRequestCancelActivityTaskDecisionAttributes(	×
106	RequestCancelActivityTaskDecisionAttributes.newBuilder()	×
107	.setActivityId(attr.getActivityId()));	×
108	}
109	break;	×
110	case StartTimer:
111	{
112	com.uber.cadence.StartTimerDecisionAttributes attr = d.getStartTimerDecisionAttributes();	×
113	decision.setStartTimerDecisionAttributes(	×
114	StartTimerDecisionAttributes.newBuilder()	×
115	.setTimerId(attr.getTimerId())	×
116	.setStartToFireTimeout(	×
117	secondsToDuration(longToInt(attr.getStartToFireTimeoutSeconds()))));	×
118	}
119	break;	×
120	case CompleteWorkflowExecution:
121	{
122	com.uber.cadence.CompleteWorkflowExecutionDecisionAttributes attr =	×
123	d.getCompleteWorkflowExecutionDecisionAttributes();	×
124	decision.setCompleteWorkflowExecutionDecisionAttributes(	×
125	CompleteWorkflowExecutionDecisionAttributes.newBuilder()	×
126	.setResult(payload(attr.getResult())));	×
127	}
128	break;	×
129	case FailWorkflowExecution:
130	{
131	com.uber.cadence.FailWorkflowExecutionDecisionAttributes attr =	×
132	d.getFailWorkflowExecutionDecisionAttributes();	×
133	decision.setFailWorkflowExecutionDecisionAttributes(	×
134	FailWorkflowExecutionDecisionAttributes.newBuilder()	×
135	.setFailure(failure(attr.getReason(), attr.getDetails())));	×
136	}
137	break;	×
138	case CancelTimer:
139	{
140	com.uber.cadence.CancelTimerDecisionAttributes attr =	×
141	d.getCancelTimerDecisionAttributes();	×
142	decision.setCancelTimerDecisionAttributes(	×
143	CancelTimerDecisionAttributes.newBuilder().setTimerId(attr.getTimerId()));	×
144	}
145	break;	×
146	case CancelWorkflowExecution:
147	{
148	com.uber.cadence.CancelWorkflowExecutionDecisionAttributes attr =	×
149	d.getCancelWorkflowExecutionDecisionAttributes();	×
150	decision.setCancelWorkflowExecutionDecisionAttributes(	×
151	CancelWorkflowExecutionDecisionAttributes.newBuilder()	×
152	.setDetails(payload(attr.getDetails())));	×
153	}
154	break;	×
155	case RequestCancelExternalWorkflowExecution:
156	{
157	com.uber.cadence.RequestCancelExternalWorkflowExecutionDecisionAttributes attr =	×
158	d.getRequestCancelExternalWorkflowExecutionDecisionAttributes();	×
159	RequestCancelExternalWorkflowExecutionDecisionAttributes.Builder builder =
160	RequestCancelExternalWorkflowExecutionDecisionAttributes.newBuilder()	×
161	.setDomain(attr.getDomain())	×
162	.setWorkflowExecution(workflowRunPair(attr.getWorkflowId(), attr.getRunId()))	×
163	.setChildWorkflowOnly(attr.isChildWorkflowOnly());	×
164	if (attr.getControl() != null) {	×
165	builder.setControl(arrayToByteString(attr.getControl()));	×
166	}
167	decision.setRequestCancelExternalWorkflowExecutionDecisionAttributes(builder);	×
168	}
169	break;	×
170	case ContinueAsNewWorkflowExecution:
171	{
172	com.uber.cadence.ContinueAsNewWorkflowExecutionDecisionAttributes attr =	×
173	d.getContinueAsNewWorkflowExecutionDecisionAttributes();	×
174	ContinueAsNewWorkflowExecutionDecisionAttributes.Builder builder =
175	ContinueAsNewWorkflowExecutionDecisionAttributes.newBuilder()	×
176	.setWorkflowType(workflowType(attr.getWorkflowType()))	×
177	.setTaskList(taskList(attr.getTaskList()))	×
178	.setInput(payload(attr.getInput()))	×
179	.setExecutionStartToCloseTimeout(	×
180	secondsToDuration(attr.getExecutionStartToCloseTimeoutSeconds()))	×
181	.setTaskStartToCloseTimeout(	×
182	secondsToDuration(attr.getTaskStartToCloseTimeoutSeconds()))	×
183	.setBackoffStartInterval(	×
184	secondsToDuration(attr.getBackoffStartIntervalInSeconds()))	×
185	.setInitiator(continueAsNewInitiator(attr.getInitiator()))	×
186	.setFailure(failure(attr.getFailureReason(), attr.getFailureDetails()))	×
187	.setLastCompletionResult(payload(attr.getLastCompletionResult()))	×
188	.setHeader(header(attr.getHeader()))	×
189	.setMemo(memo(attr.getMemo()))	×
190	.setSearchAttributes(searchAttributes(attr.getSearchAttributes()));	×
191	if (attr.getRetryPolicy() != null) {	×
192	builder.setRetryPolicy(retryPolicy(attr.getRetryPolicy()));	×
193	}
194	if (attr.getCronSchedule() != null) {	×
195	builder.setCronSchedule(attr.getCronSchedule());	×
196	}
197	decision.setContinueAsNewWorkflowExecutionDecisionAttributes(builder);	×
198	}
199	break;	×
200	case StartChildWorkflowExecution:
201	{
202	com.uber.cadence.StartChildWorkflowExecutionDecisionAttributes attr =	×
203	d.getStartChildWorkflowExecutionDecisionAttributes();	×
204	StartChildWorkflowExecutionDecisionAttributes.Builder builder =
205	StartChildWorkflowExecutionDecisionAttributes.newBuilder()	×
206	.setDomain(attr.getDomain())	×
207	.setWorkflowId(attr.getWorkflowId())	×
208	.setWorkflowType(workflowType(attr.getWorkflowType()))	×
209	.setTaskList(taskList(attr.getTaskList()))	×
210	.setInput(payload(attr.getInput()))	×
211	.setExecutionStartToCloseTimeout(	×
212	secondsToDuration(attr.getExecutionStartToCloseTimeoutSeconds()))	×
213	.setTaskStartToCloseTimeout(	×
214	secondsToDuration(attr.getTaskStartToCloseTimeoutSeconds()))	×
215	.setParentClosePolicy(parentClosePolicy(attr.getParentClosePolicy()))	×
216	.setWorkflowIdReusePolicy(workflowIdReusePolicy(attr.getWorkflowIdReusePolicy()))	×
217	.setHeader(header(attr.getHeader()))	×
218	.setMemo(memo(attr.getMemo()))	×
219	.setSearchAttributes(searchAttributes(attr.getSearchAttributes()));	×
220	if (attr.getRetryPolicy() != null) {	×
221	builder.setRetryPolicy(retryPolicy(attr.getRetryPolicy()));	×
222	}
223	if (attr.getControl() != null) {	×
224	builder.setControl(arrayToByteString(attr.getControl()));	×
225	}
226	if (attr.getCronSchedule() != null) {	×
227	builder.setCronSchedule(attr.getCronSchedule());	×
228	}
229	decision.setStartChildWorkflowExecutionDecisionAttributes(builder);	×
230	}
231	break;	×
232	case SignalExternalWorkflowExecution:
233	{
234	com.uber.cadence.SignalExternalWorkflowExecutionDecisionAttributes attr =	×
235	d.getSignalExternalWorkflowExecutionDecisionAttributes();	×
236	SignalExternalWorkflowExecutionDecisionAttributes.Builder builder =
237	SignalExternalWorkflowExecutionDecisionAttributes.newBuilder()	×
238	.setDomain(attr.getDomain())	×
239	.setWorkflowExecution(workflowExecution(attr.getExecution()))	×
240	.setSignalName(attr.getSignalName())	×
241	.setInput(payload(attr.getInput()))	×
242	.setChildWorkflowOnly(attr.isChildWorkflowOnly());	×
243	if (attr.getControl() != null) {	×
244	builder.setControl(arrayToByteString(attr.getControl()));	×
245	}
246	decision.setSignalExternalWorkflowExecutionDecisionAttributes(builder);	×
247	}
248	break;	×
249	case UpsertWorkflowSearchAttributes:
250	{
251	com.uber.cadence.UpsertWorkflowSearchAttributesDecisionAttributes attr =	×
252	d.getUpsertWorkflowSearchAttributesDecisionAttributes();	×
253	decision.setUpsertWorkflowSearchAttributesDecisionAttributes(	×
254	UpsertWorkflowSearchAttributesDecisionAttributes.newBuilder()	×
255	.setSearchAttributes(searchAttributes(attr.getSearchAttributes())));	×
256	}
257	break;	×
258	case RecordMarker:
259	{
260	com.uber.cadence.RecordMarkerDecisionAttributes attr =	×
261	d.getRecordMarkerDecisionAttributes();	×
262	decision.setRecordMarkerDecisionAttributes(	×
263	RecordMarkerDecisionAttributes.newBuilder()	×
264	.setMarkerName(attr.getMarkerName())	×
265	.setDetails(payload(attr.getDetails()))	×
266	.setHeader(header(attr.getHeader())));	×
267	}
268	break;	×
269	default:
270	throw new IllegalArgumentException("unknown decision type");	×
271	}
272	return decision.build();	×
273	}
274	}

uber / cadence-java-client / 2490

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous