'Test the "celery" task.'

@ddt.data([{}], [{'settings': 'aws'}])
@ddt.unpack
def test_celery(self, options):

    settings = options.get('settings', 'devstack_with_worker')
    call_task('pavelib.servers.celery', options=options)
    self.assertEquals(self.task_messages, [EXPECTED_CELERY_COMMAND.format(settings=settings)])
