

def get_celery_app(self, module_name):
    'Celery application getter.'
    if (module_name not in self._registry['celeries']):
        (name, conf) = self._get_options('celeries', module_name)
        celery_app = Celery(name, **conf.get('kwargs', {
            
        }))
        celery_app.conf.update({k.upper(): v for (k, v) in conf.get('config', {
            
        }).items()})
        celery_app.periodic_task = periodic_task
        self.celeries.append(k)
        for module in conf['modules']:
            self._registry['celeries'][module] = celery_app
    return self._registry['celeries'][module_name]

dataset/ETHPy150Open mtth/kit/kit/base.py Kit.get_celery_app/VarMisuse@115/162 `celery_app`->`k`