diff --git a/legacy_tasks.py b/legacy_tasks.py index 17dabcd..58dc3fa 100644 --- a/legacy_tasks.py +++ b/legacy_tasks.py @@ -914,11 +914,13 @@ def execute_recipe(self, recipe_sexp: str, input_hashes: Dict[str, str], run_id: if not effect_name: raise ValueError(f"EFFECT node missing 'effect' in config: {step.config}") - # Try specific executor first (e.g., effect:dog, effect:identity) + # Try specific executor first (e.g., effect:dog) executor = get_executor(f"effect:{effect_name}") + logger.info(f"EFFECT: get_executor('effect:{effect_name}') = {executor}") if not executor: # Fall back to generic EFFECT executor (handles IPFS effects) executor = get_executor("EFFECT") + logger.info(f"EFFECT: Fallback get_executor('EFFECT') = {executor}") if not executor: raise ValueError(f"No executor for effect: {effect_name}")