diff --git a/sdks/julia/LogicalQueryProtocol.jl/Manifest.toml b/sdks/julia/LogicalQueryProtocol.jl/Manifest.toml
index 5681a695..34b42581 100644
--- a/sdks/julia/LogicalQueryProtocol.jl/Manifest.toml
+++ b/sdks/julia/LogicalQueryProtocol.jl/Manifest.toml
@@ -24,9 +24,9 @@ uuid = "de0858da-6303-5e67-8744-51eddeeeb8d7"
 
 [[deps.ProtoBuf]]
 deps = ["BufferedStreams", "EnumX", "TOML"]
-git-tree-sha1 = "b3313ac3ba06758d9fbd11d09d2fe59cc527ff4a"
+git-tree-sha1 = "da18083a52d9d57bbe6dadaacad39731e5f7be39"
 uuid = "3349acd9-ac6a-5e09-bcdb-63829b23a429"
-version = "1.2.2"
+version = "1.3.0"
 
 [[deps.SHA]]
 uuid = "ea8e919c-243c-51af-8825-aaa63cd721ce"
diff --git a/sdks/julia/LogicalQueryProtocol.jl/src/gen/relationalai/lqp/v1/fragments_pb.jl b/sdks/julia/LogicalQueryProtocol.jl/src/gen/relationalai/lqp/v1/fragments_pb.jl
index 5529156c..ef2a3ba9 100644
--- a/sdks/julia/LogicalQueryProtocol.jl/src/gen/relationalai/lqp/v1/fragments_pb.jl
+++ b/sdks/julia/LogicalQueryProtocol.jl/src/gen/relationalai/lqp/v1/fragments_pb.jl
@@ -1,4 +1,4 @@
-# Autogenerated using ProtoBuf.jl v1.2.2
+# Autogenerated using ProtoBuf.jl v1.3.0
 # original file: relationalai/lqp/v1/fragments.proto (proto3 syntax)
 
 import ProtoBuf as PB
@@ -15,9 +15,9 @@ FragmentId(;id = UInt8[]) = FragmentId(id)
 PB.default_values(::Type{FragmentId}) = (;id = UInt8[])
 PB.field_numbers(::Type{FragmentId}) = (;id = 1)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:FragmentId})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:FragmentId}, _endpos::Int=0, _group::Bool=false)
     id = UInt8[]
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             id = PB.decode(d, Vector{UInt8})
@@ -47,10 +47,10 @@ DebugInfo(;ids = Vector{RelationId}(), orig_names = Vector{String}()) = DebugInf
 PB.default_values(::Type{DebugInfo}) = (;ids = Vector{RelationId}(), orig_names = Vector{String}())
 PB.field_numbers(::Type{DebugInfo}) = (;ids = 1, orig_names = 2)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:DebugInfo})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:DebugInfo}, _endpos::Int=0, _group::Bool=false)
     ids = PB.BufferedVector{RelationId}()
     orig_names = PB.BufferedVector{String}()
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, ids)
@@ -85,11 +85,11 @@ Fragment(;id = nothing, declarations = Vector{Declaration}(), debug_info = nothi
 PB.default_values(::Type{Fragment}) = (;id = nothing, declarations = Vector{Declaration}(), debug_info = nothing)
 PB.field_numbers(::Type{Fragment}) = (;id = 1, declarations = 2, debug_info = 3)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Fragment})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Fragment}, _endpos::Int=0, _group::Bool=false)
     id = Ref{Union{Nothing,FragmentId}}(nothing)
     declarations = PB.BufferedVector{Declaration}()
     debug_info = Ref{Union{Nothing,DebugInfo}}(nothing)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, id)
diff --git a/sdks/julia/LogicalQueryProtocol.jl/src/gen/relationalai/lqp/v1/logic_pb.jl b/sdks/julia/LogicalQueryProtocol.jl/src/gen/relationalai/lqp/v1/logic_pb.jl
index 0d4782e6..9f4f0440 100644
--- a/sdks/julia/LogicalQueryProtocol.jl/src/gen/relationalai/lqp/v1/logic_pb.jl
+++ b/sdks/julia/LogicalQueryProtocol.jl/src/gen/relationalai/lqp/v1/logic_pb.jl
@@ -1,4 +1,4 @@
-# Autogenerated using ProtoBuf.jl v1.2.2
+# Autogenerated using ProtoBuf.jl v1.3.0
 # original file: relationalai/lqp/v1/logic.proto (proto3 syntax)
 
 import ProtoBuf as PB
@@ -40,8 +40,8 @@ abstract type var"##Abstract#Upsert" end
 
 struct DateTimeType end
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:DateTimeType})
-    while !PB.message_done(d)
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:DateTimeType}, _endpos::Int=0, _group::Bool=false)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         Base.skip(d, wire_type)
     end
@@ -65,10 +65,10 @@ RelationId(;id_low = zero(UInt64), id_high = zero(UInt64)) = RelationId(id_low,
 PB.default_values(::Type{RelationId}) = (;id_low = zero(UInt64), id_high = zero(UInt64))
 PB.field_numbers(::Type{RelationId}) = (;id_low = 1, id_high = 2)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:RelationId})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:RelationId}, _endpos::Int=0, _group::Bool=false)
     id_low = zero(UInt64)
     id_high = zero(UInt64)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             id_low = PB.decode(d, UInt64, Val{:fixed})
@@ -101,9 +101,9 @@ Var(;name = "") = Var(name)
 PB.default_values(::Type{Var}) = (;name = "")
 PB.field_numbers(::Type{Var}) = (;name = 1)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Var})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Var}, _endpos::Int=0, _group::Bool=false)
     name = ""
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             name = PB.decode(d, String)
@@ -127,8 +127,8 @@ end
 
 struct FloatType end
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:FloatType})
-    while !PB.message_done(d)
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:FloatType}, _endpos::Int=0, _group::Bool=false)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         Base.skip(d, wire_type)
     end
@@ -146,8 +146,8 @@ end
 
 struct UInt128Type end
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:UInt128Type})
-    while !PB.message_done(d)
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:UInt128Type}, _endpos::Int=0, _group::Bool=false)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         Base.skip(d, wire_type)
     end
@@ -173,12 +173,12 @@ BeTreeConfig(;epsilon = zero(Float64), max_pivots = zero(Int64), max_deltas = ze
 PB.default_values(::Type{BeTreeConfig}) = (;epsilon = zero(Float64), max_pivots = zero(Int64), max_deltas = zero(Int64), max_leaf = zero(Int64))
 PB.field_numbers(::Type{BeTreeConfig}) = (;epsilon = 1, max_pivots = 2, max_deltas = 3, max_leaf = 4)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:BeTreeConfig})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:BeTreeConfig}, _endpos::Int=0, _group::Bool=false)
     epsilon = zero(Float64)
     max_pivots = zero(Int64)
     max_deltas = zero(Int64)
     max_leaf = zero(Int64)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             epsilon = PB.decode(d, Float64)
@@ -225,7 +225,7 @@ DateTimeValue(;year = zero(Int32), month = zero(Int32), day = zero(Int32), hour
 PB.default_values(::Type{DateTimeValue}) = (;year = zero(Int32), month = zero(Int32), day = zero(Int32), hour = zero(Int32), minute = zero(Int32), second = zero(Int32), microsecond = zero(Int32))
 PB.field_numbers(::Type{DateTimeValue}) = (;year = 1, month = 2, day = 3, hour = 4, minute = 5, second = 6, microsecond = 7)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:DateTimeValue})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:DateTimeValue}, _endpos::Int=0, _group::Bool=false)
     year = zero(Int32)
     month = zero(Int32)
     day = zero(Int32)
@@ -233,7 +233,7 @@ function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:DateTimeValue})
     minute = zero(Int32)
     second = zero(Int32)
     microsecond = zero(Int32)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             year = PB.decode(d, Int32)
@@ -288,11 +288,11 @@ DateValue(;year = zero(Int32), month = zero(Int32), day = zero(Int32)) = DateVal
 PB.default_values(::Type{DateValue}) = (;year = zero(Int32), month = zero(Int32), day = zero(Int32))
 PB.field_numbers(::Type{DateValue}) = (;year = 1, month = 2, day = 3)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:DateValue})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:DateValue}, _endpos::Int=0, _group::Bool=false)
     year = zero(Int32)
     month = zero(Int32)
     day = zero(Int32)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             year = PB.decode(d, Int32)
@@ -324,8 +324,8 @@ end
 
 struct OrMonoid end
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:OrMonoid})
-    while !PB.message_done(d)
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:OrMonoid}, _endpos::Int=0, _group::Bool=false)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         Base.skip(d, wire_type)
     end
@@ -349,10 +349,10 @@ CSVLocator(;paths = Vector{String}(), inline_data = UInt8[]) = CSVLocator(paths,
 PB.default_values(::Type{CSVLocator}) = (;paths = Vector{String}(), inline_data = UInt8[])
 PB.field_numbers(::Type{CSVLocator}) = (;paths = 1, inline_data = 2)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:CSVLocator})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:CSVLocator}, _endpos::Int=0, _group::Bool=false)
     paths = PB.BufferedVector{String}()
     inline_data = UInt8[]
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, paths)
@@ -380,8 +380,8 @@ end
 
 struct Int128Type end
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Int128Type})
-    while !PB.message_done(d)
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Int128Type}, _endpos::Int=0, _group::Bool=false)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         Base.skip(d, wire_type)
     end
@@ -405,10 +405,10 @@ DecimalType(;precision = zero(Int32), scale = zero(Int32)) = DecimalType(precisi
 PB.default_values(::Type{DecimalType}) = (;precision = zero(Int32), scale = zero(Int32))
 PB.field_numbers(::Type{DecimalType}) = (;precision = 1, scale = 2)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:DecimalType})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:DecimalType}, _endpos::Int=0, _group::Bool=false)
     precision = zero(Int32)
     scale = zero(Int32)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             precision = PB.decode(d, Int32)
@@ -436,8 +436,8 @@ end
 
 struct UnspecifiedType end
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:UnspecifiedType})
-    while !PB.message_done(d)
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:UnspecifiedType}, _endpos::Int=0, _group::Bool=false)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         Base.skip(d, wire_type)
     end
@@ -455,8 +455,8 @@ end
 
 struct DateType end
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:DateType})
-    while !PB.message_done(d)
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:DateType}, _endpos::Int=0, _group::Bool=false)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         Base.skip(d, wire_type)
     end
@@ -474,8 +474,8 @@ end
 
 struct MissingType end
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:MissingType})
-    while !PB.message_done(d)
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:MissingType}, _endpos::Int=0, _group::Bool=false)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         Base.skip(d, wire_type)
     end
@@ -493,8 +493,8 @@ end
 
 struct MissingValue end
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:MissingValue})
-    while !PB.message_done(d)
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:MissingValue}, _endpos::Int=0, _group::Bool=false)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         Base.skip(d, wire_type)
     end
@@ -528,7 +528,7 @@ CSVConfig(;header_row = zero(Int32), skip = zero(Int64), new_line = "", delimite
 PB.default_values(::Type{CSVConfig}) = (;header_row = zero(Int32), skip = zero(Int64), new_line = "", delimiter = "", quotechar = "", escapechar = "", comment = "", missing_strings = Vector{String}(), decimal_separator = "", encoding = "", compression = "", partition_size_mb = zero(Int64))
 PB.field_numbers(::Type{CSVConfig}) = (;header_row = 1, skip = 2, new_line = 3, delimiter = 4, quotechar = 5, escapechar = 6, comment = 7, missing_strings = 8, decimal_separator = 9, encoding = 10, compression = 11, partition_size_mb = 12)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:CSVConfig})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:CSVConfig}, _endpos::Int=0, _group::Bool=false)
     header_row = zero(Int32)
     skip = zero(Int64)
     new_line = ""
@@ -541,7 +541,7 @@ function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:CSVConfig})
     encoding = ""
     compression = ""
     partition_size_mb = zero(Int64)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             header_row = PB.decode(d, Int32)
@@ -609,8 +609,8 @@ end
 
 struct IntType end
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:IntType})
-    while !PB.message_done(d)
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:IntType}, _endpos::Int=0, _group::Bool=false)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         Base.skip(d, wire_type)
     end
@@ -628,8 +628,8 @@ end
 
 struct StringType end
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:StringType})
-    while !PB.message_done(d)
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:StringType}, _endpos::Int=0, _group::Bool=false)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         Base.skip(d, wire_type)
     end
@@ -653,10 +653,10 @@ Int128Value(;low = zero(UInt64), high = zero(UInt64)) = Int128Value(low, high)
 PB.default_values(::Type{Int128Value}) = (;low = zero(UInt64), high = zero(UInt64))
 PB.field_numbers(::Type{Int128Value}) = (;low = 1, high = 2)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Int128Value})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Int128Value}, _endpos::Int=0, _group::Bool=false)
     low = zero(UInt64)
     high = zero(UInt64)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             low = PB.decode(d, UInt64, Val{:fixed})
@@ -690,10 +690,10 @@ UInt128Value(;low = zero(UInt64), high = zero(UInt64)) = UInt128Value(low, high)
 PB.default_values(::Type{UInt128Value}) = (;low = zero(UInt64), high = zero(UInt64))
 PB.field_numbers(::Type{UInt128Value}) = (;low = 1, high = 2)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:UInt128Value})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:UInt128Value}, _endpos::Int=0, _group::Bool=false)
     low = zero(UInt64)
     high = zero(UInt64)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             low = PB.decode(d, UInt64, Val{:fixed})
@@ -721,8 +721,8 @@ end
 
 struct BooleanType end
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:BooleanType})
-    while !PB.message_done(d)
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:BooleanType}, _endpos::Int=0, _group::Bool=false)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         Base.skip(d, wire_type)
     end
@@ -747,11 +747,11 @@ DecimalValue(;precision = zero(Int32), scale = zero(Int32), value = nothing) = D
 PB.default_values(::Type{DecimalValue}) = (;precision = zero(Int32), scale = zero(Int32), value = nothing)
 PB.field_numbers(::Type{DecimalValue}) = (;precision = 1, scale = 2, value = 3)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:DecimalValue})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:DecimalValue}, _endpos::Int=0, _group::Bool=false)
     precision = zero(Int32)
     scale = zero(Int32)
     value = Ref{Union{Nothing,Int128Value}}(nothing)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             precision = PB.decode(d, Int32)
@@ -793,11 +793,11 @@ PB.oneof_field_types(::Type{BeTreeLocator}) = (;
 PB.default_values(::Type{BeTreeLocator}) = (;root_pageid = nothing, inline_data = UInt8[], element_count = zero(Int64), tree_height = zero(Int64))
 PB.field_numbers(::Type{BeTreeLocator}) = (;root_pageid = 1, inline_data = 4, element_count = 2, tree_height = 3)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:BeTreeLocator})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:BeTreeLocator}, _endpos::Int=0, _group::Bool=false)
     location = nothing
     element_count = zero(Int64)
     tree_height = zero(Int64)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             location = OneOf(:root_pageid, PB.decode(d, Ref{UInt128Value}))
@@ -849,9 +849,9 @@ PB.oneof_field_types(::Type{var"#Type"}) = (;
 PB.default_values(::Type{var"#Type"}) = (;unspecified_type = nothing, string_type = nothing, int_type = nothing, float_type = nothing, uint128_type = nothing, int128_type = nothing, date_type = nothing, datetime_type = nothing, missing_type = nothing, decimal_type = nothing, boolean_type = nothing)
 PB.field_numbers(::Type{var"#Type"}) = (;unspecified_type = 1, string_type = 2, int_type = 3, float_type = 4, uint128_type = 5, int128_type = 6, date_type = 7, datetime_type = 8, missing_type = 9, decimal_type = 10, boolean_type = 11)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:var"#Type"})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:var"#Type"}, _endpos::Int=0, _group::Bool=false)
     var"#type" = nothing
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             var"#type" = OneOf(:unspecified_type, PB.decode(d, Ref{UnspecifiedType}))
@@ -949,9 +949,9 @@ PB.oneof_field_types(::Type{Value}) = (;
 PB.default_values(::Type{Value}) = (;string_value = "", int_value = zero(Int64), float_value = zero(Float64), uint128_value = nothing, int128_value = nothing, missing_value = nothing, date_value = nothing, datetime_value = nothing, decimal_value = nothing, boolean_value = false)
 PB.field_numbers(::Type{Value}) = (;string_value = 1, int_value = 2, float_value = 3, uint128_value = 4, int128_value = 5, missing_value = 6, date_value = 7, datetime_value = 8, decimal_value = 9, boolean_value = 10)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Value})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Value}, _endpos::Int=0, _group::Bool=false)
     value = nothing
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             value = OneOf(:string_value, PB.decode(d, String))
@@ -1042,11 +1042,11 @@ GNFColumn(;column_path = Vector{String}(), target_id = nothing, types = Vector{v
 PB.default_values(::Type{GNFColumn}) = (;column_path = Vector{String}(), target_id = nothing, types = Vector{var"#Type"}())
 PB.field_numbers(::Type{GNFColumn}) = (;column_path = 1, target_id = 2, types = 3)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:GNFColumn})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:GNFColumn}, _endpos::Int=0, _group::Bool=false)
     column_path = PB.BufferedVector{String}()
     target_id = Ref{Union{Nothing,RelationId}}(nothing)
     types = PB.BufferedVector{var"#Type"}()
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, column_path)
@@ -1083,9 +1083,9 @@ MinMonoid(;var"#type" = nothing) = MinMonoid(var"#type")
 PB.default_values(::Type{MinMonoid}) = (;var"#type" = nothing)
 PB.field_numbers(::Type{MinMonoid}) = (;var"#type" = 1)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:MinMonoid})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:MinMonoid}, _endpos::Int=0, _group::Bool=false)
     var"#type" = Ref{Union{Nothing,var"#Type"}}(nothing)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, var"#type")
@@ -1114,9 +1114,9 @@ SumMonoid(;var"#type" = nothing) = SumMonoid(var"#type")
 PB.default_values(::Type{SumMonoid}) = (;var"#type" = nothing)
 PB.field_numbers(::Type{SumMonoid}) = (;var"#type" = 1)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:SumMonoid})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:SumMonoid}, _endpos::Int=0, _group::Bool=false)
     var"#type" = Ref{Union{Nothing,var"#Type"}}(nothing)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, var"#type")
@@ -1145,9 +1145,9 @@ MaxMonoid(;var"#type" = nothing) = MaxMonoid(var"#type")
 PB.default_values(::Type{MaxMonoid}) = (;var"#type" = nothing)
 PB.field_numbers(::Type{MaxMonoid}) = (;var"#type" = 1)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:MaxMonoid})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:MaxMonoid}, _endpos::Int=0, _group::Bool=false)
     var"#type" = Ref{Union{Nothing,var"#Type"}}(nothing)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, var"#type")
@@ -1180,12 +1180,12 @@ PB.reserved_fields(::Type{BeTreeInfo}) = (names = String[], numbers = Union{Int,
 PB.default_values(::Type{BeTreeInfo}) = (;key_types = Vector{var"#Type"}(), value_types = Vector{var"#Type"}(), storage_config = nothing, relation_locator = nothing)
 PB.field_numbers(::Type{BeTreeInfo}) = (;key_types = 1, value_types = 2, storage_config = 4, relation_locator = 5)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:BeTreeInfo})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:BeTreeInfo}, _endpos::Int=0, _group::Bool=false)
     key_types = PB.BufferedVector{var"#Type"}()
     value_types = PB.BufferedVector{var"#Type"}()
     storage_config = Ref{Union{Nothing,BeTreeConfig}}(nothing)
     relation_locator = Ref{Union{Nothing,BeTreeLocator}}(nothing)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, key_types)
@@ -1227,10 +1227,10 @@ Binding(;var = nothing, var"#type" = nothing) = Binding(var, var"#type")
 PB.default_values(::Type{Binding}) = (;var = nothing, var"#type" = nothing)
 PB.field_numbers(::Type{Binding}) = (;var = 1, var"#type" = 2)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Binding})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Binding}, _endpos::Int=0, _group::Bool=false)
     var = Ref{Union{Nothing,Var}}(nothing)
     var"#type" = Ref{Union{Nothing,var"#Type"}}(nothing)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, var)
@@ -1265,11 +1265,11 @@ EDB(;target_id = nothing, path = Vector{String}(), types = Vector{var"#Type"}())
 PB.default_values(::Type{EDB}) = (;target_id = nothing, path = Vector{String}(), types = Vector{var"#Type"}())
 PB.field_numbers(::Type{EDB}) = (;target_id = 1, path = 2, types = 3)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:EDB})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:EDB}, _endpos::Int=0, _group::Bool=false)
     target_id = Ref{Union{Nothing,RelationId}}(nothing)
     path = PB.BufferedVector{String}()
     types = PB.BufferedVector{var"#Type"}()
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, target_id)
@@ -1307,10 +1307,10 @@ Attribute(;name = "", args = Vector{Value}()) = Attribute(name, args)
 PB.default_values(::Type{Attribute}) = (;name = "", args = Vector{Value}())
 PB.field_numbers(::Type{Attribute}) = (;name = 1, args = 2)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Attribute})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Attribute}, _endpos::Int=0, _group::Bool=false)
     name = ""
     args = PB.BufferedVector{Value}()
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             name = PB.decode(d, String)
@@ -1346,9 +1346,9 @@ PB.oneof_field_types(::Type{Term}) = (;
 PB.default_values(::Type{Term}) = (;var = nothing, constant = nothing)
 PB.field_numbers(::Type{Term}) = (;var = 1, constant = 2)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Term})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Term}, _endpos::Int=0, _group::Bool=false)
     term_type = nothing
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             term_type = OneOf(:var, PB.decode(d, Ref{Var}))
@@ -1392,12 +1392,12 @@ CSVData(;locator = nothing, config = nothing, columns = Vector{GNFColumn}(), aso
 PB.default_values(::Type{CSVData}) = (;locator = nothing, config = nothing, columns = Vector{GNFColumn}(), asof = "")
 PB.field_numbers(::Type{CSVData}) = (;locator = 1, config = 2, columns = 3, asof = 4)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:CSVData})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:CSVData}, _endpos::Int=0, _group::Bool=false)
     locator = Ref{Union{Nothing,CSVLocator}}(nothing)
     config = Ref{Union{Nothing,CSVConfig}}(nothing)
     columns = PB.BufferedVector{GNFColumn}()
     asof = ""
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, locator)
@@ -1441,9 +1441,9 @@ PB.oneof_field_types(::Type{Monoid}) = (;
 PB.default_values(::Type{Monoid}) = (;or_monoid = nothing, min_monoid = nothing, max_monoid = nothing, sum_monoid = nothing)
 PB.field_numbers(::Type{Monoid}) = (;or_monoid = 1, min_monoid = 2, max_monoid = 3, sum_monoid = 4)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Monoid})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Monoid}, _endpos::Int=0, _group::Bool=false)
     value = nothing
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             value = OneOf(:or_monoid, PB.decode(d, Ref{OrMonoid}))
@@ -1497,10 +1497,10 @@ BeTreeRelation(;name = nothing, relation_info = nothing) = BeTreeRelation(name,
 PB.default_values(::Type{BeTreeRelation}) = (;name = nothing, relation_info = nothing)
 PB.field_numbers(::Type{BeTreeRelation}) = (;name = 1, relation_info = 2)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:BeTreeRelation})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:BeTreeRelation}, _endpos::Int=0, _group::Bool=false)
     name = Ref{Union{Nothing,RelationId}}(nothing)
     relation_info = Ref{Union{Nothing,BeTreeInfo}}(nothing)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, name)
@@ -1534,10 +1534,10 @@ Cast(;input = nothing, result = nothing) = Cast(input, result)
 PB.default_values(::Type{Cast}) = (;input = nothing, result = nothing)
 PB.field_numbers(::Type{Cast}) = (;input = 2, result = 3)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Cast})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Cast}, _endpos::Int=0, _group::Bool=false)
     input = Ref{Union{Nothing,Term}}(nothing)
     result = Ref{Union{Nothing,Term}}(nothing)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 2
             PB.decode!(d, input)
@@ -1571,10 +1571,10 @@ Pragma(;name = "", terms = Vector{Term}()) = Pragma(name, terms)
 PB.default_values(::Type{Pragma}) = (;name = "", terms = Vector{Term}())
 PB.field_numbers(::Type{Pragma}) = (;name = 1, terms = 2)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Pragma})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Pragma}, _endpos::Int=0, _group::Bool=false)
     name = ""
     terms = PB.BufferedVector{Term}()
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             name = PB.decode(d, String)
@@ -1608,10 +1608,10 @@ Atom(;name = nothing, terms = Vector{Term}()) = Atom(name, terms)
 PB.default_values(::Type{Atom}) = (;name = nothing, terms = Vector{Term}())
 PB.field_numbers(::Type{Atom}) = (;name = 1, terms = 2)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Atom})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Atom}, _endpos::Int=0, _group::Bool=false)
     name = Ref{Union{Nothing,RelationId}}(nothing)
     terms = PB.BufferedVector{Term}()
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, name)
@@ -1647,9 +1647,9 @@ PB.oneof_field_types(::Type{RelTerm}) = (;
 PB.default_values(::Type{RelTerm}) = (;specialized_value = nothing, term = nothing)
 PB.field_numbers(::Type{RelTerm}) = (;specialized_value = 1, term = 2)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:RelTerm})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:RelTerm}, _endpos::Int=0, _group::Bool=false)
     rel_term_type = nothing
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             rel_term_type = OneOf(:specialized_value, PB.decode(d, Ref{Value}))
@@ -1693,9 +1693,9 @@ PB.oneof_field_types(::Type{Data}) = (;
 PB.default_values(::Type{Data}) = (;edb = nothing, betree_relation = nothing, csv_data = nothing)
 PB.field_numbers(::Type{Data}) = (;edb = 1, betree_relation = 2, csv_data = 3)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Data})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Data}, _endpos::Int=0, _group::Bool=false)
     data_type = nothing
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             data_type = OneOf(:edb, PB.decode(d, Ref{EDB}))
@@ -1743,10 +1743,10 @@ Primitive(;name = "", terms = Vector{RelTerm}()) = Primitive(name, terms)
 PB.default_values(::Type{Primitive}) = (;name = "", terms = Vector{RelTerm}())
 PB.field_numbers(::Type{Primitive}) = (;name = 1, terms = 2)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Primitive})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Primitive}, _endpos::Int=0, _group::Bool=false)
     name = ""
     terms = PB.BufferedVector{RelTerm}()
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             name = PB.decode(d, String)
@@ -1780,10 +1780,10 @@ RelAtom(;name = "", terms = Vector{RelTerm}()) = RelAtom(name, terms)
 PB.default_values(::Type{RelAtom}) = (;name = "", terms = Vector{RelTerm}())
 PB.field_numbers(::Type{RelAtom}) = (;name = 3, terms = 2)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:RelAtom})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:RelAtom}, _endpos::Int=0, _group::Bool=false)
     name = ""
     terms = PB.BufferedVector{RelTerm}()
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 3
             name = PB.decode(d, String)
@@ -1930,10 +1930,10 @@ Abstraction(;vars = Vector{Binding}(), value = nothing) = Abstraction(vars, valu
 PB.default_values(::Type{Abstraction}) = (;vars = Vector{Binding}(), value = nothing)
 PB.field_numbers(::Type{Abstraction}) = (;vars = 1, value = 2)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Abstraction})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Abstraction}, _endpos::Int=0, _group::Bool=false)
     vars = PB.BufferedVector{Binding}()
     value = Ref{Union{Nothing,Formula}}(nothing)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, vars)
@@ -1964,10 +1964,10 @@ Algorithm(;var"#global" = Vector{RelationId}(), body = nothing) = Algorithm(var"
 PB.default_values(::Type{Algorithm}) = (;var"#global" = Vector{RelationId}(), body = nothing)
 PB.field_numbers(::Type{Algorithm}) = (;var"#global" = 1, body = 2)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Algorithm})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Algorithm}, _endpos::Int=0, _group::Bool=false)
     var"#global" = PB.BufferedVector{RelationId}()
     body = Ref{Union{Nothing,Script}}(nothing)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, var"#global")
@@ -1998,11 +1998,11 @@ Assign(;name = nothing, body = nothing, attrs = Vector{Attribute}()) = Assign(na
 PB.default_values(::Type{Assign}) = (;name = nothing, body = nothing, attrs = Vector{Attribute}())
 PB.field_numbers(::Type{Assign}) = (;name = 1, body = 2, attrs = 3)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Assign})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Assign}, _endpos::Int=0, _group::Bool=false)
     name = Ref{Union{Nothing,RelationId}}(nothing)
     body = Ref{Union{Nothing,Abstraction}}(nothing)
     attrs = PB.BufferedVector{Attribute}()
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, name)
@@ -2037,11 +2037,11 @@ Break(;name = nothing, body = nothing, attrs = Vector{Attribute}()) = Break(name
 PB.default_values(::Type{Break}) = (;name = nothing, body = nothing, attrs = Vector{Attribute}())
 PB.field_numbers(::Type{Break}) = (;name = 1, body = 2, attrs = 3)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Break})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Break}, _endpos::Int=0, _group::Bool=false)
     name = Ref{Union{Nothing,RelationId}}(nothing)
     body = Ref{Union{Nothing,Abstraction}}(nothing)
     attrs = PB.BufferedVector{Attribute}()
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, name)
@@ -2076,9 +2076,9 @@ Conjunction(;args = Vector{Formula}()) = Conjunction(args)
 PB.default_values(::Type{Conjunction}) = (;args = Vector{Formula}())
 PB.field_numbers(::Type{Conjunction}) = (;args = 1)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Conjunction})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Conjunction}, _endpos::Int=0, _group::Bool=false)
     args = PB.BufferedVector{Formula}()
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, args)
@@ -2108,10 +2108,10 @@ PB.oneof_field_types(::Type{Constraint}) = (;
 PB.default_values(::Type{Constraint}) = (;name = nothing, functional_dependency = nothing)
 PB.field_numbers(::Type{Constraint}) = (;name = 2, functional_dependency = 1)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Constraint})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Constraint}, _endpos::Int=0, _group::Bool=false)
     name = Ref{Union{Nothing,RelationId}}(nothing)
     constraint_type = nothing
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 2
             PB.decode!(d, name)
@@ -2148,11 +2148,11 @@ Def(;name = nothing, body = nothing, attrs = Vector{Attribute}()) = Def(name, bo
 PB.default_values(::Type{Def}) = (;name = nothing, body = nothing, attrs = Vector{Attribute}())
 PB.field_numbers(::Type{Def}) = (;name = 1, body = 2, attrs = 3)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Def})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Def}, _endpos::Int=0, _group::Bool=false)
     name = Ref{Union{Nothing,RelationId}}(nothing)
     body = Ref{Union{Nothing,Abstraction}}(nothing)
     attrs = PB.BufferedVector{Attribute}()
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, name)
@@ -2187,9 +2187,9 @@ Disjunction(;args = Vector{Formula}()) = Disjunction(args)
 PB.default_values(::Type{Disjunction}) = (;args = Vector{Formula}())
 PB.field_numbers(::Type{Disjunction}) = (;args = 1)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Disjunction})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Disjunction}, _endpos::Int=0, _group::Bool=false)
     args = PB.BufferedVector{Formula}()
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, args)
@@ -2216,9 +2216,9 @@ Exists(;body = nothing) = Exists(body)
 PB.default_values(::Type{Exists}) = (;body = nothing)
 PB.field_numbers(::Type{Exists}) = (;body = 3)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Exists})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Exists}, _endpos::Int=0, _group::Bool=false)
     body = Ref{Union{Nothing,Abstraction}}(nothing)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 3
             PB.decode!(d, body)
@@ -2245,11 +2245,11 @@ FFI(;name = "", args = Vector{Abstraction}(), terms = Vector{Term}()) = FFI(name
 PB.default_values(::Type{FFI}) = (;name = "", args = Vector{Abstraction}(), terms = Vector{Term}())
 PB.field_numbers(::Type{FFI}) = (;name = 1, args = 2, terms = 3)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:FFI})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:FFI}, _endpos::Int=0, _group::Bool=false)
     name = ""
     args = PB.BufferedVector{Abstraction}()
     terms = PB.BufferedVector{Term}()
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             name = PB.decode(d, String)
@@ -2284,11 +2284,11 @@ FunctionalDependency(;guard = nothing, keys = Vector{Var}(), values = Vector{Var
 PB.default_values(::Type{FunctionalDependency}) = (;guard = nothing, keys = Vector{Var}(), values = Vector{Var}())
 PB.field_numbers(::Type{FunctionalDependency}) = (;guard = 1, keys = 2, values = 3)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:FunctionalDependency})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:FunctionalDependency}, _endpos::Int=0, _group::Bool=false)
     guard = Ref{Union{Nothing,Abstraction}}(nothing)
     keys = PB.BufferedVector{Var}()
     values = PB.BufferedVector{Var}()
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, guard)
@@ -2323,13 +2323,13 @@ MonoidDef(;monoid = nothing, name = nothing, body = nothing, attrs = Vector{Attr
 PB.default_values(::Type{MonoidDef}) = (;monoid = nothing, name = nothing, body = nothing, attrs = Vector{Attribute}(), value_arity = zero(Int64))
 PB.field_numbers(::Type{MonoidDef}) = (;monoid = 1, name = 2, body = 3, attrs = 4, value_arity = 5)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:MonoidDef})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:MonoidDef}, _endpos::Int=0, _group::Bool=false)
     monoid = Ref{Union{Nothing,Monoid}}(nothing)
     name = Ref{Union{Nothing,RelationId}}(nothing)
     body = Ref{Union{Nothing,Abstraction}}(nothing)
     attrs = PB.BufferedVector{Attribute}()
     value_arity = zero(Int64)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, monoid)
@@ -2372,13 +2372,13 @@ MonusDef(;monoid = nothing, name = nothing, body = nothing, attrs = Vector{Attri
 PB.default_values(::Type{MonusDef}) = (;monoid = nothing, name = nothing, body = nothing, attrs = Vector{Attribute}(), value_arity = zero(Int64))
 PB.field_numbers(::Type{MonusDef}) = (;monoid = 1, name = 2, body = 3, attrs = 4, value_arity = 5)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:MonusDef})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:MonusDef}, _endpos::Int=0, _group::Bool=false)
     monoid = Ref{Union{Nothing,Monoid}}(nothing)
     name = Ref{Union{Nothing,RelationId}}(nothing)
     body = Ref{Union{Nothing,Abstraction}}(nothing)
     attrs = PB.BufferedVector{Attribute}()
     value_arity = zero(Int64)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, monoid)
@@ -2421,9 +2421,9 @@ Not(;arg = nothing) = Not(arg)
 PB.default_values(::Type{Not}) = (;arg = nothing)
 PB.field_numbers(::Type{Not}) = (;arg = 1)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Not})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Not}, _endpos::Int=0, _group::Bool=false)
     arg = Ref{Union{Nothing,Formula}}(nothing)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, arg)
@@ -2450,11 +2450,11 @@ Reduce(;op = nothing, body = nothing, terms = Vector{Term}()) = Reduce(op, body,
 PB.default_values(::Type{Reduce}) = (;op = nothing, body = nothing, terms = Vector{Term}())
 PB.field_numbers(::Type{Reduce}) = (;op = 1, body = 2, terms = 3)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Reduce})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Reduce}, _endpos::Int=0, _group::Bool=false)
     op = Ref{Union{Nothing,Abstraction}}(nothing)
     body = Ref{Union{Nothing,Abstraction}}(nothing)
     terms = PB.BufferedVector{Term}()
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, op)
@@ -2489,9 +2489,9 @@ Script(;constructs = Vector{Construct}()) = Script(constructs)
 PB.default_values(::Type{Script}) = (;constructs = Vector{Construct}())
 PB.field_numbers(::Type{Script}) = (;constructs = 1)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Script})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Script}, _endpos::Int=0, _group::Bool=false)
     constructs = PB.BufferedVector{Construct}()
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, constructs)
@@ -2518,12 +2518,12 @@ Upsert(;name = nothing, body = nothing, attrs = Vector{Attribute}(), value_arity
 PB.default_values(::Type{Upsert}) = (;name = nothing, body = nothing, attrs = Vector{Attribute}(), value_arity = zero(Int64))
 PB.field_numbers(::Type{Upsert}) = (;name = 1, body = 2, attrs = 3, value_arity = 4)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Upsert})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Upsert}, _endpos::Int=0, _group::Bool=false)
     name = Ref{Union{Nothing,RelationId}}(nothing)
     body = Ref{Union{Nothing,Abstraction}}(nothing)
     attrs = PB.BufferedVector{Attribute}()
     value_arity = zero(Int64)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, name)
@@ -2565,9 +2565,9 @@ PB.oneof_field_types(::Type{Construct}) = (;
 PB.default_values(::Type{Construct}) = (;loop = nothing, instruction = nothing)
 PB.field_numbers(::Type{Construct}) = (;loop = 1, instruction = 2)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Construct})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Construct}, _endpos::Int=0, _group::Bool=false)
     construct_type = nothing
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             construct_type = OneOf(:loop, PB.decode(d, Ref{Loop}))
@@ -2606,10 +2606,10 @@ Loop(;init = Vector{Instruction}(), body = nothing) = Loop(init, body)
 PB.default_values(::Type{Loop}) = (;init = Vector{Instruction}(), body = nothing)
 PB.field_numbers(::Type{Loop}) = (;init = 1, body = 2)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Loop})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Loop}, _endpos::Int=0, _group::Bool=false)
     init = PB.BufferedVector{Instruction}()
     body = Ref{Union{Nothing,Script}}(nothing)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, init)
@@ -2643,9 +2643,9 @@ PB.oneof_field_types(::Type{Declaration}) = (;
 PB.default_values(::Type{Declaration}) = (;def = nothing, algorithm = nothing, constraint = nothing, data = nothing)
 PB.field_numbers(::Type{Declaration}) = (;def = 1, algorithm = 2, constraint = 3, data = 4)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Declaration})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Declaration}, _endpos::Int=0, _group::Bool=false)
     declaration_type = nothing
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             declaration_type = OneOf(:def, PB.decode(d, Ref{Def}))
@@ -2700,9 +2700,9 @@ PB.oneof_field_types(::Type{Instruction}) = (;
 PB.default_values(::Type{Instruction}) = (;assign = nothing, upsert = nothing, var"#break" = nothing, monoid_def = nothing, monus_def = nothing)
 PB.field_numbers(::Type{Instruction}) = (;assign = 1, upsert = 2, var"#break" = 3, monoid_def = 5, monus_def = 6)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Instruction})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Instruction}, _endpos::Int=0, _group::Bool=false)
     instr_type = nothing
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             instr_type = OneOf(:assign, PB.decode(d, Ref{Assign}))
@@ -2762,9 +2762,9 @@ PB.oneof_field_types(::Type{Formula}) = (;
 PB.default_values(::Type{Formula}) = (;exists = nothing, reduce = nothing, conjunction = nothing, disjunction = nothing, not = nothing, ffi = nothing, atom = nothing, pragma = nothing, primitive = nothing, rel_atom = nothing, cast = nothing)
 PB.field_numbers(::Type{Formula}) = (;exists = 1, reduce = 2, conjunction = 3, disjunction = 4, not = 5, ffi = 6, atom = 7, pragma = 8, primitive = 9, rel_atom = 10, cast = 11)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Formula})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Formula}, _endpos::Int=0, _group::Bool=false)
     formula_type = nothing
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             formula_type = OneOf(:exists, PB.decode(d, Ref{Exists}))
diff --git a/sdks/julia/LogicalQueryProtocol.jl/src/gen/relationalai/lqp/v1/transactions_pb.jl b/sdks/julia/LogicalQueryProtocol.jl/src/gen/relationalai/lqp/v1/transactions_pb.jl
index 047fd1d1..c5f18bf0 100644
--- a/sdks/julia/LogicalQueryProtocol.jl/src/gen/relationalai/lqp/v1/transactions_pb.jl
+++ b/sdks/julia/LogicalQueryProtocol.jl/src/gen/relationalai/lqp/v1/transactions_pb.jl
@@ -1,4 +1,4 @@
-# Autogenerated using ProtoBuf.jl v1.2.2
+# Autogenerated using ProtoBuf.jl v1.3.0
 # original file: relationalai/lqp/v1/transactions.proto (proto3 syntax)
 
 import ProtoBuf as PB
@@ -23,10 +23,10 @@ ExportCSVColumn(;column_name = "", column_data = nothing) = ExportCSVColumn(colu
 PB.default_values(::Type{ExportCSVColumn}) = (;column_name = "", column_data = nothing)
 PB.field_numbers(::Type{ExportCSVColumn}) = (;column_name = 1, column_data = 2)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:ExportCSVColumn})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:ExportCSVColumn}, _endpos::Int=0, _group::Bool=false)
     column_name = ""
     column_data = Ref{Union{Nothing,RelationId}}(nothing)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             column_name = PB.decode(d, String)
@@ -59,9 +59,9 @@ Demand(;relation_id = nothing) = Demand(relation_id)
 PB.default_values(::Type{Demand}) = (;relation_id = nothing)
 PB.field_numbers(::Type{Demand}) = (;relation_id = 1)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Demand})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Demand}, _endpos::Int=0, _group::Bool=false)
     relation_id = Ref{Union{Nothing,RelationId}}(nothing)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, relation_id)
@@ -90,9 +90,9 @@ Undefine(;fragment_id = nothing) = Undefine(fragment_id)
 PB.default_values(::Type{Undefine}) = (;fragment_id = nothing)
 PB.field_numbers(::Type{Undefine}) = (;fragment_id = 1)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Undefine})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Undefine}, _endpos::Int=0, _group::Bool=false)
     fragment_id = Ref{Union{Nothing,FragmentId}}(nothing)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, fragment_id)
@@ -123,9 +123,9 @@ Define(;fragment = nothing) = Define(fragment)
 PB.default_values(::Type{Define}) = (;fragment = nothing)
 PB.field_numbers(::Type{Define}) = (;fragment = 1)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Define})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Define}, _endpos::Int=0, _group::Bool=false)
     fragment = Ref{Union{Nothing,Fragment}}(nothing)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, fragment)
@@ -154,9 +154,9 @@ Context(;relations = Vector{RelationId}()) = Context(relations)
 PB.default_values(::Type{Context}) = (;relations = Vector{RelationId}())
 PB.field_numbers(::Type{Context}) = (;relations = 1)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Context})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Context}, _endpos::Int=0, _group::Bool=false)
     relations = PB.BufferedVector{RelationId}()
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, relations)
@@ -185,9 +185,9 @@ Sync(;fragments = Vector{FragmentId}()) = Sync(fragments)
 PB.default_values(::Type{Sync}) = (;fragments = Vector{FragmentId}())
 PB.field_numbers(::Type{Sync}) = (;fragments = 1)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Sync})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Sync}, _endpos::Int=0, _group::Bool=false)
     fragments = PB.BufferedVector{FragmentId}()
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, fragments)
@@ -217,10 +217,10 @@ SnapshotMapping(;destination_path = Vector{String}(), source_relation = nothing)
 PB.default_values(::Type{SnapshotMapping}) = (;destination_path = Vector{String}(), source_relation = nothing)
 PB.field_numbers(::Type{SnapshotMapping}) = (;destination_path = 1, source_relation = 2)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:SnapshotMapping})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:SnapshotMapping}, _endpos::Int=0, _group::Bool=false)
     destination_path = PB.BufferedVector{String}()
     source_relation = Ref{Union{Nothing,RelationId}}(nothing)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, destination_path)
@@ -254,10 +254,10 @@ Abort(;name = "", relation_id = nothing) = Abort(name, relation_id)
 PB.default_values(::Type{Abort}) = (;name = "", relation_id = nothing)
 PB.field_numbers(::Type{Abort}) = (;name = 1, relation_id = 2)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Abort})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Abort}, _endpos::Int=0, _group::Bool=false)
     name = ""
     relation_id = Ref{Union{Nothing,RelationId}}(nothing)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             name = PB.decode(d, String)
@@ -291,10 +291,10 @@ Output(;name = "", relation_id = nothing) = Output(name, relation_id)
 PB.default_values(::Type{Output}) = (;name = "", relation_id = nothing)
 PB.field_numbers(::Type{Output}) = (;name = 1, relation_id = 2)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Output})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Output}, _endpos::Int=0, _group::Bool=false)
     name = ""
     relation_id = Ref{Union{Nothing,RelationId}}(nothing)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             name = PB.decode(d, String)
@@ -327,9 +327,9 @@ ExportCSVColumns(;columns = Vector{ExportCSVColumn}()) = ExportCSVColumns(column
 PB.default_values(::Type{ExportCSVColumns}) = (;columns = Vector{ExportCSVColumn}())
 PB.field_numbers(::Type{ExportCSVColumns}) = (;columns = 1)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:ExportCSVColumns})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:ExportCSVColumns}, _endpos::Int=0, _group::Bool=false)
     columns = PB.BufferedVector{ExportCSVColumn}()
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, columns)
@@ -358,9 +358,9 @@ IVMConfig(;level = MaintenanceLevel.MAINTENANCE_LEVEL_UNSPECIFIED) = IVMConfig(l
 PB.default_values(::Type{IVMConfig}) = (;level = MaintenanceLevel.MAINTENANCE_LEVEL_UNSPECIFIED)
 PB.field_numbers(::Type{IVMConfig}) = (;level = 1)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:IVMConfig})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:IVMConfig}, _endpos::Int=0, _group::Bool=false)
     level = MaintenanceLevel.MAINTENANCE_LEVEL_UNSPECIFIED
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             level = PB.decode(d, MaintenanceLevel.T)
@@ -389,9 +389,9 @@ Snapshot(;mappings = Vector{SnapshotMapping}()) = Snapshot(mappings)
 PB.default_values(::Type{Snapshot}) = (;mappings = Vector{SnapshotMapping}())
 PB.field_numbers(::Type{Snapshot}) = (;mappings = 1)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Snapshot})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Snapshot}, _endpos::Int=0, _group::Bool=false)
     mappings = PB.BufferedVector{SnapshotMapping}()
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, mappings)
@@ -423,9 +423,9 @@ PB.oneof_field_types(::Type{ExportCSVSource}) = (;
 PB.default_values(::Type{ExportCSVSource}) = (;gnf_columns = nothing, table_def = nothing)
 PB.field_numbers(::Type{ExportCSVSource}) = (;gnf_columns = 1, table_def = 2)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:ExportCSVSource})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:ExportCSVSource}, _endpos::Int=0, _group::Bool=false)
     csv_source = nothing
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             csv_source = OneOf(:gnf_columns, PB.decode(d, Ref{ExportCSVColumns}))
@@ -467,10 +467,10 @@ Configure(;semantics_version = zero(Int64), ivm_config = nothing) = Configure(se
 PB.default_values(::Type{Configure}) = (;semantics_version = zero(Int64), ivm_config = nothing)
 PB.field_numbers(::Type{Configure}) = (;semantics_version = 1, ivm_config = 2)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Configure})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Configure}, _endpos::Int=0, _group::Bool=false)
     semantics_version = zero(Int64)
     ivm_config = Ref{Union{Nothing,IVMConfig}}(nothing)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             semantics_version = PB.decode(d, Int64)
@@ -507,9 +507,9 @@ PB.oneof_field_types(::Type{Write}) = (;
 PB.default_values(::Type{Write}) = (;define = nothing, undefine = nothing, context = nothing, snapshot = nothing)
 PB.field_numbers(::Type{Write}) = (;define = 1, undefine = 2, context = 3, snapshot = 5)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Write})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Write}, _endpos::Int=0, _group::Bool=false)
     write_type = nothing
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             write_type = OneOf(:define, PB.decode(d, Ref{Define}))
@@ -572,7 +572,7 @@ ExportCSVConfig(;path = "", csv_source = nothing, csv_config = nothing, data_col
 PB.default_values(::Type{ExportCSVConfig}) = (;path = "", csv_source = nothing, csv_config = nothing, data_columns = Vector{ExportCSVColumn}(), partition_size = zero(Int64), compression = "", syntax_header_row = false, syntax_missing_string = "", syntax_delim = "", syntax_quotechar = "", syntax_escapechar = "")
 PB.field_numbers(::Type{ExportCSVConfig}) = (;path = 1, csv_source = 10, csv_config = 11, data_columns = 2, partition_size = 3, compression = 4, syntax_header_row = 5, syntax_missing_string = 6, syntax_delim = 7, syntax_quotechar = 8, syntax_escapechar = 9)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:ExportCSVConfig})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:ExportCSVConfig}, _endpos::Int=0, _group::Bool=false)
     path = ""
     csv_source = Ref{Union{Nothing,ExportCSVSource}}(nothing)
     csv_config = Ref{Union{Nothing,CSVConfig}}(nothing)
@@ -584,7 +584,7 @@ function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:ExportCSVConfig})
     syntax_delim = ""
     syntax_quotechar = ""
     syntax_escapechar = ""
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             path = PB.decode(d, String)
@@ -656,9 +656,9 @@ PB.oneof_field_types(::Type{Export}) = (;
 PB.default_values(::Type{Export}) = (;csv_config = nothing)
 PB.field_numbers(::Type{Export}) = (;csv_config = 1)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Export})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Export}, _endpos::Int=0, _group::Bool=false)
     export_config = nothing
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             export_config = OneOf(:csv_config, PB.decode(d, Ref{ExportCSVConfig}))
@@ -712,10 +712,10 @@ Epoch(;writes = Vector{Write}(), reads = Vector{Read}()) = Epoch(writes, reads)
 PB.default_values(::Type{Epoch}) = (;writes = Vector{Write}(), reads = Vector{Read}())
 PB.field_numbers(::Type{Epoch}) = (;writes = 1, reads = 2)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Epoch})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Epoch}, _endpos::Int=0, _group::Bool=false)
     writes = PB.BufferedVector{Write}()
     reads = PB.BufferedVector{Read}()
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, writes)
@@ -749,9 +749,9 @@ PB.oneof_field_types(::Type{Read}) = (;
 PB.default_values(::Type{Read}) = (;demand = nothing, output = nothing, what_if = nothing, abort = nothing, var"#export" = nothing)
 PB.field_numbers(::Type{Read}) = (;demand = 1, output = 2, what_if = 3, abort = 4, var"#export" = 5)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Read})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Read}, _endpos::Int=0, _group::Bool=false)
     read_type = nothing
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             read_type = OneOf(:demand, PB.decode(d, Ref{Demand}))
@@ -808,11 +808,11 @@ Transaction(;epochs = Vector{Epoch}(), configure = nothing, sync = nothing) = Tr
 PB.default_values(::Type{Transaction}) = (;epochs = Vector{Epoch}(), configure = nothing, sync = nothing)
 PB.field_numbers(::Type{Transaction}) = (;epochs = 1, configure = 2, sync = 3)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Transaction})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:Transaction}, _endpos::Int=0, _group::Bool=false)
     epochs = PB.BufferedVector{Epoch}()
     configure = Ref{Union{Nothing,Configure}}(nothing)
     sync = Ref{Union{Nothing,Sync}}(nothing)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             PB.decode!(d, epochs)
@@ -847,10 +847,10 @@ WhatIf(;branch = "", epoch = nothing) = WhatIf(branch, epoch)
 PB.default_values(::Type{WhatIf}) = (;branch = "", epoch = nothing)
 PB.field_numbers(::Type{WhatIf}) = (;branch = 1, epoch = 2)
 
-function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:WhatIf})
+function PB.decode(d::PB.AbstractProtoDecoder, ::Type{<:WhatIf}, _endpos::Int=0, _group::Bool=false)
     branch = ""
     epoch = Ref{Union{Nothing,Epoch}}(nothing)
-    while !PB.message_done(d)
+    while !PB.message_done(d, _endpos, _group)
         field_number, wire_type = PB.decode_tag(d)
         if field_number == 1
             branch = PB.decode(d, String)