Detect future major prerelease upgrades

Co-authored-by: Copilot App <223556219+Copilot@users.noreply.github.com>

Author: andystaples

azure-functions-durable/README.md

@@ -38,11 +38,12 @@ After the first durable-client, orchestrator, or entity invocation,
 each Python worker checks accessible `requirements.txt` files in the
 background and writes a host worker log warning when the declared constraints
 permit a later major version. The check follows local `-r` and `-c` files and
-applicable environment markers. It is best-effort: missing or unsupported
-requirements are treated as unknown. A lockfile's presence does not indicate
-whether deployment uses it, so the warning describes the risk of installing
-directly from the requirements. The check does not read dependency files during
-app startup or wait for the check before returning from an invocation.
+applicable environment markers. It is best-effort and may miss uncommon version
+ranges; missing or unsupported requirements are treated as unknown. A
+lockfile's presence does not indicate whether deployment uses it, so the warning
+describes the risk of installing directly from the requirements. The check does
+not read dependency files during app startup or wait for the check before
+returning from an invocation.
 
 ## Overview
 

azure-functions-durable/azure/durable_functions/internal/dependency_warning.py

@@ -130,6 +130,13 @@ def add_release(epoch: int, major: int, minor: int, patch: int) -> None:
         add_release(bound.epoch, bound.major, bound.minor + 1, 0)
         add_release(bound.epoch, bound.major + 1, 0, 0)
 
+    for candidate in tuple(candidates):
+        base = candidate.base_version
+        candidates.update(Version(f"{base}{suffix}") for suffix in (".dev0", "a0", "b0", "rc0"))
+        if candidate.pre and candidate.pre[1] > 0:
+            label, number = candidate.pre
+            candidates.add(Version(f"{base}{label}{number - 1}"))
+
     allowed = [candidate for candidate in candidates if specifiers.contains(candidate, prereleases=True)]
     return (
         any(candidate.major == installed.major for candidate in allowed)

tests/azure-functions-durable/test_dependency_warning.py

@@ -32,10 +32,20 @@ def _warnings(caplog):
         ("azure-functions-durable>=2.0.0b1", True),
         ("azure-functions-durable>=2,<4", True),
         ("azure-functions-durable>=2,<3.1", True),
+        ("azure-functions-durable>=2.0.0rc5,<3.0.0rc2", True),
+        ("azure-functions-durable>=2.0.0rc5,<3.0.0rc0", True),
+        ("azure-functions-durable>=2.0.0rc5,<3.0.0a0", True),
+        ("--pre\nazure-functions-durable>=2.0.0rc5,<=3.0.0,!=3.0.0", True),
+        (
+            "azure-functions-durable>=2.0.0rc5,<3.0.0rc2,"
+            "!=3.0.0.dev0,!=3.0.0a0,!=3.0.0b0,!=3.0.0rc0",
+            True,
+        ),
         ("azure-functions-durable!=3.*", True),
         ("azure-functions-durable!=3.0.0", True),
         ("azure-functions-durable<3", False),
         ("azure-functions-durable>=2.0.0b1,<3", False),
+        ("azure-functions-durable>=2.0.0rc5,<3.0.0.dev0", False),
         ("azure-functions-durable==2.*", False),
         ("azure-functions-durable==2.0.0rc5", False),
         ("azure-functions-durable~=2.0", False),
@@ -72,6 +82,14 @@ def test_suggested_constraint_preserves_the_installed_epoch(monkeypatch, tmp_pat
     assert "azure-functions-durable>=1!2.3,<1!3" in _warnings(caplog)[0]
 
 
+def test_future_major_prerelease_preserves_the_installed_epoch(monkeypatch, tmp_path, caplog):
+    monkeypatch.setattr(dependency_warning, "version", lambda name: "1!2.0rc5")
+    (tmp_path / "requirements.txt").write_text(
+        "azure-functions-durable>=1!2.0rc5,<1!3.0rc2", encoding="utf-8")
+    dependency_warning.warn_if_unbounded(str(tmp_path), logging.getLogger(__name__))
+    assert "azure-functions-durable>=1!2.0rc5,<1!3" in _warnings(caplog)[0]
+
+
 def test_a_higher_major_in_an_older_epoch_is_not_an_upgrade(monkeypatch, tmp_path, caplog):
     monkeypatch.setattr(dependency_warning, "version", lambda name: "1!2.0")
     (tmp_path / "requirements.txt").write_text("azure-functions-durable>=2,<1!3", encoding="utf-8")
@@ -320,9 +338,10 @@ async def async_fail():
 
     wrapped = invocation.wrap_invocation(async_fail if use_async else fail)
     with pytest.raises(ValueError, match="invocation failed"):
-        result = wrapped(context=context)
         if use_async:
-            await result
+            await wrapped(context=context)
+        else:
+            wrapped(context=context)
 
     assert checked == [context]
     assert invocation.get_invocation_id() is None