failing without cxonnection close

Author: bgrieder

src/module-api/src/kmip_post.py

@@ -1,4 +1,3 @@
-import json
 import requests
 from client_configuration import ClientConfiguration
 
@@ -24,11 +23,9 @@ def kmip_post(
     # see this for user facing the same issue:
     # https://snowflake.discourse.group/t/i-have-a-stored-procedure-that-utilizes-a-network-access-rules-to-make-external-calls-that-was-working-flawlessly-for-months-and-without-any-change-in-the-code-im-getting-oserror-errno-99-cannot-assign-requested-address-why/4642
     kms_server_url = configuration.kms_server_url + "/kmip/2_1"
-    # headers = {
-    #     "Content-Type": "application/json",
-    #     "Connection": "close",
-    # }
-    headers = {}
+    headers = {
+        # "Connection": "close",
+    }
 
     if configuration.kms_access_token is not None:
         headers["Authorization"] = "Bearer " + configuration.kms_access_token

src/module-api/src/op_decrypt.py

@@ -95,7 +95,7 @@ def decrypt(df: pd.DataFrame, algorithm: Algorithm, configuration: ClientConfigu
     series = pd.Series(plaintexts)
     t_parse_decrypt_response_payload = time.perf_counter() - t_start
 
-    logger.debug(
+    logger.info(
         f"decrypt: {algorithm}, size: {len(plaintexts)}, POST: {t_post_operations * 1000000 / len(ciphertexts):.3f} µs/c" +
         f" Overhead: {(t_prepare_requests + t_parse_decrypt_response_payload) * 1000000 / len(ciphertexts):.3f} µs/c",
         extra={"thread_id": threading.get_ident()}

src/module-api/src/op_encrypt.py

@@ -88,7 +88,7 @@ def encrypt(df: pd.DataFrame, algorithm: Algorithm, configuration: ClientConfigu
     series = pd.Series(ciphertexts)
     t_parse_encrypt_response_payload = time.perf_counter() - t_start
 
-    logger.debug(
+    logger.info(
         f"encrypt: {algorithm}, size: {len(plaintexts)}, POST: {t_post_operations * 1000000 / len(ciphertexts):.3f} µs/c" +
         f" Overhead: {(t_prepare_requests + t_parse_encrypt_response_payload) * 1000000 / len(ciphertexts):.3f} µs/c",
         extra={"thread_id": threading.get_ident()}