diff --git a/cloudquery/discovery_v1/discovery_pb2.py b/cloudquery/discovery_v1/discovery_pb2.py
index 37f9976..c4ed640 100644
--- a/cloudquery/discovery_v1/discovery_pb2.py
+++ b/cloudquery/discovery_v1/discovery_pb2.py
@@ -2,7 +2,7 @@
 # Generated by the protocol buffer compiler.  DO NOT EDIT!
 # NO CHECKED-IN PROTOBUF GENCODE
 # source: cloudquery/discovery_v1/discovery.proto
-# Protobuf Python Version: 5.29.0
+# Protobuf Python Version: 6.31.0
 """Generated protocol buffer code."""
 from google.protobuf import descriptor as _descriptor
 from google.protobuf import descriptor_pool as _descriptor_pool
@@ -11,8 +11,8 @@
 from google.protobuf.internal import builder as _builder
 _runtime_version.ValidateProtobufRuntimeVersion(
     _runtime_version.Domain.PUBLIC,
-    5,
-    29,
+    6,
+    31,
     0,
     '',
     'cloudquery/discovery_v1/discovery.proto'
diff --git a/cloudquery/discovery_v1/discovery_pb2.pyi b/cloudquery/discovery_v1/discovery_pb2.pyi
index 4d3ff2a..a59109f 100644
--- a/cloudquery/discovery_v1/discovery_pb2.pyi
+++ b/cloudquery/discovery_v1/discovery_pb2.pyi
@@ -1,7 +1,8 @@
 from google.protobuf.internal import containers as _containers
 from google.protobuf import descriptor as _descriptor
 from google.protobuf import message as _message
-from typing import ClassVar as _ClassVar, Iterable as _Iterable, Optional as _Optional
+from collections.abc import Iterable as _Iterable
+from typing import ClassVar as _ClassVar, Optional as _Optional
 
 DESCRIPTOR: _descriptor.FileDescriptor
 
diff --git a/cloudquery/discovery_v1/discovery_pb2_grpc.py b/cloudquery/discovery_v1/discovery_pb2_grpc.py
index 141ae65..4a3429a 100644
--- a/cloudquery/discovery_v1/discovery_pb2_grpc.py
+++ b/cloudquery/discovery_v1/discovery_pb2_grpc.py
@@ -5,7 +5,7 @@
 
 from cloudquery.discovery_v1 import discovery_pb2 as cloudquery_dot_discovery__v1_dot_discovery__pb2
 
-GRPC_GENERATED_VERSION = '1.71.0'
+GRPC_GENERATED_VERSION = '1.73.0'
 GRPC_VERSION = grpc.__version__
 _version_not_supported = False
 
diff --git a/cloudquery/plugin_v3/plugin_pb2.py b/cloudquery/plugin_v3/plugin_pb2.py
index c5072a9..d11280d 100644
--- a/cloudquery/plugin_v3/plugin_pb2.py
+++ b/cloudquery/plugin_v3/plugin_pb2.py
@@ -2,7 +2,7 @@
 # Generated by the protocol buffer compiler.  DO NOT EDIT!
 # NO CHECKED-IN PROTOBUF GENCODE
 # source: cloudquery/plugin_v3/plugin.proto
-# Protobuf Python Version: 5.29.0
+# Protobuf Python Version: 6.31.0
 """Generated protocol buffer code."""
 from google.protobuf import descriptor as _descriptor
 from google.protobuf import descriptor_pool as _descriptor_pool
@@ -11,8 +11,8 @@
 from google.protobuf.internal import builder as _builder
 _runtime_version.ValidateProtobufRuntimeVersion(
     _runtime_version.Domain.PUBLIC,
-    5,
-    29,
+    6,
+    31,
     0,
     '',
     'cloudquery/plugin_v3/plugin.proto'
diff --git a/cloudquery/plugin_v3/plugin_pb2.pyi b/cloudquery/plugin_v3/plugin_pb2.pyi
index b8e3b2b..52d7cfc 100644
--- a/cloudquery/plugin_v3/plugin_pb2.pyi
+++ b/cloudquery/plugin_v3/plugin_pb2.pyi
@@ -3,7 +3,8 @@ from google.protobuf.internal import containers as _containers
 from google.protobuf.internal import enum_type_wrapper as _enum_type_wrapper
 from google.protobuf import descriptor as _descriptor
 from google.protobuf import message as _message
-from typing import ClassVar as _ClassVar, Iterable as _Iterable, Mapping as _Mapping, Optional as _Optional, Union as _Union
+from collections.abc import Iterable as _Iterable, Mapping as _Mapping
+from typing import ClassVar as _ClassVar, Optional as _Optional, Union as _Union
 
 DESCRIPTOR: _descriptor.FileDescriptor
 
@@ -223,7 +224,7 @@ class Write(_message.Message):
         source_name: str
         sync_time: _timestamp_pb2.Timestamp
         table_name: str
-        def __init__(self, table: _Optional[bytes] = ..., source_name: _Optional[str] = ..., sync_time: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., table_name: _Optional[str] = ...) -> None: ...
+        def __init__(self, table: _Optional[bytes] = ..., source_name: _Optional[str] = ..., sync_time: _Optional[_Union[datetime.datetime, _timestamp_pb2.Timestamp, _Mapping]] = ..., table_name: _Optional[str] = ...) -> None: ...
     class MessageDeleteRecord(_message.Message):
         __slots__ = ("table_name", "where_clause", "table_relations")
         TABLE_NAME_FIELD_NUMBER: _ClassVar[int]
diff --git a/cloudquery/plugin_v3/plugin_pb2_grpc.py b/cloudquery/plugin_v3/plugin_pb2_grpc.py
index 824b053..81fe981 100644
--- a/cloudquery/plugin_v3/plugin_pb2_grpc.py
+++ b/cloudquery/plugin_v3/plugin_pb2_grpc.py
@@ -5,7 +5,7 @@
 
 from cloudquery.plugin_v3 import plugin_pb2 as cloudquery_dot_plugin__v3_dot_plugin__pb2
 
-GRPC_GENERATED_VERSION = '1.71.0'
+GRPC_GENERATED_VERSION = '1.73.0'
 GRPC_VERSION = grpc.__version__
 _version_not_supported = False