fix(grpc): catch exception using status.code instead of status

okp4 · Apr 1, 2022 · 286555b · 286555b
1 parent 0ea7590
commit 286555b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/kotlin/com/okp4/connect/cosmos/CosmosSourceTask.kt b/src/main/kotlin/com/okp4/connect/cosmos/CosmosSourceTask.kt
@@ -66,7 +66,7 @@ class CosmosSourceTask : SourceTask() {
                     onFailure = {
                         // If the status of the exception is INVALID_ARGUMENT,
                         // it means that we reached the end of the chain
-                        if ((it is StatusException) && (it.status == Status.INVALID_ARGUMENT)) return@runBlocking
+                        if ((it is StatusException) && (it.status.code == Status.Code.INVALID_ARGUMENT)) return@runBlocking
                         else throw it
                     }
                 )