Adding logging to lru evictions updateTermEmbeddingCache, a=chris
Adding logging to lru evictions updateTermEmbeddingCache, a=chris
diff --git a/src/library/media_jobs/RecommendationJob.php b/src/library/media_jobs/RecommendationJob.php
index 152ee2975..c34919711 100644
--- a/src/library/media_jobs/RecommendationJob.php
+++ b/src/library/media_jobs/RecommendationJob.php
@@ -385,11 +385,12 @@ class RecommendationJob extends MediaJob
$context_term_embedding = pack("E*",
...$context_term_embedding);
$this->updateTermEmbeddingCache($context_term_id,
- $context_term_embedding, C\THREAD_RECOMMENDATION);
+ $context_term_embedding, C\THREAD_RECOMMENDATION,
+ "context_update");
}
$term_embedding = pack("E*", ...$term_embedding);
$this->updateTermEmbeddingCache($term_id, $term_embedding,
- C\THREAD_RECOMMENDATION);
+ C\THREAD_RECOMMENDATION, "term_update");
}
$item_count++;
}
@@ -1296,13 +1297,15 @@ class RecommendationJob extends MediaJob
* @param int $term_id
* @param string $term_embedding
* @param int $item_type
+ * @param string $string
*/
public function updateTermEmbeddingCache($term_id, $term_embedding,
- $item_type)
+ $item_type, $message = "")
{
$db = $this->db;
$evicted_item = $this->lru_cache->put($term_id, $term_embedding);
if (isset($evicted_item)) {
+ L\crawlLog("$message {$evicted_item[0]} was evicted");
$on_conflict = in_array($db->to_upper_dbms, ["MYSQL"]) ?
" ON DUPLICATE KEY " :
" ON CONFLICT (ITEM_TYPE, ID) DO UPDATE ";
@@ -1320,7 +1323,7 @@ class RecommendationJob extends MediaJob
*/
public function saveTermEmbeddingsCacheToDb($item_type)
{
- L\crawlLog("Doing final persistence flush of LRU cache for $item_type");
+ L\crawlLog("Doing final persistence flush of LRU cache for $item_");
$db = $this->db;
$base_delete_sql = "DELETE FROM RECOMMENDATION_TERM_EMBEDDING" .
" WHERE ITEM_TYPE = ? AND ID IN (";