Add run-worker wrapper script

Author: CCXLV

.python-version

@@ -0,0 +1 @@
+3.13.11

crates/fluxqueue-worker/Cargo.toml

@@ -12,6 +12,7 @@ name = "fluxqueue-worker"
 path = "src/main.rs"
 
 [dependencies]
+pyo3 = { version = "0.27.2", features = ["auto-initialize"] }
 pyo3-async-runtimes = { version = "0.27.0", features = ["tokio-runtime"] }
 uuid = { version = "1.20.0", features = ["v4"] }
 redis = "0.32.7"
@@ -22,12 +23,15 @@ tokio = { version = "1.49.0", features = [
   "signal",
   "time",
 ] }
-pyo3 = { version = "0.27.2", features = ["auto-initialize"] }
 rmp-serde = "1.3.1"
 rmpv = { version = "1.3.1", features = ["with-serde"] }
 serde = { version = "1.0.228", features = ["derive"] }
 tracing = "0.1.44"
-tracing-subscriber = { version = "0.3.22", features = ["env-filter", "fmt", "time"] }
+tracing-subscriber = { version = "0.3.22", features = [
+  "env-filter",
+  "fmt",
+  "time",
+] }
 time = { version = "0.3.47", features = ["local-offset", "macros"] }
 clap = { version = "4.5.56", features = ["derive", "env"] }
 anyhow = "1.0.100"

pyproject.toml

@@ -8,26 +8,33 @@ dynamic = ["version"]
 description = "A lightweight, resource-efficient, high-throughput task queue for Python, written in Rust."
 readme = "README.md"
 requires-python = ">=3.11,<3.15"
-keywords = ["task-queue", "queue", "redis", "async", "background-tasks", "worker", "rust", "fluxqueue"]
+keywords = [
+  "task-queue",
+  "queue",
+  "redis",
+  "async",
+  "background-tasks",
+  "worker",
+  "rust",
+  "fluxqueue",
+]
 license = "Apache-2.0"
 license-files = ["LICENSE"]
-authors = [
-    {name = "Giorgi Merebashvili", email = "mereba2627@gmail.com"}
-]
+authors = [{ name = "Giorgi Merebashvili", email = "mereba2627@gmail.com" }]
 classifiers = [
-    "Development Status :: 5 - Production/Stable",
-    "Intended Audience :: Developers",
-    "Programming Language :: Python",
-    "Programming Language :: Python :: 3",
-    "Programming Language :: Python :: 3 :: Only",
-    "Programming Language :: Python :: 3.11",
-    "Programming Language :: Python :: 3.12",
-    "Programming Language :: Python :: 3.13",
-    "Programming Language :: Python :: 3.14",
-    "Programming Language :: Rust",
-    "Operating System :: OS Independent",
-    "Topic :: Software Development :: Libraries",
-    "Topic :: System :: Distributed Computing",
+  "Development Status :: 5 - Production/Stable",
+  "Intended Audience :: Developers",
+  "Programming Language :: Python",
+  "Programming Language :: Python :: 3",
+  "Programming Language :: Python :: 3 :: Only",
+  "Programming Language :: Python :: 3.11",
+  "Programming Language :: Python :: 3.12",
+  "Programming Language :: Python :: 3.13",
+  "Programming Language :: Python :: 3.14",
+  "Programming Language :: Rust",
+  "Operating System :: OS Independent",
+  "Topic :: Software Development :: Libraries",
+  "Topic :: System :: Distributed Computing",
 ]
 
 [project.urls]
@@ -39,19 +46,9 @@ Changelog = "https://github.com/CCXLV/fluxqueue/releases"
 
 [project.optional-dependencies]
 dev = ["ruff"]
-tests = [
-    "pytest-asyncio",
-    "python-dotenv",
-    "redis"
-]
-cli = [
-    "fluxqueue-cli>=0.1.0b4"
-]
-docs = [
-    "mkdocs-material", 
-    "mkdocstrings",
-    "mkdocstrings-python",
-]
+tests = ["pytest-asyncio", "python-dotenv", "redis"]
+cli = ["fluxqueue-cli>=0.1.0b4"]
+docs = ["mkdocs-material", "mkdocstrings", "mkdocstrings-python"]
 build = ["maturin"]
 
 [tool.maturin]

scripts/run-worker.sh

@@ -0,0 +1,9 @@
+#!/bin/bash
+
+LIB_DIR=$(python3 -c "import sysconfig; print(sysconfig.get_config_var('LIBDIR'))")
+
+if [ -n "$LIB_DIR" ]; then
+    export LD_LIBRARY_PATH="$LIB_DIR:$LD_LIBRARY_PATH"
+fi
+
+exec "./fluxqueue-worker" "$@"