cancel_futures in shutdown() only available in python >=3.9.0

mattdeekay · mattdeekay · commit 99dfe8e2ef34 · 2023-07-03T12:50:15.000-07:00
Signed-off-by: Matthew Kim &lt;11141331+mattdeekay@users.noreply.github.com&gt;
diff --git a/pyproject.toml b/pyproject.toml
@@ -26,6 +26,7 @@ numpy = [
 sqlalchemy = "^1.3.24"
 openpyxl = "^3.0.10"
 alembic = "^1.0.11"
+concurrent = ">=3.9.0"
 
 [tool.poetry.dev-dependencies]
 pytest = "^7.1.2"
diff --git a/src/databricks/sql/cloudfetch/download_manager.py b/src/databricks/sql/cloudfetch/download_manager.py
@@ -161,6 +161,6 @@ def _check_if_download_successful(self, handler: ResultSetDownloadHandler):
         return True
 
     def _shutdown_manager(self):
-        # Clear download handlers and shutdown the thread pool to cancel pending futures
+        # Clear download handlers and shutdown the thread pool
         self.download_handlers = []
         self.thread_pool.shutdown(wait=False, cancel_futures=True)
