Method __call__

src/environment/context.py:1404–1449

Call an environment action Args: name: Name of the environment action: Name of the action input: Input for the action Returns: Action result

(self, 
                       name: str, 
                       action: str, 
                       input: Dict[str, Any], 
                       ctx: SessionContext = None,
                       **kwargs)

            logger.error(f"| ❌ Error during environment context manager cleanup: {e}")
            
    async def __call__(self, 
                       name: str, 
                       action: str, 
                       input: Dict[str, Any], 
                       ctx: SessionContext = None,
                       **kwargs) -> Any:
        """Call an environment action
        
        Args:
            name: Name of the environment
            action: Name of the action
            input: Input for the action
            
        Returns:
            Action result
        """
        if ctx is None:
            ctx = SessionContext()
        
        if name in self._environment_configs:
            env_config = self._environment_configs[name]
            
            version = env_config.version
            env_instance = env_config.instance
            logger.info(f"| ✅ Using environment {name}@{version}")
            
            action_config = env_config.actions.get(action)
            if action_config is None:
                raise ValueError(f"Action {action} not found in environment {name}")
            action_function = action_config.function
            
            # Environment args
            env_args = {
                "ctx": ctx,
            }
            
            # Check if action_function is a bound method (already has self bound)
            # Bound methods have __self__ attribute, unbound methods don't
            if hasattr(action_function, '__self__'):
                # Bound method: call directly without passing instance
                return await action_function(**input, **env_args)
            else:
                # Unbound method: pass instance as first argument
                return await action_function(env_instance, **input, **env_args)
        else:
            raise ValueError(f"Environment {name} not found")