res_count = conn.execute(""" select count(*) from parquet_scan('s3:///*.parquet'); """).df() res_count