diff --git a/sdk/python/feast/infra/online_stores/contrib/cassandra_online_store/cassandra_online_store.py b/sdk/python/feast/infra/online_stores/contrib/cassandra_online_store/cassandra_online_store.py index 8d20e312ef..6968587390 100644 --- a/sdk/python/feast/infra/online_stores/contrib/cassandra_online_store/cassandra_online_store.py +++ b/sdk/python/feast/infra/online_stores/contrib/cassandra_online_store/cassandra_online_store.py @@ -354,7 +354,9 @@ def online_write_batch( project = config.project keyspace: str = self._keyspace + logger.info(f"keyspace: {keyspace}") fqtable = CassandraOnlineStore._fq_table_name(keyspace, project, table) + logger.info(f"fqtable: {fqtable}") insert_cql = self._get_cql_statement(config, "insert4", fqtable=fqtable) def unroll_insertion_tuples() -> Iterable[Tuple[str, bytes, str, datetime]]: