async def stop(self):
    'Stop the background task balancing tasks on the cluster.\n        This will block until all currently running stealing requests are\n        finished. Idempotent\n        '
    pc = self.scheduler.periodic_callbacks.pop('stealing', None)
    if pc:
        pc.stop()
    (await self._in_flight_event.wait())
Stop the background task balancing tasks on the cluster.
This will block until all currently running stealing requests are
finished. Idempotent
async def stop(self):
    'Stop the background task balancing tasks on the cluster.\n        This will block until all currently running stealing requests are\n        finished. Idempotent\n        '
    pc = self.scheduler.periodic_callbacks.pop('stealing', None)
    if pc:
        pc.stop()
    (await self._in_flight_event.wait())