Method execute

gunicorn/dirty/worker.py:450–500

Execute an action on a dirty app. The action runs in a thread pool executor to avoid blocking the asyncio event loop. Execution timeout is enforced using ``dirty_timeout`` config. Args: app_path: Import path of the dirty app action:

(self, app_path, action, args, kwargs)

            await gen.aclose()

    async def execute(self, app_path, action, args, kwargs):
        """
        Execute an action on a dirty app.

        The action runs in a thread pool executor to avoid blocking the
        asyncio event loop. Execution timeout is enforced using
        ``dirty_timeout`` config.

        Args:
            app_path: Import path of the dirty app
            action: Action name to execute
            args: Positional arguments
            kwargs: Keyword arguments

        Returns:
            Result from the app action

        Raises:
            DirtyAppNotFoundError: If app is not loaded
            DirtyTimeoutError: If execution exceeds timeout
            DirtyAppError: If execution fails
        """
        if app_path not in self.apps:
            raise DirtyAppNotFoundError(app_path)

        app = self.apps[app_path]
        timeout = self.cfg.dirty_timeout if self.cfg.dirty_timeout > 0 else None

        # Run the app call in the thread pool to avoid blocking
        # the event loop for CPU-bound operations
        loop = asyncio.get_running_loop()

        try:
            result = await asyncio.wait_for(
                loop.run_in_executor(
                    self._executor,
                    lambda: app(action, *args, **kwargs)
                ),
                timeout=timeout
            )
            return result
        except asyncio.TimeoutError:
            # Note: The thread continues running - we just stop waiting
            self.log.warning(
                "Execution timeout for %s.%s after %ds",
                app_path, action, timeout
            )
            raise DirtyTimeoutError(
                f"Execution of {app_path}.{action} timed out",
                timeout=timeout
            )

    def _cleanup(self):
        """Clean up resources on shutdown."""