def _tag_along_with_zero_weight(self, control: StepControl):
    'Wait for a running averaging round to finish with zero weight.'
    if (not control.triggered):
        control.weight = 0
        control.allow_allreduce()
    if (not control.done()):
        try:
            control.result(self.averaging_timeout)
        except BaseException as e:
            logger.exception(e)
            if (not control.done()):
                control.cancel()
Wait for a running averaging round to finish with zero weight.
def _tag_along_with_zero_weight(self, control: StepControl):
    
    if (not control.triggered):
        control.weight = 0
        control.allow_allreduce()
    if (not control.done()):
        try:
            control.result(self.averaging_timeout)
        except BaseException as e:
            logger.exception(e)
            if (not control.done()):
                control.cancel()