redis_length endpoint

startmunich · May 11, 2024 · 4ba6064 · 4ba6064
1 parent 54464d8
commit 4ba6064
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/apps/vectordb_sync/vectordb_sync.py b/apps/vectordb_sync/vectordb_sync.py
@@ -86,6 +86,13 @@ def empty_redis():
     redis.delete('content_queue')
     return jsonify({"message": "Redis queue cleared"}), 200
 
+@app.route('/redis_lenght', methods=['POST'])
+def redis_lenght():
+    len = redis.llen('content_queue')
+    return jsonify({"message": len}), 200
+
+
+
 
 @app.route('/enqueue', methods=['POST']) # rename to enqueue_notion together with notion_Crwaler
 def enqueue_ids():