pub async fn publish_tokio_metrics( metrics_iterators: HashMap<String, impl Iterator<Item = TaskMetrics>> ) -> Result<(), Error>