dapr
diff --git a/‎.github/workflows/build-push-to-main.yaml‎
Lines changed: 1 addition & 5 deletions b/‎.github/workflows/build-push-to-main.yaml‎
Lines changed: 1 addition & 5 deletions
diff --git a/‎.github/workflows/build-tag.yaml‎
Lines changed: 1 addition & 5 deletions b/‎.github/workflows/build-tag.yaml‎
Lines changed: 1 addition & 5 deletions
diff --git a/‎.github/workflows/build.yaml‎
Lines changed: 1 addition & 5 deletions b/‎.github/workflows/build.yaml‎
Lines changed: 1 addition & 5 deletions
diff --git a/‎.github/workflows/run-tests.yaml‎
Lines changed: 5 additions & 5 deletions b/‎.github/workflows/run-tests.yaml‎
Lines changed: 5 additions & 5 deletions
diff --git a/‎.gitignore‎
Lines changed: 6 additions & 0 deletions b/‎.gitignore‎
Lines changed: 6 additions & 0 deletions
diff --git a/‎CLAUDE.md‎
Lines changed: 14 additions & 8 deletions b/‎CLAUDE.md‎
Lines changed: 14 additions & 8 deletions
diff --git a/‎examples/pubsub-streaming-async/publisher.py‎
Lines changed: 1 addition & 1 deletion b/‎examples/pubsub-streaming-async/publisher.py‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎examples/pubsub-streaming-async/subscriber.py‎
Lines changed: 1 addition & 1 deletion b/‎examples/pubsub-streaming-async/subscriber.py‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎pyproject.toml‎
Lines changed: 5 additions & 1 deletion b/‎pyproject.toml‎
Lines changed: 5 additions & 1 deletion
diff --git a/‎tests/conftest.py‎
Lines changed: 91 additions & 0 deletions b/‎tests/conftest.py‎
Lines changed: 91 additions & 0 deletions
@@ -52,11 +52,7 @@ jobs:
       run: uv run mypy
     - name: Run unit-tests
       run: |
-        uv run coverage run -m unittest discover -v ./tests
-        for dir in ext/*/tests; do
-            uv run coverage run -a -m unittest discover -v "./$dir"
-        done
-        uv run coverage run -a -m pytest -m "not e2e" ./ext/dapr-ext-workflow/tests/durabletask/
+        uv run coverage run -m pytest tests ext -m "not e2e" --ignore=tests/integration --ignore=tests/examples --import-mode=importlib
         uv run coverage xml
     - name: Upload test coverage
       uses: codecov/codecov-action@v6
 
@@ -52,11 +52,7 @@ jobs:
       run: uv run mypy
     - name: Run unit-tests
       run: |
-        uv run coverage run -m unittest discover -v ./tests
-        for dir in ext/*/tests; do
-            uv run coverage run -a -m unittest discover -v "./$dir"
-        done
-        uv run coverage run -a -m pytest -m "not e2e" ./ext/dapr-ext-workflow/tests/durabletask/
+        uv run coverage run -m pytest tests ext -m "not e2e" --ignore=tests/integration --ignore=tests/examples --import-mode=importlib
         uv run coverage xml
     - name: Upload test coverage
       uses: codecov/codecov-action@v6
 
@@ -58,11 +58,7 @@ jobs:
       run: uv run mypy
     - name: Run unit-tests
       run: |
-        uv run coverage run -m unittest discover -v ./tests
-        for dir in ext/*/tests; do
-            uv run coverage run -a -m unittest discover -v "./$dir"
-        done
-        uv run coverage run -a -m pytest -m "not e2e" ./ext/dapr-ext-workflow/tests/durabletask/
+        uv run coverage run -m pytest tests ext -m "not e2e" --ignore=tests/integration --ignore=tests/examples --import-mode=importlib
         uv run coverage xml
     - name: Upload test coverage
       uses: codecov/codecov-action@v6
@@ -1,4 +1,4 @@
-name: validate-examples
+name: run-tests
 
 on:
   push:
@@ -86,7 +86,7 @@ jobs:
       - name: Install uv
         uses: astral-sh/setup-uv@v7
       - name: Install dependencies
-        run: uv sync --frozen --all-packages --group examples
+        run: uv sync --frozen --all-packages --group tests
       - name: Set up Dapr CLI
         uses: dapr/.github/.github/actions/setup-dapr-cli@main
         with:
@@ -103,9 +103,9 @@ jobs:
           nohup ollama serve &
           sleep 10
           ollama pull llama3.2:latest
-      - name: Check examples
-        run: |
-          uv run pytest tests/examples/
       - name: Run integration tests
         run: |
           uv run pytest tests/integration/
+      - name: Validate examples
+        run: |
+          uv run pytest tests/examples/
@@ -136,3 +136,9 @@ coverage.lcov
 
 # macOS specific files
 .DS_Store
+
+# Integration test scratch dirs
+tests/integration/.binding-data/
+
+# Crypto test material generated at test time (see tests/crypto_utils.py)
+tests/integration/keys/
@@ -1,14 +1,20 @@
 @AGENTS.md
 
-Use pathlib instead of os.path.
-Use httpx instead of urllib.
-subprocess(`shell=True`) is used only when it makes the code more readable. Use either shlex or args lists.
-subprocess calls should have a reasonable timeout.
-Use modern Python (3.10+) features.
 Make all code strongly typed.
 Keep conditional nesting to a minimum, and use guard clauses when possible.
-Aim for medium "visual complexity": use intermediate variables to store results of nested/complex function calls, but don't create a new variable for everything.
-Avoid comments unless there is a gotcha, a complex algorithm or anything an experienced code reviewer needs to be aware of. Focus on making better Google-style docstrings instead.
+Aim for medium visual complexity: use intermediate variables to store results of nested/complex function calls. A complex function call could be:
+- `f(Object(a=1, b=2, c=3))`, the inner object has more than 2 meaningful args
+- `f(Object((a, b)))`, 2 levels of nesting or anything with a long chain of closing parens
+- `small_transformation(ImportantObject())`, the object itself is the main subject of the function but the transformation steals the focus
+Use descriptive, self-documenting names for these intermediate variables.
+Closely related variable names should share a root and use different suffixes. For example, `request_original` and `request_clean`, but not `clean_request`.
+Avoid comments unless there is a gotcha, a complex algorithm or anything an experienced code reviewer needs to be aware of. Focus on making short but descriptive Google-style docstrings instead.
 
-The user is not always right. Be skeptical and do not blindly comply if something doesn't make sense.
+Use modern Python (3.10+) features.
+Use pathlib instead of os.path.
+Use httpx instead of urllib.
+`subprocess(shell=True)` is used only when it makes the code more readable. Use either shlex or args lists.
+Anything that can have an explicit timeout should have one.
 Code should be cross-platform and production ready.
+
+The user is not always right. Be skeptical and do not blindly comply if something doesn't make sense.
@@ -44,7 +44,7 @@ async def publish_events():
             )
 
             # Print the request
-            print(req_data, flush=True)
+            print(req_data)
 
             await asyncio.sleep(1)
 
 
@@ -19,7 +19,7 @@ def process_message(message):
     global counter
     counter += 1
     # Process the message here
-    print(f'Processing message: {message.data()} from {message.topic()}...', flush=True)
+    print(f'Processing message: {message.data()} from {message.topic()}...')
     return 'success'
 
 
 
@@ -71,14 +71,17 @@ dev = [
     "opentelemetry-exporter-zipkin~=1.11.1",
     "httpx~=0.28.1",
     "pyOpenSSL~=26.0.0",
+    "cryptography>=42.0.0",
+    "redis>=7.4.0",
     "Flask~=3.1.3",
     "pytest~=9.0.2",
+    "pytest-asyncio>=0.23",
     "ruff==0.14.1",
     "python-dotenv~=1.2.2",
     "pydantic~=2.13.3",
     "PyYAML~=6.0.3",
 ]
-examples = [
+tests = [
     {include-group = "dev"},
     "mechanical-markdown~=0.8.0",
     "langchain-ollama~=1.0.1",
@@ -142,3 +145,4 @@ markers = [
     'example_dir(name): set the example directory for the dapr fixture',
 ]
 pythonpath = ["."]
+asyncio_mode = "auto"
@@ -0,0 +1,91 @@
+# -*- coding: utf-8 -*-
+
+"""
+Copyright 2026 The Dapr Authors
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+    http://www.apache.org/licenses/LICENSE-2.0
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+"""
+
+import subprocess
+from typing import Callable, Iterator
+
+import pytest
+
+from tests.ollama_utils import DEFAULT_MODEL, model_available, ollama_ready
+from tests.process_utils import get_kwargs_for_process_group, terminate_process_group
+from tests.wait_utils import wait_until
+
+REDIS_CONTAINER = 'dapr_redis'
+
+
+@pytest.fixture(scope='session')
+def flush_redis() -> None:
+    """Flush the ``dapr_redis`` container once per session."""
+    subprocess.run(
+        args=('docker', 'exec', REDIS_CONTAINER, 'redis-cli', 'FLUSHDB'),
+        check=True,
+        capture_output=True,
+        timeout=10,
+    )
+
+
+@pytest.fixture(scope='session')
+def redis_set_config() -> Callable[[str, str, int], None]:
+    """Dapr encodes values in the config store as ``value||version``"""
+
+    def _set(key: str, value: str, version: int = 1) -> None:
+        subprocess.run(
+            args=(
+                'docker',
+                'exec',
+                REDIS_CONTAINER,
+                'redis-cli',
+                'SET',
+                key,
+                f'{value}||{version}',
+            ),
+            check=True,
+            capture_output=True,
+            timeout=10,
+        )
+
+    return _set
+
+
+@pytest.fixture(scope='session')
+def ollama() -> Iterator[None]:
+    """Ensure an Ollama server with the default model is running for the session."""
+    started: subprocess.Popen[str] | None = None
+    try:
+        if not ollama_ready():
+            try:
+                started = subprocess.Popen(
+                    ['ollama', 'serve'],
+                    stdout=subprocess.DEVNULL,
+                    stderr=subprocess.DEVNULL,
+                    text=True,
+                    **get_kwargs_for_process_group(),
+                )
+            except FileNotFoundError as exc:
+                pytest.fail(f'ollama CLI is not installed: {exc}')
+            wait_until(ollama_ready, timeout=30.0, interval=0.5)
+
+        if not model_available(DEFAULT_MODEL):
+            subprocess.run(['ollama', 'pull', DEFAULT_MODEL], check=True, capture_output=True)
+
+        yield
+    finally:
+        if started and started.poll() is None:
+            terminate_process_group(started)
+            try:
+                started.wait(timeout=10)
+            except subprocess.TimeoutExpired:
+                terminate_process_group(started, force=True)
+                started.wait()
Original file line number	Diff line number	Diff line change
`@@ -44,7 +44,7 @@ async def publish_events():`
`44`	`44`	`)`
`45`	`45`
`46`	`46`	`# Print the request`
`47`		`- print(req_data, flush=True)`
	`47`	`+ print(req_data)`
`48`	`48`
`49`	`49`	`await asyncio.sleep(1)`
`50`	`50`