Update processor.py

processor.py

@@ -221,6 +221,15 @@ class DatasetCommandCenter:
 
     def _apply_projection(self, row, recipe):
         new_row = {}
+        
+        # 1. Prepare Execution Context for Python Mode
+        # This allows users to write: row['text'] OR just text
+        eval_context = row.copy()
+        eval_context['row'] = row  # <--- CRITICAL FIX: explicit 'row' variable
+        eval_context['json'] = json
+        import re
+        eval_context['re'] = re  # Allow regex usage
+        
         for col_def in recipe['columns']:
             t_type = col_def.get('type', 'simple')
             
@@ -242,23 +251,32 @@ class DatasetCommandCenter:
             elif t_type == 'python':
                 # Advanced Python Eval
                 try:
-                    context = row.copy()
-                    # We inject 'json' module into context for user scripts
-                    context['json'] = json 
-                    val = eval(col_def['expression'], {}, context)
+                    # Logic: eval("row['text'].upper()", globals, locals)
+                    val = eval(col_def['expression'], {}, eval_context)
                     new_row[col_def['name']] = val
-                except:
+                except Exception as e:
+                    # If it fails (e.g. key error on specific row), return None
                     new_row[col_def['name']] = None
                     
         return new_row
 
     def _passes_filter(self, row, filter_str):
-        if not filter_str: return True
+        if not filter_str or not filter_str.strip():
+            return True
         try:
+            # Fix context here as well so filters like "len(row['text']) > 5" work
             context = row.copy()
+            context['row'] = row
+            context['json'] = json
+            import re
+            context['re'] = re
+            
             return eval(filter_str, {}, context)
         except:
             return False
+        return new_row
+
+
 
             
     def _generate_card(self, source_id, target_id, recipe, license_name):