diff options
| author | Patrick Cloke <clokep@users.noreply.github.com> | 2020-09-04 06:54:56 -0400 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-09-04 06:54:56 -0400 |
| commit | c619253db80c8d1c606dc40756dd3c9e3a55a9fb (patch) | |
| tree | dad04bd2548edff6b3457f90fea11bc0eb803500 /synapse/replication/tcp/streams/_base.py | |
| parent | Revert "Add experimental support for sharding event persister. (#8170)" (#8242) (diff) | |
| download | synapse-c619253db80c8d1c606dc40756dd3c9e3a55a9fb.tar.xz | |
Stop sub-classing object (#8249)
Diffstat (limited to 'synapse/replication/tcp/streams/_base.py')
| -rw-r--r-- | synapse/replication/tcp/streams/_base.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/synapse/replication/tcp/streams/_base.py b/synapse/replication/tcp/streams/_base.py index 8c3caf30c9..682d47f402 100644 --- a/synapse/replication/tcp/streams/_base.py +++ b/synapse/replication/tcp/streams/_base.py @@ -79,7 +79,7 @@ StreamUpdateResult = Tuple[List[Tuple[Token, StreamRow]], Token, bool] UpdateFunction = Callable[[str, Token, Token, int], Awaitable[StreamUpdateResult]] -class Stream(object): +class Stream: """Base class for the streams. Provides a `get_updates()` function that returns new updates since the last |