ayushbansal07 commented on issue #46928:
URL: https://github.com/apache/arrow/issues/46928#issuecomment-3323678035
@pitrou I wanted to work on this next. I think it's quite clear what needs
to be done, but I am not very sure if there's a good way for me to test this
issue.
I tried to reproduce it by this sample code, but I never got the mentioned
error. Can you help me with testing strategy / reproducing the issue.
```python
import pyarrow.parquet as pq
import pyarrow.parquet as pq
import os, signal, threading, time
import pyarrow as pa
def spam_signals(pid):
time.sleep(1)
while True:
os.kill(pid, signal.SIGUSR1)
time.sleep(0.001)
threading.Thread(target=spam_signals, args=(os.getpid(),),
daemon=True).start()
signal.signal(signal.SIGUSR1, lambda *a: None)
print("Starting")
for i in range(10000):
try:
print("Reading")
pq.read_table("../dataset/flights-1m.parquet")
except InterruptedError as e:
print("Reproduced:", e)
break
```
--
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]
