quyip commited on
Commit
b903ee4
·
1 Parent(s): df5c837
Files changed (2) hide show
  1. main.py +1 -1
  2. utils/cache_layer.py +1 -0
main.py CHANGED
@@ -32,6 +32,6 @@ async def summaries(request: SummariesReq):
32
  pages_summaries, uncached_pages = get_summarize_from_cache(request.pages)
33
  print(f'processing cached pages: {len(pages_summaries)}, uncached pages: {len(uncached_pages)}')
34
  loop = asyncio.get_event_loop()
35
- loop.run_in_executor(executor, summarize_un_cache_page, uncached_pages)
36
  print('return')
37
  return pages_summaries
 
32
  pages_summaries, uncached_pages = get_summarize_from_cache(request.pages)
33
  print(f'processing cached pages: {len(pages_summaries)}, uncached pages: {len(uncached_pages)}')
34
  loop = asyncio.get_event_loop()
35
+ await loop.run_in_executor(executor, summarize_un_cache_page, uncached_pages)
36
  print('return')
37
  return pages_summaries
utils/cache_layer.py CHANGED
@@ -25,6 +25,7 @@ def summarize_un_cache_page(pages: List[Page]):
25
  print(f'summarize pages length: {len(pages)}')
26
  for page in pages:
27
  id = page['id']
 
28
  summary = summarize(id, page['text'])
29
  cache.set(id, summary)
30
  print(f'processed page: {id}')
 
25
  print(f'summarize pages length: {len(pages)}')
26
  for page in pages:
27
  id = page['id']
28
+ print(f'processing page: {id}')
29
  summary = summarize(id, page['text'])
30
  cache.set(id, summary)
31
  print(f'processed page: {id}')