Skip to content

Commit feb387a

Browse files
acquite lock before notifying
Signed-off-by: varun-edachali-dbx <varun.edachali@databricks.com>
1 parent 4b0f483 commit feb387a

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/databricks/sql/backend/sea/queue.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -277,7 +277,8 @@ def _worker_loop(self):
277277
if not links_downloaded:
278278
self._shutdown_event.set()
279279
logger.debug("LinkFetcher[%s]: worker thread exiting", self._statement_id)
280-
self._link_data_update.notify_all()
280+
with self._link_data_update:
281+
self._link_data_update.notify_all()
281282

282283
def start(self):
283284
"""Spawn the worker thread."""

0 commit comments

Comments
 (0)