fix: check invalid status by its code

okp4 · Apr 8, 2022 · 284aa9a · 284aa9a
1 parent be238b8
commit 284aa9a
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
@@ -53,7 +53,7 @@ class CosmosSourceTask : SourceTask() {
                     .takeWhile { !serviceClient.isClosed() }
                     .map { serviceClient.getBlockByHeight(it) }
                     .map { it.getOrThrow() }
-                    .catch { if (it is StatusException && it.status != Status.INVALID_ARGUMENT) throw it }
+                    .catch { if (it is StatusException && it.status.code != Status.INVALID_ARGUMENT.code) throw it }
                     .map { asSourceRecord(it) }
                     .toList()
             }