Apply ruff formatting to queue adapter and tests.
PR Title Check / check-title (pull_request) Successful in 11s
Test Python Package / unit-tests (pull_request) Successful in 16s
Code Quality Pipeline / code-quality (pull_request) Failing after 30s
Test Python Package / integration-tests (pull_request) Successful in 34s
Test Python Package / coverage-report (pull_request) Successful in 16s
PR Title Check / check-title (pull_request) Successful in 11s
Test Python Package / unit-tests (pull_request) Successful in 16s
Code Quality Pipeline / code-quality (pull_request) Failing after 30s
Test Python Package / integration-tests (pull_request) Successful in 34s
Test Python Package / coverage-report (pull_request) Successful in 16s
Co-authored-by: Cursor <cursoragent@cursor.com>
This commit is contained in:
co-authored by
Cursor
parent
4f58c32dd6
commit
1822d886b1
@@ -102,9 +102,7 @@ class FileBackedQueueAdapter(QueueRepositoryInterface):
|
|||||||
if added:
|
if added:
|
||||||
self._append_items(added)
|
self._append_items(added)
|
||||||
if self._config.age_key is not None:
|
if self._config.age_key is not None:
|
||||||
cutoff = datetime.now(UTC) - timedelta(
|
cutoff = datetime.now(UTC) - timedelta(hours=self._config.max_age_hours)
|
||||||
hours=self._config.max_age_hours
|
|
||||||
)
|
|
||||||
if self._memory.evict_older_than(cutoff):
|
if self._memory.evict_older_than(cutoff):
|
||||||
self._compact()
|
self._compact()
|
||||||
|
|
||||||
|
|||||||
@@ -102,11 +102,15 @@ def test_parse_age_naive_datetime() -> None:
|
|||||||
|
|
||||||
|
|
||||||
def test_parse_age_zulu_string() -> None:
|
def test_parse_age_zulu_string() -> None:
|
||||||
assert _parse_age("2024-01-01T00:00:00Z") == datetime(2024, 1, 1, 0, 0, 0, tzinfo=UTC)
|
assert _parse_age("2024-01-01T00:00:00Z") == datetime(
|
||||||
|
2024, 1, 1, 0, 0, 0, tzinfo=UTC
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
def test_parse_age_naive_string() -> None:
|
def test_parse_age_naive_string() -> None:
|
||||||
assert _parse_age("2024-01-01T00:00:00") == datetime(2024, 1, 1, 0, 0, 0, tzinfo=UTC)
|
assert _parse_age("2024-01-01T00:00:00") == datetime(
|
||||||
|
2024, 1, 1, 0, 0, 0, tzinfo=UTC
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
def test_dequeue_rejects_negative_max_items() -> None:
|
def test_dequeue_rejects_negative_max_items() -> None:
|
||||||
|
|||||||
Reference in New Issue
Block a user