nuno-faria commented on PR #1311: URL: https://github.com/apache/datafusion-python/pull/1311#issuecomment-3587174289
I checked and in the previous version the `reader.read_all()` method in the `test_arrow_c_stream_interrupted` never has a chance to call the `check_signals` method. It executes `PartitionedDataFrameStreamReader::next`, which in turn calls `poll_next_batch`, which immediately returns the result, so the `tokio::select!` exits right away. In the new `datafusion` version a batch is never generated. But it is still odd that manually sending an interrupt with CTRL-C works but using `PyThreadState_SetAsyncExc` does not. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
