Function execute_sql_and_write_from_input_async 

async fn execute_sql_and_write_from_input_async(
    receiver: InputReceiver,
    schema: SchemaRef,
    table_name: &str,
    sql: &str,
    config: &WriteConfig,
) -> Result<usize, ReadStatError>