Hopefully fix task hang issues

api/docs.py

@@ -41,7 +41,7 @@ KREUZBERG_CONFIG: ExtractionConfig = ExtractionConfig(
     force_ocr=False, ocr_backend=None, extract_tables=True)
 
 # Unfortunately needs to be kept to 1, as libreoffice isn't built to support parallel instances
-LO_CONVERSION_MUTEX = asyncio.Semaphore(1)
+LO_CONVERSION_MUTEX = asyncio.Lock()
 
 # Supported file types for text extraction and their MIME type
 FORMAT_MIME_TYPES = {
@@ -65,54 +65,53 @@ async def convert_file_type(contents: io.BytesIO, filename: str, input_ext: str,
         filter: The conversion filter to use.
     """
 
-    await LO_CONVERSION_MUTEX.acquire()
-
-    with tempfile.TemporaryDirectory() as tmpdir:
-        dir_path = Path(tmpdir)
-        input_file_path = dir_path / f"{filename}.{input_ext}"
-        output_file_path = dir_path / f"{filename}.{output_ext}"
-
-        # write the memory contents to the input file
-        with open(input_file_path, "wb") as in_file:
-            in_file.write(contents.read())
-
-        out_bytes = io.BytesIO()
-
-        # construct the command
-        command = [
-            "libreoffice",
-            "--headless",
-            "--convert-to", f"{output_ext}:{filter}" if filter else output_ext,
-            "--outdir", tmpdir,
-            str(input_file_path)  # Ensure path is a string for subprocess
-        ]
-
-        # convert using libreoffice asynchronously
-        process = await asyncio.create_subprocess_exec(
-            *command,
-            stdout=asyncio.subprocess.PIPE,
-            stderr=asyncio.subprocess.PIPE
-        )
+    async with LO_CONVERSION_MUTEX:
+        with tempfile.TemporaryDirectory() as tmpdir:
+            dir_path = Path(tmpdir)
+            input_file_path = dir_path / f"{filename}.{input_ext}"
+            output_file_path = dir_path / f"{filename}.{output_ext}"
+
+            # write the memory contents to the input file
+            with open(input_file_path, "wb") as in_file:
+                in_file.write(contents.read())
+
+            out_bytes = io.BytesIO()
+
+            # construct the command
+            command = [
+                "libreoffice",
+                "--headless",
+                "--convert-to", f"{output_ext}:{filter}" if filter else output_ext,
+                "--outdir", tmpdir,
+                str(input_file_path)  # Ensure path is a string for subprocess
+            ]
+
+            # convert using libreoffice asynchronously
+            process = await asyncio.create_subprocess_exec(
+                *command,
+                stdout=asyncio.subprocess.PIPE,
+                stderr=asyncio.subprocess.PIPE
+            )
 
-        stdout, stderr = await process.communicate()
+            stdout, stderr = await process.communicate()
 
-        exit_code = await process.wait()
+            exit_code = await process.wait()
 
-        if exit_code != 0 and not output_file_path.exists():
-            raise subprocess.CalledProcessError(
-                exit_code,
-                command,
-                output=stdout,
-                stderr=stderr
-            )
+            if exit_code != 0 and not output_file_path.exists():
+                raise subprocess.CalledProcessError(
+                    exit_code,
+                    command,
+                    output=stdout,
+                    stderr=stderr
+                )
 
-        LO_CONVERSION_MUTEX.release()
+            # LO_CONVERSION_MUTEX.release()
 
-        with open(output_file_path, mode="rb") as out:
-            out_bytes.write(out.read())
+            with open(output_file_path, mode="rb") as out:
+                out_bytes.write(out.read())
 
-        out_bytes.seek(0)
-        return out_bytes
+            out_bytes.seek(0)
+            return out_bytes
 
 
 async def extract_text_contents(filename: str, ext: str, bytes: io.BytesIO) -> list[str]: