feat: Update IDL

build.gradle

@@ -181,8 +181,37 @@ clean {
     delete protobuf.generatedFilesBaseDir
 }
 
+// This is to suppress the deprecation warning in the generated file, because it uses a deprecated proto message.
+// Remove this once the deprecated proto message is deleted.
+task replaceGeneratedSources {
+    dependsOn 'generateProto'
+    doLast {
+        def file = file("$buildDir/generated-sources/proto/main/java/com/uber/cadence/api/v1/ActiveClusterSelectionPolicy.java")
+
+        if (!file.exists()) {
+            return
+        }
+
+        def content = file.text
+
+        def updated = content.replaceFirst(
+            /public\s+.*class\s+ActiveClusterSelectionPolicy/,
+            '@SuppressWarnings("deprecation")\n$0'
+        )
+
+        if (content == updated) {
+            println("❌ Pattern did NOT match")
+        } else {
+            file.text = updated
+            println("✅ Replacement applied")
+        }
+
+    }
+}
+
 compileJava {
     dependsOn 'googleJavaFormat'
+    dependsOn 'replaceGeneratedSources'
     options.encoding = 'UTF-8'
     options.compilerArgs << '-Xlint:none' << '-Xlint:deprecation' << '-Werror'
     options.errorprone.excludedPaths = '.*/generated-sources/.*'

src/gen/java/com/uber/cadence/ActiveClusterInfo.java

@@ -0,0 +1,12 @@
+package com.uber.cadence;
+
+import java.util.*;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+@Data
+@Accessors(chain = true)
+public class ActiveClusterInfo {
+  private String activeClusterName;
+  private long failoverVersion;
+}

src/gen/java/com/uber/cadence/ActiveClusterSelectionPolicy.java

@@ -0,0 +1,15 @@
+package com.uber.cadence;
+
+import java.util.*;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+@Data
+@Accessors(chain = true)
+public class ActiveClusterSelectionPolicy {
+  private ClusterAttribute clusterAttribute;
+  private ActiveClusterSelectionStrategy strategy;
+  private String stickyRegion;
+  private String externalEntityType;
+  private String externalEntityKey;
+}

src/gen/java/com/uber/cadence/ActiveClusterSelectionStrategy.java

@@ -0,0 +1,6 @@
+package com.uber.cadence;
+
+public enum ActiveClusterSelectionStrategy {
+  REGION_STICKY,
+  EXTERNAL_ENTITY,
+}

src/gen/java/com/uber/cadence/ActiveClusters.java

@@ -0,0 +1,12 @@
+package com.uber.cadence;
+
+import java.util.*;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+@Data
+@Accessors(chain = true)
+public class ActiveClusters {
+  private Map<String, ActiveClusterInfo> activeClustersByRegion = new HashMap<>();;
+  private Map<String, ClusterAttributeScope> activeClustersByClusterAttribute = new HashMap<>();;
+}

src/gen/java/com/uber/cadence/ClusterAttribute.java

@@ -0,0 +1,12 @@
+package com.uber.cadence;
+
+import java.util.*;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+@Data
+@Accessors(chain = true)
+public class ClusterAttribute {
+  private String scope;
+  private String name;
+}

src/gen/java/com/uber/cadence/ClusterAttributeScope.java

@@ -0,0 +1,11 @@
+package com.uber.cadence;
+
+import java.util.*;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+@Data
+@Accessors(chain = true)
+public class ClusterAttributeScope {
+  private Map<String, ActiveClusterInfo> clusterAttributes = new HashMap<>();;
+}

src/gen/java/com/uber/cadence/ClusterFailover.java

@@ -0,0 +1,13 @@
+package com.uber.cadence;
+
+import java.util.*;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+@Data
+@Accessors(chain = true)
+public class ClusterFailover {
+  private ActiveClusterInfo fromCluster;
+  private ActiveClusterInfo toCluster;
+  private ClusterAttribute clusterAttribute;
+}

src/gen/java/com/uber/cadence/ContinueAsNewWorkflowExecutionDecisionAttributes.java

@@ -23,4 +23,6 @@ public class ContinueAsNewWorkflowExecutionDecisionAttributes {
   private Memo memo;
   private SearchAttributes searchAttributes;
   private int jitterStartSeconds;
+  private CronOverlapPolicy cronOverlapPolicy;
+  private ActiveClusterSelectionPolicy activeClusterSelectionPolicy;
 }

src/gen/java/com/uber/cadence/CronOverlapPolicy.java

@@ -0,0 +1,6 @@
+package com.uber.cadence;
+
+public enum CronOverlapPolicy {
+  SKIPPED,
+  BUFFERONE,
+}

src/gen/java/com/uber/cadence/DeleteDomainRequest.java

@@ -0,0 +1,12 @@
+package com.uber.cadence;
+
+import java.util.*;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+@Data
+@Accessors(chain = true)
+public class DeleteDomainRequest {
+  private String name;
+  private String securityToken;
+}

src/gen/java/com/uber/cadence/DescribeTaskListResponse.java

@@ -9,4 +9,5 @@
 public class DescribeTaskListResponse {
   private List<PollerInfo> pollers = new ArrayList<>();;
   private TaskListStatus taskListStatus;
+  private TaskList taskList;
 }

src/gen/java/com/uber/cadence/DomainIDPredicateAttributes.java

@@ -0,0 +1,12 @@
+package com.uber.cadence;
+
+import java.util.*;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+@Data
+@Accessors(chain = true)
+public class DomainIDPredicateAttributes {
+  private List<String> domainIDs = new ArrayList<>();;
+  private boolean isExclusive;
+}

src/gen/java/com/uber/cadence/DomainNotActiveError.java

@@ -12,6 +12,7 @@ public class DomainNotActiveError extends CadenceError {
   private String domainName;
   private String currentCluster;
   private String activeCluster;
+  private List<String> activeClusters;
 
   public DomainNotActiveError() {
     super();

src/gen/java/com/uber/cadence/DomainReplicationConfiguration.java

@@ -9,4 +9,5 @@
 public class DomainReplicationConfiguration {
   private String activeClusterName;
   private List<ClusterReplicationConfiguration> clusters = new ArrayList<>();;
+  private ActiveClusters activeClusters;
 }

src/gen/java/com/uber/cadence/EmptyPredicateAttributes.java

@@ -0,0 +1,9 @@
+package com.uber.cadence;
+
+import java.util.*;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+@Data
+@Accessors(chain = true)
+public class EmptyPredicateAttributes {}

src/gen/java/com/uber/cadence/EntityNotExistsError.java

@@ -11,6 +11,7 @@
 public class EntityNotExistsError extends CadenceError {
   private String currentCluster;
   private String activeCluster;
+  private List<String> activeClusters;
 
   public EntityNotExistsError() {
     super();

src/gen/java/com/uber/cadence/FailoverDomainRequest.java

@@ -0,0 +1,14 @@
+package com.uber.cadence;
+
+import java.util.*;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+@Data
+@Accessors(chain = true)
+public class FailoverDomainRequest {
+  private String domainName;
+  private String domainActiveClusterName;
+  private ActiveClusters activeClusters;
+  private String reason;
+}

src/gen/java/com/uber/cadence/FailoverDomainResponse.java

@@ -0,0 +1,15 @@
+package com.uber.cadence;
+
+import java.util.*;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+@Data
+@Accessors(chain = true)
+public class FailoverDomainResponse {
+  private DomainInfo domainInfo;
+  private DomainConfiguration configuration;
+  private DomainReplicationConfiguration replicationConfiguration;
+  private long failoverVersion;
+  private boolean isGlobalDomain;
+}

src/gen/java/com/uber/cadence/FailoverEvent.java

@@ -0,0 +1,14 @@
+package com.uber.cadence;
+
+import java.util.*;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+@Data
+@Accessors(chain = true)
+public class FailoverEvent {
+  private String id;
+  private long createdTime;
+  private FailoverType failoverType;
+  private List<ClusterFailover> clusterFailovers = new ArrayList<>();;
+}

src/gen/java/com/uber/cadence/FailoverType.java

@@ -0,0 +1,7 @@
+package com.uber.cadence;
+
+public enum FailoverType {
+  INVALID,
+  FORCE,
+  GRACEFUL,
+}

src/gen/java/com/uber/cadence/FeatureFlags.java

@@ -8,4 +8,5 @@
 @Accessors(chain = true)
 public class FeatureFlags {
   private boolean WorkflowExecutionAlreadyCompletedErrorEnabled;
+  private boolean AutoForwardingEnabled;
 }

src/gen/java/com/uber/cadence/ListFailoverHistoryRequest.java

@@ -0,0 +1,12 @@
+package com.uber.cadence;
+
+import java.util.*;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+@Data
+@Accessors(chain = true)
+public class ListFailoverHistoryRequest {
+  private ListFailoverHistoryRequestFilters filters;
+  private PaginationOptions pagination;
+}

src/gen/java/com/uber/cadence/ListFailoverHistoryRequestFilters.java

@@ -0,0 +1,11 @@
+package com.uber.cadence;
+
+import java.util.*;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+@Data
+@Accessors(chain = true)
+public class ListFailoverHistoryRequestFilters {
+  private String domainID;
+}

src/gen/java/com/uber/cadence/ListFailoverHistoryResponse.java

@@ -0,0 +1,12 @@
+package com.uber.cadence;
+
+import java.util.*;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+@Data
+@Accessors(chain = true)
+public class ListFailoverHistoryResponse {
+  private List<FailoverEvent> failoverEvents = new ArrayList<>();;
+  private byte[] nextPageToken;
+}

src/gen/java/com/uber/cadence/PaginationOptions.java

@@ -0,0 +1,12 @@
+package com.uber.cadence;
+
+import java.util.*;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+@Data
+@Accessors(chain = true)
+public class PaginationOptions {
+  private int pageSize;
+  private byte[] nextPageToken;
+}

src/gen/java/com/uber/cadence/Predicate.java

@@ -0,0 +1,14 @@
+package com.uber.cadence;
+
+import java.util.*;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+@Data
+@Accessors(chain = true)
+public class Predicate {
+  private PredicateType predicateType;
+  private UniversalPredicateAttributes universalPredicateAttributes;
+  private EmptyPredicateAttributes emptyPredicateAttributes;
+  private DomainIDPredicateAttributes domainIDPredicateAttributes;
+}

src/gen/java/com/uber/cadence/PredicateType.java

@@ -0,0 +1,7 @@
+package com.uber.cadence;
+
+public enum PredicateType {
+  Universal,
+  Empty,
+  DomainID,
+}

src/gen/java/com/uber/cadence/QueueState.java

@@ -0,0 +1,12 @@
+package com.uber.cadence;
+
+import java.util.*;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+@Data
+@Accessors(chain = true)
+public class QueueState {
+  private Map<Long, VirtualQueueState> virtualQueueStates = new HashMap<>();;
+  private TaskKey exclusiveMaxReadLevel;
+}

src/gen/java/com/uber/cadence/RegisterDomainRequest.java

@@ -14,6 +14,8 @@ public class RegisterDomainRequest {
   private boolean emitMetric;
   private List<ClusterReplicationConfiguration> clusters = new ArrayList<>();;
   private String activeClusterName;
+  private Map<String, String> activeClustersByRegion = new HashMap<>();;
+  private ActiveClusters activeClusters;
   private Map<String, String> data = new HashMap<>();;
   private String securityToken;
   private boolean isGlobalDomain;

src/gen/java/com/uber/cadence/SignalWithStartWorkflowExecutionRequest.java

@@ -28,4 +28,6 @@ public class SignalWithStartWorkflowExecutionRequest {
   private int delayStartSeconds;
   private int jitterStartSeconds;
   private long firstRunAtTimestamp;
+  private CronOverlapPolicy cronOverlapPolicy;
+  private ActiveClusterSelectionPolicy activeClusterSelectionPolicy;
 }

src/gen/java/com/uber/cadence/StartChildWorkflowExecutionDecisionAttributes.java

@@ -22,4 +22,6 @@ public class StartChildWorkflowExecutionDecisionAttributes {
   private Header header;
   private Memo memo;
   private SearchAttributes searchAttributes;
+  private CronOverlapPolicy cronOverlapPolicy;
+  private ActiveClusterSelectionPolicy activeClusterSelectionPolicy;
 }

src/gen/java/com/uber/cadence/StartChildWorkflowExecutionInitiatedEventAttributes.java

@@ -26,4 +26,6 @@ public class StartChildWorkflowExecutionInitiatedEventAttributes {
   private int delayStartSeconds;
   private int jitterStartSeconds;
   private long firstRunAtTimestamp;
+  private CronOverlapPolicy cronOverlapPolicy;
+  private ActiveClusterSelectionPolicy activeClusterSelectionPolicy;
 }

src/gen/java/com/uber/cadence/StartWorkflowExecutionRequest.java

@@ -25,4 +25,6 @@ public class StartWorkflowExecutionRequest {
   private int delayStartSeconds;
   private int jitterStartSeconds;
   private long firstRunAtTimestamp;
+  private CronOverlapPolicy cronOverlapPolicy;
+  private ActiveClusterSelectionPolicy activeClusterSelectionPolicy;
 }