Mercurial > kallithea
diff rhodecode/lib/celerylib/__init__.py @ 783:71113f64b2d8 beta
fidex corrent variables passed to dnconfig,
fixed celerylib import problem on tests
author | Marcin Kuzminski <marcin@python-works.com> |
---|---|
date | Sat, 27 Nov 2010 20:32:34 +0100 |
parents | f6c613fba757 |
children | 3d0661b8aaa4 07a6e8c65526 |
line wrap: on
line diff
--- a/rhodecode/lib/celerylib/__init__.py Sat Nov 27 19:45:10 2010 +0100 +++ b/rhodecode/lib/celerylib/__init__.py Sat Nov 27 20:32:34 2010 +0100 @@ -1,13 +1,42 @@ +# -*- coding: utf-8 -*- +""" + package.rhodecode.lib.celerylib.__init__ + ~~~~~~~~~~~~~~ + + celery libs for RhodeCode + + :created_on: Nov 27, 2010 + :author: marcink + :copyright: (C) 2009-2010 Marcin Kuzminski <marcin@python-works.com> + :license: GPLv3, see COPYING for more details. +""" +# This program is free software; you can redistribute it and/or +# modify it under the terms of the GNU General Public License +# as published by the Free Software Foundation; version 2 +# of the License or (at your opinion) any later version of the license. +# +# This program is distributed in the hope that it will be useful, +# but WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +# GNU General Public License for more details. +# +# You should have received a copy of the GNU General Public License +# along with this program; if not, write to the Free Software +# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, +# MA 02110-1301, USA. + import os import sys import socket import traceback import logging -from rhodecode.lib.pidlock import DaemonLock, LockHeld +from hashlib import md5 +from decorator import decorator from vcs.utils.lazy import LazyProperty -from decorator import decorator -from hashlib import md5 + +from rhodecode.lib.pidlock import DaemonLock, LockHeld + from pylons import config log = logging.getLogger(__name__) @@ -15,7 +44,10 @@ def str2bool(v): return v.lower() in ["yes", "true", "t", "1"] if v else None -CELERY_ON = str2bool(config['app_conf'].get('use_celery')) +try: + CELERY_ON = str2bool(config['app_conf'].get('use_celery')) +except KeyError: + CELERY_ON = False class ResultWrapper(object): def __init__(self, task):