Removes assert on queue length

            msg['config'] = self.config  # Hacky for now, just passs the whole config dict

            pipeline.rpush(self.processing_queue,

                                json.dumps(msg, cls=JsonEncoder))

        assert len(res) == self.queue_length

        pipeline.execute()

        return len(res)