#189

Committed 26 Sep 2023 02:27PM CUT coverage: 77.349% (-0.02%) from 77.369%

Build # #189

Build Type

push

github-actions

Committed by

web-flow

Commit Message

Fix workflow options equality (#1868)

Run Details

1 of 1 new or added line in 1 file covered. (100.0%)

18665 of 24131 relevant lines covered (77.35%)

0.77 hits per line

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

56.76

/temporal-sdk/src/main/java/io/temporal/client/ActivityCompletionException.java

/*
 * Copyright (C) 2022 Temporal Technologies, Inc. All Rights Reserved.
 *
 * Copyright (C) 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
 *
 * Modifications copyright (C) 2017 Uber Technologies, Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this material except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License 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 io.temporal.client;

import io.temporal.activity.ActivityInfo;
import io.temporal.failure.TemporalException;
import java.util.Optional;

/** Base exception for all failures returned by an activity completion client. Do not extend! */
public class ActivityCompletionException extends TemporalException {

  private final String workflowId;

  private final String runId;

  private final String activityType;

  private final String activityId;

  protected ActivityCompletionException(ActivityInfo info) {
    this(info, null);
  }

  protected ActivityCompletionException(ActivityInfo info, Throwable cause) {
    super(
        info != null
            ? "WorkflowId="
                + info.getWorkflowId()
                + ", RunId="
                + info.getRunId()
                + ", ActivityType="
                + info.getActivityType()
                + ", ActivityId="
                + info.getActivityId()
            : null,
        cause);
    if (info != null) {
      workflowId = info.getWorkflowId();
      runId = info.getRunId();
      activityType = info.getActivityType();
      activityId = info.getActivityId();
    } else {
      this.workflowId = null;
      this.runId = null;
      activityType = null;
      activityId = null;
    }
  }

  protected ActivityCompletionException(String activityId, Throwable cause) {
    super("ActivityId=" + activityId, cause);
    this.workflowId = null;
    this.runId = null;
    this.activityType = null;
    this.activityId = activityId;
  }

  protected ActivityCompletionException(Throwable cause) {
    this((ActivityInfo) null, cause);
  }

  protected ActivityCompletionException() {
    super(null, null);
    workflowId = null;
    runId = null;
    activityType = null;
    activityId = null;
  }

  /** Optional as it might be not known to the exception source. */
  public Optional<String> getWorkflowId() {
    return Optional.ofNullable(workflowId);
  }

  /** Optional as it might be not known to the exception source. */
  public Optional<String> getRunId() {
    return Optional.ofNullable(runId);
  }

  /** Optional as it might be not known to the exception source. */
  public Optional<String> getActivityType() {
    return Optional.ofNullable(activityType);
  }

  /** Optional as it might be not known to the exception source. */
  public Optional<String> getActivityId() {
    return Optional.ofNullable(activityId);
  }
}

1	/*
2	* Copyright (C) 2022 Temporal Technologies, Inc. All Rights Reserved.
3	*
4	* Copyright (C) 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
5	*
6	* Modifications copyright (C) 2017 Uber Technologies, Inc.
7	*
8	* Licensed under the Apache License, Version 2.0 (the "License");
9	* you may not use this material except in compliance with the License.
10	* You may obtain a copy of the License at
11	*
12	* http://www.apache.org/licenses/LICENSE-2.0
13	*
14	* Unless required by applicable law or agreed to in writing, software
15	* distributed under the License is distributed on an "AS IS" BASIS,
16	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
17	* See the License for the specific language governing permissions and
18	* limitations under the License.
19	*/
20
21	package io.temporal.client;
22
23	import io.temporal.activity.ActivityInfo;
24	import io.temporal.failure.TemporalException;
25	import java.util.Optional;
26
27	/** Base exception for all failures returned by an activity completion client. Do not extend! */
28	public class ActivityCompletionException extends TemporalException {
29
30	private final String workflowId;
31
32	private final String runId;
33
34	private final String activityType;
35
36	private final String activityId;
37
38	protected ActivityCompletionException(ActivityInfo info) {
39	this(info, null);	1✔
40	}	1✔
41
42	protected ActivityCompletionException(ActivityInfo info, Throwable cause) {
43	super(	1✔
44	info != null	1✔
45	? "WorkflowId="
46	+ info.getWorkflowId()	1✔
47	+ ", RunId="
48	+ info.getRunId()	1✔
49	+ ", ActivityType="
50	+ info.getActivityType()	1✔
51	+ ", ActivityId="
52	+ info.getActivityId()	1✔
53	: null,	1✔
54	cause);
55	if (info != null) {	1✔
56	workflowId = info.getWorkflowId();	1✔
57	runId = info.getRunId();	1✔
58	activityType = info.getActivityType();	1✔
59	activityId = info.getActivityId();	1✔
60	} else {
61	this.workflowId = null;	×
62	this.runId = null;	×
63	activityType = null;	×
64	activityId = null;	×
65	}
66	}	1✔
67
68	protected ActivityCompletionException(String activityId, Throwable cause) {
69	super("ActivityId=" + activityId, cause);	1✔
70	this.workflowId = null;	1✔
71	this.runId = null;	1✔
72	this.activityType = null;	1✔
73	this.activityId = activityId;	1✔
74	}	1✔
75
76	protected ActivityCompletionException(Throwable cause) {
77	this((ActivityInfo) null, cause);	×
78	}	×
79
80	protected ActivityCompletionException() {
81	super(null, null);	×
82	workflowId = null;	×
83	runId = null;	×
84	activityType = null;	×
85	activityId = null;	×
86	}	×
87
88	/** Optional as it might be not known to the exception source. */
89	public Optional<String> getWorkflowId() {
90	return Optional.ofNullable(workflowId);	×
91	}
92
93	/** Optional as it might be not known to the exception source. */
94	public Optional<String> getRunId() {
95	return Optional.ofNullable(runId);	×
96	}
97
98	/** Optional as it might be not known to the exception source. */
99	public Optional<String> getActivityType() {
100	return Optional.ofNullable(activityType);	×
101	}
102
103	/** Optional as it might be not known to the exception source. */
104	public Optional<String> getActivityId() {
105	return Optional.ofNullable(activityId);	×
106	}
107	}

temporalio / sdk-java / #189

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