#347

Committed 31 Jul 2026 06:59PM UTC coverage: 68.148% (-0.03%) from 68.181%

Build # #347

Build Type

push

github

Committed by

web-flow

Commit Message

NEXUS-485: Support Workflow Update as a Nexus Operation (#2945)

* NEXUS-485: Support Workflow Update as a Nexus Operation

* address comments, change signatures to newer

* address comments 2: add all workflow exec overloads

* address comments: log failed

Coverage Stats

7166 of 12554 branches covered (57.08%)

Branch coverage included in aggregate %.

118 of 296 new or added lines in 11 files covered. (39.86%)

28 existing lines in 7 files now uncovered.

29722 of 41575 relevant lines covered (71.49%)

0.71 hits per line

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

70.0

/temporal-sdk/src/main/java/io/temporal/common/interceptors/ActivityExecutionContextBase.java

package io.temporal.common.interceptors;

import com.uber.m3.tally.Scope;
import io.temporal.activity.ActivityExecutionContext;
import io.temporal.activity.ActivityInfo;
import io.temporal.activity.ManualActivityCompletionClient;
import io.temporal.client.ActivityCanceledException;
import io.temporal.client.ActivityCompletionException;
import io.temporal.client.WorkflowClient;
import io.temporal.common.CancellationToken;
import java.lang.reflect.Type;
import java.util.Optional;

/** Convenience class for implementing ActivityInterceptors. */
public class ActivityExecutionContextBase implements ActivityExecutionContext {
  private final ActivityExecutionContext next;

  public ActivityExecutionContextBase(ActivityExecutionContext next) {
    this.next = next;
  }

  @Override
  public ActivityInfo getInfo() {
    return next.getInfo();
  }

  @Override
  public <V> void heartbeat(V details) throws ActivityCompletionException {
    next.heartbeat(details);
  }

  @Override
  public <V> Optional<V> getHeartbeatDetails(Class<V> detailsClass) {
    return next.getHeartbeatDetails(detailsClass);
  }

  @Override
  public <V> Optional<V> getHeartbeatDetails(Class<V> detailsClass, Type detailsGenericType) {
    return next.getHeartbeatDetails(detailsClass, detailsGenericType);
  }

  @Override
  public <V> Optional<V> getLastHeartbeatDetails(Class<V> detailsClass) {
    return next.getLastHeartbeatDetails(detailsClass);
  }

  @Override
  public <V> Optional<V> getLastHeartbeatDetails(Class<V> detailsClass, Type detailsGenericType) {
    return next.getLastHeartbeatDetails(detailsClass, detailsGenericType);
  }

  @Override
  public byte[] getTaskToken() {
    return next.getTaskToken();
  }

  @Override
  public CancellationToken<ActivityCanceledException> getCancellationToken() {
    return next.getCancellationToken();
  }

  @Override
  public void doNotCompleteOnReturn() {
    next.doNotCompleteOnReturn();
  }

  @Override
  public boolean isDoNotCompleteOnReturn() {
    return next.isDoNotCompleteOnReturn();
  }

  @Override
  public boolean isUseLocalManualCompletion() {
    return next.isUseLocalManualCompletion();
  }

  @Override
  public ManualActivityCompletionClient useLocalManualCompletion() {
    return next.useLocalManualCompletion();
  }

  @Override
  public Scope getMetricsScope() {
    return next.getMetricsScope();
  }

  @Override
  public WorkflowClient getWorkflowClient() {
    return next.getWorkflowClient();
  }

  @Override
  public Object getInstance() {
    return next.getInstance();
  }
}

1	package io.temporal.common.interceptors;
2
3	import com.uber.m3.tally.Scope;
4	import io.temporal.activity.ActivityExecutionContext;
5	import io.temporal.activity.ActivityInfo;
6	import io.temporal.activity.ManualActivityCompletionClient;
7	import io.temporal.client.ActivityCanceledException;
8	import io.temporal.client.ActivityCompletionException;
9	import io.temporal.client.WorkflowClient;
10	import io.temporal.common.CancellationToken;
11	import java.lang.reflect.Type;
12	import java.util.Optional;
13
14	/** Convenience class for implementing ActivityInterceptors. */
15	public class ActivityExecutionContextBase implements ActivityExecutionContext {
16	private final ActivityExecutionContext next;
17
18	public ActivityExecutionContextBase(ActivityExecutionContext next) {	1✔
19	this.next = next;	1✔
20	}	1✔
21
22	@Override
23	public ActivityInfo getInfo() {
24	return next.getInfo();	1✔
25	}
26
27	@Override
28	public <V> void heartbeat(V details) throws ActivityCompletionException {
29	next.heartbeat(details);	1✔
30	}	1✔
31
32	@Override
33	public <V> Optional<V> getHeartbeatDetails(Class<V> detailsClass) {
34	return next.getHeartbeatDetails(detailsClass);	1✔
35	}
36
37	@Override
38	public <V> Optional<V> getHeartbeatDetails(Class<V> detailsClass, Type detailsGenericType) {
39	return next.getHeartbeatDetails(detailsClass, detailsGenericType);	1✔
40	}
41
42	@Override
43	public <V> Optional<V> getLastHeartbeatDetails(Class<V> detailsClass) {
44	return next.getLastHeartbeatDetails(detailsClass);	1✔
45	}
46
47	@Override
48	public <V> Optional<V> getLastHeartbeatDetails(Class<V> detailsClass, Type detailsGenericType) {
UNCOV 49	return next.getLastHeartbeatDetails(detailsClass, detailsGenericType);	×
50	}
51
52	@Override
53	public byte[] getTaskToken() {
UNCOV 54	return next.getTaskToken();	×
55	}
56
57	@Override
58	public CancellationToken<ActivityCanceledException> getCancellationToken() {
59	return next.getCancellationToken();	1✔
60	}
61
62	@Override
63	public void doNotCompleteOnReturn() {
64	next.doNotCompleteOnReturn();	1✔
65	}	1✔
66
67	@Override
68	public boolean isDoNotCompleteOnReturn() {
UNCOV 69	return next.isDoNotCompleteOnReturn();	×
70	}
71
72	@Override
73	public boolean isUseLocalManualCompletion() {
UNCOV 74	return next.isUseLocalManualCompletion();	×
75	}
76
77	@Override
78	public ManualActivityCompletionClient useLocalManualCompletion() {
79	return next.useLocalManualCompletion();	1✔
80	}
81
82	@Override
83	public Scope getMetricsScope() {
UNCOV 84	return next.getMetricsScope();	×
85	}
86
87	@Override
88	public WorkflowClient getWorkflowClient() {
89	return next.getWorkflowClient();	1✔
90	}
91
92	@Override
93	public Object getInstance() {
UNCOV 94	return next.getInstance();	×
95	}
96	}

temporalio / sdk-java / #347

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