diff --git a/omagent-core/src/omagent_core/engine/worker/base.py b/omagent-core/src/omagent_core/engine/worker/base.py index e2869a0..c3e898b 100644 --- a/omagent-core/src/omagent_core/engine/worker/base.py +++ b/omagent-core/src/omagent_core/engine/worker/base.py @@ -78,7 +78,7 @@ def workflow_instance_id(self, value: str): self._workflow_instance_id = value @abstractmethod - def _run(self, workflow_instance_id, *args, **kwargs) -> Any: + def _run(self, *args, **kwargs) -> Any: """Run the Node.""" def execute(self, task: Task) -> TaskResult: