Skip to content

Commit 5371628

Browse files
Only shutdown combo once (finos#550)
Co-authored-by: sharpener6 <1sc2l4qi@duck.com>
1 parent a98a4d2 commit 5371628

1 file changed

Lines changed: 6 additions & 1 deletion

File tree

‎src/scaler/cluster/combo.py‎

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,6 +63,8 @@ def __init__(
6363
logging_level: str = DEFAULT_LOGGING_LEVEL,
6464
logging_config_file: Optional[str] = None,
6565
):
66+
self._shutdown_called = False
67+
6668
if address is None:
6769
self._address = ZMQConfig.from_string(f"tcp://127.0.0.1:{get_available_tcp_port()}")
6870
else:
@@ -134,9 +136,12 @@ def __init__(
134136
logging.info(f"{self.__get_prefix()} started")
135137

136138
def __del__(self):
137-
self.shutdown()
139+
if not self._shutdown_called:
140+
self.shutdown()
138141

139142
def shutdown(self):
143+
self._shutdown_called = True
144+
140145
logging.info(f"{self.__get_prefix()} shutdown")
141146
self._cluster.terminate()
142147
self._scheduler.terminate()

0 commit comments

Comments
 (0)