Increate failure delay to 2 minutes (heartbeat is likely to fail)) (#…

…10109)
airbytehq · Feb 4, 2022 · 82ba043 · 82ba043
1 parent c1ae307
commit 82ba043
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/airbyte-config/models/src/main/java/io/airbyte/config/Configs.java b/airbyte-config/models/src/main/java/io/airbyte/config/Configs.java
@@ -340,7 +340,7 @@ public interface Configs {
   /**
    * Get the duration in second between 2 activity attempts
    */
-  int getDelayBetweenActivityAttemps();
+  int getDelayBetweenActivityAttempts();
 
   /**
    * Get number of attempts of the non long running activities

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
@@ -573,11 +573,11 @@ public boolean getContainerOrchestratorEnabled() {
 
   @Override
   public int getMaxActivityTimeoutSecond() {
-    return Integer.parseInt(getEnvOrDefault(ACTIVITY_MAX_TIMEOUT_SECOND, "30"));
+    return Integer.parseInt(getEnvOrDefault(ACTIVITY_MAX_TIMEOUT_SECOND, "120"));
   }
 
   @Override
-  public int getDelayBetweenActivityAttemps() {
+  public int getDelayBetweenActivityAttempts() {
     return Integer.parseInt(getEnvOrDefault(ACTIVITY_MAX_TIMEOUT_SECOND, "30"));
   }
 

diff --git a/airbyte-workers/src/main/java/io/airbyte/workers/temporal/TemporalUtils.java b/airbyte-workers/src/main/java/io/airbyte/workers/temporal/TemporalUtils.java
@@ -63,7 +63,7 @@ public static WorkflowServiceStubs createTemporalService(final String temporalHo
   private static final Configs configs = new EnvConfigs();
   public static final RetryOptions RETRY = RetryOptions.newBuilder()
       .setMaximumAttempts(configs.getActivityNumberOfAttempt())
-      .setInitialInterval(Duration.ofSeconds(configs.getDelayBetweenActivityAttemps()))
+      .setInitialInterval(Duration.ofSeconds(configs.getDelayBetweenActivityAttempts()))
       .build();
 
   public static final String DEFAULT_NAMESPACE = "default";