in rally-custom/esrally/client/synchronous.py [0:0]
def __init__(self, *args, **kwargs):
distribution_version = kwargs.pop("distribution_version", None)
super().__init__(*args, **kwargs)
self._verified_elasticsearch = None
if distribution_version:
self.distribution_version = versions.Version.from_string(distribution_version)
else:
self.distribution_version = None