fix: Remove explicit consistency level from BatchStatement in Cassand…

…raOnlineStore
ExpediaGroup · Jan 7, 2025 · 1a04d2a · 1a04d2a
1 parent 4683447
commit 1a04d2a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...python/feast/infra/online_stores/contrib/cassandra_online_store/cassandra_online_store.py b/...python/feast/infra/online_stores/contrib/cassandra_online_store/cassandra_online_store.py
@@ -364,7 +364,7 @@ def unroll_insertion_tuples() -> Iterable[Tuple[str, bytes, str, datetime]]:
             but this way we can call `progress` after each entity is done.
             """
             for entity_key, values, timestamp, created_ts in data:
-                batch = BatchStatement(consistency_level=ConsistencyLevel.QUORUM)
+                batch = BatchStatement()
                 entity_key_bin = serialize_entity_key(
                     entity_key,
                     entity_key_serialization_version=config.entity_key_serialization_version,