art-dag/celery
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add debug logging for effect executor lookup

Browse Source 
Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
gilesb
2026-01-13 03:11:33 +00:00
parent c3d6427883
commit c5d70f61c8
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
legacy_tasks.py
View File

@@ -914,11 +914,13 @@ def execute_recipe(self, recipe_sexp: str, input_hashes: Dict[str, str], run_id:
if not effect_name: if not effect_name:
raise ValueError(f"EFFECT node missing 'effect' in config: {step.config}") 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}") executor = get_executor(f"effect:{effect_name}")
logger.info(f"EFFECT: get_executor('effect:{effect_name}') = {executor}")
if not executor: if not executor:
# Fall back to generic EFFECT executor (handles IPFS effects) # Fall back to generic EFFECT executor (handles IPFS effects)
executor = get_executor("EFFECT") executor = get_executor("EFFECT")
logger.info(f"EFFECT: Fallback get_executor('EFFECT') = {executor}")
if not executor: if not executor:
raise ValueError(f"No executor for effect: {effect_name}") raise ValueError(f"No executor for effect: {effect_name}")