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

All Samples(24)  |  Call(0)  |  Derive(11)  |  Import(13)
A celery task that serves as a base class for all :class:`Task`'s
that support aborting during execution.

All subclasses of :class:`AbortableTask` must call the
:meth:`is_aborted` method periodically and act accordingly when
the call evaluates to :const:`True`.

src/p/a/panda-HEAD/panda/tasks/base.py   panda(Download)
from celery.task import Task as CeleryTask
from celery.contrib.abortable import AbortableTask as CeleryAbortableTask
from django.utils import translation
from django.conf import settings
import logging
class AbortableTask(CeleryAbortableTask):
    def __init__(self,*args,**kwargs):
        if settings.USE_I18N:
            try:
                translation.activate(settings.LANGUAGE_CODE)

src/s/o/socorro-HEAD/webapp-django/vendor/lib/python/celery/tests/test_task/test_task_abortable.py   socorro(Download)
from __future__ import absolute_import
 
from celery.contrib.abortable import AbortableTask, AbortableAsyncResult
from celery.tests.utils import Case
 
 
class MyAbortableTask(AbortableTask):

src/o/p/openquake-packages-HEAD/celery/celery/tests/test_task/test_task_abortable.py   openquake-packages(Download)
from __future__ import absolute_import
 
from celery.contrib.abortable import AbortableTask, AbortableAsyncResult
from celery.tests.utils import unittest
 
 
class MyAbortableTask(AbortableTask):

src/m/a/make.mozilla.org-HEAD/vendor-local/lib/python/celery/tests/test_task/test_task_abortable.py   make.mozilla.org(Download)
from __future__ import absolute_import
 
from celery.contrib.abortable import AbortableTask, AbortableAsyncResult
from celery.tests.utils import Case
 
 
class MyAbortableTask(AbortableTask):

src/o/h/oh-mainline-HEAD/vendor/packages/celery/celery/tests/test_task/test_task_abortable.py   oh-mainline(Download)
from __future__ import absolute_import
 
from celery.contrib.abortable import AbortableTask, AbortableAsyncResult
from celery.tests.utils import unittest
 
 
class MyAbortableTask(AbortableTask):

src/m/o/mozillians-HEAD/vendor-local/lib/python/celery/tests/test_task/test_task_abortable.py   mozillians(Download)
from __future__ import absolute_import
 
from celery.contrib.abortable import AbortableTask, AbortableAsyncResult
from celery.tests.utils import Case
 
 
class MyAbortableTask(AbortableTask):

src/p/l/playdoh-lib-HEAD/lib/python/celery/tests/test_task/test_task_abortable.py   playdoh-lib(Download)
from __future__ import absolute_import
 
from celery.contrib.abortable import AbortableTask, AbortableAsyncResult
from celery.tests.utils import Case
 
 
class MyAbortableTask(AbortableTask):

src/k/u/kuma-lib-HEAD/packages/celery/celery/tests/test_task/test_task_abortable.py   kuma-lib(Download)
from __future__ import absolute_import
 
from celery.contrib.abortable import AbortableTask, AbortableAsyncResult
from celery.tests.utils import Case
 
 
class MyAbortableTask(AbortableTask):

src/i/n/input-lib-HEAD/packages/celery/celery/tests/test_task_abortable.py   input-lib(Download)
import unittest2 as unittest
 
from celery.contrib.abortable import AbortableTask, AbortableAsyncResult
 
 
class MyAbortableTask(AbortableTask):

src/f/i/firefox-flicks-HEAD/vendor-local/lib/python/celery/tests/contrib/test_abortable.py   firefox-flicks(Download)
from __future__ import absolute_import
 
from celery.contrib.abortable import AbortableTask, AbortableAsyncResult
from celery.result import AsyncResult
from celery.tests.utils import Case
 
 
class MyAbortableTask(AbortableTask):

  1 | 2  Next