Function run_packed_import 

async fn run_packed_import<F, Fut>(worker: F) -> Result<Output>
where
    F: FnOnce(CancellationToken) -> Fut,
    Fut: Future<Output = Result<Output>> + Send + 'static,