CalvinBackup/fuzzforge_ai
1
0
Fork 0
mirror of https://github.com/FuzzingLabs/fuzzforge_ai.git synced 2026-07-10 00:58:35 +02:00
Code Issues Packages Projects Releases Wiki Activity

fix: Filter metadata-only parameters from workflow arguments

Browse Source 
SecurityAssessmentWorkflow was receiving 7 arguments instead of 2-5.
The issue was that target_path and volume_mode from default_parameters
were being passed to the workflow, when they should only be used by
the system for configuration.

Now filters out metadata-only parameters (target_path, volume_mode)
before passing arguments to workflow execution.
This commit is contained in:
Tanguy Duhamel
2025-10-02 11:49:14 +02:00
parent 3d45b99ee8
commit 43d3eae1db
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/src/temporal/manager.py
+7 -3
View File
@@ -186,13 +186,17 @@ class TemporalManager:
# The workflow parameters are passed as individual positional args # The workflow parameters are passed as individual positional args
workflow_args = [target_id] workflow_args = [target_id]
# Filter out metadata-only parameters (target_path, volume_mode)
# These are used by the system but NOT passed to the workflow
metadata_only_params = {"target_path", "volume_mode"}
# Add parameters in order based on workflow signature # Add parameters in order based on workflow signature
# For security_assessment: scanner_config, analyzer_config, reporter_config # For security_assessment: scanner_config, analyzer_config, reporter_config
# For atheris_fuzzing: target_file, max_iterations, timeout_seconds # For atheris_fuzzing: target_file, max_iterations, timeout_seconds
# Parameters come from metadata.yaml's default_parameters merged with user params
if workflow_params: if workflow_params:
# Add all parameter values as positional args # Only add parameters that are NOT metadata-only
workflow_args.extend(workflow_params.values()) filtered_params = {k: v for k, v in workflow_params.items() if k not in metadata_only_params}
workflow_args.extend(filtered_params.values())
# Determine task queue from workflow vertical # Determine task queue from workflow vertical
vertical = workflow_info.metadata.get("vertical", "default") vertical = workflow_info.metadata.get("vertical", "default")