From ef5889eb7bfcc007f97d41618d96612d6bc271e2 Mon Sep 17 00:00:00 2001 From: Bin Yang Date: Tue, 15 May 2018 07:26:09 +0000 Subject: Enable celery for vesagent workers Change-Id: Ibd44dc86d0bc5ce203043ed18d5e968472462b8f Issue-ID: MULTICLOUD-230 Signed-off-by: Bin Yang --- windriver/titanium_cloud/celery.py | 38 ++++++++++++++++++++++++++++++++++++++ 1 file changed, 38 insertions(+) create mode 100644 windriver/titanium_cloud/celery.py (limited to 'windriver/titanium_cloud/celery.py') diff --git a/windriver/titanium_cloud/celery.py b/windriver/titanium_cloud/celery.py new file mode 100644 index 00000000..368c5ddb --- /dev/null +++ b/windriver/titanium_cloud/celery.py @@ -0,0 +1,38 @@ +# Copyright (c) 2017-2018 Wind River Systems, Inc. +# +# Licensed under the Apache License, Version 2.0 (the "License"); +# you may not use this file except in compliance with the License. +# You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. + +from __future__ import absolute_import, unicode_literals +import os +from celery import Celery +import logging + +# set the default Django settings module for the 'celery' program. +os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'titanium_cloud.settings') + +app = Celery('titanium_cloud') + +# Using a string here means the worker doesn't have to serialize +# the configuration object to child processes. +# - namespace='CELERY' means all celery-related configuration keys +# should have a `CELERY_` prefix. +app.config_from_object('django.conf:settings', namespace='CELERY') + +# Load task modules from all registered Django app configs. +app.autodiscover_tasks() + +logger = logging.getLogger(__name__) + +@app.task(bind=True) +def debug_task(self): + logger.debug("self.request") -- cgit 1.2.3-korg