💥 Standalone Activities for Java

.github/workflows/ci.yml

@@ -110,7 +110,11 @@ jobs:
               --dynamic-config-value history.enableRequestIdRefLinks=true \
               --dynamic-config-value frontend.WorkerHeartbeatsEnabled=true \
               --dynamic-config-value frontend.ListWorkersEnabled=true \
-              --dynamic-config-value 'component.callbacks.allowedAddresses=[{"Pattern":"localhost:7243","AllowInsecure":true}]' &
+              --dynamic-config-value 'component.callbacks.allowedAddresses=[{"Pattern":"localhost:7243","AllowInsecure":true}]' \
+              --dynamic-config-value frontend.activityAPIsEnabled=true \
+              --dynamic-config-value activity.enableStandalone=true \
+              --dynamic-config-value history.enableChasm=true \
+              --dynamic-config-value history.enableTransitionHistory=true &
           sleep 10s
 
       # Can't actually run tests against Java 8 because Mockito 5 requires Java 11+.

contrib/temporal-opentracing/src/main/java/io/temporal/opentracing/internal/OpenTracingActivityInboundCallsInterceptor.java

@@ -51,7 +51,7 @@ public ActivityOutput execute(ActivityInput input) {
                 tracer,
                 activityInfo.getActivityType(),
                 activityInfo.getWorkflowId(),
-                activityInfo.getRunId(),
+                activityInfo.getWorkflowRunId(),
                 rootSpanContext)
             .start();
     try (Scope scope = tracer.scopeManager().activate(activityRunSpan)) {

temporal-sdk/src/main/java/io/temporal/activity/ActivityInfo.java

@@ -7,6 +7,7 @@
 import java.time.Duration;
 import java.util.Optional;
 import javax.annotation.Nonnull;
+import javax.annotation.Nullable;
 
 /**
  * Information about the Activity Task that the current Activity Execution is handling. Use {@link
@@ -21,15 +22,35 @@ public interface ActivityInfo {
   byte[] getTaskToken();
 
   /**
-   * @return WorkflowId of the Workflow Execution that scheduled the Activity Execution.
+   * @return WorkflowId of the Workflow Execution that scheduled the Activity Execution, or {@code
+   *     null} for standalone activities not scheduled by a workflow.
    */
+  @Nullable
   String getWorkflowId();
 
   /**
-   * @return RunId of the Workflow Execution that scheduled the Activity Execution.
+   * @return RunId of the Workflow Execution that scheduled the Activity Execution, or {@code null}
+   *     for standalone activities not scheduled by a workflow.
+   * @deprecated use {@link #getWorkflowRunId()}
    */
+  @Deprecated
+  @Nullable
   String getRunId();
 
+  /**
+   * @return RunId of the Workflow Execution that scheduled the Activity Execution, or {@code null}
+   *     for standalone activities not scheduled by a workflow.
+   */
+  @Nullable
+  String getWorkflowRunId();
+
+  /**
+   * @return the run ID of this standalone Activity Execution, or {@code null} for activities
+   *     scheduled by a workflow.
+   */
+  @Nullable
+  String getActivityRunId();
+
   /**
    * ID of the Activity Execution. This ID can be used to complete the Activity Execution
    * asynchronously through {@link io.temporal.client.ActivityCompletionClient#complete(String,
@@ -82,8 +103,10 @@ public interface ActivityInfo {
   Optional<Payloads> getHeartbeatDetails();
 
   /**
-   * @return the Workflow Type of the Workflow Execution that executed the Activity.
+   * @return the Workflow Type of the Workflow Execution that executed the Activity, or {@code null}
+   *     for standalone activities not scheduled by a workflow.
    */
+  @Nullable
   String getWorkflowType();
 
   /**
@@ -92,10 +115,12 @@ public interface ActivityInfo {
    * same namespace, hence no need for different {@code getWorkflowNamespace()} and {@link
    * #getActivityNamespace()} methods.
    *
-   * @return the Namespace of Workflow Execution that scheduled the Activity.
+   * @return the Namespace of Workflow Execution that scheduled the Activity, or null for standalone
+   *     activities.
    * @deprecated use {@link #getNamespace()}
    */
   @Deprecated
+  @Nullable
   String getWorkflowNamespace();
 
   /**
@@ -110,8 +135,19 @@ public interface ActivityInfo {
   @Deprecated
   String getActivityNamespace();
 
+  /**
+   * @return the Namespace of this Activity Execution.
+   */
   String getNamespace();
 
+  /**
+   * @return {@code true} if this activity was scheduled by a workflow execution; {@code false} for
+   *     standalone activities.
+   */
+  default boolean isInWorkflow() {
+    return getWorkflowId() != null;
+  }
+
   String getActivityTaskQueue();
 
   /**

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

@@ -0,0 +1,35 @@
+package io.temporal.client;
+
+import io.temporal.common.Experimental;
+import javax.annotation.Nullable;
+
+/**
+ * Thrown by {@link ActivityClient#start} when the server returns an ALREADY_EXISTS error because an
+ * activity with the same ID is already running (or has a completed run that conflicts with the
+ * requested {@link StartActivityOptions#getIdReusePolicy()} / {@link
+ * StartActivityOptions#getIdConflictPolicy()}).
+ */
+@Experimental
+public final class ActivityAlreadyStartedException extends ActivityException {
+
+  private final String activityType;
+
+  public ActivityAlreadyStartedException(
+      String activityId, String activityType, @Nullable String runId, Throwable cause) {
+    super(
+        "Activity already started: activityId='"
+            + activityId
+            + "', activityType='"
+            + activityType
+            + (runId != null ? "', runId='" + runId + "'" : "'"),
+        activityId,
+        runId,
+        cause);
+    this.activityType = activityType;
+  }
+
+  /** The activity type that was requested. */
+  public String getActivityType() {
+    return activityType;
+  }
+}