async def start(self, scheduler=None):
    'Start the background coroutine to balance the tasks on the cluster.\n        Idempotent.\n        The scheduler argument is ignored. It is merely required to satisify the\n        plugin interface. Since this class is simultaneouly an extension, the\n        scheudler instance is already registered during initialization\n        '
    if ('stealing' in self.scheduler.periodic_callbacks):
        return
    pc = PeriodicCallback(callback=self.balance, callback_time=(self._callback_time * 1000))
    pc.start()
    self.scheduler.periodic_callbacks['stealing'] = pc
    self._in_flight_event.set()
Start the background coroutine to balance the tasks on the cluster.
Idempotent.
The scheduler argument is ignored. It is merely required to satisify the
plugin interface. Since this class is simultaneouly an extension, the
scheudler instance is already registered during initialization
async def start(self, scheduler=None):
    'Start the background coroutine to balance the tasks on the cluster.\n        Idempotent.\n        The scheduler argument is ignored. It is merely required to satisify the\n        plugin interface. Since this class is simultaneouly an extension, the\n        scheudler instance is already registered during initialization\n        '
    if ('stealing' in self.scheduler.periodic_callbacks):
        return
    pc = PeriodicCallback(callback=self.balance, callback_time=(self._callback_time * 1000))
    pc.start()
    self.scheduler.periodic_callbacks['stealing'] = pc
    self._in_flight_event.set()