Skip to content
Permalink

Comparing changes

Choose two branches to see what’s changed or to start a new pull request. If you need to, you can also or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: python-arq/arq
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: v0.26.2
Choose a base ref
...
head repository: python-arq/arq
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: main
Choose a head ref
  • 2 commits
  • 3 files changed
  • 2 contributors

Commits on Jan 6, 2025

  1. Fix negative expires_ms and avoid worker freezing while using cron (#479 

    )
    @Matvey-Kuk
    Matvey-Kuk authored Jan 6, 2025
    Loading
    Loading status checks…

    Verified

    This commit was created on GitHub.com and signed with GitHub’s verified signature.
    GPG key ID: B5690EEEBB952194
    Verified
    Learn about vigilant mode
    Copy the full SHA
    3bacb07 View commit details

  2. Prepare for 0.26.3 (#494)

    @chrisguidry
    chrisguidry authored Jan 6, 2025
    Loading
    Loading status checks…

    Verified

    This commit was created on GitHub.com and signed with GitHub’s verified signature.
    GPG key ID: B5690EEEBB952194
    Verified
    Learn about vigilant mode
    Copy the full SHA
    7a911f3 View commit details
Showing with 14 additions and 2 deletions.
  1. +7 −0 HISTORY.rst
  2. +1 −1 arq/version.py
  3. +6 −1 arq/worker.py
7 changes: 7 additions & 0 deletions HISTORY.rst
View file
Original file line number Diff line number Diff line change
@@ -3,6 +3,13 @@
History
-------

v0.26.3 (2025-01-06)
....................

* Fix negative expires_ms and avoid worker freezing while using cron by @Matvey-Kuk in #479
* Fix race condition on task retry by @RB387 in #487


v0.26.1 (2023-08-29)
....................

2 changes: 1 addition & 1 deletion arq/version.py
View file
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
# Version here is used for the package version via the `[tool.hatch.version]` section of `pyproject.toml`.
VERSION = '0.26.1'
VERSION = '0.26.3'
7 changes: 6 additions & 1 deletion arq/worker.py
View file
Original file line number Diff line number Diff line change
@@ -753,7 +753,12 @@ async def run_cron(self, n: datetime, delay: float, num_windows: int = 2) -> Non
job_id = f'{cron_job.name}:{to_unix_ms(cron_job.next_run)}' if cron_job.unique else None
job_futures.add(
self.pool.enqueue_job(
cron_job.name, _job_id=job_id, _queue_name=self.queue_name, _defer_until=cron_job.next_run
cron_job.name,
_job_id=job_id,
_queue_name=self.queue_name,
_defer_until=(
cron_job.next_run if cron_job.next_run > datetime.now(tz=self.timezone) else None
),
)
)
cron_job.calculate_next(cron_job.next_run)