fix: rate limit

pipelines/examples/rate_limit_filter_pipeline.py

@@ -108,9 +108,10 @@ class Pipeline:
         print(body)
         print(user)
 
-        user_id = user["id"] if user and "id" in user else "default_user"
+        if user["role"] == "user":
-        if self.rate_limited(user_id):
+            user_id = user["id"] if user and "id" in user else "default_user"
-            raise Exception("Rate limit exceeded. Please try again later.")
+            if self.rate_limited(user_id):
+                raise Exception("Rate limit exceeded. Please try again later.")
 
         self.log_request(user_id)
         return body

requirements.txt

@@ -13,8 +13,11 @@ requests==2.32.2
 aiohttp==3.9.5
 httpx
 
+
+# AI libraries
 openai
 anthropic
+google-generativeai
 
 # Database
 pymongo
@@ -60,6 +63,7 @@ playwright
 beautifulsoup4
 
 # Misc
+APScheduler
 youtube_dl
 twilio
 streamlit