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

All Samples(0)  |  Call(0)  |  Derive(0)  |  Import(0)

src/i/n/input-lib-HEAD/packages/celery/celery/backends/database.py   input-lib(Download)
    def __init__(self, dburi=None, result_expires=None,
            engine_options=None, **kwargs):
        self.result_expires = result_expires or conf.TASK_RESULT_EXPIRES
        self.dburi = dburi or conf.RESULT_DBURI
        self.engine_options = dict(engine_options or {},

src/i/n/input-lib-HEAD/packages/celery/celery/backends/amqp.py   input-lib(Download)
        self.expires = expires
        if self.expires is None:
            self.expires = conf.TASK_RESULT_EXPIRES
        if isinstance(self.expires, timedelta):
            self.expires = timeutils.timedelta_seconds(self.expires)

src/i/n/input-lib-HEAD/packages/django-celery/djcelery/backends/cache.py   input-lib(Download)
    def __init__(self, *args, **kwargs):
        super(CacheBackend, self).__init__(self, *args, **kwargs)
        expires = conf.TASK_RESULT_EXPIRES
        if isinstance(expires, timedelta):
            expires = int(timedelta_seconds(conf.TASK_RESULT_EXPIRES))

src/i/n/input-lib-HEAD/packages/celery/celery/backends/mongodb.py   input-lib(Download)
        """
        self.result_expires = kwargs.get("result_expires") or \
                                conf.TASK_RESULT_EXPIRES
 
        if not pymongo:

src/i/n/input-lib-HEAD/packages/celery/celery/backends/cassandra.py   input-lib(Download)
 
        self.result_expires = kwargs.get("result_expires") or \
                                conf.TASK_RESULT_EXPIRES
 
        if not pycassa:

src/i/n/input-lib-HEAD/packages/django-celery/djcelery/managers.py   input-lib(Download)
    def get_all_expired(self):
        """Get all expired task results."""
        from celery import conf
        expires = conf.TASK_RESULT_EXPIRES
        return self.filter(date_done__lt=datetime.now() - expires)