in runmetrics/stats_collector.py [0:0]
def _with_worker_id(self, tags: Dict[str, str]) -> Optional[Dict[str, str]]:
if self._worker_id is not None:
tags.update({"worker.id": f"{self._worker_id}"})
if len(tags) == 0:
return None
else:
return tags