1
1
import os .path
2
2
import logging
3
+ import time
3
4
from multiprocessing import cpu_count , set_start_method
4
5
from multiprocessing .pool import Pool
5
6
from typing import Dict , Iterable , List , Optional , Tuple , Set
@@ -247,7 +248,13 @@ def get_docs(file_id: FileId) -> Optional[Tuple[int, str, LinesListDict]]:
247
248
family = getFileFamily (filename )
248
249
if family in (None , 'M' ): return
249
250
251
+ start = time .time ()
250
252
lines = (line .decode () for line in scriptLines ('parse-docs' , hash , filename ))
253
+ parser_time = time .time ()- start
254
+
255
+ if parser_time > 10 :
256
+ print ("docs timeout" , parser_time , file_id )
257
+
251
258
docs = collect_get_blob_output (lines )
252
259
253
260
return (idx , family , docs )
@@ -259,7 +266,14 @@ def get_comps(file_id: FileId) -> Optional[Tuple[int, str, LinesListDict]]:
259
266
if family in (None , 'K' , 'M' ): return
260
267
261
268
compatibles_parser = FindCompatibleDTS ()
269
+
270
+ start = time .time ()
262
271
lines = compatibles_parser .run (scriptLines ('get-blob' , hash ), family )
272
+ parser_time = time .time ()- start
273
+
274
+ if parser_time > 10 :
275
+ print ("comps docs timeout" , parser_time , file_id )
276
+
263
277
comps = collect_get_blob_output (lines )
264
278
265
279
return (idx , family , comps )
@@ -340,6 +354,9 @@ def update_version(db: DB, tag: bytes, pool: Pool, dts_comp_support: bool):
340
354
set_start_method ('spawn' )
341
355
with Pool () as pool :
342
356
for tag in scriptLines ('list-tags' ):
357
+ if not tag .startswith (b'v6.1' ) or b'rc' in tag :
358
+ continue
359
+
343
360
if not db .vers .exists (tag ):
344
361
logger .info ("updating tag %s" , tag )
345
362
update_version (db , tag , pool , dts_comp_support )
0 commit comments