To be remove

Author: benmoriceau

airbyte-workers/src/main/java/io/airbyte/workers/config/ActivityBeanFactory.java

@@ -190,7 +190,7 @@ public RetryOptions shortRetryOptions(@Property(name = "airbyte.activity.max-att
                                         @Property(name = "airbyte.activity.max-delay",
                                                   defaultValue = "600") final Integer maxDelayBetweenActivityAttemptsSeconds) {
     return RetryOptions.newBuilder()
-        .setMaximumAttempts(activityNumberOfAttempts)
+        .setMaximumAttempts(1)
         .setInitialInterval(Duration.ofSeconds(initialDelayBetweenActivityAttemptsSeconds))
         .setMaximumInterval(Duration.ofSeconds(maxDelayBetweenActivityAttemptsSeconds))
         .build();

airbyte-workers/src/main/java/io/airbyte/workers/temporal/scheduling/ConnectionManagerWorkflowImpl.java

@@ -622,7 +622,7 @@ private <INPUT, OUTPUT> OUTPUT runMandatoryActivityWithOutput(final Function<INP
       // overwhelming temporal.
       log.info("Waiting {} before restarting the workflow for connection {}, to prevent spamming temporal with restarts.", workflowDelay,
           connectionId);
-      Workflow.await(workflowDelay, () -> workflowState.isRetryFailedActivity());
+      Workflow.await(Duration.ofSeconds(1), () -> workflowState.isRetryFailedActivity());
 
       // Accept a manual signal to retry the failed activity during this window
       if (workflowState.isRetryFailedActivity()) {

airbyte-workers/src/main/java/io/airbyte/workers/temporal/scheduling/activities/JobCreationAndStatusUpdateActivityImpl.java

@@ -249,12 +249,12 @@ public void jobSuccess(final JobSuccessInput input) {
   @Trace(operationName = ACTIVITY_TRACE_OPERATION_NAME)
   @Override
   public void jobSuccessWithAttemptNumber(final JobSuccessInputWithAttemptNumber input) {
-    ApmTraceUtils.addTagsToTrace(Map.of(CONNECTION_ID_KEY, input.getConnectionId(), JOB_ID_KEY, input.getJobId()));
-    jobSuccess(new JobSuccessInput(
-        input.getJobId(),
-        input.getAttemptNumber(),
-        input.getConnectionId(),
-        input.getStandardSyncOutput()));
+    throw new RuntimeException("C'est casse");
+    /*
+     * ApmTraceUtils.addTagsToTrace(Map.of(CONNECTION_ID_KEY, input.getConnectionId(), JOB_ID_KEY,
+     * input.getJobId())); jobSuccess(new JobSuccessInput( input.getJobId(), input.getAttemptNumber(),
+     * input.getConnectionId(), input.getStandardSyncOutput()));
+     */
   }
 
   @Trace(operationName = ACTIVITY_TRACE_OPERATION_NAME)