From 2098c76f99768d17c56d920ee465512747863b1b Mon Sep 17 00:00:00 2001 From: Ruifeng Zheng Date: Wed, 20 Mar 2024 18:28:50 +0900 Subject: [PATCH] [SPARK-41625][PYTHON][CONNECT][TESTS] Enable doctest `pyspark.sql.connect.dataframe.DataFrame.isStreaming` ### What changes were proposed in this pull request? Enable doctest `pyspark.sql.connect.dataframe.DataFrame.isStreaming` ### Why are the changes needed? for test coverage the related functions like `readStream` were already implemented ### Does this PR introduce _any_ user-facing change? no, test-only ### How was this patch tested? ci ### Was this patch authored or co-authored using generative AI tooling? no Closes #45603 from zhengruifeng/enable_stream_doctest. Authored-by: Ruifeng Zheng Signed-off-by: Hyukjin Kwon --- python/pyspark/sql/connect/dataframe.py | 3 --- 1 file changed, 3 deletions(-) diff --git a/python/pyspark/sql/connect/dataframe.py b/python/pyspark/sql/connect/dataframe.py index f300774b6e57f..7171bee24bd77 100644 --- a/python/pyspark/sql/connect/dataframe.py +++ b/python/pyspark/sql/connect/dataframe.py @@ -2243,9 +2243,6 @@ def _test() -> None: globs = pyspark.sql.connect.dataframe.__dict__.copy() - # TODO(SPARK-41625): Support Structured Streaming - del pyspark.sql.connect.dataframe.DataFrame.isStreaming.__doc__ - # TODO(SPARK-41888): Support StreamingQueryListener for DataFrame.observe del pyspark.sql.connect.dataframe.DataFrame.observe.__doc__