chore: use separate message for empty exit code file. (#13997)

Author: tryangul

airbyte-commons-worker/src/main/kotlin/io/airbyte/workers/internal/ContainerIOHandle.kt

@@ -30,7 +30,8 @@ data class ContainerIOHandle(
   private val terminationFile: File,
 ) {
   companion object {
-    const val EXIT_CODE_CHECK_FAILURE = "No exit code found."
+    const val EXIT_CODE_CHECK_EXISTS_FAILURE = "No exit code found."
+    const val EXIT_CODE_CHECK_NOT_EMPTY_FAILURE = "Exit code file empty."
     const val TERMINATION_FILE_BODY = "TERMINATE"
 
     /**
@@ -100,8 +101,8 @@ data class ContainerIOHandle(
   fun exitCodeExists(): Boolean = exitValueFile.exists()
 
   fun getExitCode(): Int {
-    check(exitCodeExists()) { EXIT_CODE_CHECK_FAILURE }
-    check(exitValueFile.readText().isNotEmpty()) { EXIT_CODE_CHECK_FAILURE }
+    check(exitCodeExists()) { EXIT_CODE_CHECK_EXISTS_FAILURE }
+    check(exitValueFile.readText().isNotEmpty()) { EXIT_CODE_CHECK_NOT_EMPTY_FAILURE }
     return exitValueFile.readText().trim().toInt()
   }
 

airbyte-commons-worker/src/test/kotlin/io/airbyte/workers/internal/ContainerIOHandleTest.kt

@@ -4,7 +4,8 @@
 
 package io.airbyte.workers.internal
 
-import io.airbyte.workers.internal.ContainerIOHandle.Companion.EXIT_CODE_CHECK_FAILURE
+import io.airbyte.workers.internal.ContainerIOHandle.Companion.EXIT_CODE_CHECK_EXISTS_FAILURE
+import io.airbyte.workers.internal.ContainerIOHandle.Companion.EXIT_CODE_CHECK_NOT_EMPTY_FAILURE
 import io.airbyte.workers.internal.ContainerIOHandle.Companion.TERMINATION_FILE_BODY
 import io.mockk.mockk
 import org.junit.jupiter.api.AfterEach
@@ -70,7 +71,7 @@ internal class ContainerIOHandleTest {
   internal fun testGetErrorCode() {
     // File exists but is empty
     val emptyFileError = assertThrows(IllegalStateException::class.java, containerIOHandle::getExitCode)
-    assertEquals(EXIT_CODE_CHECK_FAILURE, emptyFileError.message)
+    assertEquals(EXIT_CODE_CHECK_NOT_EMPTY_FAILURE, emptyFileError.message)
 
     // File exists and contains an exit value
     val exitCode = -122
@@ -80,7 +81,7 @@ internal class ContainerIOHandleTest {
     // File does not exist
     exitValueFile.delete()
     val notExistError = assertThrows(IllegalStateException::class.java, containerIOHandle::getExitCode)
-    assertEquals(EXIT_CODE_CHECK_FAILURE, notExistError.message)
+    assertEquals(EXIT_CODE_CHECK_EXISTS_FAILURE, notExistError.message)
   }
 
   @Test

airbyte-commons-worker/src/test/kotlin/io/airbyte/workers/internal/LocalContainerAirbyteDestinationTest.kt

@@ -7,7 +7,7 @@ package io.airbyte.workers.internal
 import io.airbyte.config.WorkerDestinationConfig
 import io.airbyte.protocol.models.AirbyteMessage
 import io.airbyte.workers.exception.WorkerException
-import io.airbyte.workers.internal.ContainerIOHandle.Companion.EXIT_CODE_CHECK_FAILURE
+import io.airbyte.workers.internal.ContainerIOHandle.Companion.EXIT_CODE_CHECK_EXISTS_FAILURE
 import io.mockk.every
 import io.mockk.mockk
 import io.mockk.verify
@@ -251,7 +251,7 @@ internal class LocalContainerAirbyteDestinationTest {
 
     exitValueFile.delete()
     val error = assertThrows(IllegalStateException::class.java, { destination.exitValue })
-    assertEquals(EXIT_CODE_CHECK_FAILURE, error.message)
+    assertEquals(EXIT_CODE_CHECK_EXISTS_FAILURE, error.message)
   }
 
   @Test

airbyte-commons-worker/src/test/kotlin/io/airbyte/workers/internal/LocalContainerAirbyteSourceTest.kt

@@ -7,7 +7,7 @@ package io.airbyte.workers.internal
 import io.airbyte.config.WorkerSourceConfig
 import io.airbyte.protocol.models.AirbyteMessage
 import io.airbyte.workers.exception.WorkerException
-import io.airbyte.workers.internal.ContainerIOHandle.Companion.EXIT_CODE_CHECK_FAILURE
+import io.airbyte.workers.internal.ContainerIOHandle.Companion.EXIT_CODE_CHECK_EXISTS_FAILURE
 import io.mockk.every
 import io.mockk.mockk
 import io.mockk.verify
@@ -142,7 +142,7 @@ internal class LocalContainerAirbyteSourceTest {
 
     exitValueFile.delete()
     val error = assertThrows(IllegalStateException::class.java, { source.exitValue })
-    assertEquals(EXIT_CODE_CHECK_FAILURE, error.message)
+    assertEquals(EXIT_CODE_CHECK_EXISTS_FAILURE, error.message)
   }
 
   @Test