diff options
| author | Patrick Cloke <clokep@users.noreply.github.com> | 2020-08-07 09:44:48 -0400 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-08-07 09:44:48 -0400 |
| commit | 4e874ed5932c8d912e5ad9cf7822c216a5bc9266 (patch) | |
| tree | e30a0565ff19c9eef6444c3ccc270094af4ef068 /synapse/util/caches/descriptors.py | |
| parent | Add health check endpoint (#8048) (diff) | |
| download | synapse-4e874ed5932c8d912e5ad9cf7822c216a5bc9266.tar.xz | |
Remove unnecessary maybeDeferred calls (#8044)
Diffstat (limited to 'synapse/util/caches/descriptors.py')
| -rw-r--r-- | synapse/util/caches/descriptors.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/synapse/util/caches/descriptors.py b/synapse/util/caches/descriptors.py index 9b09c08b89..c2d72a82cf 100644 --- a/synapse/util/caches/descriptors.py +++ b/synapse/util/caches/descriptors.py @@ -192,7 +192,7 @@ class Cache(object): callbacks = [callback] if callback else [] self.check_thread() observable = ObservableDeferred(value, consumeErrors=True) - observer = defer.maybeDeferred(observable.observe) + observer = observable.observe() entry = CacheEntry(deferred=observable, callbacks=callbacks) existing_entry = self._pending_deferred_cache.pop(key, None) |