We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 92821e7 commit 63deb04Copy full SHA for 63deb04
1 file changed
src/databricks/sql/cloudfetch/download_manager.py
@@ -48,7 +48,7 @@ def __init__(
48
session_id_hex: Optional[str],
49
statement_id: str,
50
chunk_id: int,
51
- expiry_callback: Optional[Callable[[TSparkArrowResultLink], None]] = None,
+ expiry_callback: Callable[[TSparkArrowResultLink], None],
52
):
53
self._pending_links: List[Tuple[int, TSparkArrowResultLink]] = []
54
self.chunk_id = chunk_id
@@ -141,7 +141,7 @@ def to_cancel(link: TSparkArrowResultLink) -> bool:
141
self._download_tasks = tasks_to_keep
142
143
pending_links_to_keep = [
144
- link for link in self._pending_links if not to_cancel(link)
+ link for link in self._pending_links if not to_cancel(link[1])
145
]
146
self._pending_links = pending_links_to_keep
147
logger.info(
0 commit comments