(args, client, connection_args={})
| 64 | |
| 65 | |
| 66 | def do_action(args, client, connection_args={}): |
| 67 | try: |
| 68 | buf = pyarrow.allocate_buffer(0) |
| 69 | action = pyarrow.flight.Action(args.action_type, buf) |
| 70 | print('Running action', args.action_type) |
| 71 | for result in client.do_action(action): |
| 72 | print("Got result", result.body.to_pybytes()) |
| 73 | except pyarrow.lib.ArrowIOError as e: |
| 74 | print("Error calling action:", e) |
| 75 | |
| 76 | |
| 77 | def push_data(args, client, connection_args={}): |