yes

backend/invoke_worker/chapter_queue.py

@@ -13,7 +13,7 @@ from asgiref.sync import async_to_sync
 
 from django.db.models import Count
 
-import requests, environ, os, subprocess, shutil, zipfile, uuid
+import requests, environ, os, subprocess, shutil, zipfile, uuid, sys
 
 env = environ.Env()
 
@@ -56,7 +56,7 @@ class Job(Thread):
                     if (options.get("translate").get("state")): 
                         target_lang = options.get("translate").get("target")
                     else: target_lang = ""
-                    print(options)
+                    
                     stored = ComicStorageCache.objects.filter(
                         source=source,
                         comic_id=comic_id,
@@ -99,20 +99,20 @@ class Job(Thread):
                             
                             job = web_scrap.source_control[source].get_chapter.scrap(comic_id=comic_id,chapter_id=chapter_id,output_dir=input_dir)
                             if job.get("status") == "success":
-                                print("IT REACHED HERE???")
-                                with open(os.path.join(LOG_DIR,"image_translator_output.log"), "w") as file:
-                                    result = subprocess.run(
-                                        script,
-                                        cwd=os.path.join(BASE_DIR, "backend", "module", "utils", "image_translator"),
-                                        check=True,
-                                        stdout=file,
-                                        stderr=file,
-                                        text=True,
-                                    )
-                                    
-                                print("IT DONE AND PRINT OUTPUT???")
-                                with open(os.path.join(LOG_DIR,"image_translator_output.log"), "r") as file:
-                                    print(file.read())
+                                
+                                # with open(os.path.join(LOG_DIR,"image_translator_output.log"), "w") as file:
+                                result = subprocess.run(
+                                    script,
+                                    cwd=os.path.join(BASE_DIR, "backend", "module", "utils", "image_translator"),
+                                    check=True,
+                                    shell=False if sys.platform.startswith('linux') else True,
+                                    # stdout=file,
+                                    # stderr=file,
+                                    text=True,
+                                )
+                                
+                                
+                                
                                 if result.returncode != 0: raise Exception("Image Translator Execution error!")
                                 os.makedirs(managed_output_dir,exist_ok=True)
                                 shutil.rmtree(input_dir)
@@ -235,10 +235,10 @@ class UpdateSocketQueue(Thread):
                 MAX_QUEUE = SocketRequestChapterQueueCache.objects.count()
                 
                 if (MAX_QUEUE):
-                    query_result = list(set(SocketRequestChapterQueueCache.objects.order_by("datetime").values_list('socket_id', flat=True).distinct()))
+                    query_result = list(set(SocketRequestChapterQueueCache.objects.order_by("-datetime").values_list('socket_id', flat=True).distinct()))
                     for socket_id in query_result:
                         object = {}
-                        query_result_2 = SocketRequestChapterQueueCache.objects.filter(socket_id=socket_id).order_by("datetime").values("source","comic_id","chapter_idx")
+                        query_result_2 = SocketRequestChapterQueueCache.objects.filter(socket_id=socket_id).order_by("-datetime").values("source","comic_id","chapter_idx")
                         
                         for item in query_result_2:
                             source = item.get("source")