Merge pull request #11198 from xinhai-ai/refa_filters

chore: move the filter_type check earlier to avoid unnecessary valve reads.
This commit is contained in:
Timothy Jaeryang Baek 2025-03-04 21:27:36 -08:00 committed by GitHub
commit c9e2ba56c6
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

View File

@ -49,6 +49,11 @@ async def process_filter_functions(
function_module, _, _ = load_function_module_by_id(filter_id)
request.app.state.FUNCTIONS[filter_id] = function_module
# Prepare handler function
handler = getattr(function_module, filter_type, None)
if not handler:
continue
# Check if the function has a file_handler variable
if filter_type == "inlet" and hasattr(function_module, "file_handler"):
skip_files = function_module.file_handler
@ -60,10 +65,6 @@ async def process_filter_functions(
**(valves if valves else {})
)
# Prepare handler function
handler = getattr(function_module, filter_type, None)
if not handler:
continue
try:
# Prepare parameters