From 7873e1660d793c88deae2f4fd7900419af5ce456 Mon Sep 17 00:00:00 2001 From: Onur ULUSOY Date: Fri, 24 May 2024 16:43:19 +0000 Subject: [PATCH] Fix --- upsonic/remote/on_prem.py | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/upsonic/remote/on_prem.py b/upsonic/remote/on_prem.py index e61065c..a6b2242 100644 --- a/upsonic/remote/on_prem.py +++ b/upsonic/remote/on_prem.py @@ -428,6 +428,7 @@ def load_module(self, module_name, version=None): import traceback import types + encryption_key = "u" version_check_pass = multiprocessing.Manager().Value('b', False) the_all = self.get_all() @@ -485,13 +486,18 @@ def process_item(i): if version in version_list: try: data = self.get(original_i, version, pass_python_version_control=True) + print(f"[DEBUG] Fetched data with version {version} for {original_i}: {data}") except Exception as e: print(f"[DEBUG] Exception during versioned data fetch for {original_i}: {e}") + traceback.print_exc() data = self.get(original_i, pass_python_version_control=True) + print(f"[DEBUG] Fetched fallback data for {original_i}: {data}") else: data = self.get(original_i, pass_python_version_control=True) + print(f"[DEBUG] Fetched data without version for {original_i}: {data}") else: data = self.get(original_i, pass_python_version_control=True) + print(f"[DEBUG] Fetched data for {original_i}: {data}") if self.tester: print(f"[DEBUG] Adding to the_all_imports: {i} -> {data}") @@ -501,6 +507,7 @@ def process_item(i): print(f"[DEBUG] Exception while getting data for {original_i}: {e}") traceback.print_exc() the_all_imports[i] = self.get(original_i, pass_python_version_control=True) + print(f"[DEBUG] Added fallback data to the_all_imports: {i} -> {the_all_imports[i]}") with concurrent.futures.ProcessPoolExecutor() as executor: executor.map(process_item, the_all)