summary refs log tree commit diff
path: root/synapse/replication/slave/storage/groups.py
diff options
context:
space:
mode:
authorAmber Brown <hawkowl@atleastfornow.net>2018-10-13 00:14:08 +1100
committerGitHub <noreply@github.com>2018-10-13 00:14:08 +1100
commit381d2cfdf0f02935b743f4b6dc1b5133d7ed27b7 (patch)
treeff35333a1bd6658ff25ad6465ccc0ed6f27d4e76 /synapse/replication/slave/storage/groups.py
parentComments on get_all_new_events_stream (diff)
downloadsynapse-381d2cfdf0f02935b743f4b6dc1b5133d7ed27b7.tar.xz
Make workers work on Py3 (#4027)
Diffstat (limited to 'synapse/replication/slave/storage/groups.py')
-rw-r--r--synapse/replication/slave/storage/groups.py8
1 files changed, 4 insertions, 4 deletions
diff --git a/synapse/replication/slave/storage/groups.py b/synapse/replication/slave/storage/groups.py
index 5777f07c8d..e933b170bb 100644
--- a/synapse/replication/slave/storage/groups.py
+++ b/synapse/replication/slave/storage/groups.py
@@ -16,7 +16,7 @@
 from synapse.storage import DataStore
 from synapse.util.caches.stream_change_cache import StreamChangeCache
 
-from ._base import BaseSlavedStore
+from ._base import BaseSlavedStore, __func__
 from ._slaved_id_tracker import SlavedIdTracker
 
 
@@ -33,9 +33,9 @@ class SlavedGroupServerStore(BaseSlavedStore):
             "_group_updates_stream_cache", self._group_updates_id_gen.get_current_token(),
         )
 
-    get_groups_changes_for_user = DataStore.get_groups_changes_for_user.__func__
-    get_group_stream_token = DataStore.get_group_stream_token.__func__
-    get_all_groups_for_user = DataStore.get_all_groups_for_user.__func__
+    get_groups_changes_for_user = __func__(DataStore.get_groups_changes_for_user)
+    get_group_stream_token = __func__(DataStore.get_group_stream_token)
+    get_all_groups_for_user = __func__(DataStore.get_all_groups_for_user)
 
     def stream_positions(self):
         result = super(SlavedGroupServerStore, self).stream_positions()