pub async fn register_run( channel: &str, chat_id: i64, source_message_id: Option<String>, ) -> (u64, Arc<AtomicBool>, Arc<Notify>)