Использование фрагментов Vec в задаче tokio приводит к запутанным ошибкам

У меня есть фрейм данных Polars, который я обработал в Vec столбчатых данных типа Option<&str>. Я хочу отправить это в базу данных, но там десятки тысяч строк, и я получаю предупреждения SQL о «длинной транзакции». Чтобы решить эту проблему, я хочу распределить работу по нескольким соединениям с БД. Итак, я создал tokio::JoinSet и создал кучу задач для выполнения SQL-запросов. Чтобы отслеживать индексы в каждом фрагменте, я использую очень удобный контейнер paginate.

Я последовал этому ответу, чтобы попытаться заставить это работать, в котором рекомендуется заключить мои Vec в Arc, поскольку мне не нужно изменять данные. К сожалению, мне пока это не удалось.

Обновление Я создал CodeSandbox, показывающий проблему, с которой столкнулся.

Обновление 2. Я полностью выровнял код в этом вопросе, сообщения об ошибках и CodeSandbox. Все еще ищу ответ на ошибку №1.

use anyhow::Result;
use paginate::{Page, Pages};
use polars::prelude::*;
use rand::Rng;
use std::sync::Arc;
use tokio::task::JoinSet;
const CONNECTION_COUNT: usize = 14;

#[tokio::main]
async fn main() -> Result<()> {
    let mut rng = rand::thread_rng();
    let values: Vec<String> = (0..76_000)
        .map(|_| rng.gen_range(0..1000).to_string())
        .collect();
    let rand_df = df!("A" => values).unwrap();

    load_resources("NUMS", &rand_df);

    Ok(())
}

async fn load_resources(source_str: &str, in_df: &DataFrame) -> Result<()> {
    let merged_df = in_df.clone();

    // Error #1 is here ↴ -- see below
    let ids: Arc<Vec<_>> = Arc::new(merged_df.column("A")?.str()?.iter().collect());

    let count = in_df.shape().0;
    let pages = Pages::new(count, 5_000);
    let mut join_set = JoinSet::new();
    let mut results = Vec::new();

    for page in pages.into_iter() {
        join_set.spawn(async move {
            insert_resources(
                source_str,
                page,
                ids.clone(), // Error #2, see below
            )
            .await
        });

        if join_set.len() >= CONNECTION_COUNT {
            if let Some(result) = join_set.join_next().await {
                results.push(result.unwrap());
            }
        }
    }

    // Await the completion of all tasks
    while let Some(result) = join_set.join_next().await {
        results.push(result.unwrap());
    }

    Ok(())
}

async fn insert_resources(
    source_str: &str, // Error #3, see below
    page: Page,
    ids: Arc<Vec<Option<&str>>>,
) -> Result<()> {
    println!("source: {} page: {:?} names: {:?}", source_str, page, ids);

    Ok(())
}

Ошибки по-прежнему говорят о том, что мое заимствованное значение не живет достаточно долго, несмотря на то, что я клонирую DataFrame (после того, как завернул его в Arc).

1. merged_df живет недостаточно долго

error[E0597]: `merged_df` does not live long enough
  --> src/main.rs:26:37
   |
23 |     let merged_df = in_df.clone();
   |         --------- binding `merged_df` declared here
...
26 |     let ids: Arc<Vec<_>> = Arc::new(merged_df.column("A")?.str()?.iter().co...
   |                                     ^^^^^^^^^---------------------------
   |                                     |
   |                                     borrowed value does not live long enough
   |                                     argument requires that `merged_df` is borrowed for `'static`
...
56 | }
   | - `merged_df` dropped here while still borrowed

2. использование перемещенного значения: names. И что за странное предложение поставить .clone() после блока async move?? Я попробовал, и он не компилируется.

error[E0382]: use of moved value: `ids`
  --> src/main.rs:34:24
   |
26 |       let ids: Arc<Vec<_>> = Arc::new(merged_df.column("A")?.str()?.iter...
   |           --- move occurs because `ids` has type `Arc<Vec<Option<&str>>>`, which does not implement the `Copy` trait
...
33 |       for page in pages.into_iter() {
   |       ----------------------------- inside of this loop
34 |           join_set.spawn(async move {
   |  ________________________^
35 | |             insert_resources(
36 | |                 source_str,
37 | |                 page,
38 | |                 ids.clone(), // Error #2, see below
   | |                 --- use occurs due to use in coroutine
39 | |             )
40 | |             .await
41 | |         });
   | |_________^ value moved here, in previous iteration of loop
   |
help: clone the value to increment its reference count
   |
41 |         }.clone());
   |          ++++++++

3. заимствованные данные выходят за пределы функции

error[E0521]: borrowed data escapes outside of function
  --> src/main.rs:34:9
   |
22 |   async fn load_resources(source_str: &str, in_df: &DataFrame) -> Result...
   |                           ----------  - let's call the lifetime of this reference `'1`
   |                           |
   |                           `source_str` is a reference that is only valid in the function body
...
34 | /         join_set.spawn(async move {
35 | |             insert_resources(
36 | |                 source_str,
37 | |                 page,
...  |
40 | |             .await
41 | |         });
   | |          ^
   | |          |
   | |__________`source_str` escapes the function body here
   |            argument requires that `'1` must outlive `'static`

Как правильно это сделать?