1919from synapse .http .servlet import RestServlet , parse_integer , parse_string
2020from synapse .http .site import SynapseRequest
2121from synapse .rest .admin ._base import admin_patterns , assert_requester_is_admin
22- from synapse .storage .databases .main .transactions import (
23- DestinationRetryTimings ,
24- DestinationSortOrder ,
25- )
22+ from synapse .storage .databases .main .transactions import DestinationSortOrder
2623from synapse .types import JsonDict
2724
2825if TYPE_CHECKING :
@@ -121,10 +118,19 @@ async def on_GET(
121118 destination
122119 )
123120
124- if destination_retry_timings is None :
125- destination_retry_timings = DestinationRetryTimings (
126- failure_ts = None , retry_last_ts = 0 , retry_interval = 0
127- )
121+ retry_timing_respone : JsonDict = {}
122+ if destination_retry_timings :
123+ retry_timing_respone = {
124+ "failure_ts" : destination_retry_timings .failure_ts ,
125+ "retry_last_ts" : destination_retry_timings .retry_last_ts ,
126+ "retry_interval" : destination_retry_timings .retry_interval ,
127+ }
128+ else :
129+ retry_timing_respone = {
130+ "failure_ts" : None ,
131+ "retry_last_ts" : 0 ,
132+ "retry_interval" : 0 ,
133+ }
128134
129135 last_successful_stream_ordering = (
130136 await self ._store .get_destination_last_successful_stream_ordering (
@@ -134,10 +140,8 @@ async def on_GET(
134140
135141 response = {
136142 "destination" : destination ,
137- "failure_ts" : destination_retry_timings .failure_ts ,
138- "retry_last_ts" : destination_retry_timings .retry_last_ts ,
139- "retry_interval" : destination_retry_timings .retry_interval ,
140143 "last_successful_stream_ordering" : last_successful_stream_ordering ,
144+ ** retry_timing_respone ,
141145 }
142146
143147 return HTTPStatus .OK , response
0 commit comments