refac: filters

This commit is contained in:
星海 2025-03-05 13:05:14 +08:00
parent 8ce6c8cf78
commit 3ee1ae8c95

View File

@ -52,7 +52,7 @@ async def process_filter_functions(
# Prepare handler function
handler = getattr(function_module, filter_type, None)
if not handler:
continue
continue
# Check if the function has a file_handler variable
if filter_type == "inlet" and hasattr(function_module, "file_handler"):