2016

Committed 11 Oct 2023 04:32PM CUT coverage: 60.271% (+0.08%) from 60.196%

Build # 2016

Build Type

push

buildkite

Committed by

web-flow

Commit Message

Release 3.10.1-fix (#860)

* fixed bug: Added alreadyStarted workflow case
* populate tasklist kind in poll request

Run Details

11349 of 18830 relevant lines covered (60.27%)

0.6 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/EnumMapper.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.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_BINARY;
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_CANCEL_TIMER_ATTRIBUTES;
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_CANCEL_WORKFLOW_EXECUTION_ATTRIBUTES;
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_COMPLETE_WORKFLOW_EXECUTION_ATTRIBUTES;
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_CONTINUE_AS_NEW_ATTRIBUTES;
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_FAIL_WORKFLOW_EXECUTION_ATTRIBUTES;
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_RECORD_MARKER_ATTRIBUTES;
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_REQUEST_CANCEL_ACTIVITY_ATTRIBUTES;
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_ATTRIBUTES;
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_SCHEDULE_ACTIVITY_ATTRIBUTES;
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_SEARCH_ATTRIBUTES;
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_SIGNAL_INPUT_SIZE;
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_SIGNAL_WORKFLOW_EXECUTION_ATTRIBUTES;
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_START_CHILD_EXECUTION_ATTRIBUTES;
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_START_TIMER_ATTRIBUTES;
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_FAILOVER_CLOSE_DECISION;
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_FORCE_CLOSE_DECISION;
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_INVALID;
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_RESET_STICKY_TASK_LIST;
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_RESET_WORKFLOW;
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_SCHEDULE_ACTIVITY_DUPLICATE_ID;
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_START_TIMER_DUPLICATE_ID;
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_UNHANDLED_DECISION;
import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_WORKFLOW_WORKER_UNHANDLED_FAILURE;
import static com.uber.cadence.api.v1.QueryResultType.QUERY_RESULT_TYPE_ANSWERED;
import static com.uber.cadence.api.v1.QueryResultType.QUERY_RESULT_TYPE_FAILED;
import static com.uber.cadence.api.v1.QueryResultType.QUERY_RESULT_TYPE_INVALID;

import com.uber.cadence.api.v1.ArchivalStatus;
import com.uber.cadence.api.v1.ContinueAsNewInitiator;
import com.uber.cadence.api.v1.DecisionTaskFailedCause;
import com.uber.cadence.api.v1.EventFilterType;
import com.uber.cadence.api.v1.ParentClosePolicy;
import com.uber.cadence.api.v1.QueryConsistencyLevel;
import com.uber.cadence.api.v1.QueryRejectCondition;
import com.uber.cadence.api.v1.QueryResultType;
import com.uber.cadence.api.v1.TaskListKind;
import com.uber.cadence.api.v1.TaskListType;
import com.uber.cadence.api.v1.WorkflowExecutionCloseStatus;
import com.uber.cadence.api.v1.WorkflowIdReusePolicy;

class EnumMapper {

  static TaskListKind taskListKind(com.uber.cadence.TaskListKind t) {
    if (t == null) {
      return TaskListKind.TASK_LIST_KIND_INVALID;
    }
    switch (t) {
      case NORMAL:
        return TaskListKind.TASK_LIST_KIND_NORMAL;
      case STICKY:
        return TaskListKind.TASK_LIST_KIND_STICKY;
    }
    throw new IllegalArgumentException("unexpected enum value");
  }

  static TaskListType taskListType(com.uber.cadence.TaskListType t) {
    if (t == null) {
      return TaskListType.TASK_LIST_TYPE_INVALID;
    }
    switch (t) {
      case Decision:
        return TaskListType.TASK_LIST_TYPE_DECISION;
      case Activity:
        return TaskListType.TASK_LIST_TYPE_ACTIVITY;
    }
    throw new IllegalArgumentException("unexpected enum value");
  }

  static EventFilterType eventFilterType(com.uber.cadence.HistoryEventFilterType t) {
    if (t == null) {
      return EventFilterType.EVENT_FILTER_TYPE_INVALID;
    }
    switch (t) {
      case ALL_EVENT:
        return EventFilterType.EVENT_FILTER_TYPE_ALL_EVENT;
      case CLOSE_EVENT:
        return EventFilterType.EVENT_FILTER_TYPE_CLOSE_EVENT;
    }
    throw new IllegalArgumentException("unexpected enum value");
  }

  static QueryRejectCondition queryRejectCondition(com.uber.cadence.QueryRejectCondition t) {
    if (t == null) {
      return QueryRejectCondition.QUERY_REJECT_CONDITION_INVALID;
    }
    switch (t) {
      case NOT_OPEN:
        return QueryRejectCondition.QUERY_REJECT_CONDITION_NOT_OPEN;
      case NOT_COMPLETED_CLEANLY:
        return QueryRejectCondition.QUERY_REJECT_CONDITION_NOT_COMPLETED_CLEANLY;
    }
    throw new IllegalArgumentException("unexpected enum value");
  }

  static QueryConsistencyLevel queryConsistencyLevel(com.uber.cadence.QueryConsistencyLevel t) {
    if (t == null) {
      return QueryConsistencyLevel.QUERY_CONSISTENCY_LEVEL_INVALID;
    }
    switch (t) {
      case EVENTUAL:
        return QueryConsistencyLevel.QUERY_CONSISTENCY_LEVEL_EVENTUAL;
      case STRONG:
        return QueryConsistencyLevel.QUERY_CONSISTENCY_LEVEL_STRONG;
    }
    throw new IllegalArgumentException("unexpected enum value");
  }

  static ContinueAsNewInitiator continueAsNewInitiator(com.uber.cadence.ContinueAsNewInitiator t) {
    if (t == null) {
      return ContinueAsNewInitiator.CONTINUE_AS_NEW_INITIATOR_INVALID;
    }
    switch (t) {
      case Decider:
        return ContinueAsNewInitiator.CONTINUE_AS_NEW_INITIATOR_DECIDER;
      case RetryPolicy:
        return ContinueAsNewInitiator.CONTINUE_AS_NEW_INITIATOR_RETRY_POLICY;
      case CronSchedule:
        return ContinueAsNewInitiator.CONTINUE_AS_NEW_INITIATOR_CRON_SCHEDULE;
    }
    throw new IllegalArgumentException("unexpected enum value");
  }

  static WorkflowIdReusePolicy workflowIdReusePolicy(com.uber.cadence.WorkflowIdReusePolicy t) {
    if (t == null) {
      return WorkflowIdReusePolicy.WORKFLOW_ID_REUSE_POLICY_INVALID;
    }
    switch (t) {
      case AllowDuplicateFailedOnly:
        return WorkflowIdReusePolicy.WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE_FAILED_ONLY;
      case AllowDuplicate:
        return WorkflowIdReusePolicy.WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE;
      case RejectDuplicate:
        return WorkflowIdReusePolicy.WORKFLOW_ID_REUSE_POLICY_REJECT_DUPLICATE;
      case TerminateIfRunning:
        return WorkflowIdReusePolicy.WORKFLOW_ID_REUSE_POLICY_TERMINATE_IF_RUNNING;
    }
    throw new IllegalArgumentException("unexpected enum value");
  }

  static QueryResultType queryResultType(com.uber.cadence.QueryResultType t) {
    if (t == null) {
      return QUERY_RESULT_TYPE_INVALID;
    }
    switch (t) {
      case ANSWERED:
        return QUERY_RESULT_TYPE_ANSWERED;
      case FAILED:
        return QUERY_RESULT_TYPE_FAILED;
    }
    throw new IllegalArgumentException("unexpected enum value");
  }

  static ArchivalStatus archivalStatus(com.uber.cadence.ArchivalStatus t) {
    if (t == null) {
      return ArchivalStatus.ARCHIVAL_STATUS_INVALID;
    }
    switch (t) {
      case DISABLED:
        return ArchivalStatus.ARCHIVAL_STATUS_DISABLED;
      case ENABLED:
        return ArchivalStatus.ARCHIVAL_STATUS_ENABLED;
    }
    throw new IllegalArgumentException("unexpected enum value");
  }

  static ParentClosePolicy parentClosePolicy(com.uber.cadence.ParentClosePolicy t) {
    if (t == null) {
      return ParentClosePolicy.PARENT_CLOSE_POLICY_INVALID;
    }
    switch (t) {
      case ABANDON:
        return ParentClosePolicy.PARENT_CLOSE_POLICY_ABANDON;
      case REQUEST_CANCEL:
        return ParentClosePolicy.PARENT_CLOSE_POLICY_REQUEST_CANCEL;
      case TERMINATE:
        return ParentClosePolicy.PARENT_CLOSE_POLICY_TERMINATE;
    }
    throw new IllegalArgumentException("unexpected enum value");
  }

  static DecisionTaskFailedCause decisionTaskFailedCause(
      com.uber.cadence.DecisionTaskFailedCause t) {
    if (t == null) {
      return DECISION_TASK_FAILED_CAUSE_INVALID;
    }
    switch (t) {
      case UNHANDLED_DECISION:
        return DECISION_TASK_FAILED_CAUSE_UNHANDLED_DECISION;
      case BAD_SCHEDULE_ACTIVITY_ATTRIBUTES:
        return DECISION_TASK_FAILED_CAUSE_BAD_SCHEDULE_ACTIVITY_ATTRIBUTES;
      case BAD_REQUEST_CANCEL_ACTIVITY_ATTRIBUTES:
        return DECISION_TASK_FAILED_CAUSE_BAD_REQUEST_CANCEL_ACTIVITY_ATTRIBUTES;
      case BAD_START_TIMER_ATTRIBUTES:
        return DECISION_TASK_FAILED_CAUSE_BAD_START_TIMER_ATTRIBUTES;
      case BAD_CANCEL_TIMER_ATTRIBUTES:
        return DECISION_TASK_FAILED_CAUSE_BAD_CANCEL_TIMER_ATTRIBUTES;
      case BAD_RECORD_MARKER_ATTRIBUTES:
        return DECISION_TASK_FAILED_CAUSE_BAD_RECORD_MARKER_ATTRIBUTES;
      case BAD_COMPLETE_WORKFLOW_EXECUTION_ATTRIBUTES:
        return DECISION_TASK_FAILED_CAUSE_BAD_COMPLETE_WORKFLOW_EXECUTION_ATTRIBUTES;
      case BAD_FAIL_WORKFLOW_EXECUTION_ATTRIBUTES:
        return DECISION_TASK_FAILED_CAUSE_BAD_FAIL_WORKFLOW_EXECUTION_ATTRIBUTES;
      case BAD_CANCEL_WORKFLOW_EXECUTION_ATTRIBUTES:
        return DECISION_TASK_FAILED_CAUSE_BAD_CANCEL_WORKFLOW_EXECUTION_ATTRIBUTES;
      case BAD_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_ATTRIBUTES:
        return DECISION_TASK_FAILED_CAUSE_BAD_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_ATTRIBUTES;
      case BAD_CONTINUE_AS_NEW_ATTRIBUTES:
        return DECISION_TASK_FAILED_CAUSE_BAD_CONTINUE_AS_NEW_ATTRIBUTES;
      case START_TIMER_DUPLICATE_ID:
        return DECISION_TASK_FAILED_CAUSE_START_TIMER_DUPLICATE_ID;
      case RESET_STICKY_TASKLIST:
        return DECISION_TASK_FAILED_CAUSE_RESET_STICKY_TASK_LIST;
      case WORKFLOW_WORKER_UNHANDLED_FAILURE:
        return DECISION_TASK_FAILED_CAUSE_WORKFLOW_WORKER_UNHANDLED_FAILURE;
      case BAD_SIGNAL_WORKFLOW_EXECUTION_ATTRIBUTES:
        return DECISION_TASK_FAILED_CAUSE_BAD_SIGNAL_WORKFLOW_EXECUTION_ATTRIBUTES;
      case BAD_START_CHILD_EXECUTION_ATTRIBUTES:
        return DECISION_TASK_FAILED_CAUSE_BAD_START_CHILD_EXECUTION_ATTRIBUTES;
      case FORCE_CLOSE_DECISION:
        return DECISION_TASK_FAILED_CAUSE_FORCE_CLOSE_DECISION;
      case FAILOVER_CLOSE_DECISION:
        return DECISION_TASK_FAILED_CAUSE_FAILOVER_CLOSE_DECISION;
      case BAD_SIGNAL_INPUT_SIZE:
        return DECISION_TASK_FAILED_CAUSE_BAD_SIGNAL_INPUT_SIZE;
      case RESET_WORKFLOW:
        return DECISION_TASK_FAILED_CAUSE_RESET_WORKFLOW;
      case BAD_BINARY:
        return DECISION_TASK_FAILED_CAUSE_BAD_BINARY;
      case SCHEDULE_ACTIVITY_DUPLICATE_ID:
        return DECISION_TASK_FAILED_CAUSE_SCHEDULE_ACTIVITY_DUPLICATE_ID;
      case BAD_SEARCH_ATTRIBUTES:
        return DECISION_TASK_FAILED_CAUSE_BAD_SEARCH_ATTRIBUTES;
    }
    throw new IllegalArgumentException("unexpected enum value");
  }

  static WorkflowExecutionCloseStatus workflowExecutionCloseStatus(
      com.uber.cadence.WorkflowExecutionCloseStatus t) {
    if (t == null) {
      return WorkflowExecutionCloseStatus.WORKFLOW_EXECUTION_CLOSE_STATUS_INVALID;
    }
    switch (t) {
      case COMPLETED:
        return WorkflowExecutionCloseStatus.WORKFLOW_EXECUTION_CLOSE_STATUS_COMPLETED;
      case FAILED:
        return WorkflowExecutionCloseStatus.WORKFLOW_EXECUTION_CLOSE_STATUS_FAILED;
      case CANCELED:
        return WorkflowExecutionCloseStatus.WORKFLOW_EXECUTION_CLOSE_STATUS_CANCELED;
      case TERMINATED:
        return WorkflowExecutionCloseStatus.WORKFLOW_EXECUTION_CLOSE_STATUS_TERMINATED;
      case CONTINUED_AS_NEW:
        return WorkflowExecutionCloseStatus.WORKFLOW_EXECUTION_CLOSE_STATUS_CONTINUED_AS_NEW;
      case TIMED_OUT:
        return WorkflowExecutionCloseStatus.WORKFLOW_EXECUTION_CLOSE_STATUS_TIMED_OUT;
    }
    throw new IllegalArgumentException("unexpected enum value");
  }

  static QueryResultType queryTaskCompletedType(com.uber.cadence.QueryTaskCompletedType t) {
    if (t == null) {
      return QUERY_RESULT_TYPE_INVALID;
    }
    switch (t) {
      case COMPLETED:
        return QUERY_RESULT_TYPE_ANSWERED;
      case FAILED:
        return QUERY_RESULT_TYPE_FAILED;
    }
    throw new IllegalArgumentException("unexpected enum value");
  }
}

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.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_BINARY;
19	import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_CANCEL_TIMER_ATTRIBUTES;
20	import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_CANCEL_WORKFLOW_EXECUTION_ATTRIBUTES;
21	import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_COMPLETE_WORKFLOW_EXECUTION_ATTRIBUTES;
22	import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_CONTINUE_AS_NEW_ATTRIBUTES;
23	import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_FAIL_WORKFLOW_EXECUTION_ATTRIBUTES;
24	import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_RECORD_MARKER_ATTRIBUTES;
25	import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_REQUEST_CANCEL_ACTIVITY_ATTRIBUTES;
26	import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_ATTRIBUTES;
27	import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_SCHEDULE_ACTIVITY_ATTRIBUTES;
28	import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_SEARCH_ATTRIBUTES;
29	import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_SIGNAL_INPUT_SIZE;
30	import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_SIGNAL_WORKFLOW_EXECUTION_ATTRIBUTES;
31	import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_START_CHILD_EXECUTION_ATTRIBUTES;
32	import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_BAD_START_TIMER_ATTRIBUTES;
33	import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_FAILOVER_CLOSE_DECISION;
34	import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_FORCE_CLOSE_DECISION;
35	import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_INVALID;
36	import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_RESET_STICKY_TASK_LIST;
37	import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_RESET_WORKFLOW;
38	import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_SCHEDULE_ACTIVITY_DUPLICATE_ID;
39	import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_START_TIMER_DUPLICATE_ID;
40	import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_UNHANDLED_DECISION;
41	import static com.uber.cadence.api.v1.DecisionTaskFailedCause.DECISION_TASK_FAILED_CAUSE_WORKFLOW_WORKER_UNHANDLED_FAILURE;
42	import static com.uber.cadence.api.v1.QueryResultType.QUERY_RESULT_TYPE_ANSWERED;
43	import static com.uber.cadence.api.v1.QueryResultType.QUERY_RESULT_TYPE_FAILED;
44	import static com.uber.cadence.api.v1.QueryResultType.QUERY_RESULT_TYPE_INVALID;
45
46	import com.uber.cadence.api.v1.ArchivalStatus;
47	import com.uber.cadence.api.v1.ContinueAsNewInitiator;
48	import com.uber.cadence.api.v1.DecisionTaskFailedCause;
49	import com.uber.cadence.api.v1.EventFilterType;
50	import com.uber.cadence.api.v1.ParentClosePolicy;
51	import com.uber.cadence.api.v1.QueryConsistencyLevel;
52	import com.uber.cadence.api.v1.QueryRejectCondition;
53	import com.uber.cadence.api.v1.QueryResultType;
54	import com.uber.cadence.api.v1.TaskListKind;
55	import com.uber.cadence.api.v1.TaskListType;
56	import com.uber.cadence.api.v1.WorkflowExecutionCloseStatus;
57	import com.uber.cadence.api.v1.WorkflowIdReusePolicy;
58
59	class EnumMapper {	×
60
61	static TaskListKind taskListKind(com.uber.cadence.TaskListKind t) {
62	if (t == null) {	×
63	return TaskListKind.TASK_LIST_KIND_INVALID;	×
64	}
65	switch (t) {	×
66	case NORMAL:
67	return TaskListKind.TASK_LIST_KIND_NORMAL;	×
68	case STICKY:
69	return TaskListKind.TASK_LIST_KIND_STICKY;	×
70	}
71	throw new IllegalArgumentException("unexpected enum value");	×
72	}
73
74	static TaskListType taskListType(com.uber.cadence.TaskListType t) {
75	if (t == null) {	×
76	return TaskListType.TASK_LIST_TYPE_INVALID;	×
77	}
78	switch (t) {	×
79	case Decision:
80	return TaskListType.TASK_LIST_TYPE_DECISION;	×
81	case Activity:
82	return TaskListType.TASK_LIST_TYPE_ACTIVITY;	×
83	}
84	throw new IllegalArgumentException("unexpected enum value");	×
85	}
86
87	static EventFilterType eventFilterType(com.uber.cadence.HistoryEventFilterType t) {
88	if (t == null) {	×
89	return EventFilterType.EVENT_FILTER_TYPE_INVALID;	×
90	}
91	switch (t) {	×
92	case ALL_EVENT:
93	return EventFilterType.EVENT_FILTER_TYPE_ALL_EVENT;	×
94	case CLOSE_EVENT:
95	return EventFilterType.EVENT_FILTER_TYPE_CLOSE_EVENT;	×
96	}
97	throw new IllegalArgumentException("unexpected enum value");	×
98	}
99
100	static QueryRejectCondition queryRejectCondition(com.uber.cadence.QueryRejectCondition t) {
101	if (t == null) {	×
102	return QueryRejectCondition.QUERY_REJECT_CONDITION_INVALID;	×
103	}
104	switch (t) {	×
105	case NOT_OPEN:
106	return QueryRejectCondition.QUERY_REJECT_CONDITION_NOT_OPEN;	×
107	case NOT_COMPLETED_CLEANLY:
108	return QueryRejectCondition.QUERY_REJECT_CONDITION_NOT_COMPLETED_CLEANLY;	×
109	}
110	throw new IllegalArgumentException("unexpected enum value");	×
111	}
112
113	static QueryConsistencyLevel queryConsistencyLevel(com.uber.cadence.QueryConsistencyLevel t) {
114	if (t == null) {	×
115	return QueryConsistencyLevel.QUERY_CONSISTENCY_LEVEL_INVALID;	×
116	}
117	switch (t) {	×
118	case EVENTUAL:
119	return QueryConsistencyLevel.QUERY_CONSISTENCY_LEVEL_EVENTUAL;	×
120	case STRONG:
121	return QueryConsistencyLevel.QUERY_CONSISTENCY_LEVEL_STRONG;	×
122	}
123	throw new IllegalArgumentException("unexpected enum value");	×
124	}
125
126	static ContinueAsNewInitiator continueAsNewInitiator(com.uber.cadence.ContinueAsNewInitiator t) {
127	if (t == null) {	×
128	return ContinueAsNewInitiator.CONTINUE_AS_NEW_INITIATOR_INVALID;	×
129	}
130	switch (t) {	×
131	case Decider:
132	return ContinueAsNewInitiator.CONTINUE_AS_NEW_INITIATOR_DECIDER;	×
133	case RetryPolicy:
134	return ContinueAsNewInitiator.CONTINUE_AS_NEW_INITIATOR_RETRY_POLICY;	×
135	case CronSchedule:
136	return ContinueAsNewInitiator.CONTINUE_AS_NEW_INITIATOR_CRON_SCHEDULE;	×
137	}
138	throw new IllegalArgumentException("unexpected enum value");	×
139	}
140
141	static WorkflowIdReusePolicy workflowIdReusePolicy(com.uber.cadence.WorkflowIdReusePolicy t) {
142	if (t == null) {	×
143	return WorkflowIdReusePolicy.WORKFLOW_ID_REUSE_POLICY_INVALID;	×
144	}
145	switch (t) {	×
146	case AllowDuplicateFailedOnly:
147	return WorkflowIdReusePolicy.WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE_FAILED_ONLY;	×
148	case AllowDuplicate:
149	return WorkflowIdReusePolicy.WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE;	×
150	case RejectDuplicate:
151	return WorkflowIdReusePolicy.WORKFLOW_ID_REUSE_POLICY_REJECT_DUPLICATE;	×
152	case TerminateIfRunning:
153	return WorkflowIdReusePolicy.WORKFLOW_ID_REUSE_POLICY_TERMINATE_IF_RUNNING;	×
154	}
155	throw new IllegalArgumentException("unexpected enum value");	×
156	}
157
158	static QueryResultType queryResultType(com.uber.cadence.QueryResultType t) {
159	if (t == null) {	×
160	return QUERY_RESULT_TYPE_INVALID;	×
161	}
162	switch (t) {	×
163	case ANSWERED:
164	return QUERY_RESULT_TYPE_ANSWERED;	×
165	case FAILED:
166	return QUERY_RESULT_TYPE_FAILED;	×
167	}
168	throw new IllegalArgumentException("unexpected enum value");	×
169	}
170
171	static ArchivalStatus archivalStatus(com.uber.cadence.ArchivalStatus t) {
172	if (t == null) {	×
173	return ArchivalStatus.ARCHIVAL_STATUS_INVALID;	×
174	}
175	switch (t) {	×
176	case DISABLED:
177	return ArchivalStatus.ARCHIVAL_STATUS_DISABLED;	×
178	case ENABLED:
179	return ArchivalStatus.ARCHIVAL_STATUS_ENABLED;	×
180	}
181	throw new IllegalArgumentException("unexpected enum value");	×
182	}
183
184	static ParentClosePolicy parentClosePolicy(com.uber.cadence.ParentClosePolicy t) {
185	if (t == null) {	×
186	return ParentClosePolicy.PARENT_CLOSE_POLICY_INVALID;	×
187	}
188	switch (t) {	×
189	case ABANDON:
190	return ParentClosePolicy.PARENT_CLOSE_POLICY_ABANDON;	×
191	case REQUEST_CANCEL:
192	return ParentClosePolicy.PARENT_CLOSE_POLICY_REQUEST_CANCEL;	×
193	case TERMINATE:
194	return ParentClosePolicy.PARENT_CLOSE_POLICY_TERMINATE;	×
195	}
196	throw new IllegalArgumentException("unexpected enum value");	×
197	}
198
199	static DecisionTaskFailedCause decisionTaskFailedCause(
200	com.uber.cadence.DecisionTaskFailedCause t) {
201	if (t == null) {	×
202	return DECISION_TASK_FAILED_CAUSE_INVALID;	×
203	}
204	switch (t) {	×
205	case UNHANDLED_DECISION:
206	return DECISION_TASK_FAILED_CAUSE_UNHANDLED_DECISION;	×
207	case BAD_SCHEDULE_ACTIVITY_ATTRIBUTES:
208	return DECISION_TASK_FAILED_CAUSE_BAD_SCHEDULE_ACTIVITY_ATTRIBUTES;	×
209	case BAD_REQUEST_CANCEL_ACTIVITY_ATTRIBUTES:
210	return DECISION_TASK_FAILED_CAUSE_BAD_REQUEST_CANCEL_ACTIVITY_ATTRIBUTES;	×
211	case BAD_START_TIMER_ATTRIBUTES:
212	return DECISION_TASK_FAILED_CAUSE_BAD_START_TIMER_ATTRIBUTES;	×
213	case BAD_CANCEL_TIMER_ATTRIBUTES:
214	return DECISION_TASK_FAILED_CAUSE_BAD_CANCEL_TIMER_ATTRIBUTES;	×
215	case BAD_RECORD_MARKER_ATTRIBUTES:
216	return DECISION_TASK_FAILED_CAUSE_BAD_RECORD_MARKER_ATTRIBUTES;	×
217	case BAD_COMPLETE_WORKFLOW_EXECUTION_ATTRIBUTES:
218	return DECISION_TASK_FAILED_CAUSE_BAD_COMPLETE_WORKFLOW_EXECUTION_ATTRIBUTES;	×
219	case BAD_FAIL_WORKFLOW_EXECUTION_ATTRIBUTES:
220	return DECISION_TASK_FAILED_CAUSE_BAD_FAIL_WORKFLOW_EXECUTION_ATTRIBUTES;	×
221	case BAD_CANCEL_WORKFLOW_EXECUTION_ATTRIBUTES:
222	return DECISION_TASK_FAILED_CAUSE_BAD_CANCEL_WORKFLOW_EXECUTION_ATTRIBUTES;	×
223	case BAD_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_ATTRIBUTES:
224	return DECISION_TASK_FAILED_CAUSE_BAD_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_ATTRIBUTES;	×
225	case BAD_CONTINUE_AS_NEW_ATTRIBUTES:
226	return DECISION_TASK_FAILED_CAUSE_BAD_CONTINUE_AS_NEW_ATTRIBUTES;	×
227	case START_TIMER_DUPLICATE_ID:
228	return DECISION_TASK_FAILED_CAUSE_START_TIMER_DUPLICATE_ID;	×
229	case RESET_STICKY_TASKLIST:
230	return DECISION_TASK_FAILED_CAUSE_RESET_STICKY_TASK_LIST;	×
231	case WORKFLOW_WORKER_UNHANDLED_FAILURE:
232	return DECISION_TASK_FAILED_CAUSE_WORKFLOW_WORKER_UNHANDLED_FAILURE;	×
233	case BAD_SIGNAL_WORKFLOW_EXECUTION_ATTRIBUTES:
234	return DECISION_TASK_FAILED_CAUSE_BAD_SIGNAL_WORKFLOW_EXECUTION_ATTRIBUTES;	×
235	case BAD_START_CHILD_EXECUTION_ATTRIBUTES:
236	return DECISION_TASK_FAILED_CAUSE_BAD_START_CHILD_EXECUTION_ATTRIBUTES;	×
237	case FORCE_CLOSE_DECISION:
238	return DECISION_TASK_FAILED_CAUSE_FORCE_CLOSE_DECISION;	×
239	case FAILOVER_CLOSE_DECISION:
240	return DECISION_TASK_FAILED_CAUSE_FAILOVER_CLOSE_DECISION;	×
241	case BAD_SIGNAL_INPUT_SIZE:
242	return DECISION_TASK_FAILED_CAUSE_BAD_SIGNAL_INPUT_SIZE;	×
243	case RESET_WORKFLOW:
244	return DECISION_TASK_FAILED_CAUSE_RESET_WORKFLOW;	×
245	case BAD_BINARY:
246	return DECISION_TASK_FAILED_CAUSE_BAD_BINARY;	×
247	case SCHEDULE_ACTIVITY_DUPLICATE_ID:
248	return DECISION_TASK_FAILED_CAUSE_SCHEDULE_ACTIVITY_DUPLICATE_ID;	×
249	case BAD_SEARCH_ATTRIBUTES:
250	return DECISION_TASK_FAILED_CAUSE_BAD_SEARCH_ATTRIBUTES;	×
251	}
252	throw new IllegalArgumentException("unexpected enum value");	×
253	}
254
255	static WorkflowExecutionCloseStatus workflowExecutionCloseStatus(
256	com.uber.cadence.WorkflowExecutionCloseStatus t) {
257	if (t == null) {	×
258	return WorkflowExecutionCloseStatus.WORKFLOW_EXECUTION_CLOSE_STATUS_INVALID;	×
259	}
260	switch (t) {	×
261	case COMPLETED:
262	return WorkflowExecutionCloseStatus.WORKFLOW_EXECUTION_CLOSE_STATUS_COMPLETED;	×
263	case FAILED:
264	return WorkflowExecutionCloseStatus.WORKFLOW_EXECUTION_CLOSE_STATUS_FAILED;	×
265	case CANCELED:
266	return WorkflowExecutionCloseStatus.WORKFLOW_EXECUTION_CLOSE_STATUS_CANCELED;	×
267	case TERMINATED:
268	return WorkflowExecutionCloseStatus.WORKFLOW_EXECUTION_CLOSE_STATUS_TERMINATED;	×
269	case CONTINUED_AS_NEW:
270	return WorkflowExecutionCloseStatus.WORKFLOW_EXECUTION_CLOSE_STATUS_CONTINUED_AS_NEW;	×
271	case TIMED_OUT:
272	return WorkflowExecutionCloseStatus.WORKFLOW_EXECUTION_CLOSE_STATUS_TIMED_OUT;	×
273	}
274	throw new IllegalArgumentException("unexpected enum value");	×
275	}
276
277	static QueryResultType queryTaskCompletedType(com.uber.cadence.QueryTaskCompletedType t) {
278	if (t == null) {	×
279	return QUERY_RESULT_TYPE_INVALID;	×
280	}
281	switch (t) {	×
282	case COMPLETED:
283	return QUERY_RESULT_TYPE_ANSWERED;	×
284	case FAILED:
285	return QUERY_RESULT_TYPE_FAILED;	×
286	}
287	throw new IllegalArgumentException("unexpected enum value");	×
288	}
289	}

uber / cadence-java-client / 2016

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