def inject(self):
        logger.info('Trying to inject')
        while self.get_unpublished_task() is not None:
            pass
Get a message from storage and injects it into the job stream
dataset/ETHPy150Open seatgeek/cronq/cronq/backends/mysql.py/Storage.inject