shutdown dask cluster gracefully

opendatacube · Nov 25, 2024 · 7fe2af4 · 7fe2af4
1 parent 50fdef1
commit 7fe2af4
Showing 1 changed file with 4 additions and 0 deletions.
diff --git 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:
     """