Merge pull request #6364 from tomachalek/query_hist_logging_b

Fixes: 1) missing comma in sql call, 2) missing exported task

lib/plugins/mysql_query_history/__init__.py

@@ -214,16 +214,16 @@ async def get_user_queries(
             ''', values)
             rows = [item for item in await cursor.fetchall()]
             full_data = await self._process_rows(plugin_ctx, corpus_factory, rows)
-        
+
         for i, item in enumerate(full_data):
             item['idx'] = offset + i
 
         return full_data
-    
+
     async def _process_rows(self, plugin_ctx, corpus_factory, rows):
         async def extract_id(item_id: str, item_data: Dict) -> Tuple[str, Dict]:
             return item_id, item_data
-        
+
         full_data = []
         corpora = CorpusCache(corpus_factory)
         qdata_map = {}
@@ -336,7 +336,7 @@ async def extract_id(item_id: str, item_data: Dict) -> Tuple[str, Dict]:
                 full_data.append(tmp)
             else:
                 logging.getLogger(__name__).error('Unknown query supertype: ', q_supertype)
-        
+
         return full_data
 
     async def delete_old_records(self):
@@ -359,7 +359,7 @@ async def delete_old_records(self):
                     ) AS tmp
                     WHERE row_num > %s
                 )
-                '''
+                ''',
                 (self.preserve_amount,)
             )
 

lib/plugins/ucnk_query_history/__init__.py

@@ -264,6 +264,13 @@ async def _delete_indexed_item(self, plugin_ctx, query_id, user_id, created):
                 data = await resp.json()
                 raise Exception(f'Failed to delete query from index: {data}')
 
+    def export_tasks(self):
+        """
+        For ucnk_query_history, we have to export action to regularly remove old records
+        so our fulltext index in Camus won't grow indefinitely.
+        """
+        return self.delete_old_records,
+
 
 @inject(
     plugins.runtime.INTEGRATION_DB,