diff --git a/cassandra/cqltypes.py b/cassandra/cqltypes.py index e36c48563c..114be3f405 100644 --- a/cassandra/cqltypes.py +++ b/cassandra/cqltypes.py @@ -730,6 +730,10 @@ def deserialize(byts, protocol_version): def serialize(byts, protocol_version): return int16_pack(byts) + @classmethod + def serial_size(cls): + return 2 + class TimeType(_CassandraType): typename = 'time' # Time should be a fixed size 8 byte type but Cassandra 5.0 code marks it as