@@ -816,6 +816,36 @@ def alter_table(txn: LoggingTransaction) -> None:
816
816
)
817
817
],
818
818
)
819
+ await self ._setup_sequence (
820
+ "device_lists_sequence" ,
821
+ [
822
+ ("device_lists_stream" , "stream_id" ),
823
+ ("user_signature_stream" , "stream_id" ),
824
+ ("device_lists_outbound_pokes" , "stream_id" ),
825
+ ("device_lists_changes_in_room" , "stream_id" ),
826
+ ("device_lists_remote_pending" , "stream_id" ),
827
+ ("device_lists_changes_converted_stream_position" , "stream_id" ),
828
+ ],
829
+ )
830
+ await self ._setup_sequence (
831
+ "e2e_cross_signing_keys_sequence" ,
832
+ [
833
+ ("e2e_cross_signing_keys" , "stream_id" ),
834
+ ],
835
+ )
836
+ await self ._setup_sequence (
837
+ "push_rules_stream_sequence" ,
838
+ [
839
+ ("push_rules_stream" , "stream_id" ),
840
+ ],
841
+ )
842
+ await self ._setup_sequence (
843
+ "pushers_sequence" ,
844
+ [
845
+ ("pushers" , "id" ),
846
+ ("deleted_pushers" , "stream_id" ),
847
+ ],
848
+ )
819
849
820
850
# Step 3. Get tables.
821
851
self .progress .set_state ("Fetching tables" )
0 commit comments