remove debug lines

airbytehq · Jun 22, 2022 · 5e1f24f · 5e1f24f
1 parent 51feb3d
commit 5e1f24f
Showing 1 changed file with 0 additions and 5 deletions.
diff --git a/...s/src/main/java/io/airbyte/workers/temporal/scheduling/ConnectionManagerWorkflowImpl.java b/...s/src/main/java/io/airbyte/workers/temporal/scheduling/ConnectionManagerWorkflowImpl.java
@@ -150,7 +150,6 @@ public void run(final ConnectionUpdaterInput connectionUpdaterInput) throws Retr
 
       // "Cancel" button was pressed on a job
       if (workflowState.isCancelled()) {
-        log.info("--LAKE-- isCancelled is true");
         deleteResetJobStreams();
         reportCancelledAndContinueWith(false, connectionUpdaterInput);
       }
@@ -527,7 +526,6 @@ private <INPUT, OUTPUT> OUTPUT runMandatoryActivityWithOutput(final Function<INP
    */
   private <INPUT> void runMandatoryActivity(final Consumer<INPUT> consumer, final INPUT input) {
     runMandatoryActivityWithOutput((inputInternal) -> {
-      log.info("--LAKE-- runMandatoryActivity called");
       consumer.accept(inputInternal);
       return null;
     }, input);
@@ -760,16 +758,13 @@ private void reportCancelled() {
   }
 
   private void deleteResetJobStreams() {
-    log.info("--LAKE-- start of deleteResetJobStreams");
     final int deleteResetJobStreamsVersion =
         Workflow.getVersion(DELETE_RESET_JOB_STREAMS_TAG, Workflow.DEFAULT_VERSION, DELETE_RESET_JOB_STREAMS_CURRENT_VERSION);
 
-    log.info("--LAKE-- deleteResetJobStreamsVersion: {}", deleteResetJobStreamsVersion);
     if (deleteResetJobStreamsVersion < DELETE_RESET_JOB_STREAMS_CURRENT_VERSION) {
       return;
     }
 
-    log.info("--LAKE-- running deleteStreamResetRecordsForJob activity");
     runMandatoryActivity(streamResetActivity::deleteStreamResetRecordsForJob,
         new DeleteStreamResetRecordsForJobInput(connectionId, workflowInternalState.getJobId()));
   }