Method handle_manage_request

gunicorn/dirty/arbiter.py:697–789

Handle a worker management request. Supports adding or removing dirty workers via protocol messages. Args: message: Manage request message client_writer: StreamWriter to send response to client

(self, message, client_writer)

        await DirtyProtocol.write_message_async(client_writer, response)

    async def handle_manage_request(self, message, client_writer):
        """
        Handle a worker management request.

        Supports adding or removing dirty workers via protocol messages.

        Args:
            message: Manage request message
            client_writer: StreamWriter to send response to client
        """
        request_id = message.get("id", "unknown")
        op = message.get("op")
        count = max(1, int(message.get("count", 1)))

        try:
            if op == MANAGE_OP_ADD:
                # Add workers - only loads apps that need more workers
                spawned = 0
                for _ in range(count):
                    result = self.spawn_worker()
                    if result is not None:
                        self.num_workers += 1
                        spawned += 1
                    await asyncio.sleep(0.1)

                # Provide feedback about why no workers were spawned
                if spawned == 0:
                    result = {
                        "success": True,
                        "operation": "add",
                        "requested": count,
                        "spawned": 0,
                        "reason": "All apps have reached their worker limits",
                        "total_workers": len(self.workers),
                        "target_workers": self.num_workers,
                    }
                else:
                    result = {
                        "success": True,
                        "operation": "add",
                        "requested": count,
                        "spawned": spawned,
                        "total_workers": len(self.workers),
                        "target_workers": self.num_workers,
                    }

            elif op == MANAGE_OP_REMOVE:
                # Remove workers (similar to TTOU signal but via message)
                min_workers = self._get_minimum_workers()
                removed = 0

                for _ in range(count):
                    if self.num_workers <= min_workers:
                        break
                    if len(self.workers) <= 1:
                        break

                    self.num_workers -= 1