def get_celery_app(self, module_name):
    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(celery_app)
      for module in conf['modules']:
        self._registry['celeries'][module] = celery_app
    return self._registry['celeries'][module_name]
Celery application getter.
dataset/ETHPy150Open mtth/kit/kit/base.py/Kit.get_celery_app