We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9ce0803 commit d04b983Copy full SHA for d04b983
src/databricks/sql/backend/sea/queue.py
@@ -130,7 +130,8 @@ def __init__(
130
self._map_lock = threading.Lock()
131
self.chunk_index_to_link: Dict[int, "ExternalLink"] = {}
132
133
- def _set_current_chunk_link(self, link: "ExternalLink"):
+ def _set_current_chunk_link(self):
134
+ link = self._current_chunk_link
135
with self._map_lock:
136
self.chunk_index_to_link[link.chunk_index] = link
137
0 commit comments