Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(25)  |  Call(14)  |  Derive(0)  |  Import(11)

        def current_app():
    return getattr(_tls, "current_app", None) or default_app
        


src/f/l/Flask-Celery-2.4.3/flask_celery.py   Flask-Celery(Download)
import argparse
 
from celery.app import App, AppPickler, current_app as current_celery
from celery.loaders import default as _default
from celery.utils import get_full_cls_name
    def worker(self):
        from celery.bin.celeryd import WorkerCommand
        return WorkerCommand(app=current_celery())
 
 
    def beat(self):
        from celery.bin.celerybeat import BeatCommand
        return BeatCommand(app=current_celery())
 
 
    def ev(self):
        from celery.bin.celeryev import EvCommand
        return EvCommand(app=current_celery())
 
 

src/f/l/flask-celery-HEAD/flask_celery.py   flask-celery(Download)
import argparse
 
from celery.app import App, AppPickler, current_app as current_celery
from celery.loaders import default as _default
from celery.utils import get_full_cls_name
    def worker(self):
        from celery.bin.celeryd import WorkerCommand
        return WorkerCommand(app=current_celery())
 
 
    def beat(self):
        from celery.bin.celerybeat import BeatCommand
        return BeatCommand(app=current_celery())
 
 
    def ev(self):
        from celery.bin.celeryev import EvCommand
        return EvCommand(app=current_celery())
 
 

src/o/h/oh-mainline-HEAD/vendor/packages/celery/celery/bin/celeryctl.py   oh-mainline(Download)
 
from celery import __version__
from celery.app import app_or_default, current_app
from celeryutils import term
 
    def run(self, *args, **kwargs):
        app = current_app()
        queues = len(app.amqp.queues.keys())
        messages_removed = app.control.discard_all()
        if messages_removed:

src/o/p/openquake-packages-HEAD/celery/celery/bin/celeryctl.py   openquake-packages(Download)
 
from celery import __version__
from celery.app import app_or_default, current_app
from celeryutils import term
 
    def run(self, *args, **kwargs):
        app = current_app()
        queues = len(app.amqp.queues.keys())
        messages_removed = app.control.discard_all()
        if messages_removed:

src/m/o/molly-1.4.10/molly/conf/admin.py   molly(Download)
from celery.app import current_app
from molly.conf.celery_util import init_providers
from djcelery.admin import PeriodicTaskAdmin
 
 
def run_now(modeladmin, request, queryset):
    app = current_app()

src/m/o/mollyproject-HEAD/molly/conf/admin.py   mollyproject(Download)
from celery.app import current_app
from molly.conf.celery_util import init_providers
from djcelery.admin import PeriodicTaskAdmin
 
 
def run_now(modeladmin, request, queryset):
    app = current_app()

src/m/o/molly-1.4.10/molly/conf/provider.py   molly(Download)
from djcelery.models import PeriodicTask as PerodicTaskModel
from celery.task import PeriodicTask, Task
from celery.app import current_app
 
 
    def save(self, update_last_modified=False, *arg, **kwargs):
        if not update_last_modified:
            app = current_app()
            provider = self.provider.split('.')[-1]
            for task in app.tasks:

src/m/o/mollyproject-HEAD/molly/conf/provider.py   mollyproject(Download)
from djcelery.models import PeriodicTask as PerodicTaskModel
from celery.task import PeriodicTask, Task
from celery.app import current_app
 
 
    def save(self, update_last_modified=False, *arg, **kwargs):
        if not update_last_modified:
            app = current_app()
            provider = self.provider.split('.')[-1]
            for task in app.tasks:

src/s/o/socorro-HEAD/webapp-django/vendor/src/test-utils/test_utils/__init__.py   socorro(Download)
 
    try:
        from celery.app import current_app
        current_app().conf.CELERY_ALWAYS_EAGER = True
    except ImportError:

src/f/i/firefox-flicks-HEAD/vendor-local/lib/python/celery/tests/utils.py   firefox-flicks(Download)
    def setUp(self):
        from celery.app import current_app
        from celery.backends.cache import CacheBackend, DummyClient
        app = self.app = self._current_app = current_app()
        if isinstance(app.backend, CacheBackend):

  1 | 2  Next