test: log sidecar port retry attempts

Author: GHX5T-SOL

tests/examples/conftest.py

@@ -52,7 +52,7 @@ def run(
         *,
         timeout: int = 30,
         until: list[str] | None = None,
-        port_bind_retries: int = 1,
+        port_bind_retries: int = 3,
     ) -> str:
         """Run a foreground command, block until it finishes, and return output.
 
@@ -71,11 +71,16 @@ def run(
         for attempt in range(attempts):
             output = self._run_once(args, timeout=timeout, until=until)
             if attempt < attempts - 1 and self._is_dapr_port_bind_failure(output):
+                print(
+                    'Dapr sidecar failed to bind a random port; '
+                    f'retrying startup after {2**attempt}s '
+                    f'(attempt {attempt + 1}/{attempts})',
+                    flush=True,
+                )
+                time.sleep(2**attempt)
                 continue
             return output
 
-        return output
-
     def _run_once(self, args: str, *, timeout: int, until: list[str] | None) -> str:
         proc = subprocess.Popen(
             args=('dapr', 'run', *shlex.split(args)),

tests/examples/test_dapr_runner.py

@@ -1,6 +1,9 @@
 import subprocess
+import time
 from pathlib import Path
 
+import pytest
+
 from tests.examples.conftest import DaprRunner
 
 
@@ -16,7 +19,9 @@ def wait(self, timeout: int | None = None) -> int:
         return self.returncode
 
 
-def test_run_retries_transient_dapr_port_bind_failure(monkeypatch, tmp_path: Path) -> None:
+def test_run_retries_transient_dapr_port_bind_failure(
+    monkeypatch, tmp_path: Path, capsys: pytest.CaptureFixture[str]
+) -> None:
     outputs = [
         (
             'level=error msg="Failed to listen for gRPC server on TCP address :33223 '
@@ -33,11 +38,18 @@ def fake_popen(*args, **kwargs) -> FakeProcess:
         return FakeProcess(outputs.pop(0))
 
     monkeypatch.setattr(subprocess, 'Popen', fake_popen)
+    sleeps: list[int] = []
+    monkeypatch.setattr(time, 'sleep', sleeps.append)
 
     output = DaprRunner(tmp_path).run('--app-id=secretsapp -- python3 example.py', timeout=1)
 
     assert output == "{'secretKey': 'secretValue'}\n"
     assert len(popen_calls) == 2
+    assert sleeps == [1]
+    assert (
+        'Dapr sidecar failed to bind a random port; retrying startup after 1s'
+        in capsys.readouterr().out
+    )
 
 
 def test_run_does_not_retry_non_port_bind_failure(monkeypatch, tmp_path: Path) -> None: