Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@
import com.fasterxml.jackson.databind.ObjectReader;
import com.fasterxml.jackson.databind.ObjectWriter;
import com.fasterxml.jackson.dataformat.toml.TomlMapper;
import io.temporal.common.Experimental;
import java.io.*;
import java.nio.file.Paths;
import java.util.HashMap;
Expand All @@ -21,7 +20,6 @@
* <li>Linux/other: $HOME/.config/temporalio/temporal.toml
* </ul>
*/
@Experimental
public class ClientConfig {
/** Creates a new builder to build a {@link ClientConfig}. */
public static Builder newBuilder() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@
import io.grpc.netty.shaded.io.netty.handler.ssl.SslContextBuilder;
import io.grpc.netty.shaded.io.netty.handler.ssl.util.InsecureTrustManagerFactory;
import io.temporal.client.WorkflowClientOptions;
import io.temporal.common.Experimental;
import io.temporal.serviceclient.WorkflowServiceStubsOptions;
import java.io.ByteArrayInputStream;
import java.io.IOException;
Expand All @@ -16,7 +15,6 @@
import java.util.Objects;

/** ClientConfigProfile is profile-level configuration for a client. */
@Experimental
public class ClientConfigProfile {
/** Creates a new builder to build a {@link ClientConfigProfile}. */
public static Builder newBuilder() {
Expand Down
Original file line number Diff line number Diff line change
@@ -1,11 +1,9 @@
package io.temporal.envconfig;

import io.temporal.common.Experimental;
import java.util.Arrays;
import java.util.Objects;

/** TLS configuration for a client. */
@Experimental
public class ClientConfigTLS {
/** Create a builder for {@link ClientConfigTLS}. */
public static Builder newBuilder() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.annotation.JsonProperty;
import io.grpc.Metadata;
import io.temporal.common.Experimental;
import java.nio.charset.StandardCharsets;
import java.util.HashMap;
import java.util.Map;
Expand All @@ -15,7 +14,6 @@
* <p>These are package private, use {@link ClientConfig} and {@link ClientConfigProfile} to load
* and work with client configs.
*/
@Experimental
class ClientConfigToml {
@JsonInclude(JsonInclude.Include.NON_EMPTY)
static class TomlClientConfig {
Expand Down
Original file line number Diff line number Diff line change
@@ -1,10 +1,8 @@
package io.temporal.envconfig;

import io.temporal.common.Experimental;
import java.util.Map;

/** Options for loading a client config via {@link ClientConfig#load(LoadClientConfigOptions)} */
@Experimental
public class LoadClientConfigOptions {
/** Create a builder for {@link LoadClientConfigOptions}. */
public static Builder newBuilder() {
Expand Down
Original file line number Diff line number Diff line change
@@ -1,13 +1,11 @@
package io.temporal.envconfig;

import io.temporal.common.Experimental;
import java.util.Map;

/**
* Options for loading a client config profile via {@link
* ClientConfigProfile#load(LoadClientConfigProfileOptions)}
*/
@Experimental
public class LoadClientConfigProfileOptions {
/** Create a builder for {@link LoadClientConfigProfileOptions}. */
public static Builder newBuilder() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,7 @@
* <p>See each public static method to learn about and construct the available operations.
*/
@Experimental
@Deprecated
public abstract class BuildIdOperation {
private BuildIdOperation() {}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,8 +7,14 @@
import java.util.Optional;
import java.util.stream.Collectors;

/** Represents the sets of compatible Build Ids associated with a particular task queue. */
/**
* Represents the sets of compatible Build Ids associated with a particular task queue.
*
* @deprecated Worker Versioning is now deprecated please migrate to the <a
* href="https://docs.temporal.io/worker-deployments">Worker Deployment API</a>.
*/
@Experimental
@Deprecated
public class WorkerBuildIdVersionSets {

/** Represents a set of Build Ids which are compatible with one another. */
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -345,8 +345,11 @@ WorkflowStub newUntypedWorkflowStub(
* @param operation The operation to perform. See {@link BuildIdOperation} for more.
* @throws WorkflowServiceException for any failures including networking and service availability
* issues.
* @deprecated Worker Versioning is now deprecated please migrate to the <a
* href="https://docs.temporal.io/worker-deployments">Worker Deployment API</a>.
*/
@Experimental
@Deprecated
void updateWorkerBuildIdCompatability(
@Nonnull String taskQueue, @Nonnull BuildIdOperation operation);

Expand All @@ -357,8 +360,11 @@ void updateWorkerBuildIdCompatability(
* @return The version set(s) for the task queue.
* @throws WorkflowServiceException for any failures including networking and service availability
* issues.
* @deprecated Worker Versioning is now deprecated please migrate to the <a
* href="https://docs.temporal.io/worker-deployments">Worker Deployment API</a>.
*/
@Experimental
@Deprecated
WorkerBuildIdVersionSets getWorkerBuildIdCompatability(@Nonnull String taskQueue);

/**
Expand All @@ -373,8 +379,11 @@ void updateWorkerBuildIdCompatability(
* @return The reachability information.
* @throws WorkflowServiceException for any failures including networking and service availability
* issues.
* @deprecated Worker Versioning is now deprecated please migrate to the <a
* href="https://docs.temporal.io/worker-deployments">Worker Deployment API</a>.
*/
@Experimental
@Deprecated
WorkerTaskReachability getWorkerTaskReachability(
@Nonnull Iterable<String> buildIds,
@Nonnull Iterable<String> taskQueues,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -383,6 +383,7 @@ public WorkflowExecutionHistory fetchHistory(@Nonnull String workflowId, @Nullab
workflowId);
}

@SuppressWarnings("deprecation")
@Override
public void updateWorkerBuildIdCompatability(
@Nonnull String taskQueue, @Nonnull BuildIdOperation operation) {
Expand All @@ -394,6 +395,7 @@ public void updateWorkerBuildIdCompatability(
genericClient.updateWorkerBuildIdCompatability(reqBuilder.build());
}

@SuppressWarnings("deprecation")
@Override
public WorkerBuildIdVersionSets getWorkerBuildIdCompatability(@Nonnull String taskQueue) {
GetWorkerBuildIdCompatibilityRequest req =
Expand All @@ -405,6 +407,7 @@ public WorkerBuildIdVersionSets getWorkerBuildIdCompatability(@Nonnull String ta
return new WorkerBuildIdVersionSets(resp);
}

@SuppressWarnings("deprecation")
@Override
public WorkerTaskReachability getWorkerTaskReachability(
@Nonnull Iterable<String> buildIds,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -477,7 +477,6 @@ public Builder setPriority(Priority priority) {
}

/** Sets the versioning override to use when starting this workflow. */
@Experimental
public Builder setVersioningOverride(VersioningOverride versioningOverride) {
this.versioningOverride = versioningOverride;
return this;
Expand Down Expand Up @@ -737,7 +736,6 @@ public Priority getPriority() {
return priority;
}

@Experimental
public VersioningOverride getVersioningOverride() {
return versioningOverride;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@
import io.temporal.worker.WorkerDeploymentOptions;

/** Specifies when a workflow might move from a worker of one Build Id to another. */
@Experimental
public enum VersioningBehavior {
/**
* An unspecified versioning behavior. By default, workers opting into worker versioning will be
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@
import javax.annotation.Nonnull;

/** Represents the override of a worker's versioning behavior for a workflow execution. */
@Experimental
public abstract class VersioningOverride {
private VersioningOverride() {}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@
import javax.annotation.Nullable;

/** Represents the version of a specific worker deployment. */
@Experimental
public class WorkerDeploymentVersion {
private final String deploymentName;
private final String buildId;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -230,7 +230,6 @@ public List<POJOWorkflowMethodMetadata> getUpdateValidatorMethods() {
* @throws RuntimeException if the method is not found on the implementation class or is not a
* workflow method.
*/
@Experimental
@Nullable
public static VersioningBehavior getVersioningBehaviorForMethod(
Class<?> implementationClass, POJOWorkflowMethodMetadata workflowMethod) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -62,6 +62,7 @@ DescribeWorkflowExecutionResponse describeWorkflowExecution(
DescribeWorkflowExecutionRequest request);

@Experimental
@Deprecated
UpdateWorkerBuildIdCompatibilityResponse updateWorkerBuildIdCompatability(
UpdateWorkerBuildIdCompatibilityRequest request);

Expand All @@ -70,9 +71,11 @@ ExecuteMultiOperationResponse executeMultiOperation(
ExecuteMultiOperationRequest request, @Nonnull Deadline deadline);

@Experimental
@Deprecated
GetWorkerBuildIdCompatibilityResponse getWorkerBuildIdCompatability(
GetWorkerBuildIdCompatibilityRequest req);

@Experimental
@Deprecated
GetWorkerTaskReachabilityResponse GetWorkerTaskReachability(GetWorkerTaskReachabilityRequest req);
}
Original file line number Diff line number Diff line change
Expand Up @@ -364,6 +364,7 @@ public CompletableFuture<PollWorkflowExecutionUpdateResponse> pollUpdateAsync(
new GrpcRetryer.GrpcRetryerOptions(DefaultStubLongPollRpcRetryOptions.INSTANCE, deadline));
}

@SuppressWarnings("deprecation")
@Override
public UpdateWorkerBuildIdCompatibilityResponse updateWorkerBuildIdCompatability(
UpdateWorkerBuildIdCompatibilityRequest request) {
Expand All @@ -376,6 +377,7 @@ public UpdateWorkerBuildIdCompatibilityResponse updateWorkerBuildIdCompatability
grpcRetryerOptions);
}

@SuppressWarnings("deprecation")
@Override
public GetWorkerBuildIdCompatibilityResponse getWorkerBuildIdCompatability(
GetWorkerBuildIdCompatibilityRequest req) {
Expand All @@ -388,6 +390,7 @@ public GetWorkerBuildIdCompatibilityResponse getWorkerBuildIdCompatability(
grpcRetryerOptions);
}

@SuppressWarnings("deprecation")
@Override
public GetWorkerTaskReachabilityResponse GetWorkerTaskReachability(
GetWorkerTaskReachabilityRequest req) {
Expand Down
Original file line number Diff line number Diff line change
@@ -1,13 +1,11 @@
package io.temporal.worker;

import com.google.common.base.Preconditions;
import io.temporal.common.Experimental;
import io.temporal.common.VersioningBehavior;
import io.temporal.common.WorkerDeploymentVersion;
import java.util.Objects;

/** Options for configuring the Worker Versioning feature. */
@Experimental
public class WorkerDeploymentOptions {
public static Builder newBuilder() {
return new Builder();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -376,6 +376,9 @@ public Builder setDisableEagerExecution(boolean disableEagerExecution) {
* will only receive tasks which it is compatible with.
*
* <p>Defaults to false
*
* @deprecated Worker Versioning is now deprecated please migrate to the <a
* href="https://docs.temporal.io/worker-deployments">Worker Deployment API</a>.
*/
@Experimental
@Deprecated
Expand All @@ -389,6 +392,9 @@ public Builder setUseBuildIdForVersioning(boolean useBuildIdForVersioning) {
* code the worker uses for workflows, activities, and interceptors.
*
* <p>A Build Id must be set if {@link #setUseBuildIdForVersioning(boolean)} is set true.
*
* @deprecated Worker Versioning is now deprecated please migrate to the <a
* href="https://docs.temporal.io/worker-deployments">Worker Deployment API</a>.
*/
@Experimental
@Deprecated
Expand Down Expand Up @@ -486,7 +492,6 @@ public Builder setIdentity(String identity) {
* Set deployment options for the worker. Exclusive with {@link #setUseBuildIdForVersioning} and
* {@link #setBuildId(String)}.
*/
@Experimental
public Builder setDeploymentOptions(WorkerDeploymentOptions deploymentOptions) {
this.deploymentOptions = deploymentOptions;
return this;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
package io.temporal.workflow;

import io.temporal.common.Experimental;
import io.temporal.common.VersioningBehavior;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
Expand All @@ -13,7 +12,6 @@
*/
@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
@Experimental
public @interface WorkflowVersioningBehavior {
/**
* The behavior to apply to this workflow. See {@link VersioningBehavior} for more information.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@
import io.temporal.activity.Activity;
import io.temporal.activity.ActivityOptions;
import io.temporal.api.common.v1.WorkflowExecution;
import io.temporal.client.BuildIdOperation;
import io.temporal.client.WorkflowClient;
import io.temporal.client.WorkflowOptions;
import io.temporal.internal.Signal;
Expand Down Expand Up @@ -45,7 +44,7 @@ public void testBuildIdVersioningDataSetProperly() {

// Add 1.0 to the queue
workflowClient.updateWorkerBuildIdCompatability(
taskQueue, BuildIdOperation.newIdInNewDefaultSet("1.0"));
taskQueue, io.temporal.client.BuildIdOperation.newIdInNewDefaultSet("1.0"));

// Now start the worker (to avoid poll timeout while queue is unversioned)
testWorkflowRule.getTestEnvironment().start();
Expand All @@ -65,7 +64,7 @@ public void testBuildIdVersioningDataSetProperly() {

// Add 2.0 to the queue
workflowClient.updateWorkerBuildIdCompatability(
taskQueue, BuildIdOperation.newIdInNewDefaultSet("2.0"));
taskQueue, io.temporal.client.BuildIdOperation.newIdInNewDefaultSet("2.0"));

// Continue driving original workflow
wf1.mySignal("activity");
Expand Down Expand Up @@ -121,7 +120,7 @@ public void testCurrentBuildIDSetProperly() throws InterruptedException {

// Add 1.0 to the queue
workflowClient.updateWorkerBuildIdCompatability(
taskQueue, BuildIdOperation.newIdInNewDefaultSet("1.0"));
taskQueue, io.temporal.client.BuildIdOperation.newIdInNewDefaultSet("1.0"));

// Now start the worker (to avoid poll timeout while queue is unversioned)
testWorkflowRule.getTestEnvironment().start();
Expand Down Expand Up @@ -154,7 +153,7 @@ public void testCurrentBuildIDSetProperly() throws InterruptedException {

// Add 1.1 to the queue
workflowClient.updateWorkerBuildIdCompatability(
taskQueue, BuildIdOperation.newCompatibleVersion("1.1", "1.0"));
taskQueue, io.temporal.client.BuildIdOperation.newCompatibleVersion("1.1", "1.0"));

WorkerFactory w11F =
WorkerFactory.newInstance(workflowClient, testWorkflowRule.getWorkerFactoryOptions());
Expand Down
Loading