Function drain_pending 

async fn drain_pending(
    pending_controls: &Arc<Mutex<HashMap<String, Sender<Result<Value, Error>>>>>,
)