let (repo_tx_in, repo_rx_in) = mpsc::unbounded_channel::<repo::MsgIn>();
    let (repo_tx_out, repo_rx_out) = mpsc::unbounded_channel::<repo::MsgOut>();
    let repo_path_clone = repo_path.clone();
    let repo_task = Task::future(async move {
        repo::manage(repo_path_clone, repo_rx_in, repo_tx_out).await;
        Msg::RepoTaskExited
    });
    let repo_rx_out = UnboundedReceiverStream::new(repo_rx_out);
    let repo_msg_out_task = Task::run(repo_rx_out, Msg::FromRepo);

    let (repo_task, repo_tx_in) = start_task_to_manage_repo(repo_path.clone());

        repo_msg_out_task,

            panic!("Repo task exited")

            error!("Task managing repo has crashed. This shouldn't happen, please report what happened!");
            info!("Starting a new task to manage repo");
            let (task, repo_tx_in) =
                start_task_to_manage_repo(state.repo_path.clone());
            state.repo_tx_in = repo_tx_in;
            task

}
fn start_task_to_manage_repo(
    repo_path: PathBuf,
) -> (Task<Msg>, mpsc::UnboundedSender<repo::MsgIn>) {
    let (repo_tx_in, repo_rx_in) = mpsc::unbounded_channel::<repo::MsgIn>();
    let (repo_tx_out, repo_rx_out) = mpsc::unbounded_channel::<repo::MsgOut>();
    let repo_task = Task::future(async move {
        repo::manage(repo_path, repo_rx_in, repo_tx_out).await;
        Msg::RepoTaskExited
    });
    let repo_rx_out = UnboundedReceiverStream::new(repo_rx_out);
    let repo_msg_out_task = Task::run(repo_rx_out, Msg::FromRepo);
    (Task::batch([repo_task, repo_msg_out_task]), repo_tx_in)