Skip to content

Commit 4b03d04

Browse files
Merge branch 'main' into improve-read-sql-query-docs
2 parents 549c614 + 433bbae commit 4b03d04

File tree

2 files changed

+34
-33
lines changed

2 files changed

+34
-33
lines changed

awswrangler/athena/_cache.py

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -73,9 +73,10 @@ def sorted_successful_generator(self) -> list["QueryExecutionTypeDef"]:
7373
Returns successful DDL and DML queries sorted by query completion time.
7474
"""
7575
filtered: list["QueryExecutionTypeDef"] = []
76-
for query in self._cache.values():
77-
if (query["Status"].get("State") == "SUCCEEDED") and (query.get("StatementType") in ["DDL", "DML"]):
78-
filtered.append(query)
76+
with self._lock:
77+
for query in self._cache.values():
78+
if (query["Status"].get("State") == "SUCCEEDED") and (query.get("StatementType") in ["DDL", "DML"]):
79+
filtered.append(query)
7980
return sorted(filtered, key=lambda e: str(e["Status"]["CompletionDateTime"]), reverse=True)
8081

8182
def __contains__(self, key: str) -> bool:

poetry.lock

Lines changed: 30 additions & 30 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)