codeant-ai-for-open-source[bot] commented on code in PR #43759:
URL: https://github.com/apache/superset/pull/43759#discussion_r4107580342


##########
superset/datasets/schemas.py:
##########
@@ -516,6 +516,24 @@ class GetOrCreateDatasetSchema(Schema):
     always_filter_main_dttm = fields.Boolean(load_default=False)
 
 
+class PartitionMappingPreviewSchema(Schema):
+    """Payload for the dataset editor's partition mapping preview panel."""
+
+    mapped_column = fields.String(
+        required=True,
+        metadata={"description": "Column whose filters would be mirrored"},
+    )
+    value_transform = fields.String(
+        required=True,
+        allow_none=True,
+        metadata={"description": "SQL expression containing a :value 
placeholder"},
+    )
+    sample_value = fields.String(
+        required=True,
+        metadata={"description": "Value to evaluate the transform at"},
+    )

Review Comment:
   ✅ **CodeAnt verified this suggestion was addressed in subsequent commits and 
marked this thread resolved** as of `8ab5bba`.
   
   Added marshmallow length validators limiting `mapped_column` and 
`sample_value` to 250 characters and `value_transform` to 1024 characters.
   
   <sub>If that's not right, unresolve this thread and CodeAnt will leave it 
open.</sub>
   
   <!-- codeant-auto-resolve-reply -->



##########
superset/datasets/api.py:
##########
@@ -153,6 +161,31 @@
 )
 
 
+def _consume_preview_rate_limit(dataset_id: int) -> bool:
+    """
+    Fixed-window per-user, per-dataset throttle on the preview endpoint.
+
+    Debouncing on the client is a courtesy, not a guard: a held keydown, or a
+    handful of owners with the editor open, becomes sustained load on a
+    production cluster. Returns False once the window's budget is spent.
+    """
+    limit = app.config.get("PARTITION_TRANSFORM_PREVIEW_RATE_LIMIT", 30)
+    if not limit:
+        return True
+
+    user_id = get_user_id() or 0
+    key = f"partition_mapping_preview:{user_id}:{dataset_id}"
+    try:
+        used = cache_manager.cache.get(key) or 0
+        if used >= limit:
+            return False
+        cache_manager.cache.set(key, used + 1, timeout=60)

Review Comment:
   ✅ **CodeAnt verified this suggestion was addressed in subsequent commits and 
marked this thread resolved** as of `8ab5bba`.
   
   Changed rate-limit initialization to use `backend.add` with the 60-second 
timeout only for the first request, followed by `backend.inc` without resetting 
the TTL.
   
   <sub>If that's not right, unresolve this thread and CodeAnt will leave it 
open.</sub>
   
   <!-- codeant-auto-resolve-reply -->



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to