vtk9 opened a new issue, #38359:
URL: https://github.com/apache/arrow/issues/38359

   ### Describe the bug, including details regarding any error messages, 
version, and platform.
   
   ### Warning message
   
   ```
   
/Users/voltrondata/github-actions-runner/_work/crossbow/crossbow/arrow/cpp/src/arrow/status.cc:152:
 Invalid: Signal stop source already set up
   ```
   
   Pyarrow 13.0.0 on MacOS.
   
   ```
   $ pip3 list
   Package    Version
   ---------- -------
   numpy      1.26.0
   pip        23.2.1
   pyarrow    13.0.0
   setuptools 68.2.0
   wheel      0.41.2
   ```
   
   Was able to reproduce with the [example 
server](https://github.com/apache/arrow/blob/main/python/examples/flight/server.py)
 by adding some CSV data using the client. Then I used a different client 
(below) 
   Can you help me understand if this is a bug or misuse of the api? Thank you!
   
   
   
   ### No warning
   ```
   import pyarrow.flight as flight
   print("-- Working Start")
   client = flight.FlightClient('grpc://127.0.0.1:5005')
   ticket = next(client.list_flights()).endpoints[0].ticket
   reader = client.do_get(ticket)
   table = reader.read_all()
   ```
   
   ### Warning present (only difference is `list_flights()` is called outside 
of `next(...)`)
   ```
   import pyarrow.flight as flight
   print("-- Not working, list_flights -> next ")
   client = flight.FlightClient('grpc://127.0.0.1:5005')
   flights = client.list_flights()
   ticket = next(flights).endpoints[0].ticket
   reader = client.do_get(ticket)
   table = reader.read_all()
   ```
   
   ### Warning present (consuming all endpoints in all the flights)
   ```
   import pyarrow.flight as flight
   print("-- Not working, for loop list_flights -> do_get ")
   client = flight.FlightClient('grpc://127.0.0.1:5005')
   
   for f in client.list_flights():
       endpoint = f.endpoints
       for endpoint in endpoint:
           ticket = endpoint.ticket
           flightStreamReader = client.do_get(ticket)
           table = flightStreamReader.read_all()
   
   ```
   
   
   ### Component(s)
   
   FlightRPC, Python


-- 
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]

Reply via email to