Update rq dependencies and pass request object in process entry

Author: vegito22

llmstack/data/apis.py

@@ -287,7 +287,7 @@ def create_entry(self, user, document: DataDocument):
 
     def process_entry(self, request, uid):
         entry = get_object_or_404(DataSourceEntry, uuid=uuid.UUID(uid))
-        if request and request.user != entry.datasource.owner:
+        if request and request.user != entry.datasource.has_write_permission(request.user):
             return DRFResponse(status=404)
 
         document = DataDocument(**entry.config)
@@ -569,7 +569,9 @@ def add_entry(self, request, uid):
         documents = self.process_add_entry_request(datasource, source_data)
         for document in documents:
             create_result = DataSourceEntryViewSet().create_entry(user=request.user, document=document)
-            process_result = DataSourceEntryViewSet().process_entry(request=None, uid=str(create_result.data["uuid"]))
+            process_result = DataSourceEntryViewSet().process_entry(
+                request=request, uid=str(create_result.data["uuid"])
+            )
             datasource.size += process_result.data["size"]
 
         datasource.save()

poetry.lock

@@ -38,7 +38,6 @@ django-allauth = "^0.63.3"
 django-environ = "^0.11.2"
 django-picklefield = "^3.2"
 django-redis = "^5.4.0"
-django-rq = "^2.10.2"
 djangorestframework = "^3.15.2"
 django-flags = "^5.0.13"
 django-jsonform = {version = "^2.17.4"}
@@ -50,7 +49,6 @@ channels = "^4.1.0"
 importlib-metadata = {version = "^6.0.0" }
 pyyaml = {version = "^6.0" }
 redis = {version = "^4.5.4" }
-rq = "^1.16.2"
 sendgrid = {version = "^6.10.0" }
 python-liquid = {version ="^1.12.1"}
 orjson = {version = "^3.8.14" }
@@ -72,6 +70,9 @@ daphne = "^4.1.2"
 striprtf = "^0.0.26"
 langrocks = "0.1.4"
 diff-match-patch = "^20230430"
+rq = "^2.0.0"
+django-rq = "^3.0.0"
+distlib = "^0.3.9"
 
 [tool.poetry.group.faiss.dependencies]
 faiss-cpu = "^1.8.0"