def setUp(self):
        sentinel = Sentinel(settings_test.REDIS_SENTINEL)
        db = getattr(settings_test, 'REDIS_DB', 0)
        self.connection = sentinel.master_for('mymaster', db=db)
        self.connection.flushall()
        self.scheduler = Scheduler('test_queue', connection=self.connection)