manyi/taskmanager/operator.py

# -*- coding: utf-8 -*-
# !/usr/bin/env python

from patch_celery import patch_requests
patch_requests()

from celery import Celery

app = Celery('manyi_taskmanager', include = ['taskmanager.tasks'])

import os

app.config_from_object(os.getenv('CELERY_CONFIG', 'taskmanager.config'))

if __name__ == '__main__':
    from patch import patch_requests
    patch_requests()
    app.start()