Fix issue 5

.pre-commit-config.yaml

@@ -1,19 +1,19 @@
 repos:
   - repo: https://github.com/pre-commit/pre-commit-hooks
-    rev: v4.4.0
+    rev: v4.6.0
     hooks:
       - id: trailing-whitespace
       - id: end-of-file-fixer
         exclude: \.(min\.css|min\.js|po|mo|txt)$
   - repo: https://github.com/psf/black
-    rev: 23.3.0
+    rev: 24.4.2
     hooks:
       - id: black
   - repo: https://github.com/pre-commit/mirrors-isort
     rev: "v5.10.1"
     hooks:
       - id: isort
   - repo: https://github.com/pycqa/flake8
-    rev: "6.0.0"
+    rev: "7.0.0"
     hooks:
       - id: flake8

CHANGELOG.md

@@ -13,6 +13,12 @@ and this project adheres to [Semantic Versioning](http://semver.org/).
 
 ### Fixed
 
+## [0.1.2] - 2024-05-08
+
+### Changed
+
+- Refactored SQL in remove_item() of sqlite engine to address potential compatibility issue (#5)
+
 ## [0.1.1] - 2023-06-09
 
 ### Changed

measurements/run.py

@@ -2,6 +2,7 @@
 
 Runs multiple producers and consumers in parallel and measures duration and throughput.
 """
+
 import argparse
 import asyncio
 import csv

src/aiodiskqueue/__init__.py

@@ -4,7 +4,7 @@
 from aiodiskqueue.exceptions import QueueEmpty, QueueFull
 from aiodiskqueue.queues import Queue
 
-__version__ = "0.1.1"
+__version__ = "0.1.2"
 
 
 __all__ = ["engines", "Queue", "QueueEmpty", "QueueFull"]

src/aiodiskqueue/engines/__init__.py

@@ -1,4 +1,5 @@
 """Queue storage engines."""
+
 # flake8: noqa
 from .dbm import DbmEngine
 

src/aiodiskqueue/engines/sqlite.py

@@ -66,7 +66,11 @@ async def remove_item(self):
                 await db.execute(
                     """
                         DELETE FROM queue
-                        ORDER BY rowid
-                        LIMIT 1;
+                        WHERE rowid IN (
+                            SELECT rowid
+                            FROM queue
+                            ORDER BY rowid
+                            LIMIT 1
+                        );
                     """
                 )