checking in progress

franciscojavierarceo · franciscojavierarceo · commit d34db1d132a3 · 2024-09-29T15:06:29.000-04:00
Signed-off-by: Francisco Javier Arceo &lt;farceo@redhat.com&gt;
diff --git a/sdk/python/feast/inference.py b/sdk/python/feast/inference.py
@@ -283,18 +283,17 @@ def _infer_on_demand_features_and_entities(
 
         batch_source = getattr(source_feature_view, "batch_source")
         batch_field_mapping = getattr(batch_source or None, "field_mapping")
-        if batch_field_mapping:
-            for (
-                original_col,
-                mapped_col,
-            ) in batch_field_mapping.items():
-                if mapped_col in columns_to_exclude:
-                    columns_to_exclude.remove(mapped_col)
-                    columns_to_exclude.add(original_col)
+        for (
+            original_col,
+            mapped_col,
+        ) in batch_field_mapping.items():
+            if mapped_col in columns_to_exclude:
+                columns_to_exclude.remove(mapped_col)
+                columns_to_exclude.add(original_col)
 
-            table_column_names_and_types = (
-                batch_source.get_table_column_names_and_types(config)
-            )
+        table_column_names_and_types = batch_source.get_table_column_names_and_types(
+            config
+        )
         for col_name, col_datatype in table_column_names_and_types:
             if col_name in columns_to_exclude:
                 continue
diff --git a/sdk/python/feast/infra/online_stores/sqlite.py b/sdk/python/feast/infra/online_stores/sqlite.py
@@ -192,16 +192,16 @@ def online_write_batch(
                                 ),
                             )
                         else:
-                        # except Exception as e:
-                            print(
-                                f"error writing online batch for {table_name} - {feature_name} = {val}\n {e}"
-                            )
+                            # print(
+                            #     f"error writing online batch for {table_name} - {feature_name} = {val}\n {e}"
+                            # )
                             print(
                                 f'querying all records for table: {conn.execute(f"select * from {table_name}").fetchall()}'
                             )
                             r = conn.execute("""
                             SELECT * FROM sqlite_master WHERE type='table' and name = 'test_on_demand_python_transformation_python_stored_writes_feature_view';
                                 """)
+                            print(f"table exists: {r.fetchall()}")
                 if progress:
                     progress(1)
 
