diff --git a/python/packages/azurefunctions/tests/integration_tests/testutils.py b/python/packages/azurefunctions/tests/integration_tests/testutils.py
index 75deb352bd..9186b45339 100644
--- a/python/packages/azurefunctions/tests/integration_tests/testutils.py
+++ b/python/packages/azurefunctions/tests/integration_tests/testutils.py
@@ -234,7 +234,7 @@ def get_sample_path_from_marker(request) -> tuple[Path | None, str | None]:
 
     sample_name = marker.args[0]
     repo_root = _resolve_repo_root()
-    sample_path = repo_root / "samples" / "getting_started" / "azure_functions" / sample_name
+    sample_path = repo_root / "samples" / "durable" / "azure_functions" / sample_name
 
     if not sample_path.exists():
         return None, f"Sample directory does not exist: {sample_path}"
diff --git a/python/packages/durabletask/tests/integration_tests/conftest.py b/python/packages/durabletask/tests/integration_tests/conftest.py
index 2cd045f291..6aca273fab 100644
--- a/python/packages/durabletask/tests/integration_tests/conftest.py
+++ b/python/packages/durabletask/tests/integration_tests/conftest.py
@@ -169,7 +169,7 @@ def worker_process(
         pytest.fail("Test class must have @pytest.mark.sample() marker")
 
     sample_name: str = cast(str, sample_marker.args[0])  # type: ignore[union-attr]
-    sample_path: Path = Path(__file__).parents[4] / "samples" / "getting_started" / "durabletask" / sample_name
+    sample_path: Path = Path(__file__).parents[4] / "samples" / "durable" / "console_apps" / sample_name
     worker_file: Path = sample_path / "worker.py"
 
     if not worker_file.exists():
diff --git a/python/packages/durabletask/tests/integration_tests/test_03_dt_single_agent_streaming.py b/python/packages/durabletask/tests/integration_tests/test_03_dt_single_agent_streaming.py
index d127a87356..ab360a81f3 100644
--- a/python/packages/durabletask/tests/integration_tests/test_03_dt_single_agent_streaming.py
+++ b/python/packages/durabletask/tests/integration_tests/test_03_dt_single_agent_streaming.py
@@ -29,7 +29,7 @@ import redis.asyncio as aioredis
 from dt_testutils import OrchestrationHelper, create_agent_client
 
 # Add sample directory to path to import RedisStreamResponseHandler
-SAMPLE_DIR = Path(__file__).parents[4] / "samples" / "getting_started" / "durabletask" / "03_single_agent_streaming"
+SAMPLE_DIR = Path(__file__).parents[4] / "samples" / "durable" / "console_apps" / "03_single_agent_streaming"
 sys.path.insert(0, str(SAMPLE_DIR))
 
 from redis_stream_response_handler import RedisStreamResponseHandler  # type: ignore[reportMissingImports] # noqa: E402