diff --git a/odc/stats/proc.py b/odc/stats/proc.py index 4749846..deceb18 100644 --- a/odc/stats/proc.py +++ b/odc/stats/proc.py @@ -327,6 +327,10 @@ def run( ) raise ValueError("Must supply one of tasks= or sqs=") + def __del__(self): + if self.client(): + self.client().close() + def get_max_mem() -> int: """