Skip to content

Commit b7afd8c

Browse files
Update
1 parent 0bee5a9 commit b7afd8c

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

src/snowflake/snowpark/session.py

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3462,11 +3462,14 @@ def query_history(self, include_describe: bool = False) -> QueryHistory:
34623462
Args:
34633463
include_describe: Include query notifications for describe queries
34643464
3465-
>>> with session.query_history() as query_history:
3465+
>>> with session.query_history(True) as query_history:
34663466
... df = session.create_dataframe([[1, 2], [3, 4]], schema=["a", "b"])
34673467
... df = df.filter(df.a == 1)
34683468
... res = df.collect()
3469-
>>> assert len(query_history.queries) == 1
3469+
>>> assert len(query_history.queries) == 2
3470+
>>> assert query_history.queries[0].is_describe
3471+
>>> assert query_history.queries[1].is_describe
3472+
>>> assert not query_history.queries[2].is_describe
34703473
"""
34713474
query_listener = QueryHistory(self, include_describe)
34723475
self._conn.add_query_listener(query_listener)

0 commit comments

Comments
 (0)