diff --git a/drivers/py/cql/decoders.py b/drivers/py/cql/decoders.py index 76036a1938..e22703d7f5 100644 --- a/drivers/py/cql/decoders.py +++ b/drivers/py/cql/decoders.py @@ -59,11 +59,11 @@ class SchemaDecoder(object): unmarshal = unmarshallers.get(comparator, unmarshal_noop) values = [key] for column in row.columns: - if column.value == None: - continue - description.append((unmarshal(column.name), comparator, None, None, None, None, True)) validator = self.__validator_for(keyspace, column_family, column.name) - values.append(unmarshallers.get(validator, unmarshal_noop)(column.value)) + if column.value is None: + values.append(None) + else: + values.append(unmarshallers.get(validator, unmarshal_noop)(column.value)) return description, values