This is an automated email from the ASF dual-hosted git repository. kabhwan pushed a commit to branch WIP-python-data-source-admission-control-trigger-availablenow-change-the-method-signature in repository https://gitbox.apache.org/repos/asf/spark.git
commit c54de00f002b1d2cc327ea68d2148a43161cfc36 Author: Jungtaek Lim <[email protected]> AuthorDate: Thu Jan 22 08:10:32 2026 +0900 fix --- python/pyspark/sql/streaming/python_streaming_source_runner.py | 1 - 1 file changed, 1 deletion(-) diff --git a/python/pyspark/sql/streaming/python_streaming_source_runner.py b/python/pyspark/sql/streaming/python_streaming_source_runner.py index 83f955f06cd7..c6391bceffd3 100644 --- a/python/pyspark/sql/streaming/python_streaming_source_runner.py +++ b/python/pyspark/sql/streaming/python_streaming_source_runner.py @@ -145,7 +145,6 @@ def check_support_func(reader: DataSourceStreamReader, outfile: IO) -> None: if isinstance(reader, _SimpleStreamReaderWrapper): # We consider the method of `read` in simple_reader to already have admission control # into it. - support_flags |= SUPPORTS_TRIGGER_AVAILABLE_NOW if isinstance(reader.simple_reader, SupportsTriggerAvailableNow): support_flags |= SUPPORTS_TRIGGER_AVAILABLE_NOW else: --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
