File tree Expand file tree Collapse file tree 5 files changed +2
-740
lines changed
src/flight_sql_websocket_proxy Expand file tree Collapse file tree 5 files changed +2
-740
lines changed Original file line number Diff line number Diff line change @@ -29,7 +29,7 @@ dependencies = [
2929 " click==8.2.*" ,
3030 " codetiming==1.4.*" ,
3131 " munch==4.0.*" ,
32- " adbc-driver-flightsql==1.6 .*" ,
32+ " adbc-driver-flightsql==1.7 .*" ,
3333 " pyarrow==20.0.*" ,
3434 " python-dateutil==2.9.*" ,
3535 " pytz==2025.*" ,
@@ -45,8 +45,7 @@ requires-python = ">=3.12"
4545[project .optional-dependencies ]
4646dev = [" bumpver" , " pip-tools" , " pytest" ]
4747client = [
48- " pandas==2.2.*" ,
49- " pglast==7.3.*"
48+ " pandas==2.3.*"
5049]
5150
5251[project .urls ]
Original file line number Diff line number Diff line change 1414import click
1515import pandas as pd
1616from munch import munchify
17- from pglast import parser
1817from websockets .exceptions import ConnectionClosed
1918from websockets .frames import Close
2019from websockets .legacy .client import connect
@@ -109,15 +108,6 @@ def print_over_input(string: str) -> None:
109108 sys .stdout .flush ()
110109
111110
112- async def is_sql_command (message : str ) -> bool :
113- try :
114- tree = parser .parse_sql_json (message )
115- except Exception as exc :
116- return False
117- else :
118- return True
119-
120-
121111async def _run_client (
122112 server_protocol : str ,
123113 server_hostname : str ,
You can’t perform that action at this time.
0 commit comments