From 7a5b569056d1e6317698b261cb6c99abd0862a72 Mon Sep 17 00:00:00 2001 From: Cole Snodgrass Date: Tue, 30 May 2023 19:22:44 -0700 Subject: [PATCH] add log if createNewAttemptNumber throws an exception (#6914) --- .../activities/JobCreationAndStatusUpdateActivityImpl.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/airbyte-workers/src/main/java/io/airbyte/workers/temporal/scheduling/activities/JobCreationAndStatusUpdateActivityImpl.java b/airbyte-workers/src/main/java/io/airbyte/workers/temporal/scheduling/activities/JobCreationAndStatusUpdateActivityImpl.java index 95aa8cacc68..b2a61c7a8ec 100644 --- a/airbyte-workers/src/main/java/io/airbyte/workers/temporal/scheduling/activities/JobCreationAndStatusUpdateActivityImpl.java +++ b/airbyte-workers/src/main/java/io/airbyte/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); } }