Method _execute_with_timeout

orchestrator.py:171–210

Execute an action with a timeout to prevent hanging. Uses direct threading instead of ThreadPoolExecutor to avoid executor shutdown issues. Args: action_callable: Callable that executes the action timeout: Maximum execution time in seconds

(self, action_callable, timeout, action_name="unknown")

        return status
    
    def _execute_with_timeout(self, action_callable, timeout, action_name="unknown"):
        """
        Execute an action with a timeout to prevent hanging.
        Uses direct threading instead of ThreadPoolExecutor to avoid executor shutdown issues.
        
        Args:
            action_callable: Callable that executes the action
            timeout: Maximum execution time in seconds
            action_name: Name of the action for logging
            
        Returns:
            str: 'success', 'failed', or 'timeout'
        """
        result_container = {'result': None, 'exception': None, 'completed': False}
        
        def run_action():
            try:
                result_container['result'] = action_callable()
                result_container['completed'] = True
            except Exception as e:
                result_container['exception'] = e
                result_container['completed'] = True
        
        # Run action in separate thread
        action_thread = threading.Thread(target=run_action, name=f"Action_{action_name}")
        action_thread.daemon = True
        action_thread.start()
        
        # Wait for completion with timeout
        action_thread.join(timeout=timeout)
        
        if not result_container['completed']:
            logger.error(f"Action {action_name} timed out after {timeout} seconds")
            return 'timeout'
        
        if result_container['exception']:
            logger.error(f"Action {action_name} raised exception: {result_container['exception']}")
            return 'failed'
        
        return result_container['result'] if result_container['result'] else 'failed'

    def load_actions(self):
        """Load all actions from the actions file"""