diff --git a/omagent-core/src/omagent_core/engine/automator/task_runner.py b/omagent-core/src/omagent_core/engine/automator/task_runner.py index 5a85330..311a55a 100644 --- a/omagent-core/src/omagent_core/engine/automator/task_runner.py +++ b/omagent-core/src/omagent_core/engine/automator/task_runner.py @@ -148,7 +148,7 @@ def __execute_task(self, task: Task) -> TaskResult: try: _input = workflow_client.get_workflow(task.workflow_instance_id).input if 'conversationInfo' in _input: - task.conversation_info = _input + task.conversation_info = _input.get('conversationInfo', {}) logging.info(f'conversation_info: {task.conversation_info}') conductor_log_handler = ConductorLogHandler(self.task_client)