async def _start_pushers(self) -> None:
    'Start all the pushers'
    pushers = (await self.store.get_all_pushers())
    (await concurrently_execute(self._start_pusher, pushers, 10))
    logger.info('Started pushers')
Start all the pushers
async def _start_pushers(self) -> None:
    
    pushers = (await self.store.get_all_pushers())
    (await concurrently_execute(self._start_pusher, pushers, 10))
    logger.info('Started pushers')