#408

Committed 15 Oct 2026 09:15PM UTC coverage: 69.728% (-0.01%) from 69.738%

Build # #408

Build Type

push

github

Committed by

web-flow

Commit Message

Add promise-based workflow await (#3055)

Coverage Stats

7963 of 13522 branches covered (58.89%)

Branch coverage included in aggregate %.

4 of 4 new or added lines in 2 files covered. (100.0%)

11 existing lines in 5 files now uncovered.

32272 of 44181 relevant lines covered (73.04%)

0.73 hits per line

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

56.1

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

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.getWorkflowRunId()
                + ", ActivityType="
                + info.getActivityType()
                + ", ActivityId="
                + info.getActivityId()
            : null,
        cause);
    if (info != null) {
      workflowId = info.getWorkflowId();
      runId = info.getWorkflowRunId();
      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	package io.temporal.client;
2
3	import io.temporal.activity.ActivityInfo;
4	import io.temporal.failure.TemporalException;
5	import java.util.Optional;
6
7	/** Base exception for all failures returned by an activity completion client. Do not extend! */
8	public class ActivityCompletionException extends TemporalException {
9
10	private final String workflowId;
11
12	private final String runId;
13
14	private final String activityType;
15
16	private final String activityId;
17
18	protected ActivityCompletionException(ActivityInfo info) {
19	this(info, null);	1 ✔
20	}	1 ✔
21
22	protected ActivityCompletionException(ActivityInfo info, Throwable cause) {
23	super(	1 ✔
24	info != null	1 !
25	? "WorkflowId="
26	+ info.getWorkflowId()	1 ✔
27	+ ", RunId="
28	+ info.getWorkflowRunId()	1 ✔
29	+ ", ActivityType="
30	+ info.getActivityType()	1 ✔
31	+ ", ActivityId="
32	+ info.getActivityId()	1 ✔
33	: null,	1 ✔
34	cause);
35	if (info != null) {	1 !
36	workflowId = info.getWorkflowId();	1 ✔
37	runId = info.getWorkflowRunId();	1 ✔
38	activityType = info.getActivityType();	1 ✔
39	activityId = info.getActivityId();	1 ✔
40	} else {
41	this.workflowId = null;	×
42	this.runId = null;	×
43	activityType = null;	×
44	activityId = null;	×
45	}
46	}	1 ✔
47
48	protected ActivityCompletionException(String activityId, Throwable cause) {
49	super("ActivityId=" + activityId, cause);	1 ✔
50	this.workflowId = null;	1 ✔
51	this.runId = null;	1 ✔
52	this.activityType = null;	1 ✔
53	this.activityId = activityId;	1 ✔
54	}	1 ✔
55
56	protected ActivityCompletionException(Throwable cause) {
57	this((ActivityInfo) null, cause);	×
58	}	×
59
60	protected ActivityCompletionException() {
UNCOV 61	super(null, null);	×
UNCOV 62	workflowId = null;	×
UNCOV 63	runId = null;	×
UNCOV 64	activityType = null;	×
UNCOV 65	activityId = null;	×
UNCOV 66	}	×
67
68	/** Optional as it might be not known to the exception source. */
69	public Optional<String> getWorkflowId() {
70	return Optional.ofNullable(workflowId);	×
71	}
72
73	/** Optional as it might be not known to the exception source. */
74	public Optional<String> getRunId() {
75	return Optional.ofNullable(runId);	×
76	}
77
78	/** Optional as it might be not known to the exception source. */
79	public Optional<String> getActivityType() {
80	return Optional.ofNullable(activityType);	×
81	}
82
83	/** Optional as it might be not known to the exception source. */
84	public Optional<String> getActivityId() {
85	return Optional.ofNullable(activityId);	×
86	}
87	}

temporalio / sdk-java / #408

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