Rm logs

airbytehq · Dec 17, 2024 · af41f97 · af41f97
1 parent 38c3c02
commit af41f97
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 5 deletions.
diff --git a/...dk/bulk/core/load/src/main/kotlin/io/airbyte/cdk/load/task/implementor/ProcessFileTask.kt b/...dk/bulk/core/load/src/main/kotlin/io/airbyte/cdk/load/task/implementor/ProcessFileTask.kt
@@ -36,7 +36,6 @@ class DefaultProcessFileTask(
     override suspend fun execute() {
         outputQueue.use {
             inputQueue.consume().collect { (streamDescriptor, file, index) ->
-                log.error { "consuming index $index" }
                 val streamLoader = syncManager.getOrAwaitStreamLoader(streamDescriptor)
 
                 val acc = accumulators.getOrPut(streamDescriptor) {
@@ -52,19 +51,16 @@ class DefaultProcessFileTask(
 
                     if (read == -1) {
                         handleFilePart(file, ByteArray(0), index, true, acc, streamDescriptor, index)
-                        log.error { "end of file" }
                         break
                     } else if (read < bytePart.size) {
                         handleFilePart(file, bytePart.copyOfRange(0, read), index, true, acc, streamDescriptor, index)
-                        log.error { "end of file" }
                         break
                     } else {
                         handleFilePart(file, bytePart, index, false, acc, streamDescriptor, index)
                     }
                 }
                 localFile.delete()
             }
-            log.error { "Closing input queue" }
         }
     }
 

diff --git a/...cdk/bulk/core/load/src/main/kotlin/io/airbyte/cdk/load/task/internal/InputConsumerTask.kt b/...cdk/bulk/core/load/src/main/kotlin/io/airbyte/cdk/load/task/internal/InputConsumerTask.kt
@@ -106,7 +106,6 @@ class DefaultInputConsumerTask(
                 reserved.release() // safe because multiple calls conflate
                 manager.markEndOfStream(true)
                 fileTransferQueue.close()
-                log.error { "End Of Stream" }
                 val envelope =
                     BatchEnvelope(
                         SimpleBatch(Batch.State.COMPLETE),