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

Fix DogExecutor to use new process() API instead of effect_dog()

Browse Source 
The dog effect was updated to use process() but DogExecutor
was still importing the old effect_dog() function.

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
gilesb
2026-01-13 02:05:15 +00:00
parent be4d0da84f
commit f28edf7ab6
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
legacy_tasks.py
View File

@@ -88,10 +88,10 @@ class DogExecutor(Executor):
"""Executor for the dog effect.""" """Executor for the dog effect."""
def execute(self, config: Dict, inputs: List[Path], output_path: Path) -> Path: def execute(self, config: Dict, inputs: List[Path], output_path: Path) -> Path:
from effect import effect_dog from effect import process as dog_process
if len(inputs) != 1: if len(inputs) != 1:
raise ValueError(f"Dog effect expects 1 input, got {len(inputs)}") raise ValueError(f"Dog effect expects 1 input, got {len(inputs)}")
return effect_dog(inputs[0], output_path, config) return dog_process(inputs, output_path, config, None)
@register_executor("effect:identity") @register_executor("effect:identity")