diff --git a/.release-please-manifest.json b/.release-please-manifest.json
index 25bf810..9efa5ca 100644
--- a/.release-please-manifest.json
+++ b/.release-please-manifest.json
@@ -1,3 +1,3 @@
 {
-  ".": "0.0.33"
+  ".": "0.0.34"
 }
diff --git a/CHANGELOG.md b/CHANGELOG.md
index c72417d..26e7ac7 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,5 +1,15 @@
 # Changelog
 
+## [0.0.34](https://github.com/cloudquery/plugin-pb-java/compare/v0.0.33...v0.0.34) (2025-07-01)
+
+
+### Bug Fixes
+
+* **deps:** Update dependency com.google.protobuf:protobuf-java-util to v4.31.1 ([#172](https://github.com/cloudquery/plugin-pb-java/issues/172)) ([7316e77](https://github.com/cloudquery/plugin-pb-java/commit/7316e773aeabfdee3c0d267a76718bd5cd3586d5))
+* **deps:** Update dependency gradle to v8.14.2 ([#173](https://github.com/cloudquery/plugin-pb-java/issues/173)) ([553ee1d](https://github.com/cloudquery/plugin-pb-java/commit/553ee1d5c5408d36c7ce9348a60112cc14eb1a81))
+* Generate Java Code from `plugin-pb` ([#170](https://github.com/cloudquery/plugin-pb-java/issues/170)) ([338d022](https://github.com/cloudquery/plugin-pb-java/commit/338d02226b6e75c2b4a609c6ba1563f4b603578b))
+* Generate Java Code from `plugin-pb` ([#174](https://github.com/cloudquery/plugin-pb-java/issues/174)) ([d2e0187](https://github.com/cloudquery/plugin-pb-java/commit/d2e01871acd83621eee23e86c540cedd1a20682f))
+
 ## [0.0.33](https://github.com/cloudquery/plugin-pb-java/compare/v0.0.32...v0.0.33) (2025-06-26)
 
 
diff --git a/build.gradle b/build.gradle
index 8d1267b..6d12840 100644
--- a/build.gradle
+++ b/build.gradle
@@ -10,7 +10,7 @@ mainClassName = 'main.Main'
 
 group 'io.cloudquery'
 // x-release-please-start-version
-version = '0.0.33'
+version = '0.0.34'
 // x-release-please-end
 
 repositories {
@@ -24,7 +24,7 @@ sourceCompatibility = 1.8
 targetCompatibility = 1.8
 
 def grpcVersion = '1.72.0'
-def protobufVersion = '4.30.2'
+def protobufVersion = '4.31.1'
 def protocVersion = protobufVersion
 
 dependencies {
diff --git a/build/generated/source/proto/main/java/io/cloudquery/discovery/v1/DiscoveryOuterClass.java b/build/generated/source/proto/main/java/io/cloudquery/discovery/v1/DiscoveryOuterClass.java
index ff3e34a..dec4f8e 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/discovery/v1/DiscoveryOuterClass.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/discovery/v1/DiscoveryOuterClass.java
@@ -1,18 +1,19 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/discovery/v1/discovery.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.discovery.v1;
 
+@com.google.protobuf.Generated
 public final class DiscoveryOuterClass {
   private DiscoveryOuterClass() {}
   static {
     com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
       com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
       /* major= */ 4,
-      /* minor= */ 30,
-      /* patch= */ 2,
+      /* minor= */ 31,
+      /* patch= */ 1,
       /* suffix= */ "",
       DiscoveryOuterClass.class.getName());
   }
diff --git a/build/generated/source/proto/main/java/io/cloudquery/discovery/v1/GetVersions.java b/build/generated/source/proto/main/java/io/cloudquery/discovery/v1/GetVersions.java
index 384fa5d..211a819 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/discovery/v1/GetVersions.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/discovery/v1/GetVersions.java
@@ -1,13 +1,14 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/discovery/v1/discovery.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.discovery.v1;
 
 /**
  * Protobuf type {@code cloudquery.discovery.v1.GetVersions}
  */
+@com.google.protobuf.Generated
 public final class GetVersions extends
     com.google.protobuf.GeneratedMessage implements
     // @@protoc_insertion_point(message_implements:cloudquery.discovery.v1.GetVersions)
@@ -17,8 +18,8 @@ public final class GetVersions extends
     com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
       com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
       /* major= */ 4,
-      /* minor= */ 30,
-      /* patch= */ 2,
+      /* minor= */ 31,
+      /* patch= */ 1,
       /* suffix= */ "",
       GetVersions.class.getName());
   }
@@ -58,8 +59,8 @@ public static final class Request extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         Request.class.getName());
     }
@@ -430,8 +431,8 @@ public static final class Response extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         Response.class.getName());
     }
diff --git a/build/generated/source/proto/main/java/io/cloudquery/discovery/v1/GetVersionsOrBuilder.java b/build/generated/source/proto/main/java/io/cloudquery/discovery/v1/GetVersionsOrBuilder.java
index f6f9b2f..e3cf63d 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/discovery/v1/GetVersionsOrBuilder.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/discovery/v1/GetVersionsOrBuilder.java
@@ -1,10 +1,11 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/discovery/v1/discovery.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.discovery.v1;
 
+@com.google.protobuf.Generated
 public interface GetVersionsOrBuilder extends
     // @@protoc_insertion_point(interface_extends:cloudquery.discovery.v1.GetVersions)
     com.google.protobuf.MessageOrBuilder {
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Close.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Close.java
index 80d221b..172b2e4 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Close.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Close.java
@@ -1,13 +1,14 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
 /**
  * Protobuf type {@code cloudquery.plugin.v3.Close}
  */
+@com.google.protobuf.Generated
 public final class Close extends
     com.google.protobuf.GeneratedMessage implements
     // @@protoc_insertion_point(message_implements:cloudquery.plugin.v3.Close)
@@ -17,8 +18,8 @@ public final class Close extends
     com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
       com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
       /* major= */ 4,
-      /* minor= */ 30,
-      /* patch= */ 2,
+      /* minor= */ 31,
+      /* patch= */ 1,
       /* suffix= */ "",
       Close.class.getName());
   }
@@ -58,8 +59,8 @@ public static final class Request extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         Request.class.getName());
     }
@@ -413,8 +414,8 @@ public static final class Response extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         Response.class.getName());
     }
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/CloseOrBuilder.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/CloseOrBuilder.java
index 248a8e6..cfb5b6c 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/CloseOrBuilder.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/CloseOrBuilder.java
@@ -1,10 +1,11 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
+@com.google.protobuf.Generated
 public interface CloseOrBuilder extends
     // @@protoc_insertion_point(interface_extends:cloudquery.plugin.v3.Close)
     com.google.protobuf.MessageOrBuilder {
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetName.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetName.java
index 259b32e..c8f9c42 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetName.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetName.java
@@ -1,13 +1,14 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
 /**
  * Protobuf type {@code cloudquery.plugin.v3.GetName}
  */
+@com.google.protobuf.Generated
 public final class GetName extends
     com.google.protobuf.GeneratedMessage implements
     // @@protoc_insertion_point(message_implements:cloudquery.plugin.v3.GetName)
@@ -17,8 +18,8 @@ public final class GetName extends
     com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
       com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
       /* major= */ 4,
-      /* minor= */ 30,
-      /* patch= */ 2,
+      /* minor= */ 31,
+      /* patch= */ 1,
       /* suffix= */ "",
       GetName.class.getName());
   }
@@ -58,8 +59,8 @@ public static final class Request extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         Request.class.getName());
     }
@@ -425,8 +426,8 @@ public static final class Response extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         Response.class.getName());
     }
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetNameOrBuilder.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetNameOrBuilder.java
index ea2b949..073a44c 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetNameOrBuilder.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetNameOrBuilder.java
@@ -1,10 +1,11 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
+@com.google.protobuf.Generated
 public interface GetNameOrBuilder extends
     // @@protoc_insertion_point(interface_extends:cloudquery.plugin.v3.GetName)
     com.google.protobuf.MessageOrBuilder {
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetSpecSchema.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetSpecSchema.java
index 529b7f6..8320263 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetSpecSchema.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetSpecSchema.java
@@ -1,13 +1,14 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
 /**
  * Protobuf type {@code cloudquery.plugin.v3.GetSpecSchema}
  */
+@com.google.protobuf.Generated
 public final class GetSpecSchema extends
     com.google.protobuf.GeneratedMessage implements
     // @@protoc_insertion_point(message_implements:cloudquery.plugin.v3.GetSpecSchema)
@@ -17,8 +18,8 @@ public final class GetSpecSchema extends
     com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
       com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
       /* major= */ 4,
-      /* minor= */ 30,
-      /* patch= */ 2,
+      /* minor= */ 31,
+      /* patch= */ 1,
       /* suffix= */ "",
       GetSpecSchema.class.getName());
   }
@@ -58,8 +59,8 @@ public static final class Request extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         Request.class.getName());
     }
@@ -445,8 +446,8 @@ public static final class Response extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         Response.class.getName());
     }
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetSpecSchemaOrBuilder.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetSpecSchemaOrBuilder.java
index 3059be9..5e25f78 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetSpecSchemaOrBuilder.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetSpecSchemaOrBuilder.java
@@ -1,10 +1,11 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
+@com.google.protobuf.Generated
 public interface GetSpecSchemaOrBuilder extends
     // @@protoc_insertion_point(interface_extends:cloudquery.plugin.v3.GetSpecSchema)
     com.google.protobuf.MessageOrBuilder {
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetTables.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetTables.java
index a262d67..47b75d5 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetTables.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetTables.java
@@ -1,13 +1,14 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
 /**
  * Protobuf type {@code cloudquery.plugin.v3.GetTables}
  */
+@com.google.protobuf.Generated
 public final class GetTables extends
     com.google.protobuf.GeneratedMessage implements
     // @@protoc_insertion_point(message_implements:cloudquery.plugin.v3.GetTables)
@@ -17,8 +18,8 @@ public final class GetTables extends
     com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
       com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
       /* major= */ 4,
-      /* minor= */ 30,
-      /* patch= */ 2,
+      /* minor= */ 31,
+      /* patch= */ 1,
       /* suffix= */ "",
       GetTables.class.getName());
   }
@@ -114,8 +115,8 @@ public static final class Request extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         Request.class.getName());
     }
@@ -950,8 +951,8 @@ public static final class Response extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         Response.class.getName());
     }
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetTablesOrBuilder.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetTablesOrBuilder.java
index 84ecf3f..81b6d47 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetTablesOrBuilder.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetTablesOrBuilder.java
@@ -1,10 +1,11 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
+@com.google.protobuf.Generated
 public interface GetTablesOrBuilder extends
     // @@protoc_insertion_point(interface_extends:cloudquery.plugin.v3.GetTables)
     com.google.protobuf.MessageOrBuilder {
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetVersion.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetVersion.java
index 6cc582a..d3376dd 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetVersion.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetVersion.java
@@ -1,13 +1,14 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
 /**
  * Protobuf type {@code cloudquery.plugin.v3.GetVersion}
  */
+@com.google.protobuf.Generated
 public final class GetVersion extends
     com.google.protobuf.GeneratedMessage implements
     // @@protoc_insertion_point(message_implements:cloudquery.plugin.v3.GetVersion)
@@ -17,8 +18,8 @@ public final class GetVersion extends
     com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
       com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
       /* major= */ 4,
-      /* minor= */ 30,
-      /* patch= */ 2,
+      /* minor= */ 31,
+      /* patch= */ 1,
       /* suffix= */ "",
       GetVersion.class.getName());
   }
@@ -58,8 +59,8 @@ public static final class Request extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         Request.class.getName());
     }
@@ -425,8 +426,8 @@ public static final class Response extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         Response.class.getName());
     }
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetVersionOrBuilder.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetVersionOrBuilder.java
index a149970..5c355ef 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetVersionOrBuilder.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/GetVersionOrBuilder.java
@@ -1,10 +1,11 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
+@com.google.protobuf.Generated
 public interface GetVersionOrBuilder extends
     // @@protoc_insertion_point(interface_extends:cloudquery.plugin.v3.GetVersion)
     com.google.protobuf.MessageOrBuilder {
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Init.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Init.java
index 8918a88..028035c 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Init.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Init.java
@@ -1,13 +1,14 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
 /**
  * Protobuf type {@code cloudquery.plugin.v3.Init}
  */
+@com.google.protobuf.Generated
 public final class Init extends
     com.google.protobuf.GeneratedMessage implements
     // @@protoc_insertion_point(message_implements:cloudquery.plugin.v3.Init)
@@ -17,8 +18,8 @@ public final class Init extends
     com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
       com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
       /* major= */ 4,
-      /* minor= */ 30,
-      /* patch= */ 2,
+      /* minor= */ 31,
+      /* patch= */ 1,
       /* suffix= */ "",
       Init.class.getName());
   }
@@ -98,8 +99,8 @@ public static final class Request extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         Request.class.getName());
     }
@@ -790,8 +791,8 @@ public static final class Response extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         Response.class.getName());
     }
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/InitOrBuilder.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/InitOrBuilder.java
index 5dfc1f3..85f8c64 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/InitOrBuilder.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/InitOrBuilder.java
@@ -1,10 +1,11 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
+@com.google.protobuf.Generated
 public interface InitOrBuilder extends
     // @@protoc_insertion_point(interface_extends:cloudquery.plugin.v3.Init)
     com.google.protobuf.MessageOrBuilder {
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/PluginOuterClass.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/PluginOuterClass.java
index 3679a0e..7edcd03 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/PluginOuterClass.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/PluginOuterClass.java
@@ -1,18 +1,19 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
+@com.google.protobuf.Generated
 public final class PluginOuterClass {
   private PluginOuterClass() {}
   static {
     com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
       com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
       /* major= */ 4,
-      /* minor= */ 30,
-      /* patch= */ 2,
+      /* minor= */ 31,
+      /* patch= */ 1,
       /* suffix= */ "",
       PluginOuterClass.class.getName());
   }
@@ -291,7 +292,7 @@ public static void registerAllExtensions(
       "ponse\"v\n\tGetTables\032M\n\007Request\022\016\n\006tables\030" +
       "\001 \003(\t\022\023\n\013skip_tables\030\002 \003(\t\022\035\n\025skip_depen" +
       "dent_tables\030\003 \001(\010\032\032\n\010Response\022\016\n\006tables\030" +
-      "\001 \003(\014\"\227\007\n\004Sync\032\037\n\rMessageInsert\022\016\n\006recor" +
+      "\001 \003(\014\"\262\007\n\004Sync\032\037\n\rMessageInsert\022\016\n\006recor" +
       "d\030\001 \001(\014\032$\n\023MessageMigrateTable\022\r\n\005table\030" +
       "\001 \001(\014\032\244\001\n\023MessageDeleteRecord\022\022\n\ntable_n" +
       "ame\030\001 \001(\t\022;\n\014where_clause\030\002 \003(\0132%.cloudq" +
@@ -300,87 +301,88 @@ public static void registerAllExtensions(
       "ableRelation\0321\n\014MessageError\022\022\n\ntable_na" +
       "me\030\001 \001(\t\022\r\n\005error\030\002 \001(\t\0328\n\016BackendOption" +
       "s\022\022\n\ntable_name\030\001 \001(\t\022\022\n\nconnection\030\002 \001(" +
-      "\t\032\223\002\n\007Request\022\016\n\006tables\030\001 \003(\t\022\023\n\013skip_ta" +
+      "\t\032\256\002\n\007Request\022\016\n\006tables\030\001 \003(\t\022\023\n\013skip_ta" +
       "bles\030\002 \003(\t\022\035\n\025skip_dependent_tables\030\003 \001(" +
       "\010\022\033\n\023deterministic_cq_id\030\004 \001(\010\022:\n\007backen" +
       "d\030\005 \001(\0132).cloudquery.plugin.v3.Sync.Back" +
       "endOptions\022<\n\005shard\030\006 \001(\0132(.cloudquery.p" +
-      "lugin.v3.Sync.Request.ShardH\000\210\001\001\032#\n\005Shar" +
-      "d\022\013\n\003num\030\001 \001(\005\022\r\n\005total\030\002 \001(\005B\010\n\006_shard\032" +
-      "\235\002\n\010Response\022G\n\rmigrate_table\030\001 \001(\0132..cl" +
-      "oudquery.plugin.v3.Sync.MessageMigrateTa" +
-      "bleH\000\022:\n\006insert\030\002 \001(\0132(.cloudquery.plugi" +
-      "n.v3.Sync.MessageInsertH\000\022G\n\rdelete_reco" +
-      "rd\030\003 \001(\0132..cloudquery.plugin.v3.Sync.Mes" +
-      "sageDeleteRecordH\000\0228\n\005error\030\004 \001(\0132\'.clou" +
-      "dquery.plugin.v3.Sync.MessageErrorH\000B\t\n\007" +
-      "message\"<\n\004Read\032\030\n\007Request\022\r\n\005table\030\001 \001(" +
-      "\014\032\032\n\010Response\022\016\n\006record\030\001 \001(\014\"9\n\rTableRe" +
-      "lation\022\022\n\ntable_name\030\001 \001(\t\022\024\n\014parent_tab" +
-      "le\030\002 \001(\t\"{\n\tPredicate\022:\n\010operator\030\001 \001(\0162" +
-      "(.cloudquery.plugin.v3.Predicate.Operato" +
-      "r\022\016\n\006column\030\002 \001(\t\022\016\n\006record\030\003 \001(\014\"\022\n\010Ope" +
-      "rator\022\006\n\002EQ\020\000\"\262\001\n\017PredicatesGroup\022I\n\rgro" +
-      "uping_type\030\001 \001(\01622.cloudquery.plugin.v3." +
-      "PredicatesGroup.GroupingType\0223\n\npredicat" +
-      "es\030\002 \003(\0132\037.cloudquery.plugin.v3.Predicat" +
-      "e\"\037\n\014GroupingType\022\007\n\003AND\020\000\022\006\n\002OR\020\001\"\303\005\n\005W" +
-      "rite\032;\n\023MessageMigrateTable\022\r\n\005table\030\001 \001" +
-      "(\014\022\025\n\rmigrate_force\030\002 \001(\010\032\037\n\rMessageInse" +
-      "rt\022\016\n\006record\030\001 \001(\014\032\177\n\022MessageDeleteStale" +
-      "\022\021\n\005table\030\001 \001(\014B\002\030\001\022\023\n\013source_name\030\002 \001(\t" +
-      "\022-\n\tsync_time\030\003 \001(\0132\032.google.protobuf.Ti" +
-      "mestamp\022\022\n\ntable_name\030\004 \001(\t\032\244\001\n\023MessageD" +
-      "eleteRecord\022\022\n\ntable_name\030\001 \001(\t\022;\n\014where" +
-      "_clause\030\002 \003(\0132%.cloudquery.plugin.v3.Pre" +
-      "dicatesGroup\022<\n\017table_relations\030\003 \003(\0132#." +
-      "cloudquery.plugin.v3.TableRelation\032\247\002\n\007R" +
-      "equest\022H\n\rmigrate_table\030\001 \001(\0132/.cloudque" +
-      "ry.plugin.v3.Write.MessageMigrateTableH\000" +
-      "\022;\n\006insert\030\002 \001(\0132).cloudquery.plugin.v3." +
-      "Write.MessageInsertH\000\022@\n\006delete\030\003 \001(\0132.." +
-      "cloudquery.plugin.v3.Write.MessageDelete" +
-      "StaleH\000\022H\n\rdelete_record\030\004 \001(\0132/.cloudqu" +
-      "ery.plugin.v3.Write.MessageDeleteRecordH" +
-      "\000B\t\n\007message\032\n\n\010Response\"B\n\tTransform\032\031\n" +
-      "\007Request\022\016\n\006record\030\001 \001(\014\032\032\n\010Response\022\016\n\006" +
-      "record\030\001 \001(\014\"H\n\017TransformSchema\032\031\n\007Reque" +
-      "st\022\016\n\006schema\030\001 \001(\014\032\032\n\010Response\022\016\n\006schema" +
-      "\030\001 \001(\014\"\036\n\005Close\032\t\n\007Request\032\n\n\010Response\"y" +
-      "\n\016TestConnection\032\027\n\007Request\022\014\n\004spec\030\001 \001(" +
-      "\014\032N\n\010Response\022\017\n\007success\030\001 \001(\010\022\024\n\014failur" +
-      "e_code\030\002 \001(\t\022\033\n\023failure_description\030\003 \001(" +
-      "\t2\367\010\n\006Plugin\022X\n\007GetName\022%.cloudquery.plu" +
-      "gin.v3.GetName.Request\032&.cloudquery.plug" +
-      "in.v3.GetName.Response\022a\n\nGetVersion\022(.c" +
-      "loudquery.plugin.v3.GetVersion.Request\032)" +
-      ".cloudquery.plugin.v3.GetVersion.Respons" +
-      "e\022j\n\rGetSpecSchema\022+.cloudquery.plugin.v" +
-      "3.GetSpecSchema.Request\032,.cloudquery.plu" +
-      "gin.v3.GetSpecSchema.Response\022O\n\004Init\022\"." +
-      "cloudquery.plugin.v3.Init.Request\032#.clou" +
-      "dquery.plugin.v3.Init.Response\022^\n\tGetTab" +
-      "les\022\'.cloudquery.plugin.v3.GetTables.Req" +
-      "uest\032(.cloudquery.plugin.v3.GetTables.Re" +
-      "sponse\022Q\n\004Sync\022\".cloudquery.plugin.v3.Sy" +
-      "nc.Request\032#.cloudquery.plugin.v3.Sync.R" +
-      "esponse0\001\022Q\n\004Read\022\".cloudquery.plugin.v3" +
-      ".Read.Request\032#.cloudquery.plugin.v3.Rea" +
-      "d.Response0\001\022T\n\005Write\022#.cloudquery.plugi" +
-      "n.v3.Write.Request\032$.cloudquery.plugin.v" +
-      "3.Write.Response(\001\022b\n\tTransform\022\'.cloudq" +
-      "uery.plugin.v3.Transform.Request\032(.cloud" +
-      "query.plugin.v3.Transform.Response(\0010\001\022p" +
-      "\n\017TransformSchema\022-.cloudquery.plugin.v3" +
-      ".TransformSchema.Request\032..cloudquery.pl" +
-      "ugin.v3.TransformSchema.Response\022R\n\005Clos" +
-      "e\022#.cloudquery.plugin.v3.Close.Request\032$" +
-      ".cloudquery.plugin.v3.Close.Response\022m\n\016" +
-      "TestConnection\022,.cloudquery.plugin.v3.Te" +
-      "stConnection.Request\032-.cloudquery.plugin" +
-      ".v3.TestConnection.ResponseBS\n\027io.cloudq" +
-      "uery.plugin.v3P\001Z6github.amrom.workers.dev/cloudquery/" +
-      "plugin-pb-go/pb/plugin/v3;pluginb\006proto3"
+      "lugin.v3.Sync.Request.ShardH\000\210\001\001\022\031\n\021with" +
+      "ErrorMessages\030\007 \001(\010\032#\n\005Shard\022\013\n\003num\030\001 \001(" +
+      "\005\022\r\n\005total\030\002 \001(\005B\010\n\006_shard\032\235\002\n\010Response\022" +
+      "G\n\rmigrate_table\030\001 \001(\0132..cloudquery.plug" +
+      "in.v3.Sync.MessageMigrateTableH\000\022:\n\006inse" +
+      "rt\030\002 \001(\0132(.cloudquery.plugin.v3.Sync.Mes" +
+      "sageInsertH\000\022G\n\rdelete_record\030\003 \001(\0132..cl" +
+      "oudquery.plugin.v3.Sync.MessageDeleteRec" +
+      "ordH\000\0228\n\005error\030\004 \001(\0132\'.cloudquery.plugin" +
+      ".v3.Sync.MessageErrorH\000B\t\n\007message\"<\n\004Re" +
+      "ad\032\030\n\007Request\022\r\n\005table\030\001 \001(\014\032\032\n\010Response" +
+      "\022\016\n\006record\030\001 \001(\014\"9\n\rTableRelation\022\022\n\ntab" +
+      "le_name\030\001 \001(\t\022\024\n\014parent_table\030\002 \001(\t\"{\n\tP" +
+      "redicate\022:\n\010operator\030\001 \001(\0162(.cloudquery." +
+      "plugin.v3.Predicate.Operator\022\016\n\006column\030\002" +
+      " \001(\t\022\016\n\006record\030\003 \001(\014\"\022\n\010Operator\022\006\n\002EQ\020\000" +
+      "\"\262\001\n\017PredicatesGroup\022I\n\rgrouping_type\030\001 " +
+      "\001(\01622.cloudquery.plugin.v3.PredicatesGro" +
+      "up.GroupingType\0223\n\npredicates\030\002 \003(\0132\037.cl" +
+      "oudquery.plugin.v3.Predicate\"\037\n\014Grouping" +
+      "Type\022\007\n\003AND\020\000\022\006\n\002OR\020\001\"\303\005\n\005Write\032;\n\023Messa" +
+      "geMigrateTable\022\r\n\005table\030\001 \001(\014\022\025\n\rmigrate" +
+      "_force\030\002 \001(\010\032\037\n\rMessageInsert\022\016\n\006record\030" +
+      "\001 \001(\014\032\177\n\022MessageDeleteStale\022\021\n\005table\030\001 \001" +
+      "(\014B\002\030\001\022\023\n\013source_name\030\002 \001(\t\022-\n\tsync_time" +
+      "\030\003 \001(\0132\032.google.protobuf.Timestamp\022\022\n\nta" +
+      "ble_name\030\004 \001(\t\032\244\001\n\023MessageDeleteRecord\022\022" +
+      "\n\ntable_name\030\001 \001(\t\022;\n\014where_clause\030\002 \003(\013" +
+      "2%.cloudquery.plugin.v3.PredicatesGroup\022" +
+      "<\n\017table_relations\030\003 \003(\0132#.cloudquery.pl" +
+      "ugin.v3.TableRelation\032\247\002\n\007Request\022H\n\rmig" +
+      "rate_table\030\001 \001(\0132/.cloudquery.plugin.v3." +
+      "Write.MessageMigrateTableH\000\022;\n\006insert\030\002 " +
+      "\001(\0132).cloudquery.plugin.v3.Write.Message" +
+      "InsertH\000\022@\n\006delete\030\003 \001(\0132..cloudquery.pl" +
+      "ugin.v3.Write.MessageDeleteStaleH\000\022H\n\rde" +
+      "lete_record\030\004 \001(\0132/.cloudquery.plugin.v3" +
+      ".Write.MessageDeleteRecordH\000B\t\n\007message\032" +
+      "\n\n\010Response\"B\n\tTransform\032\031\n\007Request\022\016\n\006r" +
+      "ecord\030\001 \001(\014\032\032\n\010Response\022\016\n\006record\030\001 \001(\014\"" +
+      "H\n\017TransformSchema\032\031\n\007Request\022\016\n\006schema\030" +
+      "\001 \001(\014\032\032\n\010Response\022\016\n\006schema\030\001 \001(\014\"\036\n\005Clo" +
+      "se\032\t\n\007Request\032\n\n\010Response\"y\n\016TestConnect" +
+      "ion\032\027\n\007Request\022\014\n\004spec\030\001 \001(\014\032N\n\010Response" +
+      "\022\017\n\007success\030\001 \001(\010\022\024\n\014failure_code\030\002 \001(\t\022" +
+      "\033\n\023failure_description\030\003 \001(\t2\367\010\n\006Plugin\022" +
+      "X\n\007GetName\022%.cloudquery.plugin.v3.GetNam" +
+      "e.Request\032&.cloudquery.plugin.v3.GetName" +
+      ".Response\022a\n\nGetVersion\022(.cloudquery.plu" +
+      "gin.v3.GetVersion.Request\032).cloudquery.p" +
+      "lugin.v3.GetVersion.Response\022j\n\rGetSpecS" +
+      "chema\022+.cloudquery.plugin.v3.GetSpecSche" +
+      "ma.Request\032,.cloudquery.plugin.v3.GetSpe" +
+      "cSchema.Response\022O\n\004Init\022\".cloudquery.pl" +
+      "ugin.v3.Init.Request\032#.cloudquery.plugin" +
+      ".v3.Init.Response\022^\n\tGetTables\022\'.cloudqu" +
+      "ery.plugin.v3.GetTables.Request\032(.cloudq" +
+      "uery.plugin.v3.GetTables.Response\022Q\n\004Syn" +
+      "c\022\".cloudquery.plugin.v3.Sync.Request\032#." +
+      "cloudquery.plugin.v3.Sync.Response0\001\022Q\n\004" +
+      "Read\022\".cloudquery.plugin.v3.Read.Request" +
+      "\032#.cloudquery.plugin.v3.Read.Response0\001\022" +
+      "T\n\005Write\022#.cloudquery.plugin.v3.Write.Re" +
+      "quest\032$.cloudquery.plugin.v3.Write.Respo" +
+      "nse(\001\022b\n\tTransform\022\'.cloudquery.plugin.v" +
+      "3.Transform.Request\032(.cloudquery.plugin." +
+      "v3.Transform.Response(\0010\001\022p\n\017TransformSc" +
+      "hema\022-.cloudquery.plugin.v3.TransformSch" +
+      "ema.Request\032..cloudquery.plugin.v3.Trans" +
+      "formSchema.Response\022R\n\005Close\022#.cloudquer" +
+      "y.plugin.v3.Close.Request\032$.cloudquery.p" +
+      "lugin.v3.Close.Response\022m\n\016TestConnectio" +
+      "n\022,.cloudquery.plugin.v3.TestConnection." +
+      "Request\032-.cloudquery.plugin.v3.TestConne" +
+      "ction.ResponseBS\n\027io.cloudquery.plugin.v" +
+      "3P\001Z6github.amrom.workers.dev/cloudquery/plugin-pb-go/" +
+      "pb/plugin/v3;pluginb\006proto3"
     };
     descriptor = com.google.protobuf.Descriptors.FileDescriptor
       .internalBuildGeneratedFileFrom(descriptorData,
@@ -518,7 +520,7 @@ public static void registerAllExtensions(
     internal_static_cloudquery_plugin_v3_Sync_Request_fieldAccessorTable = new
       com.google.protobuf.GeneratedMessage.FieldAccessorTable(
         internal_static_cloudquery_plugin_v3_Sync_Request_descriptor,
-        new java.lang.String[] { "Tables", "SkipTables", "SkipDependentTables", "DeterministicCqId", "Backend", "Shard", });
+        new java.lang.String[] { "Tables", "SkipTables", "SkipDependentTables", "DeterministicCqId", "Backend", "Shard", "WithErrorMessages", });
     internal_static_cloudquery_plugin_v3_Sync_Request_Shard_descriptor =
       internal_static_cloudquery_plugin_v3_Sync_Request_descriptor.getNestedTypes().get(0);
     internal_static_cloudquery_plugin_v3_Sync_Request_Shard_fieldAccessorTable = new
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Predicate.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Predicate.java
index 5262f9e..57d9af3 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Predicate.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Predicate.java
@@ -1,13 +1,14 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
 /**
  * Protobuf type {@code cloudquery.plugin.v3.Predicate}
  */
+@com.google.protobuf.Generated
 public final class Predicate extends
     com.google.protobuf.GeneratedMessage implements
     // @@protoc_insertion_point(message_implements:cloudquery.plugin.v3.Predicate)
@@ -17,8 +18,8 @@ public final class Predicate extends
     com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
       com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
       /* major= */ 4,
-      /* minor= */ 30,
-      /* patch= */ 2,
+      /* minor= */ 31,
+      /* patch= */ 1,
       /* suffix= */ "",
       Predicate.class.getName());
   }
@@ -68,8 +69,8 @@ public enum Operator
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         Operator.class.getName());
     }
@@ -139,7 +140,7 @@ public Operator findValueByNumber(int number) {
         getDescriptorForType() {
       return getDescriptor();
     }
-    public static final com.google.protobuf.Descriptors.EnumDescriptor
+    public static com.google.protobuf.Descriptors.EnumDescriptor
         getDescriptor() {
       return io.cloudquery.plugin.v3.Predicate.getDescriptor().getEnumTypes().get(0);
     }
@@ -612,9 +613,7 @@ public io.cloudquery.plugin.v3.Predicate.Operator getOperator() {
      * @return This builder for chaining.
      */
     public Builder setOperator(io.cloudquery.plugin.v3.Predicate.Operator value) {
-      if (value == null) {
-        throw new NullPointerException();
-      }
+      if (value == null) { throw new NullPointerException(); }
       bitField0_ |= 0x00000001;
       operator_ = value.getNumber();
       onChanged();
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/PredicateOrBuilder.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/PredicateOrBuilder.java
index c9bffc3..ef95220 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/PredicateOrBuilder.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/PredicateOrBuilder.java
@@ -1,10 +1,11 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
+@com.google.protobuf.Generated
 public interface PredicateOrBuilder extends
     // @@protoc_insertion_point(interface_extends:cloudquery.plugin.v3.Predicate)
     com.google.protobuf.MessageOrBuilder {
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/PredicatesGroup.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/PredicatesGroup.java
index 68359d8..a9b0f26 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/PredicatesGroup.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/PredicatesGroup.java
@@ -1,13 +1,14 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
 /**
  * Protobuf type {@code cloudquery.plugin.v3.PredicatesGroup}
  */
+@com.google.protobuf.Generated
 public final class PredicatesGroup extends
     com.google.protobuf.GeneratedMessage implements
     // @@protoc_insertion_point(message_implements:cloudquery.plugin.v3.PredicatesGroup)
@@ -17,8 +18,8 @@ public final class PredicatesGroup extends
     com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
       com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
       /* major= */ 4,
-      /* minor= */ 30,
-      /* patch= */ 2,
+      /* minor= */ 31,
+      /* patch= */ 1,
       /* suffix= */ "",
       PredicatesGroup.class.getName());
   }
@@ -64,8 +65,8 @@ public enum GroupingType
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         GroupingType.class.getName());
     }
@@ -133,7 +134,7 @@ public GroupingType findValueByNumber(int number) {
         getDescriptorForType() {
       return getDescriptor();
     }
-    public static final com.google.protobuf.Descriptors.EnumDescriptor
+    public static com.google.protobuf.Descriptors.EnumDescriptor
         getDescriptor() {
       return io.cloudquery.plugin.v3.PredicatesGroup.getDescriptor().getEnumTypes().get(0);
     }
@@ -618,9 +619,7 @@ public io.cloudquery.plugin.v3.PredicatesGroup.GroupingType getGroupingType() {
      * @return This builder for chaining.
      */
     public Builder setGroupingType(io.cloudquery.plugin.v3.PredicatesGroup.GroupingType value) {
-      if (value == null) {
-        throw new NullPointerException();
-      }
+      if (value == null) { throw new NullPointerException(); }
       bitField0_ |= 0x00000001;
       groupingType_ = value.getNumber();
       onChanged();
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/PredicatesGroupOrBuilder.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/PredicatesGroupOrBuilder.java
index af00cb3..412b1eb 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/PredicatesGroupOrBuilder.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/PredicatesGroupOrBuilder.java
@@ -1,10 +1,11 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
+@com.google.protobuf.Generated
 public interface PredicatesGroupOrBuilder extends
     // @@protoc_insertion_point(interface_extends:cloudquery.plugin.v3.PredicatesGroup)
     com.google.protobuf.MessageOrBuilder {
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Read.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Read.java
index 8b5e7bf..37303e8 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Read.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Read.java
@@ -1,13 +1,14 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
 /**
  * Protobuf type {@code cloudquery.plugin.v3.Read}
  */
+@com.google.protobuf.Generated
 public final class Read extends
     com.google.protobuf.GeneratedMessage implements
     // @@protoc_insertion_point(message_implements:cloudquery.plugin.v3.Read)
@@ -17,8 +18,8 @@ public final class Read extends
     com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
       com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
       /* major= */ 4,
-      /* minor= */ 30,
-      /* patch= */ 2,
+      /* minor= */ 31,
+      /* patch= */ 1,
       /* suffix= */ "",
       Read.class.getName());
   }
@@ -68,8 +69,8 @@ public static final class Request extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         Request.class.getName());
     }
@@ -523,8 +524,8 @@ public static final class Response extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         Response.class.getName());
     }
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/ReadOrBuilder.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/ReadOrBuilder.java
index 74b81e8..12d87b2 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/ReadOrBuilder.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/ReadOrBuilder.java
@@ -1,10 +1,11 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
+@com.google.protobuf.Generated
 public interface ReadOrBuilder extends
     // @@protoc_insertion_point(interface_extends:cloudquery.plugin.v3.Read)
     com.google.protobuf.MessageOrBuilder {
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Sync.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Sync.java
index fe09417..e73bf69 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Sync.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Sync.java
@@ -1,13 +1,14 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
 /**
  * Protobuf type {@code cloudquery.plugin.v3.Sync}
  */
+@com.google.protobuf.Generated
 public final class Sync extends
     com.google.protobuf.GeneratedMessage implements
     // @@protoc_insertion_point(message_implements:cloudquery.plugin.v3.Sync)
@@ -17,8 +18,8 @@ public final class Sync extends
     com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
       com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
       /* major= */ 4,
-      /* minor= */ 30,
-      /* patch= */ 2,
+      /* minor= */ 31,
+      /* patch= */ 1,
       /* suffix= */ "",
       Sync.class.getName());
   }
@@ -68,8 +69,8 @@ public static final class MessageInsert extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         MessageInsert.class.getName());
     }
@@ -523,8 +524,8 @@ public static final class MessageMigrateTable extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         MessageMigrateTable.class.getName());
     }
@@ -1028,8 +1029,8 @@ public static final class MessageDeleteRecord extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         MessageDeleteRecord.class.getName());
     }
@@ -2254,8 +2255,8 @@ public static final class MessageError extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         MessageError.class.getName());
     }
@@ -2928,8 +2929,8 @@ public static final class BackendOptions extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         BackendOptions.class.getName());
     }
@@ -3697,6 +3698,16 @@ public interface RequestOrBuilder extends
      * <code>optional .cloudquery.plugin.v3.Sync.Request.Shard shard = 6;</code>
      */
     io.cloudquery.plugin.v3.Sync.Request.ShardOrBuilder getShardOrBuilder();
+
+    /**
+     * <pre>
+     * If true, the plugin will send error messages in the response stream
+     * </pre>
+     *
+     * <code>bool withErrorMessages = 7;</code>
+     * @return The withErrorMessages.
+     */
+    boolean getWithErrorMessages();
   }
   /**
    * Protobuf type {@code cloudquery.plugin.v3.Sync.Request}
@@ -3710,8 +3721,8 @@ public static final class Request extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         Request.class.getName());
     }
@@ -3767,8 +3778,8 @@ public static final class Shard extends
         com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
           com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
           /* major= */ 4,
-          /* minor= */ 30,
-          /* patch= */ 2,
+          /* minor= */ 31,
+          /* patch= */ 1,
           /* suffix= */ "",
           Shard.class.getName());
       }
@@ -4394,6 +4405,21 @@ public io.cloudquery.plugin.v3.Sync.Request.ShardOrBuilder getShardOrBuilder() {
       return shard_ == null ? io.cloudquery.plugin.v3.Sync.Request.Shard.getDefaultInstance() : shard_;
     }
 
+    public static final int WITHERRORMESSAGES_FIELD_NUMBER = 7;
+    private boolean withErrorMessages_ = false;
+    /**
+     * <pre>
+     * If true, the plugin will send error messages in the response stream
+     * </pre>
+     *
+     * <code>bool withErrorMessages = 7;</code>
+     * @return The withErrorMessages.
+     */
+    @java.lang.Override
+    public boolean getWithErrorMessages() {
+      return withErrorMessages_;
+    }
+
     private byte memoizedIsInitialized = -1;
     @java.lang.Override
     public final boolean isInitialized() {
@@ -4426,6 +4452,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output)
       if (((bitField0_ & 0x00000002) != 0)) {
         output.writeMessage(6, getShard());
       }
+      if (withErrorMessages_ != false) {
+        output.writeBool(7, withErrorMessages_);
+      }
       getUnknownFields().writeTo(output);
     }
 
@@ -4467,6 +4496,10 @@ public int getSerializedSize() {
         size += com.google.protobuf.CodedOutputStream
           .computeMessageSize(6, getShard());
       }
+      if (withErrorMessages_ != false) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeBoolSize(7, withErrorMessages_);
+      }
       size += getUnknownFields().getSerializedSize();
       memoizedSize = size;
       return size;
@@ -4500,6 +4533,8 @@ public boolean equals(final java.lang.Object obj) {
         if (!getShard()
             .equals(other.getShard())) return false;
       }
+      if (getWithErrorMessages()
+          != other.getWithErrorMessages()) return false;
       if (!getUnknownFields().equals(other.getUnknownFields())) return false;
       return true;
     }
@@ -4533,6 +4568,9 @@ public int hashCode() {
         hash = (37 * hash) + SHARD_FIELD_NUMBER;
         hash = (53 * hash) + getShard().hashCode();
       }
+      hash = (37 * hash) + WITHERRORMESSAGES_FIELD_NUMBER;
+      hash = (53 * hash) + com.google.protobuf.Internal.hashBoolean(
+          getWithErrorMessages());
       hash = (29 * hash) + getUnknownFields().hashCode();
       memoizedHashCode = hash;
       return hash;
@@ -4687,6 +4725,7 @@ public Builder clear() {
           shardBuilder_.dispose();
           shardBuilder_ = null;
         }
+        withErrorMessages_ = false;
         return this;
       }
 
@@ -4747,6 +4786,9 @@ private void buildPartial0(io.cloudquery.plugin.v3.Sync.Request result) {
               : shardBuilder_.build();
           to_bitField0_ |= 0x00000002;
         }
+        if (((from_bitField0_ & 0x00000040) != 0)) {
+          result.withErrorMessages_ = withErrorMessages_;
+        }
         result.bitField0_ |= to_bitField0_;
       }
 
@@ -4794,6 +4836,9 @@ public Builder mergeFrom(io.cloudquery.plugin.v3.Sync.Request other) {
         if (other.hasShard()) {
           mergeShard(other.getShard());
         }
+        if (other.getWithErrorMessages() != false) {
+          setWithErrorMessages(other.getWithErrorMessages());
+        }
         this.mergeUnknownFields(other.getUnknownFields());
         onChanged();
         return this;
@@ -4856,6 +4901,11 @@ public Builder mergeFrom(
                 bitField0_ |= 0x00000020;
                 break;
               } // case 50
+              case 56: {
+                withErrorMessages_ = input.readBool();
+                bitField0_ |= 0x00000040;
+                break;
+              } // case 56
               default: {
                 if (!super.parseUnknownField(input, extensionRegistry, tag)) {
                   done = true; // was an endgroup tag
@@ -5401,6 +5451,50 @@ public io.cloudquery.plugin.v3.Sync.Request.ShardOrBuilder getShardOrBuilder() {
         return shardBuilder_;
       }
 
+      private boolean withErrorMessages_ ;
+      /**
+       * <pre>
+       * If true, the plugin will send error messages in the response stream
+       * </pre>
+       *
+       * <code>bool withErrorMessages = 7;</code>
+       * @return The withErrorMessages.
+       */
+      @java.lang.Override
+      public boolean getWithErrorMessages() {
+        return withErrorMessages_;
+      }
+      /**
+       * <pre>
+       * If true, the plugin will send error messages in the response stream
+       * </pre>
+       *
+       * <code>bool withErrorMessages = 7;</code>
+       * @param value The withErrorMessages to set.
+       * @return This builder for chaining.
+       */
+      public Builder setWithErrorMessages(boolean value) {
+
+        withErrorMessages_ = value;
+        bitField0_ |= 0x00000040;
+        onChanged();
+        return this;
+      }
+      /**
+       * <pre>
+       * If true, the plugin will send error messages in the response stream
+       * </pre>
+       *
+       * <code>bool withErrorMessages = 7;</code>
+       * @return This builder for chaining.
+       */
+      public Builder clearWithErrorMessages() {
+        bitField0_ = (bitField0_ & ~0x00000040);
+        withErrorMessages_ = false;
+        onChanged();
+        return this;
+      }
+
       // @@protoc_insertion_point(builder_scope:cloudquery.plugin.v3.Sync.Request)
     }
 
@@ -5530,8 +5624,8 @@ public static final class Response extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         Response.class.getName());
     }
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/SyncOrBuilder.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/SyncOrBuilder.java
index 38bd9d1..f17c3cc 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/SyncOrBuilder.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/SyncOrBuilder.java
@@ -1,10 +1,11 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
+@com.google.protobuf.Generated
 public interface SyncOrBuilder extends
     // @@protoc_insertion_point(interface_extends:cloudquery.plugin.v3.Sync)
     com.google.protobuf.MessageOrBuilder {
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TableRelation.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TableRelation.java
index a2751f0..391747e 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TableRelation.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TableRelation.java
@@ -1,13 +1,14 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
 /**
  * Protobuf type {@code cloudquery.plugin.v3.TableRelation}
  */
+@com.google.protobuf.Generated
 public final class TableRelation extends
     com.google.protobuf.GeneratedMessage implements
     // @@protoc_insertion_point(message_implements:cloudquery.plugin.v3.TableRelation)
@@ -17,8 +18,8 @@ public final class TableRelation extends
     com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
       com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
       /* major= */ 4,
-      /* minor= */ 30,
-      /* patch= */ 2,
+      /* minor= */ 31,
+      /* patch= */ 1,
       /* suffix= */ "",
       TableRelation.class.getName());
   }
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TableRelationOrBuilder.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TableRelationOrBuilder.java
index 59077a8..0e69a6f 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TableRelationOrBuilder.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TableRelationOrBuilder.java
@@ -1,10 +1,11 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
+@com.google.protobuf.Generated
 public interface TableRelationOrBuilder extends
     // @@protoc_insertion_point(interface_extends:cloudquery.plugin.v3.TableRelation)
     com.google.protobuf.MessageOrBuilder {
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TestConnection.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TestConnection.java
index 0c4b860..7775398 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TestConnection.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TestConnection.java
@@ -1,13 +1,14 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
 /**
  * Protobuf type {@code cloudquery.plugin.v3.TestConnection}
  */
+@com.google.protobuf.Generated
 public final class TestConnection extends
     com.google.protobuf.GeneratedMessage implements
     // @@protoc_insertion_point(message_implements:cloudquery.plugin.v3.TestConnection)
@@ -17,8 +18,8 @@ public final class TestConnection extends
     com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
       com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
       /* major= */ 4,
-      /* minor= */ 30,
-      /* patch= */ 2,
+      /* minor= */ 31,
+      /* patch= */ 1,
       /* suffix= */ "",
       TestConnection.class.getName());
   }
@@ -68,8 +69,8 @@ public static final class Request extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         Request.class.getName());
     }
@@ -543,8 +544,8 @@ public static final class Response extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         Response.class.getName());
     }
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TestConnectionOrBuilder.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TestConnectionOrBuilder.java
index f5c51fd..0894c1d 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TestConnectionOrBuilder.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TestConnectionOrBuilder.java
@@ -1,10 +1,11 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
+@com.google.protobuf.Generated
 public interface TestConnectionOrBuilder extends
     // @@protoc_insertion_point(interface_extends:cloudquery.plugin.v3.TestConnection)
     com.google.protobuf.MessageOrBuilder {
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Transform.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Transform.java
index 2717e3c..07ccec0 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Transform.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Transform.java
@@ -1,13 +1,14 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
 /**
  * Protobuf type {@code cloudquery.plugin.v3.Transform}
  */
+@com.google.protobuf.Generated
 public final class Transform extends
     com.google.protobuf.GeneratedMessage implements
     // @@protoc_insertion_point(message_implements:cloudquery.plugin.v3.Transform)
@@ -17,8 +18,8 @@ public final class Transform extends
     com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
       com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
       /* major= */ 4,
-      /* minor= */ 30,
-      /* patch= */ 2,
+      /* minor= */ 31,
+      /* patch= */ 1,
       /* suffix= */ "",
       Transform.class.getName());
   }
@@ -68,8 +69,8 @@ public static final class Request extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         Request.class.getName());
     }
@@ -523,8 +524,8 @@ public static final class Response extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         Response.class.getName());
     }
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TransformOrBuilder.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TransformOrBuilder.java
index 1a26579..9b91cbd 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TransformOrBuilder.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TransformOrBuilder.java
@@ -1,10 +1,11 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
+@com.google.protobuf.Generated
 public interface TransformOrBuilder extends
     // @@protoc_insertion_point(interface_extends:cloudquery.plugin.v3.Transform)
     com.google.protobuf.MessageOrBuilder {
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TransformSchema.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TransformSchema.java
index ef5c5f3..0821bef 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TransformSchema.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TransformSchema.java
@@ -1,13 +1,14 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
 /**
  * Protobuf type {@code cloudquery.plugin.v3.TransformSchema}
  */
+@com.google.protobuf.Generated
 public final class TransformSchema extends
     com.google.protobuf.GeneratedMessage implements
     // @@protoc_insertion_point(message_implements:cloudquery.plugin.v3.TransformSchema)
@@ -17,8 +18,8 @@ public final class TransformSchema extends
     com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
       com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
       /* major= */ 4,
-      /* minor= */ 30,
-      /* patch= */ 2,
+      /* minor= */ 31,
+      /* patch= */ 1,
       /* suffix= */ "",
       TransformSchema.class.getName());
   }
@@ -68,8 +69,8 @@ public static final class Request extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         Request.class.getName());
     }
@@ -523,8 +524,8 @@ public static final class Response extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         Response.class.getName());
     }
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TransformSchemaOrBuilder.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TransformSchemaOrBuilder.java
index b6084e8..8edbc44 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TransformSchemaOrBuilder.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/TransformSchemaOrBuilder.java
@@ -1,10 +1,11 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
+@com.google.protobuf.Generated
 public interface TransformSchemaOrBuilder extends
     // @@protoc_insertion_point(interface_extends:cloudquery.plugin.v3.TransformSchema)
     com.google.protobuf.MessageOrBuilder {
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Write.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Write.java
index 5998f84..0bf29a5 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Write.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/Write.java
@@ -1,13 +1,14 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
 /**
  * Protobuf type {@code cloudquery.plugin.v3.Write}
  */
+@com.google.protobuf.Generated
 public final class Write extends
     com.google.protobuf.GeneratedMessage implements
     // @@protoc_insertion_point(message_implements:cloudquery.plugin.v3.Write)
@@ -17,8 +18,8 @@ public final class Write extends
     com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
       com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
       /* major= */ 4,
-      /* minor= */ 30,
-      /* patch= */ 2,
+      /* minor= */ 31,
+      /* patch= */ 1,
       /* suffix= */ "",
       Write.class.getName());
   }
@@ -74,8 +75,8 @@ public static final class MessageMigrateTable extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         MessageMigrateTable.class.getName());
     }
@@ -596,8 +597,8 @@ public static final class MessageInsert extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         MessageInsert.class.getName());
     }
@@ -1036,7 +1037,7 @@ public interface MessageDeleteStaleOrBuilder extends
      *
      * <code>bytes table = 1 [deprecated = true];</code>
      * @deprecated cloudquery.plugin.v3.Write.MessageDeleteStale.table is deprecated.
-     *     See cloudquery/plugin/v3/plugin.proto;l=186
+     *     See cloudquery/plugin/v3/plugin.proto;l=187
      * @return The table.
      */
     @java.lang.Deprecated com.google.protobuf.ByteString getTable();
@@ -1092,8 +1093,8 @@ public static final class MessageDeleteStale extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         MessageDeleteStale.class.getName());
     }
@@ -1130,7 +1131,7 @@ private MessageDeleteStale() {
      *
      * <code>bytes table = 1 [deprecated = true];</code>
      * @deprecated cloudquery.plugin.v3.Write.MessageDeleteStale.table is deprecated.
-     *     See cloudquery/plugin/v3/plugin.proto;l=186
+     *     See cloudquery/plugin/v3/plugin.proto;l=187
      * @return The table.
      */
     @java.lang.Override
@@ -1636,7 +1637,7 @@ public Builder mergeFrom(
        *
        * <code>bytes table = 1 [deprecated = true];</code>
        * @deprecated cloudquery.plugin.v3.Write.MessageDeleteStale.table is deprecated.
-       *     See cloudquery/plugin/v3/plugin.proto;l=186
+       *     See cloudquery/plugin/v3/plugin.proto;l=187
        * @return The table.
        */
       @java.lang.Override
@@ -1650,7 +1651,7 @@ public Builder mergeFrom(
        *
        * <code>bytes table = 1 [deprecated = true];</code>
        * @deprecated cloudquery.plugin.v3.Write.MessageDeleteStale.table is deprecated.
-       *     See cloudquery/plugin/v3/plugin.proto;l=186
+       *     See cloudquery/plugin/v3/plugin.proto;l=187
        * @param value The table to set.
        * @return This builder for chaining.
        */
@@ -1668,7 +1669,7 @@ public Builder mergeFrom(
        *
        * <code>bytes table = 1 [deprecated = true];</code>
        * @deprecated cloudquery.plugin.v3.Write.MessageDeleteStale.table is deprecated.
-       *     See cloudquery/plugin/v3/plugin.proto;l=186
+       *     See cloudquery/plugin/v3/plugin.proto;l=187
        * @return This builder for chaining.
        */
       @java.lang.Deprecated public Builder clearTable() {
@@ -2070,8 +2071,8 @@ public static final class MessageDeleteRecord extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         MessageDeleteRecord.class.getName());
     }
@@ -3334,8 +3335,8 @@ public static final class Request extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         Request.class.getName());
     }
@@ -4603,8 +4604,8 @@ public static final class Response extends
       com.google.protobuf.RuntimeVersion.validateProtobufGencodeVersion(
         com.google.protobuf.RuntimeVersion.RuntimeDomain.PUBLIC,
         /* major= */ 4,
-        /* minor= */ 30,
-        /* patch= */ 2,
+        /* minor= */ 31,
+        /* patch= */ 1,
         /* suffix= */ "",
         Response.class.getName());
     }
diff --git a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/WriteOrBuilder.java b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/WriteOrBuilder.java
index 18fdcdb..3eee27e 100644
--- a/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/WriteOrBuilder.java
+++ b/build/generated/source/proto/main/java/io/cloudquery/plugin/v3/WriteOrBuilder.java
@@ -1,10 +1,11 @@
 // Generated by the protocol buffer compiler.  DO NOT EDIT!
 // NO CHECKED-IN PROTOBUF GENCODE
 // source: cloudquery/plugin/v3/plugin.proto
-// Protobuf Java Version: 4.30.2
+// Protobuf Java Version: 4.31.1
 
 package io.cloudquery.plugin.v3;
 
+@com.google.protobuf.Generated
 public interface WriteOrBuilder extends
     // @@protoc_insertion_point(interface_extends:cloudquery.plugin.v3.Write)
     com.google.protobuf.MessageOrBuilder {
diff --git a/gradle/wrapper/gradle-wrapper.jar b/gradle/wrapper/gradle-wrapper.jar
index 9bbc975..1b33c55 100644
Binary files a/gradle/wrapper/gradle-wrapper.jar and b/gradle/wrapper/gradle-wrapper.jar differ
diff --git a/gradle/wrapper/gradle-wrapper.properties b/gradle/wrapper/gradle-wrapper.properties
index 37f853b..ff23a68 100644
--- a/gradle/wrapper/gradle-wrapper.properties
+++ b/gradle/wrapper/gradle-wrapper.properties
@@ -1,6 +1,6 @@
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-8.13-bin.zip
+distributionUrl=https\://services.gradle.org/distributions/gradle-8.14.2-bin.zip
 networkTimeout=10000
 validateDistributionUrl=true
 zipStoreBase=GRADLE_USER_HOME
diff --git a/gradlew b/gradlew
index faf9300..23d15a9 100755
--- a/gradlew
+++ b/gradlew
@@ -114,7 +114,7 @@ case "$( uname )" in                #(
   NONSTOP* )        nonstop=true ;;
 esac
 
-CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
+CLASSPATH="\\\"\\\""
 
 
 # Determine the Java command to use to start the JVM.
@@ -213,7 +213,7 @@ DEFAULT_JVM_OPTS='"-Xmx64m" "-Xms64m"'
 set -- \
         "-Dorg.gradle.appname=$APP_BASE_NAME" \
         -classpath "$CLASSPATH" \
-        org.gradle.wrapper.GradleWrapperMain \
+        -jar "$APP_HOME/gradle/wrapper/gradle-wrapper.jar" \
         "$@"
 
 # Stop when "xargs" is not available.
diff --git a/gradlew.bat b/gradlew.bat
index 9b42019..5eed7ee 100644
--- a/gradlew.bat
+++ b/gradlew.bat
@@ -70,11 +70,11 @@ goto fail
 :execute
 @rem Setup the command line
 
-set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar
+set CLASSPATH=
 
 
 @rem Execute Gradle
-"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %*
+"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" -jar "%APP_HOME%\gradle\wrapper\gradle-wrapper.jar" %*
 
 :end
 @rem End local scope for the variables with windows NT shell
diff --git a/src/main/proto/cloudquery/plugin/v3/plugin.proto b/src/main/proto/cloudquery/plugin/v3/plugin.proto
index fd423aa..5822eef 100644
--- a/src/main/proto/cloudquery/plugin/v3/plugin.proto
+++ b/src/main/proto/cloudquery/plugin/v3/plugin.proto
@@ -118,6 +118,7 @@ message Sync {
     bool deterministic_cq_id = 4;
     BackendOptions backend = 5;
     optional Shard shard = 6;
+    bool withErrorMessages = 7; // If true, the plugin will send error messages in the response stream
   }
   message Response {
     oneof message {