Function execute_sql_from_input_async 

async fn execute_sql_from_input_async(
    receiver: InputReceiver,
    schema: SchemaRef,
    table_name: &str,
    sql: &str,
) -> Result<Vec<RecordBatch>, ReadStatError>