add log if createNewAttemptNumber throws an exception (#6914)

airbytehq · May 31, 2023 · 7a5b569 · 7a5b569
1 parent 0f0b75d
commit 7a5b569
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...irbyte/workers/temporal/scheduling/activities/JobCreationAndStatusUpdateActivityImpl.java b/...irbyte/workers/temporal/scheduling/activities/JobCreationAndStatusUpdateActivityImpl.java
@@ -221,6 +221,7 @@ public JobCreationOutput createNewJob(final JobCreationInput input) {
         return new JobCreationOutput(jobId);
       }
     } catch (final JsonValidationException | ConfigNotFoundException | IOException e) {
+      log.error("createNewJob for connection {} failed with exception: {}", input.getConnectionId(), e.getMessage(), e);
       throw new RetryableException(e);
     }
   }
@@ -257,6 +258,7 @@ public AttemptNumberCreationOutput createNewAttemptNumber(final AttemptCreationI
       LogClientSingleton.getInstance().setJobMdc(workerEnvironment, logConfigs, jobRoot);
       return new AttemptNumberCreationOutput(persistedAttemptNumber);
     } catch (final IOException e) {
+      log.error("createNewAttemptNumber for job {} failed with exception: {}", input.getJobId(), e.getMessage(), e);
       throw new RetryableException(e);
     }
   }
@@ -353,6 +355,7 @@ public void attemptFailureWithAttemptNumber(final AttemptNumberFailureInput inpu
       emitJobIdToReleaseStagesMetric(OssMetricsRegistry.ATTEMPT_FAILED_BY_RELEASE_STAGE, jobId);
       trackFailures(failureSummary);
     } catch (final IOException e) {
+      log.error("attemptFailureWithAttemptNumber for job {} failed with exception: {}", input.getJobId(), e.getMessage(), e);
       throw new RetryableException(e);
     }
   }