What is the correct way to pass in a connection pool to tokio threads?

[RohanKapurDEV]

I have the following code below. It's really basic and self-explanatory. My main issue is that I am not entirely sure how to pass in the MySql connection pool to the tokio::spawn in the loop. My conceptual understanding of the issue (which might be flawed on it's own) is that I'm moveing the connection pool into the thread on one iteration of the loop, which means future iterations cannot access that value to pass it in the calculate_refreshed_obligation function to begin with.

#[tokio::main]
async fn main() {
    dotenv().ok();
    let database_url = env::var("DATABASE_URL").expect("DATABASE_URL must be set");

    let conn_pool = MySqlPoolOptions::new()
        .max_connections(50)
        .connect(&database_url)
        .await
        .expect("Failed to create pool");

    loop {
        println!("| Fetching obligations from database");

        let mut rows = sqlx::query("SELECT * FROM obligation").fetch(&conn_pool);

        while let Some(row) = rows.try_next().await.unwrap() {
            let obligation_pubkey: &str = row.try_get("pubkey").unwrap();
            let obligation_data: &str = row.try_get("data").unwrap();

            let data_buffer = base64::decode(obligation_data).unwrap();
            let obligation = Obligation::unpack_from_slice(&data_buffer).unwrap();

            println!(
                "Obligation {} found with {} borrows",
                obligation_pubkey,
                obligation.borrows.len()
            );
            
            // This is illegal
            tokio::spawn(async move {
                calculate_refreshed_obligation(&obligation, &conn_pool).await;
            });

        }
    }
}

Any help would be much appreciated