@@ -1815,7 +1815,7 @@ def _add_device_outbound_room_poke_txn(
1815
1815
1816
1816
async def get_uncoverted_outbound_room_pokes (
1817
1817
self , limit : int = 10
1818
- ) -> List [Tuple [str , str , str , int , Dict [str , str ]]]:
1818
+ ) -> List [Tuple [str , str , str , int , Optional [ Dict [str , str ] ]]]:
1819
1819
"""Get device list changes by room that have not yet been handled and
1820
1820
written to `device_lists_outbound_pokes`.
1821
1821
@@ -1833,7 +1833,7 @@ async def get_uncoverted_outbound_room_pokes(
1833
1833
1834
1834
def get_uncoverted_outbound_room_pokes_txn (
1835
1835
txn : LoggingTransaction ,
1836
- ) -> List [Tuple [str , str , str , int , Dict [str , str ]]]:
1836
+ ) -> List [Tuple [str , str , str , int , Optional [ Dict [str , str ] ]]]:
1837
1837
txn .execute (sql , (limit ,))
1838
1838
1839
1839
return [
@@ -1842,7 +1842,7 @@ def get_uncoverted_outbound_room_pokes_txn(
1842
1842
device_id ,
1843
1843
room_id ,
1844
1844
stream_id ,
1845
- db_to_json (opentracing_context ) or {} ,
1845
+ db_to_json (opentracing_context ),
1846
1846
)
1847
1847
for user_id , device_id , room_id , stream_id , opentracing_context in txn
1848
1848
]
@@ -1858,7 +1858,7 @@ async def add_device_list_outbound_pokes(
1858
1858
room_id : str ,
1859
1859
stream_id : int ,
1860
1860
hosts : Collection [str ],
1861
- context : Dict [str , str ],
1861
+ context : Optional [ Dict [str , str ] ],
1862
1862
) -> None :
1863
1863
"""Queue the device update to be sent to the given set of hosts,
1864
1864
calculated from the room ID.
0 commit comments