Celery v5.0.1 Documentationmethod _Zone.to_system of>, bytes= , proto1_to_proto2= proto1_to_proto2>)[source] Default task execution strategy. Note Strategies are here as an optimization d def _sync_with(self, d): self._revoked_tasks.purge() d.update({ '__proto__': 3, 'zrevoked': self.compress(self._dumps(self._revoked_tasks)), 'clock': disable=redefined-outer-name # We cache globals and attribute lookups, so disable this warning. def hybrid_to_proto2(message, body): """Create a fresh protocol 2 message from a hybrid protocol 1/2 message.""" 0 码力 | 2313 页 | 2.13 MB | 1 年前3- Celery v5.0.2 Documentationmethod _Zone.to_system of
>, bytes= , proto1_to_proto2= proto1_to_proto2>)[source] Default task execution strategy. Note Strategies are here as an optimization d def _sync_with(self, d): self._revoked_tasks.purge() d.update({ '__proto__': 3, 'zrevoked': self.compress(self._dumps(self._revoked_tasks)), 'clock': disable=redefined-outer-name # We cache globals and attribute lookups, so disable this warning. def hybrid_to_proto2(message, body): """Create a fresh protocol 2 message from a hybrid protocol 1/2 message.""" 0 码力 | 2313 页 | 2.14 MB | 1 年前3 - Celery v5.0.0 Documentationmethod _Zone.to_system of
>, bytes= , proto1_to_proto2= proto1_to_proto2>)[source] Default task execution strategy. Note Strategies are here as an optimization d def _sync_with(self, d): self._revoked_tasks.purge() d.update({ '__proto__': 3, 'zrevoked': self.compress(self._dumps(self._revoked_tasks)), 'clock': disable=redefined-outer-name # We cache globals and attribute lookups, so disable this warning. def hybrid_to_proto2(message, body): """Create a fresh protocol 2 message from a hybrid protocol 1/2 message.""" 0 码力 | 2309 页 | 2.13 MB | 1 年前3 - Celery v5.0.5 Documentationmethod _Zone.to_system of
>, bytes= , proto1_to_proto2= proto1_to_proto2>)[source] Default task execution strategy. Note Strategies are here as an optimization d def _sync_with(self, d): self._revoked_tasks.purge() d.update({ '__proto__': 3, 'zrevoked': self.compress(self._dumps(self._revoked_tasks)), 'clock': disable=redefined-outer-name # We cache globals and attribute lookups, so disable this warning. def hybrid_to_proto2(message, body): """Create a fresh protocol 2 message from a hybrid protocol 1/2 message.""" 0 码力 | 2315 页 | 2.14 MB | 1 年前3 - Celery 3.0 Documentation
>, bytes= , buffer_t= , proto1_to_proto2= proto1_to_proto2>)[source] Default task execution strategy. Note Strategies are here as an optimization def _sync_with(self, d): self._revoked_tasks.purge() d.update({ b'__proto__': 3, b'zrevoked': self.compress(self._dumps(self._revoked_tasks)), b'clock': disable=redefined-outer-name # We cache globals and attribute lookups, so disable this warning. def proto1_to_proto2(message, body): """Convert Task message protocol 1 arguments to protocol 2. Returns: 0 码力 | 2110 页 | 2.23 MB | 1 年前3 - Celery v4.0.0 Documentation
>, bytes= , buffer_t= , proto1_to_proto2= proto1_to_proto2>)[source] Default task execution strategy. Note Strategies are here as an optimization def _sync_with(self, d): self._revoked_tasks.purge() d.update({ b'__proto__': 3, b'zrevoked': self.compress(self._dumps(self._revoked_tasks)), b'clock': disable=redefined-outer-name # We cache globals and attribute lookups, so disable this warning. def proto1_to_proto2(message, body): """Convert Task message protocol 1 arguments to protocol 2. Returns: 0 码力 | 2106 页 | 2.23 MB | 1 年前3 
Celery 3.0 Documentation>, bytes= , buffer_t= , proto1_to_proto2= proto1_to_proto2>) Default task execution strategy. 2.12. API Reference 381 Celery Documentation result store backend. class celery.backends.riak.RiakBackend(host=None, port=None, bucket_name=None, proto- col=None, url=None, *args, **kwargs) Riak result backend. Raises celery.exceptions.ImproperlyConfigured 0 码力 | 703 页 | 2.60 MB | 1 年前3- Celery v4.1.0 Documentation
>, bytes= , buffer_t= , proto1_to_proto2= proto1_to_proto2>) Default task execution strategy. Note: Strategies are here as an optimization Documentation, Release 4.1.0 class celery.backends.riak.RiakBackend(host=None, port=None, bucket_name=None, proto- col=None, url=None, *args, **kwargs) Riak result backend. Raises celery.exceptions.ImproperlyConfigured 0 码力 | 714 页 | 2.63 MB | 1 年前3 - Celery v4.0.1 Documentation
>, bytes= , buffer_t= , proto1_to_proto2= proto1_to_proto2>) Default task execution strategy. Note: Strategies are here as an optimization result store backend. class celery.backends.riak.RiakBackend(host=None, port=None, bucket_name=None, proto- col=None, url=None, *args, **kwargs) Riak result backend. Raises celery.exceptions.ImproperlyConfigured 0 码力 | 705 页 | 2.63 MB | 1 年前3 - Celery v4.0.0 Documentation
>, bytes= , buffer_t= , proto1_to_proto2= proto1_to_proto2>) Default task execution strategy. 2.12. API Reference 381 Celery Documentation result store backend. class celery.backends.riak.RiakBackend(host=None, port=None, bucket_name=None, proto- col=None, url=None, *args, **kwargs) Riak result backend. Raises celery.exceptions.ImproperlyConfigured 0 码力 | 701 页 | 2.59 MB | 1 年前3
共 35 条
- 1
- 2
- 3
- 4