fix: loadbalance right method

jina/serve/runtimes/gateway/request_handling.py

@@ -1,6 +1,8 @@
 import itertools
 from typing import TYPE_CHECKING, AsyncIterator, Dict
 
+from aiohttp.client import _RequestContextManager
+
 from jina.enums import ProtocolType
 from jina.helper import get_full_version
 from jina.proto import jina_pb2
@@ -157,18 +159,19 @@ async def _load_balance(self, request):
         try:
             async with aiohttp.ClientSession() as session:
 
-                if request.method == 'GET':
-                    request_kwargs = {}
-                    try:
-                        payload = await request.json()
-                        if payload:
-                            request_kwargs['json'] = payload
-                    except Exception:
-                        self.logger.debug('No JSON payload found in request')
-
-                    async with session.get(
-                        url=target_url, **request_kwargs
-                    ) as response:
+                request_kwargs = {}
+                try:
+                    payload = await request.json()
+                    if payload:
+                        request_kwargs['json'] = payload
+                except Exception:
+                    self.logger.debug('No JSON payload found in request')
+
+                async with _RequestContextManager(
+                    session._request(request.method, target_url, **request_kwargs)
+                ) as response:
+                    if request.content_type.endswith('stream'):
+
                         # Create a StreamResponse with the same headers and status as the target response
                         stream_response = web.StreamResponse(
                             status=response.status,
@@ -185,14 +188,7 @@ async def _load_balance(self, request):
                         # Close the stream response once all chunks are sent
                         await stream_response.write_eof()
                         return stream_response
-
-                elif request.method == 'POST':
-                    d = await request.read()
-                    import json
-
-                    async with session.post(
-                        url=target_url, json=json.loads(d.decode())
-                    ) as response:
+                    else:
                         content = await response.read()
                         return web.Response(
                             body=content,