From 827e909689d95153ae64fa0fa8046f9e5ef6e0fc Mon Sep 17 00:00:00 2001 From: Ehsan Totoni Date: Wed, 18 Dec 2024 19:57:25 -0500 Subject: [PATCH] Avoid logging in __del__ functions (#76) --- bodo/pandas/array_manager.py | 8 -------- bodo/pandas/arrow/array.py | 4 ---- bodo/pandas/managers.py | 8 -------- 3 files changed, 20 deletions(-) diff --git a/bodo/pandas/array_manager.py b/bodo/pandas/array_manager.py index 0a9266023c..62660a4e5e 100644 --- a/bodo/pandas/array_manager.py +++ b/bodo/pandas/array_manager.py @@ -261,10 +261,6 @@ def __del__(self): otherwise we do nothing because the data is already collected/deleted. """ if (r_id := self._md_result_id) is not None: - debug_msg( - self.logger, - f"[LazyArrayManager] Asking workers to delete result '{r_id}'", - ) assert self._del_func is not None self._del_func(r_id) self._del_func = None @@ -501,10 +497,6 @@ def __del__(self): otherwise we do nothing because the data is already collected/deleted. """ if (r_id := self._md_result_id) is not None: - debug_msg( - self.logger, - f"[LazySingleArrayManager] Asking workers to delete result '{r_id}'", - ) assert self._del_func is not None self._del_func(r_id) self._del_func = None diff --git a/bodo/pandas/arrow/array.py b/bodo/pandas/arrow/array.py index c5576240b8..b7f68321c8 100644 --- a/bodo/pandas/arrow/array.py +++ b/bodo/pandas/arrow/array.py @@ -128,10 +128,6 @@ def __del__(self): Delete the result from workers if it exists. """ if (r_id := self._md_result_id) is not None: - debug_msg( - self.logger, - f"[LazyArrowExtensionArray] Asking workers to delete result '{r_id}'", - ) assert self._del_func is not None self._del_func(r_id) self._del_func = None diff --git a/bodo/pandas/managers.py b/bodo/pandas/managers.py index d3668a9dc4..1d794a4e8a 100644 --- a/bodo/pandas/managers.py +++ b/bodo/pandas/managers.py @@ -244,10 +244,6 @@ def __del__(self): Delete the result from the workers if it hasn't been collected yet. """ if (r_id := self._md_result_id) is not None: - debug_msg( - self.logger, - f"[LazyBlockManager] Asking workers to delete result '{r_id}'", - ) assert self._del_func is not None self._del_func(r_id) self._del_func = None @@ -437,10 +433,6 @@ def __del__(self): Delete the result from the workers if it hasn't been collected yet. """ if (r_id := self._md_result_id) is not None: - debug_msg( - self.logger, - f"[LazySingleBlockManager] Asking workers to delete result '{r_id}'", - ) assert self._del_func is not None self._del_func(r_id) self._del_func = None