async def _execute(self, data: Dict[str, Any]) -> Tuple[str, str]:
        """
        Internal implementation of execute with no retry logic.

        Args:
            data: Dictionary containing execution data

        Returns:
            Tuple of (score, feedback)

        Raises:
            Exception: If execution fails
        """
        instance = None

        # Set timeouts to ensure we don't block indefinitely
        # INSTANCE_TIMEOUT = 300  # 5 minutes for instance operations
        TOTAL_EXECUTION_TIMEOUT = 600  # 10 minutes total execution time

        with tempfile.TemporaryDirectory(prefix="morph_exec_") as temp_dir:
            snapshot = await self._get_or_create_base_snapshot()
            instance = await self.client.instances.astart(
                snapshot.id, ttl_seconds=600
            )  # Auto-terminate after 10 minutes

            async with instance:
                # Use asyncio.wait_for to add overall timeout to the execution process
                return await asyncio.wait_for(
                    self._execute_with_instance(instance, data, temp_dir),
                    timeout=TOTAL_EXECUTION_TIMEOUT,
                )

        Internal implementation of execute with no retry logic.

        Args:
            data: Dictionary containing execution data

        Returns:
            Tuple of (score, feedback)

        Raises:
            Exception: If execution fails
        
src/open_r1/utils/competitive_programming/morph_client.py