modify connection bug in stream mode

heyingyue · heyingyue · commit e29dddda7b34 · 2024-01-04T09:45:06.000+08:00
diff --git a/kubesys/client.py b/kubesys/client.py
@@ -4,7 +4,7 @@
 import sys
 from typing import Union
 from kubesys.common import getLastIndex, dictToJsonString, jsonStringToBytes, getParams, formatURL
-from kubesys.http_request import createRequest
+from kubesys.http_request import createRequest,doCreateRequest
 from kubesys.analyzer import KubernetesAnalyzer
 import requests
 import json
@@ -253,7 +253,7 @@ def watchResourcesBase(self, kind, namespace, handlerFunction, thread_name=None,
 
     @staticmethod
     def watching(url, token, config, watchHandler, kwargs):
-        response=createRequest(url=formatURL(url, getParams(kwargs)), token=token, method="GET", keep_json=False, config=config,stream=True)[0]
+        response=doCreateRequest(url=formatURL(url, getParams(kwargs)), token=token, method="GET", config=config,stream=True)[0]
         for json_bytes in response.iter_lines():
             if len(json_bytes) < 1:
                 continue
diff --git a/kubesys/http_request.py b/kubesys/http_request.py
@@ -14,9 +14,9 @@
 
 
 def createRequest(url, token, method="GET", body=None, verify=False,
-                  keep_json=False, config=None,stream=False, **kwargs) -> Union[object, bool, str]:
+                  keep_json=False, config=None, **kwargs) -> Union[object, bool, str]:
     response, OK, status_code = doCreateRequest(
-        formatURL(url, getParams(kwargs)), token, method, body, config,stream)
+        formatURL(url, getParams(kwargs)), token, method, body, config)
 
     result = response.json()
     if keep_json:
