rm schedule to close and start and more retries (#10114)

airbytehq · Feb 4, 2022 · 2eb73c5 · 2eb73c5
1 parent 983d6ae
commit 2eb73c5
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 3 deletions.
diff --git a/airbyte-config/models/src/main/java/io/airbyte/config/EnvConfigs.java b/airbyte-config/models/src/main/java/io/airbyte/config/EnvConfigs.java
@@ -583,7 +583,7 @@ public int getDelayBetweenActivityAttempts() {
 
   @Override
   public int getActivityNumberOfAttempt() {
-    return Integer.parseInt(getEnvOrDefault(ACTIVITY_MAX_ATTEMPT, "3"));
+    return Integer.parseInt(getEnvOrDefault(ACTIVITY_MAX_ATTEMPT, "10"));
   }
 
   // Helpers

diff --git a/...rs/src/main/java/io/airbyte/workers/temporal/scheduling/shared/ActivityConfiguration.java b/...rs/src/main/java/io/airbyte/workers/temporal/scheduling/shared/ActivityConfiguration.java
@@ -34,9 +34,7 @@ public class ActivityConfiguration {
       .build();
 
   public static final ActivityOptions SHORT_ACTIVITY_OPTIONS = ActivityOptions.newBuilder()
-      .setScheduleToCloseTimeout(DB_INTERACTION_TIMEOUT)
       .setStartToCloseTimeout(DB_INTERACTION_TIMEOUT)
-      .setScheduleToStartTimeout(DB_INTERACTION_TIMEOUT)
       .setCancellationType(ActivityCancellationType.WAIT_CANCELLATION_COMPLETED)
       .setRetryOptions(TemporalUtils.RETRY)
       .setHeartbeatTimeout(TemporalUtils.HEARTBEAT_TIMEOUT)