Skip to content

Commit 941f52d

Browse files
authored
Python 3.14 support (#71)
* Add support for python3.14 * Add todo in the worker tasks * Update python versions in prerequisites
1 parent 0024ea0 commit 941f52d

File tree

8 files changed

+9
-7
lines changed

8 files changed

+9
-7
lines changed

.gitignore

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,10 @@
11
target/
22
_tests/
33

4-
.venv
4+
.venv*
55
.env
66

7-
fluxqueue_core.cpython**
7+
fluxqueue_core.cp**
88
__pycache__/
99
.ruff_cache/
1010
.pytest_cache/

Cargo.lock

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

Cargo.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ members = ["crates/fluxqueue-common", "crates/fluxqueue-worker"]
33

44
[package]
55
name = "fluxqueue_core"
6-
version = "0.1.0-beta.2"
6+
version = "0.1.0-beta.3"
77
edition = "2024"
88

99
[lib]

README.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ FluxQueue is a task queue for Python that gets out of your way. The Rust core ma
2929

3030
## Requirements
3131

32-
- Python 3.11, 3.12, or 3.13
32+
- Python 3.11, 3.12, 3.13 or 3,14
3333
- Redis server
3434
- Linux (Windows and macOS support coming soon)
3535

crates/fluxqueue-worker/src/main.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -81,6 +81,7 @@ async fn main() -> Result<()> {
8181
tokio::signal::ctrl_c()
8282
.await
8383
.expect("Failed to listen for Ctrl+C");
84+
8485
warn!("Shutdown signal received! Starting graceful shutdown...");
8586

8687
let _ = shutdown_tx.send(true);

crates/fluxqueue-worker/src/task.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,7 @@ impl TaskRegistry {
1414
}
1515
}
1616

17+
// TODO: Add task name duplication error
1718
pub fn insert(&self, name: String, func: Py<PyAny>) -> Result<()> {
1819
let mut tasks = self.tasks.write().map_err(|_| {
1920
anyhow::anyhow!("Internal Error: Task registry lock poisoned (a thread panicked)")

docs/tutorial/installation.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ FluxQueue has two parts: the Python client library for enqueueing tasks, and the
44

55
## Prerequisites
66

7-
- Python 3.11, 3.12, or 3.13
7+
- Python 3.11, 3.12, 3.13 or 3,14
88
- Redis server running and accessible
99
- Linux (Windows and macOS support coming soon)
1010

pyproject.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ name = "fluxqueue"
77
dynamic = ["version"]
88
description = "A blazingly fast, lightweight task queue for Python, written in Rust"
99
readme = "README.md"
10-
requires-python = ">=3.11,<3.14"
10+
requires-python = ">=3.11,<3.15"
1111
license = "Apache-2.0"
1212
license-files = ["LICENSE"]
1313
authors = [

0 commit comments

Comments
 (0)