Update package versions (#3838)

* Replace Hosted*Tool classes with client static factory methods

* fixed failing test

* mypy fix

* mypy fix 2

* declarative mypy fix

* addressed comments

* ToolProtocol removal

* fixed test

* agents mypy fix

* fix failing tests

* mypy fix

* addressed comments

* fixed tests

* addressed comments + added factory method overrides for azureai v2 client

* mypy fix

* added kwargs to azureai tool methods

* fixed in test

* _sessions fix

* test fix

.github/copilot-instructions.md

@@ -1,69 +1,19 @@
 # GitHub Copilot Instructions
 
-This repository contains both Python and C# code.
-All python code resides under the `python/` directory.
-All C# code resides under the `dotnet/` directory.
+Microsoft Agent Framework - a multi-language framework for building, orchestrating, and deploying AI agents.
 
-The purpose of the code is to provide a framework for building AI agents.
+## Repository Structure
 
-When contributing to this repository, please follow these guidelines:
+- `python/` - Python implementation → see [python/AGENTS.md](../python/AGENTS.md)
+- `dotnet/` - C#/.NET implementation → see [dotnet/AGENTS.md](../dotnet/AGENTS.md)
+- `docs/` - Design documents and architectural decision records
 
-## C# Code Guidelines
+## Architectural Decision Records (ADRs)
 
-Here are some general guidelines that apply to all code.
+ADRs in `docs/decisions/` capture significant design decisions and their rationale. They document considered alternatives, trade-offs, and the reasoning behind choices.
 
-- The top of all *.cs files should have a copyright notice: `// Copyright (c) Microsoft. All rights reserved.`
-- All public methods and classes should have XML documentation comments.
-- After adding, modifying or deleting code, run `dotnet build`, and then fix any reported build errors.
-- After adding or modifying code, run `dotnet format` to automatically fix any formatting errors.
+**Templates:**
+- `adr-template.md` - Full template with detailed sections
+- `adr-short-template.md` - Abbreviated template for simpler decisions
 
-### C# Sample Code Guidelines
-
-Sample code is located in the `dotnet/samples` directory.
-
-When adding a new sample, follow these steps:
-
-- The sample should be a standalone .net project in one of the subdirectories of the samples directory.
-- The directory name should be the same as the project name.
-- The directory should contain a README.md file that explains what the sample does and how to run it.
-- The README.md file should follow the same format as other samples.
-- The csproj file should match the directory name.
-- The csproj file should be configured in the same way as other samples.
-- The project should preferably contain a single Program.cs file that contains all the sample code.
-- The sample should be added to the solution file in the samples directory.
-- The sample should be tested to ensure it works as expected.
-- A reference to the new samples should be added to the README.md file in the parent directory of the new sample.
-
-The sample code should follow these guidelines:
-
-- Configuration settings should be read from environment variables, e.g. `var endpoint = Environment.GetEnvironmentVariable("AZURE_OPENAI_ENDPOINT") ?? throw new InvalidOperationException("AZURE_OPENAI_ENDPOINT is not set.");`.
-- Environment variables should use upper snake_case naming convention.
-- Secrets should not be hardcoded in the code or committed to the repository.
-- The code should be well-documented with comments explaining the purpose of each step.
-- The code should be simple and to the point, avoiding unnecessary complexity.
-- Prefer inline literals over constants for values that are not reused. For example, use `new ChatClientAgent(chatClient, instructions: "You are a helpful assistant.")` instead of defining a constant for "instructions".
-- Ensure that all private classes are sealed
-- Use the Async suffix on the name of all async methods that return a Task or ValueTask.
-- Prefer defining variables using types rather than var, to help users understand the types involved.
-- Follow the patterns in the samples in the same directories where new samples are being added.
-- The structure of the sample should be as follows:
-  - The top of the Program.cs should have a copyright notice: `// Copyright (c) Microsoft. All rights reserved.`
-  - Then add a comment describing what the sample is demonstrating.
-  - Then add the necessary using statements.
-  - Then add the main code logic.
-  - Finally, add any helper methods or classes at the bottom of the file.
-
-### C# Unit Test Guidelines
-
-Unit tests are located in the `dotnet/tests` directory in projects with a `.UnitTests.csproj` suffix.
-
-Unit tests should follow these guidelines:
-
-- Use `this.` for accessing class members
-- Add Arrange, Act and Assert comments for each test
-- Ensure that all private classes, that are not subclassed, are sealed
-- Use the Async suffix on the name of all async methods
-- Use the Moq library for mocking objects where possible
-- Validate that each test actually tests the target behavior, e.g. we should not have tests that creates a mock, calls the mock and then verifies that the mock was called, without the target code being involved. We also shouldn't have tests that test language features, e.g. something that the compiler would catch anyway.
-- Avoid adding excessive comments to tests. Instead favour clear easy to understand code.
-- Follow the patterns in the unit tests in the same project or classes to which new tests are being added
+When proposing architectural changes, create an ADR to capture options considered and the decision rationale. See [docs/decisions/README.md](../docs/decisions/README.md) for the full process.

.github/workflows/python-code-quality.yml

@@ -12,13 +12,13 @@ env:
   UV_CACHE_DIR: /tmp/.uv-cache
 
 jobs:
-  pre-commit:
-    name: Checks
+  pre-commit-hooks:
+    name: Pre-commit Hooks
     if: "!cancelled()"
     strategy:
       fail-fast: false
       matrix:
-        python-version: ["3.10", "3.14"]
+        python-version: ["3.10"]
     runs-on: ubuntu-latest
     continue-on-error: true
     defaults:
@@ -37,16 +37,106 @@ jobs:
           python-version: ${{ matrix.python-version }}
           os: ${{ runner.os }}
         env:
-          # Configure a constant location for the uv cache
           UV_CACHE_DIR: /tmp/.uv-cache
       - uses: actions/cache@v5
         with:
-          path: ~/.cache/pre-commit
-          key: pre-commit|${{ matrix.python-version }}|${{ hashFiles('python/.pre-commit-config.yaml') }}
-      - uses: pre-commit/action@v3.0.1
-        name: Run Pre-Commit Hooks
+          path: ~/.cache/prek
+          key: prek|${{ matrix.python-version }}|${{ hashFiles('python/.pre-commit-config.yaml') }}
+      - uses: j178/prek-action@v1
+        name: Run Pre-commit Hooks (excluding poe-check)
+        env:
+          SKIP: poe-check
         with:
-          extra_args: --config python/.pre-commit-config.yaml --all-files
+          extra-args: --cd python --all-files
+
+  package-checks:
+    name: Package Checks
+    if: "!cancelled()"
+    strategy:
+      fail-fast: false
+      matrix:
+        python-version: ["3.10"]
+    runs-on: ubuntu-latest
+    continue-on-error: true
+    defaults:
+      run:
+        working-directory: ./python
+    env:
+      UV_PYTHON: ${{ matrix.python-version }}
+    steps:
+      - uses: actions/checkout@v6
+        with:
+          fetch-depth: 0
+      - name: Set up python and install the project
+        id: python-setup
+        uses: ./.github/actions/python-setup
+        with:
+          python-version: ${{ matrix.python-version }}
+          os: ${{ runner.os }}
+        env:
+          UV_CACHE_DIR: /tmp/.uv-cache
+      - name: Run fmt, lint, pyright in parallel across packages
+        run: uv run poe check-packages
+
+  samples-markdown:
+    name: Samples & Markdown
+    if: "!cancelled()"
+    strategy:
+      fail-fast: false
+      matrix:
+        python-version: ["3.10"]
+    runs-on: ubuntu-latest
+    continue-on-error: true
+    defaults:
+      run:
+        working-directory: ./python
+    env:
+      UV_PYTHON: ${{ matrix.python-version }}
+    steps:
+      - uses: actions/checkout@v6
+        with:
+          fetch-depth: 0
+      - name: Set up python and install the project
+        id: python-setup
+        uses: ./.github/actions/python-setup
+        with:
+          python-version: ${{ matrix.python-version }}
+          os: ${{ runner.os }}
+        env:
+          UV_CACHE_DIR: /tmp/.uv-cache
+      - name: Run samples lint
+        run: uv run poe samples-lint
+      - name: Run samples syntax check
+        run: uv run poe samples-syntax
+      - name: Run markdown code lint
+        run: uv run poe markdown-code-lint
+
+  mypy:
+    name: Mypy Checks
+    if: "!cancelled()"
+    strategy:
+      fail-fast: false
+      matrix:
+        python-version: ["3.10"]
+    runs-on: ubuntu-latest
+    continue-on-error: true
+    defaults:
+      run:
+        working-directory: ./python
+    env:
+      UV_PYTHON: ${{ matrix.python-version }}
+    steps:
+      - uses: actions/checkout@v6
+        with:
+          fetch-depth: 0
+      - name: Set up python and install the project
+        id: python-setup
+        uses: ./.github/actions/python-setup
+        with:
+          python-version: ${{ matrix.python-version }}
+          os: ${{ runner.os }}
+        env:
+          UV_CACHE_DIR: /tmp/.uv-cache
       - name: Run Mypy
         env:
           GITHUB_BASE_REF: ${{ github.event.pull_request.base.ref || github.base_ref || 'main' }}

.github/workflows/python-merge-tests.yml

@@ -96,8 +96,7 @@ jobs:
         uses: ./.github/actions/azure-functions-integration-setup
         id: azure-functions-setup
       - name: Test with pytest
-        timeout-minutes: 10
-        run: uv run poe all-tests -n logical --dist loadfile --dist worksteal --timeout 900 --retries 3 --retry-delay 10
+        run: uv run poe all-tests -n logical --dist loadfile --dist worksteal --timeout=120 --session-timeout=900 --timeout_method thread --retries 2 --retry-delay 5
         working-directory: ./python
       - name: Test core samples
         timeout-minutes: 10
@@ -153,8 +152,8 @@ jobs:
           tenant-id: ${{ secrets.AZURE_TENANT_ID }}
           subscription-id: ${{ secrets.AZURE_SUBSCRIPTION_ID }}
       - name: Test with pytest
-        timeout-minutes: 10
-        run: uv run --directory packages/azure-ai poe integration-tests -n logical --dist loadfile --dist worksteal --timeout 300 --retries 3 --retry-delay 10
+        timeout-minutes: 15
+        run: uv run --directory packages/azure-ai poe integration-tests -n logical --dist loadfile --dist worksteal --timeout=120 --session-timeout=900 --timeout_method thread --retries 2 --retry-delay 5
         working-directory: ./python
       - name: Test Azure AI samples
         timeout-minutes: 10

.gitignore

@@ -199,8 +199,6 @@ temp*/
 .tmp/
 .temp/
 
-agents.md
-
 # AI
 .claude/
 WARP.md

docs/decisions/0012-python-typeddict-options.md

@@ -126,4 +126,4 @@ response = await client.get_response(
 
 Chosen option: **"Option 2: TypedDict with Generic Type Parameters"**, because it provides full type safety, excellent IDE support with autocompletion, and allows users to extend provider-specific options for their use cases. Extended this Generic to ChatAgents in order to also properly type the options used in agent construction and run methods.
 
-See [typed_options.py](../../python/samples/getting_started/chat_client/typed_options.py) for a complete example demonstrating the usage of typed options with custom extensions.
+See [typed_options.py](../../python/samples/concepts/typed_options.py) for a complete example demonstrating the usage of typed options with custom extensions.

docs/decisions/0015-agent-run-context.md

@@ -0,0 +1,147 @@
+---
+status: proposed
+contact: westey-m
+date: 2026-01-27
+deciders: sergeymenshykh, markwallace, rbarreto, dmytrostruk, westey-m, eavanvalkenburg, stephentoub, lokitoth, alliscode, taochenosu, moonbox3
+consulted: 
+informed: 
+---
+
+# AgentRunContext for Agent Run
+
+## Context and Problem Statement
+
+During an agent run, various components involved in the execution (middleware, filters, tools, nested agents, etc.) may need access to contextual information about the current run, such as:
+
+1. The agent that is executing the run
+2. The session associated with the run
+3. The request messages passed to the agent
+4. The run options controlling the agent's behavior
+
+Additionally, some components may need to modify this context during execution, for example:
+
+- Replacing the session with a different one
+- Modifying the request messages before they reach the agent core
+- Updating or replacing the run options entirely
+
+Currently, there is no standardized way to access or modify this context from arbitrary code that executes during an agent run, especially from deeply nested call stacks where the context is not explicitly passed.
+
+## Sample Scenario
+
+When using an Agent as an AIFunction developers may want to pass context from the parent agent run to the child agent run. For example, the developer may want to copy chat history to the child agent, or share the same session across both agents.
+
+To enable these scenarios, we need a way to access the parent agent run context, including e.g. the parent agent itself, the parent agent session, and the parent run options from function tool calls.
+
+```csharp
+    public static AIFunction AsAIFunctionWithSessionPropagation(this ChatClientAgent agent, AIFunctionFactoryOptions? options = null)
+    {
+        Throw.IfNull(agent);
+
+        [Description("Invoke an agent to retrieve some information.")]
+        async Task<string> InvokeAgentAsync(
+            [Description("Input query to invoke the agent.")] string query,
+            CancellationToken cancellationToken)
+        {
+            // Get the session from the parent agent and pass it to the child agent.
+            var session = AIAgent.CurrentRunContext?.Session;
+
+            // Alternatively, the developer may want to create a new session but copy over the chat history from the parent agent.
+            // var parentChatHistory = AIAgent.CurrentRunContext?.Session?.GetService<IList<ChatMessage>>();
+            // if (parentChatHistory != null)
+            // {
+            //     var chp = new InMemoryChatHistoryProvider();
+            //     foreach (var message in parentChatHistory)
+            //     {
+            //         chp.Add(message);
+            //     }
+            //     session = agent.GetNewSession(chp);
+            // }
+
+            var response = await agent.RunAsync(query, session: session, cancellationToken: cancellationToken).ConfigureAwait(false);
+            return response.Text;
+        }
+
+        options ??= new();
+        options.Name ??= SanitizeAgentName(agent.Name);
+        options.Description ??= agent.Description;
+
+        return AIFunctionFactory.Create(InvokeAgentAsync, options);
+    }
+```
+
+## Decision Drivers
+
+- Components executing during an agent run need access to run context without explicit parameter passing through every layer
+- Context should flow naturally across async calls without manual propagation
+- The design should allow modification of context properties by agent decorators (e.g., replacing options or session)
+- Solution should be consistent with patterns used in similar frameworks (e.g., `FunctionInvokingChatClient.CurrentContext` `HttpContext.Current`, `Activity.Current`)
+
+## Considered Options
+
+- **Option 1**: Pass context explicitly through all method signatures
+- **Option 2**: Use `AsyncLocal<T>` to provide ambient context accessible anywhere during the run
+- **Option 3**: Use a combination of explicit parameters for `RunCoreAsync` and `AsyncLocal<T>` for ambient access
+
+## Decision Outcome
+
+Chosen option: **Option 3** - Combination of explicit parameters and AsyncLocal ambient access.
+
+This approach provides the best of both worlds:
+
+1. **Explicit parameters are passed to `RunCoreAsync`**: The core agent implementation receives the parameters explicitly, making it clear what data is available and enabling easy unit testing. Any modification of these in a decorator will require calling `RunAsync` on the inner agent with the updated parameters, which would result in the inner agent creating a new `AgentRunContext` instance.
+
+   ```csharp
+    public async Task<AgentResponse> RunAsync(
+        IEnumerable<ChatMessage> messages,
+        AgentSession? session = null,
+        AgentRunOptions? options = null,
+        CancellationToken cancellationToken = default)
+    {
+
+        CurrentRunContext = new(this, session, messages as IReadOnlyCollection<ChatMessage> ?? messages.ToList(), options);
+        return await this.RunCoreAsync(messages, session, options, cancellationToken).ConfigureAwait(false);
+    }
+   ```
+
+2. **`AsyncLocal<AgentRunContext?>` for ambient access**: The context is stored in an `AsyncLocal<T>` field, making it accessible from any code executing during the agent run via a static property.
+
+    The main scenario for this is to allow deeply nested components (e.g., tools, chat client middleware) to access the context without needing to pass it through every method signature. These are external components that cannot easily be modified to accept additional parameters. For internal components, we prefer passing any parameters explicitly.
+
+   ```csharp
+   public static AgentRunContext? CurrentRunContext
+   {
+       get => s_currentContext.Value;
+       protected set => s_currentContext.Value = value;
+   }
+   ```
+
+### AgentRunContext Design
+
+The `AgentRunContext` class encapsulates all run-related state:
+
+```csharp
+public class AgentRunContext
+{
+    public AgentRunContext(
+        AIAgent agent,
+        AgentSession? session,
+        IReadOnlyCollection<ChatMessage> requestMessages,
+        AgentRunOptions? agentRunOptions)
+
+    public AIAgent Agent { get; }
+    public AgentSession? Session { get; }
+    public IReadOnlyCollection<ChatMessage> RequestMessages { get; }
+    public AgentRunOptions? RunOptions { get; }
+}
+```
+
+Key design decisions:
+
+- **All properties are read-only**: While some of the sub-properties on the provided properties (like `AgentRunOptions.AllowBackgroundResponses`) may be mutable, the `AgentRunContext` itself is immutable and we want to discourage anyone modifying the values in the context.  Modifying the context is unlikely to result in the desired behavior, as the values will typically already have been used by the time any custom code accesses them.
+
+### Benefits
+
+1. **Ambient Access**: Any code executing during the run can access context via `AIAgent.CurrentRunContext` without needing explicit parameters
+2. **Async Flow**: `AsyncLocal<T>` automatically flows across async/await boundaries
+3. **Modifiability**: Components can modify or replace session, messages, or options as needed
+4. **Testability**: The explicit parameter to `RunCoreAsync` makes unit testing straightforward

dotnet/AGENTS.md

@@ -0,0 +1,66 @@
+# AGENTS.md
+
+Instructions for AI coding agents working in the .NET codebase.
+
+## Build, Test, and Lint Commands
+
+```bash
+# From dotnet/ directory
+dotnet build              # Build all projects
+dotnet test               # Run all tests
+dotnet format             # Auto-fix formatting
+
+# Build/test a specific project (preferred for isolated changes)
+dotnet build src/Microsoft.Agents.AI.<Package>
+dotnet test tests/Microsoft.Agents.AI.<Package>.UnitTests
+
+# Run a single test
+dotnet test --filter "FullyQualifiedName~TestClassName.TestMethodName"
+```
+
+**Note**: Changes to core packages (`Microsoft.Agents.AI`, `Microsoft.Agents.AI.Abstractions`) affect dependent projects - run checks across the entire solution. For isolated changes, build/test only the affected project to save time.
+
+## Project Structure
+
+```
+dotnet/
+├── src/
+│   ├── Microsoft.Agents.AI/              # Core AI agent abstractions
+│   ├── Microsoft.Agents.AI.Abstractions/ # Shared abstractions and interfaces
+│   ├── Microsoft.Agents.AI.OpenAI/       # OpenAI provider
+│   ├── Microsoft.Agents.AI.AzureAI/      # Azure AI provider
+│   ├── Microsoft.Agents.AI.Anthropic/    # Anthropic provider
+│   ├── Microsoft.Agents.AI.Workflows/    # Workflow orchestration
+│   └── ...                               # Other packages
+├── samples/                              # Sample applications
+└── tests/                                # Unit and integration tests
+```
+
+### External Dependencies
+
+The framework integrates with `Microsoft.Extensions.AI` and `Microsoft.Extensions.AI.Abstractions` (external NuGet packages) using types like `IChatClient`, `FunctionInvokingChatClient`, `AITool`, and `AIContent`.
+
+## Key Conventions
+
+- **Copyright header**: `// Copyright (c) Microsoft. All rights reserved.` at top of all `.cs` files
+- **XML docs**: Required for all public methods and classes
+- **Async**: Use `Async` suffix for methods returning `Task`/`ValueTask`
+- **Private classes**: Should be `sealed` unless subclassed
+- **Config**: Read from environment variables with `UPPER_SNAKE_CASE` naming
+- **Tests**: Add Arrange/Act/Assert comments; use Moq for mocking
+
+## Sample Structure
+
+1. Copyright header: `// Copyright (c) Microsoft. All rights reserved.`
+2. Description comment explaining what the sample demonstrates
+3. Using statements
+4. Main code logic
+5. Helper methods at bottom
+
+Configuration via environment variables (never hardcode secrets). Keep samples simple and focused.
+
+When adding a new sample:
+- Create a standalone project in `samples/` with matching directory and project names
+- Include a README.md explaining what the sample does and how to run it
+- Add the project to the solution file
+- Reference the sample in the parent directory's README.md

dotnet/Directory.Packages.props

@@ -113,14 +113,14 @@
     <PackageVersion Include="Microsoft.Agents.ObjectModel.PowerFx" Version="2026.1.2.3" />
     <PackageVersion Include="Microsoft.PowerFx.Interpreter" Version="1.5.0-build.20251008-1002" />
     <!-- Durable Task -->
-    <PackageVersion Include="Microsoft.DurableTask.Client" Version="1.19.1" />
-    <PackageVersion Include="Microsoft.DurableTask.Client.AzureManaged" Version="1.19.0" />
-    <PackageVersion Include="Microsoft.DurableTask.Worker" Version="1.19.0" />
-    <PackageVersion Include="Microsoft.DurableTask.Worker.AzureManaged" Version="1.19.0" />
+    <PackageVersion Include="Microsoft.DurableTask.Client" Version="1.18.0" />
+    <PackageVersion Include="Microsoft.DurableTask.Client.AzureManaged" Version="1.18.0" />
+    <PackageVersion Include="Microsoft.DurableTask.Worker" Version="1.18.0" />
+    <PackageVersion Include="Microsoft.DurableTask.Worker.AzureManaged" Version="1.18.0" />
     <!-- Azure Functions -->
     <PackageVersion Include="Microsoft.Azure.Functions.Worker" Version="2.50.0" />
     <PackageVersion Include="Microsoft.Azure.Functions.Worker.ApplicationInsights" Version="2.50.0" />
-    <PackageVersion Include="Microsoft.Azure.Functions.Worker.Extensions.DurableTask" Version="1.13.1" />
+    <PackageVersion Include="Microsoft.Azure.Functions.Worker.Extensions.DurableTask" Version="1.11.0" />
     <PackageVersion Include="Microsoft.Azure.Functions.Worker.Extensions.DurableTask.AzureManaged" Version="1.0.1" />
     <PackageVersion Include="Microsoft.Azure.Functions.Worker.Extensions.Http" Version="3.3.0" />
     <PackageVersion Include="Microsoft.Azure.Functions.Worker.Extensions.Http.AspNetCore" Version="2.1.0" />

dotnet/agent-framework-dotnet.slnx

@@ -47,20 +47,6 @@
     <Project Path="samples/Durable/Agents/ConsoleApps/06_LongRunningTools/06_LongRunningTools.csproj" />
     <Project Path="samples/Durable/Agents/ConsoleApps/07_ReliableStreaming/07_ReliableStreaming.csproj" />
   </Folder>
-  <Folder Name="/Samples/Durable/Workflows/">
-    <Project Path="samples/Durable/Workflow/ConsoleApps/01_SequentialWorkflow/01_SequentialWorkflow.csproj" />
-    <Project Path="samples/Durable/Workflow/ConsoleApps/02_ConcurrentWorkflow/02_ConcurrentWorkflow.csproj" />
-    <Project Path="samples/Durable/Workflow/ConsoleApps/03_ConditionalEdges/03_ConditionalEdges.csproj" />
-    <Project Path="samples/Durable/Workflow/ConsoleApps/04_WorkflowAndAgents/04_WorkflowAndAgents.csproj" />
-    <Project Path="samples/Durable/Workflow/ConsoleApps/05_WorkflowEvents/05_WorkflowEvents.csproj" />
-    <Project Path="samples/Durable/Workflow/ConsoleApps/06_WorkflowSharedState/06_WorkflowSharedState.csproj" />
-    <Project Path="samples/Durable/Workflow/ConsoleApps/07_SubWorkflows/07_SubWorkflows.csproj" />
-    <Project Path="samples/Durable/Workflow/ConsoleApps/08_WorkflowLoop/08_WorkflowLoop.csproj" />
-  </Folder>
-  <Folder Name="/Samples/Durable/Workflows/AzureFunctions/">
-    <Project Path="samples/Durable/Workflow/AzureFunctions/01_SequentialWorkflow/01_SequentialWorkflow.csproj" />
-    <Project Path="samples/Durable/Workflow/AzureFunctions/02_ConcurrentWorkflow/02_ConcurrentWorkflow.csproj" />
-  </Folder>
   <Folder Name="/Samples/GettingStarted/">
     <File Path="samples/GettingStarted/README.md" />
   </Folder>
@@ -95,7 +81,7 @@
     <Project Path="samples/GettingStarted/Agents/Agent_Step04_UsingFunctionToolsWithApprovals/Agent_Step04_UsingFunctionToolsWithApprovals.csproj" />
     <Project Path="samples/GettingStarted/Agents/Agent_Step05_StructuredOutput/Agent_Step05_StructuredOutput.csproj" />
     <Project Path="samples/GettingStarted/Agents/Agent_Step06_PersistedConversations/Agent_Step06_PersistedConversations.csproj" />
-    <Project Path="samples/GettingStarted/Agents/Agent_Step07_3rdPartyThreadStorage/Agent_Step07_3rdPartyThreadStorage.csproj" />
+    <Project Path="samples/GettingStarted/Agents/Agent_Step07_3rdPartyChatHistoryStorage/Agent_Step07_3rdPartyChatHistoryStorage.csproj" />
     <Project Path="samples/GettingStarted/Agents/Agent_Step08_Observability/Agent_Step08_Observability.csproj" />
     <Project Path="samples/GettingStarted/Agents/Agent_Step09_DependencyInjection/Agent_Step09_DependencyInjection.csproj" />
     <Project Path="samples/GettingStarted/Agents/Agent_Step10_AsMcpTool/Agent_Step10_AsMcpTool.csproj" />
@@ -145,6 +131,7 @@
     <Project Path="samples/GettingStarted/AgentWithAnthropic/Agent_Anthropic_Step01_Running/Agent_Anthropic_Step01_Running.csproj" />
     <Project Path="samples/GettingStarted/AgentWithAnthropic/Agent_Anthropic_Step02_Reasoning/Agent_Anthropic_Step02_Reasoning.csproj" />
     <Project Path="samples/GettingStarted/AgentWithAnthropic/Agent_Anthropic_Step03_UsingFunctionTools/Agent_Anthropic_Step03_UsingFunctionTools.csproj" />
+    <Project Path="samples/GettingStarted/AgentWithAnthropic/Agent_Anthropic_Step04_UsingSkills/Agent_Anthropic_Step04_UsingSkills.csproj" />
   </Folder>
   <Folder Name="/Samples/GettingStarted/AgentWithMemory/">
     <File Path="samples/GettingStarted/AgentWithMemory/README.md" />

dotnet/nuget/nuget-package.props

@@ -2,9 +2,9 @@
   <PropertyGroup>
     <!-- Central version prefix - applies to all nuget packages. -->
     <VersionPrefix>1.0.0</VersionPrefix>
-    <PackageVersion Condition="'$(VersionSuffix)' != ''">$(VersionPrefix)-$(VersionSuffix).260128.1</PackageVersion>
-    <PackageVersion Condition="'$(VersionSuffix)' == ''">$(VersionPrefix)-preview.260128.1</PackageVersion>
-    <GitTag>1.0.0-preview.260128.1</GitTag>
+    <PackageVersion Condition="'$(VersionSuffix)' != ''">$(VersionPrefix)-$(VersionSuffix).260209.1</PackageVersion>
+    <PackageVersion Condition="'$(VersionSuffix)' == ''">$(VersionPrefix)-preview.260209.1</PackageVersion>
+    <GitTag>1.0.0-preview.260209.1</GitTag>
 
     <Configurations>Debug;Release;Publish</Configurations>
     <IsPackable>true</IsPackable>

dotnet/samples/A2AClientServer/A2AClient/Program.cs

@@ -42,7 +42,7 @@ public static class Program
         // Create the Host agent
         var hostAgent = new HostClientAgent(loggerFactory);
         await hostAgent.InitializeAgentAsync(modelId, apiKey, agentUrls!.Split(";"));
-        AgentSession session = await hostAgent.Agent!.GetNewSessionAsync(cancellationToken);
+        AgentSession session = await hostAgent.Agent!.CreateSessionAsync(cancellationToken);
         try
         {
             while (true)

dotnet/samples/AGUIClientServer/AGUIClient/Program.cs

@@ -88,7 +88,7 @@ public static class Program
             description: "AG-UI Client Agent",
             tools: [changeBackground, readClientClimateSensors]);
 
-        AgentSession session = await agent.GetNewSessionAsync(cancellationToken);
+        AgentSession session = await agent.CreateSessionAsync(cancellationToken);
         List<ChatMessage> messages = [new(ChatRole.System, "You are a helpful assistant.")];
         try
         {

dotnet/samples/Durable/Agents/AzureFunctions/01_SingleAgent/Program.cs

@@ -1,5 +1,7 @@
 // Copyright (c) Microsoft. All rights reserved.
 
+#pragma warning disable IDE0002 // Simplify Member Access
+
 using Azure;
 using Azure.AI.OpenAI;
 using Azure.Identity;

dotnet/samples/Durable/Agents/AzureFunctions/02_AgentOrchestration_Chaining/FunctionTriggers.cs

@@ -19,7 +19,7 @@ public static class FunctionTriggers
     public static async Task<string> RunOrchestrationAsync([OrchestrationTrigger] TaskOrchestrationContext context)
     {
         DurableAIAgent writer = context.GetAgent("WriterAgent");
-        AgentSession writerSession = await writer.GetNewSessionAsync();
+        AgentSession writerSession = await writer.CreateSessionAsync();
 
         AgentResponse<TextResponse> initial = await writer.RunAsync<TextResponse>(
             message: "Write a concise inspirational sentence about learning.",

dotnet/samples/Durable/Agents/AzureFunctions/02_AgentOrchestration_Chaining/Program.cs

@@ -1,5 +1,7 @@
 // Copyright (c) Microsoft. All rights reserved.
 
+#pragma warning disable IDE0002 // Simplify Member Access
+
 using Azure;
 using Azure.AI.OpenAI;
 using Azure.Identity;

dotnet/samples/Durable/Agents/AzureFunctions/03_AgentOrchestration_Concurrency/Program.cs

@@ -1,5 +1,7 @@
 // Copyright (c) Microsoft. All rights reserved.
 
+#pragma warning disable IDE0002 // Simplify Member Access
+
 using Azure;
 using Azure.AI.OpenAI;
 using Azure.Identity;

dotnet/samples/Durable/Agents/AzureFunctions/04_AgentOrchestration_Conditionals/FunctionTriggers.cs

@@ -21,7 +21,7 @@ public static class FunctionTriggers
 
         // Get the spam detection agent
         DurableAIAgent spamDetectionAgent = context.GetAgent("SpamDetectionAgent");
-        AgentSession spamSession = await spamDetectionAgent.GetNewSessionAsync();
+        AgentSession spamSession = await spamDetectionAgent.CreateSessionAsync();
 
         // Step 1: Check if the email is spam
         AgentResponse<DetectionResult> spamDetectionResponse = await spamDetectionAgent.RunAsync<DetectionResult>(
@@ -43,7 +43,7 @@ public static class FunctionTriggers
 
         // Generate and send response for legitimate email
         DurableAIAgent emailAssistantAgent = context.GetAgent("EmailAssistantAgent");
-        AgentSession emailSession = await emailAssistantAgent.GetNewSessionAsync();
+        AgentSession emailSession = await emailAssistantAgent.CreateSessionAsync();
 
         AgentResponse<EmailResponse> emailAssistantResponse = await emailAssistantAgent.RunAsync<EmailResponse>(
             message:

dotnet/samples/Durable/Agents/AzureFunctions/04_AgentOrchestration_Conditionals/Program.cs

@@ -1,5 +1,7 @@
 // Copyright (c) Microsoft. All rights reserved.
 
+#pragma warning disable IDE0002 // Simplify Member Access
+
 using Azure;
 using Azure.AI.OpenAI;
 using Azure.Identity;

dotnet/samples/Durable/Agents/AzureFunctions/05_AgentOrchestration_HITL/FunctionTriggers.cs

@@ -24,7 +24,7 @@ public static class FunctionTriggers
 
         // Get the writer agent
         DurableAIAgent writerAgent = context.GetAgent("WriterAgent");
-        AgentSession writerSession = await writerAgent.GetNewSessionAsync();
+        AgentSession writerSession = await writerAgent.CreateSessionAsync();
 
         // Set initial status
         context.SetCustomStatus($"Starting content generation for topic: {input.Topic}");

dotnet/samples/Durable/Agents/AzureFunctions/05_AgentOrchestration_HITL/Program.cs

@@ -1,5 +1,7 @@
 // Copyright (c) Microsoft. All rights reserved.
 
+#pragma warning disable IDE0002 // Simplify Member Access
+
 using Azure;
 using Azure.AI.OpenAI;
 using Azure.Identity;

dotnet/samples/Durable/Agents/AzureFunctions/06_LongRunningTools/FunctionTriggers.cs

@@ -20,7 +20,7 @@ public static class FunctionTriggers
 
         // Get the writer agent
         DurableAIAgent writerAgent = context.GetAgent("Writer");
-        AgentSession writerSession = await writerAgent.GetNewSessionAsync();
+        AgentSession writerSession = await writerAgent.CreateSessionAsync();
 
         // Set initial status
         context.SetCustomStatus($"Starting content generation for topic: {input.Topic}");

dotnet/samples/Durable/Agents/AzureFunctions/06_LongRunningTools/Program.cs

@@ -1,5 +1,7 @@
 // Copyright (c) Microsoft. All rights reserved.
 
+#pragma warning disable IDE0002 // Simplify Member Access
+
 using Azure;
 using Azure.AI.OpenAI;
 using Azure.Identity;

dotnet/samples/Durable/Agents/AzureFunctions/07_AgentAsMcpTool/Program.cs

@@ -5,6 +5,8 @@
 // generate a remote MCP endpoint for the app at /runtime/webhooks/mcp with a agent-specific
 // query tool name.
 
+#pragma warning disable IDE0002 // Simplify Member Access
+
 using Azure;
 using Azure.AI.OpenAI;
 using Azure.Identity;

dotnet/samples/Durable/Agents/AzureFunctions/08_ReliableStreaming/FunctionTriggers.cs

@@ -95,7 +95,7 @@ public sealed class FunctionTriggers
         AIAgent agentProxy = durableClient.AsDurableAgentProxy(context, "TravelPlanner");
 
         // Create a new agent session
-        AgentSession session = await agentProxy.GetNewSessionAsync(cancellationToken);
+        AgentSession session = await agentProxy.CreateSessionAsync(cancellationToken);
         string agentSessionId = session.GetService<AgentSessionId>().ToString();
 
         this._logger.LogInformation("Creating new agent session: {AgentSessionId}", agentSessionId);

dotnet/samples/Durable/Agents/AzureFunctions/08_ReliableStreaming/Program.cs

@@ -8,6 +8,8 @@
 // This pattern is inspired by OpenAI's background mode for the Responses API, which allows clients
 // to disconnect and reconnect to ongoing agent responses without losing messages.
 
+#pragma warning disable IDE0002 // Simplify Member Access
+
 using Azure;
 using Azure.AI.OpenAI;
 using Azure.Identity;

dotnet/samples/Durable/Agents/ConsoleApps/01_SingleAgent/Program.cs

@@ -61,7 +61,7 @@ Console.WriteLine("Enter a message for the Joker agent (or 'exit' to quit):");
 Console.WriteLine();
 
 // Create a session for the conversation
-AgentSession session = await agentProxy.GetNewSessionAsync();
+AgentSession session = await agentProxy.CreateSessionAsync();
 
 while (true)
 {

dotnet/samples/Durable/Agents/ConsoleApps/02_AgentOrchestration_Chaining/Program.cs

@@ -47,7 +47,7 @@ AIAgent writerAgent = client.GetChatClient(deploymentName).AsAIAgent(WriterInstr
 static async Task<string> RunOrchestratorAsync(TaskOrchestrationContext context)
 {
     DurableAIAgent writer = context.GetAgent("WriterAgent");
-    AgentSession writerSession = await writer.GetNewSessionAsync();
+    AgentSession writerSession = await writer.CreateSessionAsync();
 
     AgentResponse<TextResponse> initial = await writer.RunAsync<TextResponse>(
         message: "Write a concise inspirational sentence about learning.",

dotnet/samples/Durable/Agents/ConsoleApps/04_AgentOrchestration_Conditionals/Program.cs

@@ -56,7 +56,7 @@ static async Task<string> RunOrchestratorAsync(TaskOrchestrationContext context,
 {
     // Get the spam detection agent
     DurableAIAgent spamDetectionAgent = context.GetAgent(SpamDetectionAgentName);
-    AgentSession spamSession = await spamDetectionAgent.GetNewSessionAsync();
+    AgentSession spamSession = await spamDetectionAgent.CreateSessionAsync();
 
     // Step 1: Check if the email is spam
     AgentResponse<DetectionResult> spamDetectionResponse = await spamDetectionAgent.RunAsync<DetectionResult>(
@@ -78,7 +78,7 @@ static async Task<string> RunOrchestratorAsync(TaskOrchestrationContext context,
 
     // Generate and send response for legitimate email
     DurableAIAgent emailAssistantAgent = context.GetAgent(EmailAssistantAgentName);
-    AgentSession emailSession = await emailAssistantAgent.GetNewSessionAsync();
+    AgentSession emailSession = await emailAssistantAgent.CreateSessionAsync();
 
     AgentResponse<EmailResponse> emailAssistantResponse = await emailAssistantAgent.RunAsync<EmailResponse>(
         message:

dotnet/samples/Durable/Agents/ConsoleApps/05_AgentOrchestration_HITL/Program.cs

@@ -48,7 +48,7 @@ static async Task<object> RunOrchestratorAsync(TaskOrchestrationContext context,
 {
     // Get the writer agent
     DurableAIAgent writerAgent = context.GetAgent("WriterAgent");
-    AgentSession writerSession = await writerAgent.GetNewSessionAsync();
+    AgentSession writerSession = await writerAgent.CreateSessionAsync();
 
     // Set initial status
     context.SetCustomStatus($"Starting content generation for topic: {input.Topic}");

dotnet/samples/Durable/Agents/ConsoleApps/06_LongRunningTools/Program.cs

@@ -59,7 +59,7 @@ static async Task<object> RunOrchestratorAsync(TaskOrchestrationContext context,
 {
     // Get the writer agent
     DurableAIAgent writerAgent = context.GetAgent(WriterAgentName);
-    AgentSession writerSession = await writerAgent.GetNewSessionAsync();
+    AgentSession writerSession = await writerAgent.CreateSessionAsync();
 
     // Set initial status
     context.SetCustomStatus($"Starting content generation for topic: {input.Topic}");
@@ -299,7 +299,7 @@ Console.WriteLine("Enter a topic for the Publisher agent to write about (or 'exi
 Console.WriteLine();
 
 // Create a session for the conversation
-AgentSession session = await agentProxy.GetNewSessionAsync();
+AgentSession session = await agentProxy.CreateSessionAsync();
 
 using CancellationTokenSource cts = new();
 Console.CancelKeyPress += (sender, e) =>

dotnet/samples/Durable/Agents/ConsoleApps/07_ReliableStreaming/Program.cs

@@ -305,7 +305,7 @@ if (string.IsNullOrWhiteSpace(prompt) || prompt.Equals("exit", StringComparison.
 }
 
 // Create a new agent session
-AgentSession session = await agentProxy.GetNewSessionAsync();
+AgentSession session = await agentProxy.CreateSessionAsync();
 AgentSessionId sessionId = session.GetService<AgentSessionId>();
 string conversationId = sessionId.ToString();
 

dotnet/samples/Durable/Workflow/AzureFunctions/01_SequentialWorkflow/01_SequentialWorkflow.csproj

@@ -1,42 +0,0 @@
-<Project Sdk="Microsoft.NET.Sdk">
-  <PropertyGroup>
-    <TargetFrameworks>net10.0</TargetFrameworks>
-    <AzureFunctionsVersion>v4</AzureFunctionsVersion>
-    <OutputType>Exe</OutputType>
-    <ImplicitUsings>enable</ImplicitUsings>
-    <Nullable>enable</Nullable>
-    <!-- The Functions build tools don't like namespaces that start with a number -->
-    <AssemblyName>SingleAgent</AssemblyName>
-    <RootNamespace>SingleAgent</RootNamespace>
-  </PropertyGroup>
-
-  <ItemGroup>
-    <FrameworkReference Include="Microsoft.AspNetCore.App" />
-  </ItemGroup>
-
-  <!-- Azure Functions packages -->
-  <ItemGroup>
-    <PackageReference Include="Microsoft.Azure.Functions.Worker" />
-    <PackageReference Include="Microsoft.Azure.Functions.Worker.Extensions.DurableTask" />
-    <PackageReference Include="Microsoft.Azure.Functions.Worker.Extensions.DurableTask.AzureManaged" />
-    <PackageReference Include="Microsoft.Azure.Functions.Worker.Extensions.Http.AspNetCore" />
-    <PackageReference Include="Microsoft.Azure.Functions.Worker.Sdk" />
-  </ItemGroup>
-
-  <ItemGroup>
-    <PackageReference Include="Azure.AI.OpenAI" />
-    <PackageReference Include="Azure.Identity" />
-  </ItemGroup>
-
-  <!-- Local projects that should be switched to package references when using the sample outside of this MAF repo -->
-  <!--
-  <ItemGroup>
-    <PackageReference Include="Microsoft.Agents.AI.Hosting.AzureFunctions" />
-    <PackageReference Include="Microsoft.Agents.AI.OpenAI" />
-  </ItemGroup>
-  -->
-  <ItemGroup>
-    <ProjectReference Include="..\..\..\..\..\src\Microsoft.Agents.AI.Hosting.AzureFunctions\Microsoft.Agents.AI.Hosting.AzureFunctions.csproj" />
-    <ProjectReference Include="..\..\..\..\..\src\Microsoft.Agents.AI.OpenAI\Microsoft.Agents.AI.OpenAI.csproj" />
-  </ItemGroup>
-</Project>

dotnet/samples/Durable/Workflow/AzureFunctions/01_SequentialWorkflow/OrderCancelExecutors.cs

@@ -1,215 +0,0 @@
-// Copyright (c) Microsoft. All rights reserved.
-
-using Microsoft.Agents.AI.Workflows;
-
-namespace SequentialWorkflow;
-
-/// <summary>
-/// Looks up an order by its ID and return an Order object.
-/// </summary>
-internal sealed class OrderLookup() : Executor<string, Order>("OrderLookup")
-{
-    public override async ValueTask<Order> HandleAsync(
-        string message,
-        IWorkflowContext context,
-        CancellationToken cancellationToken = default)
-    {
-        Console.WriteLine();
-        Console.ForegroundColor = ConsoleColor.Magenta;
-        Console.WriteLine("┌─────────────────────────────────────────────────────────────────┐");
-        Console.WriteLine($"│ [Activity] OrderLookup: Starting lookup for order '{message}'");
-        Console.ResetColor();
-
-        // Simulate database lookup with delay
-        await Task.Delay(TimeSpan.FromMicroseconds(100), cancellationToken);
-
-        Order order = new(
-            Id: message,
-            OrderDate: DateTime.UtcNow.AddDays(-1),
-            IsCancelled: false,
-            Customer: new Customer(Name: "Jerry", Email: "jerry@example.com"));
-
-        Console.ForegroundColor = ConsoleColor.Magenta;
-        Console.WriteLine($"│ [Activity] OrderLookup: Found order '{message}' for customer '{order.Customer.Name}'");
-        Console.WriteLine("└─────────────────────────────────────────────────────────────────┘");
-        Console.ResetColor();
-
-        return order;
-    }
-}
-
-/// <summary>
-/// Cancels an order.
-/// </summary>
-internal sealed class OrderCancel() : Executor<Order, Order>("OrderCancel")
-{
-    public override async ValueTask<Order> HandleAsync(
-        Order message,
-        IWorkflowContext context,
-        CancellationToken cancellationToken = default)
-    {
-        Console.WriteLine();
-        Console.ForegroundColor = ConsoleColor.Yellow;
-        Console.WriteLine("┌─────────────────────────────────────────────────────────────────┐");
-        Console.WriteLine($"│ [Activity] OrderCancel: Starting cancellation for order '{message.Id}'");
-        Console.ResetColor();
-
-        // Simulate a slow cancellation process (e.g., calling external payment system)
-        for (int i = 1; i <= 3; i++)
-        {
-            await Task.Delay(TimeSpan.FromMilliseconds(100), cancellationToken);
-            Console.ForegroundColor = ConsoleColor.DarkYellow;
-            Console.WriteLine("│ [Activity] OrderCancel: Processing...");
-            Console.ResetColor();
-        }
-
-        Order cancelledOrder = message with { IsCancelled = true };
-
-        Console.ForegroundColor = ConsoleColor.Yellow;
-        Console.WriteLine($"│ [Activity] OrderCancel: ✓ Order '{cancelledOrder.Id}' has been cancelled");
-        Console.WriteLine("└─────────────────────────────────────────────────────────────────┘");
-        Console.ResetColor();
-
-        return cancelledOrder;
-    }
-}
-
-/// <summary>
-/// Sends a cancellation confirmation email to the customer.
-/// </summary>
-internal sealed class SendEmail() : Executor<Order, string>("SendEmail")
-{
-    public override ValueTask<string> HandleAsync(
-        Order message,
-        IWorkflowContext context,
-        CancellationToken cancellationToken = default)
-    {
-        Console.WriteLine();
-        Console.ForegroundColor = ConsoleColor.Cyan;
-        Console.WriteLine("┌─────────────────────────────────────────────────────────────────┐");
-        Console.WriteLine($"│ [Activity] SendEmail: Sending email to '{message.Customer.Email}'...");
-        Console.ResetColor();
-
-        string result = $"Cancellation email sent for order {message.Id} to {message.Customer.Email}.";
-
-        Console.ForegroundColor = ConsoleColor.Cyan;
-        Console.WriteLine("│ [Activity] SendEmail: ✓ Email sent successfully!");
-        Console.WriteLine("└─────────────────────────────────────────────────────────────────┘");
-        Console.ResetColor();
-
-        return ValueTask.FromResult(result);
-    }
-}
-
-internal sealed record Order(string Id, DateTime OrderDate, bool IsCancelled, Customer Customer);
-
-internal sealed record Customer(string Name, string Email);
-
-/// <summary>
-/// Represents a batch cancellation request with multiple order IDs and a reason.
-/// This demonstrates using a complex typed object as workflow input.
-/// </summary>
-#pragma warning disable CA1812 // Instantiated via JSON deserialization at runtime
-internal sealed record BatchCancelRequest(string[] OrderIds, string Reason, bool NotifyCustomers);
-#pragma warning restore CA1812
-
-/// <summary>
-/// Represents the result of processing a batch cancellation.
-/// </summary>
-internal sealed record BatchCancelResult(int TotalOrders, int CancelledCount, string Reason);
-
-/// <summary>
-/// Generates a status report for an order.
-/// </summary>
-internal sealed class StatusReport() : Executor<Order, string>("StatusReport")
-{
-    public override ValueTask<string> HandleAsync(
-        Order message,
-        IWorkflowContext context,
-        CancellationToken cancellationToken = default)
-    {
-        Console.WriteLine();
-        Console.ForegroundColor = ConsoleColor.Green;
-        Console.WriteLine("┌─────────────────────────────────────────────────────────────────┐");
-        Console.WriteLine($"│ [Activity] StatusReport: Generating report for order '{message.Id}'");
-        Console.ResetColor();
-
-        string status = message.IsCancelled ? "Cancelled" : "Active";
-        string result = $"Order {message.Id} for {message.Customer.Name}: Status={status}, Date={message.OrderDate:yyyy-MM-dd}";
-
-        Console.ForegroundColor = ConsoleColor.Green;
-        Console.WriteLine($"│ [Activity] StatusReport: ✓ {result}");
-        Console.WriteLine("└─────────────────────────────────────────────────────────────────┘");
-        Console.ResetColor();
-
-        return ValueTask.FromResult(result);
-    }
-}
-
-/// <summary>
-/// Processes a batch cancellation request. Accepts a complex <see cref="BatchCancelRequest"/> object
-/// as input, demonstrating how workflows can receive structured JSON input.
-/// </summary>
-internal sealed class BatchCancelProcessor() : Executor<BatchCancelRequest, BatchCancelResult>("BatchCancelProcessor")
-{
-    public override async ValueTask<BatchCancelResult> HandleAsync(
-        BatchCancelRequest message,
-        IWorkflowContext context,
-        CancellationToken cancellationToken = default)
-    {
-        Console.WriteLine();
-        Console.ForegroundColor = ConsoleColor.Yellow;
-        Console.WriteLine("┌─────────────────────────────────────────────────────────────────┐");
-        Console.WriteLine($"│ [Activity] BatchCancelProcessor: Processing {message.OrderIds.Length} orders");
-        Console.WriteLine($"│ [Activity] BatchCancelProcessor: Reason: {message.Reason}");
-        Console.WriteLine($"│ [Activity] BatchCancelProcessor: Notify customers: {message.NotifyCustomers}");
-        Console.ResetColor();
-
-        // Simulate processing each order
-        int cancelledCount = 0;
-        foreach (string orderId in message.OrderIds)
-        {
-            await Task.Delay(TimeSpan.FromMilliseconds(100), cancellationToken);
-            cancelledCount++;
-            Console.ForegroundColor = ConsoleColor.DarkYellow;
-            Console.WriteLine($"│ [Activity] BatchCancelProcessor: ✓ Cancelled order '{orderId}'");
-            Console.ResetColor();
-        }
-
-        BatchCancelResult result = new(message.OrderIds.Length, cancelledCount, message.Reason);
-
-        Console.ForegroundColor = ConsoleColor.Yellow;
-        Console.WriteLine($"│ [Activity] BatchCancelProcessor: ✓ Batch complete: {cancelledCount}/{message.OrderIds.Length} cancelled");
-        Console.WriteLine("└─────────────────────────────────────────────────────────────────┘");
-        Console.ResetColor();
-
-        return result;
-    }
-}
-
-/// <summary>
-/// Generates a summary of the batch cancellation.
-/// </summary>
-internal sealed class BatchCancelSummary() : Executor<BatchCancelResult, string>("BatchCancelSummary")
-{
-    public override ValueTask<string> HandleAsync(
-        BatchCancelResult message,
-        IWorkflowContext context,
-        CancellationToken cancellationToken = default)
-    {
-        Console.WriteLine();
-        Console.ForegroundColor = ConsoleColor.Cyan;
-        Console.WriteLine("┌─────────────────────────────────────────────────────────────────┐");
-        Console.WriteLine("│ [Activity] BatchCancelSummary: Generating summary");
-        Console.ResetColor();
-
-        string result = $"Batch cancellation complete: {message.CancelledCount}/{message.TotalOrders} orders cancelled. Reason: {message.Reason}";
-
-        Console.ForegroundColor = ConsoleColor.Cyan;
-        Console.WriteLine($"│ [Activity] BatchCancelSummary: ✓ {result}");
-        Console.WriteLine("└─────────────────────────────────────────────────────────────────┘");
-        Console.ResetColor();
-
-        return ValueTask.FromResult(result);
-    }
-}

dotnet/samples/Durable/Workflow/AzureFunctions/01_SequentialWorkflow/Program.cs

@@ -1,52 +0,0 @@
-// Copyright (c) Microsoft. All rights reserved.
-
-// This sample demonstrates three workflows that share executors.
-// The CancelOrder workflow cancels an order and notifies the customer.
-// The OrderStatus workflow looks up an order and generates a status report.
-// The BatchCancelOrders workflow accepts a complex JSON input to cancel multiple orders.
-// Both CancelOrder and OrderStatus reuse the same OrderLookup executor, demonstrating executor sharing.
-
-using Microsoft.Agents.AI.Hosting.AzureFunctions;
-using Microsoft.Agents.AI.Workflows;
-using Microsoft.Azure.Functions.Worker.Builder;
-using Microsoft.Extensions.Hosting;
-using SequentialWorkflow;
-
-// Define executors for all workflows
-OrderLookup orderLookup = new();
-OrderCancel orderCancel = new();
-SendEmail sendEmail = new();
-StatusReport statusReport = new();
-BatchCancelProcessor batchCancelProcessor = new();
-BatchCancelSummary batchCancelSummary = new();
-
-// Build the CancelOrder workflow: OrderLookup -> OrderCancel -> SendEmail
-Workflow cancelOrder = new WorkflowBuilder(orderLookup)
-    .WithName("CancelOrder")
-    .WithDescription("Cancel an order and notify the customer")
-    .AddEdge(orderLookup, orderCancel)
-    .AddEdge(orderCancel, sendEmail)
-    .Build();
-
-// Build the OrderStatus workflow: OrderLookup -> StatusReport
-// This workflow shares the OrderLookup executor with the CancelOrder workflow.
-Workflow orderStatus = new WorkflowBuilder(orderLookup)
-    .WithName("OrderStatus")
-    .WithDescription("Look up an order and generate a status report")
-    .AddEdge(orderLookup, statusReport)
-    .Build();
-
-// Build the BatchCancelOrders workflow: BatchCancelProcessor -> BatchCancelSummary
-// This workflow demonstrates using a complex JSON object as the workflow input.
-Workflow batchCancelOrders = new WorkflowBuilder(batchCancelProcessor)
-    .WithName("BatchCancelOrders")
-    .WithDescription("Cancel multiple orders in a batch using a complex JSON input")
-    .AddEdge(batchCancelProcessor, batchCancelSummary)
-    .Build();
-
-using IHost app = FunctionsApplication
-    .CreateBuilder(args)
-    .ConfigureFunctionsWebApplication()
-    .ConfigureDurableWorkflows(workflows => workflows.AddWorkflows(cancelOrder, orderStatus, batchCancelOrders))
-    .Build();
-app.Run();

dotnet/samples/Durable/Workflow/AzureFunctions/01_SequentialWorkflow/README.md

@@ -1,100 +0,0 @@
-# Sequential Workflow Sample
-
-This sample demonstrates how to use the Microsoft Agent Framework to create an Azure Functions app that hosts durable workflows with sequential executor chains. It showcases two workflows that share a common executor, demonstrating executor reuse across workflows.
-
-## Key Concepts Demonstrated
-
-- Defining workflows with sequential executor chains using `WorkflowBuilder`
-- Sharing executors across multiple workflows (the `OrderLookup` executor is used by both workflows)
-- Registering workflows with the Function app using `ConfigureDurableWorkflows`
-- Durable orchestration ensuring workflows survive process restarts and failures
-- Starting workflows via HTTP requests
-- Viewing workflow execution history and status in the Durable Task Scheduler (DTS) dashboard
-
-## Workflows
-
-This sample defines two workflows:
-
-1. **CancelOrder**: `OrderLookup` → `OrderCancel` → `SendEmail` — Looks up an order, cancels it, and sends a confirmation email.
-2. **OrderStatus**: `OrderLookup` → `StatusReport` — Looks up an order and generates a status report.
-
-Both workflows share the `OrderLookup` executor, which is registered only once by the framework.
-
-## Environment Setup
-
-See the [README.md](../../README.md) file in the parent directory for more information on how to configure the environment, including how to install and run common sample dependencies.
-
-## Running the Sample
-
-With the environment setup and function app running, you can test the sample by sending HTTP requests to the workflow endpoints.
-
-You can use the `demo.http` file to trigger the workflows, or a command line tool like `curl` as shown below:
-
-### Cancel an Order
-
-Bash (Linux/macOS/WSL):
-
-```bash
-curl -X POST http://localhost:7071/api/workflows/CancelOrder/run \
-    -H "Content-Type: text/plain" \
-    -d "12345"
-```
-
-PowerShell:
-
-```powershell
-Invoke-RestMethod -Method Post `
-    -Uri http://localhost:7071/api/workflows/CancelOrder/run `
-    -ContentType text/plain `
-    -Body "12345"
-```
-
-The response will confirm the workflow orchestration has started:
-
-```text
-Workflow orchestration started for CancelOrder. Orchestration runId: abc123def456
-```
-
-> **Tip:** You can provide a custom run ID by appending a `runId` query parameter:
->
-> ```bash
-> curl -X POST "http://localhost:7071/api/workflows/CancelOrder/run?runId=my-order-123" \
->     -H "Content-Type: text/plain" \
->     -d "12345"
-> ```
->
-> If not provided, a unique run ID is auto-generated.
-
-In the function app logs, you will see the sequential execution of each executor:
-
-```text
-│ [Activity] OrderLookup: Starting lookup for order '12345'
-│ [Activity] OrderLookup: Found order '12345' for customer 'Jerry'
-│ [Activity] OrderCancel: Starting cancellation for order '12345'
-│ [Activity] OrderCancel: ✓ Order '12345' has been cancelled
-│ [Activity] SendEmail: Sending email to 'jerry@example.com'...
-│ [Activity] SendEmail: ✓ Email sent successfully!
-```
-
-### Get Order Status
-
-```bash
-curl -X POST http://localhost:7071/api/workflows/OrderStatus/run \
-    -H "Content-Type: text/plain" \
-    -d "12345"
-```
-
-The `OrderStatus` workflow reuses the same `OrderLookup` executor and then generates a status report:
-
-```text
-│ [Activity] OrderLookup: Starting lookup for order '12345'
-│ [Activity] OrderLookup: Found order '12345' for customer 'Jerry'
-│ [Activity] StatusReport: Generating report for order '12345'
-│ [Activity] StatusReport: ✓ Order 12345 for Jerry: Status=Active, Date=2025-01-01
-```
-
-### Viewing Workflows in the DTS Dashboard
-
-After running a workflow, you can navigate to the Durable Task Scheduler (DTS) dashboard to visualize the completed orchestration, inspect inputs/outputs for each step, and view execution history.
-
-If you are using the DTS emulator, the dashboard is available at `http://localhost:8082`.

dotnet/samples/Durable/Workflow/AzureFunctions/01_SequentialWorkflow/demo.http

@@ -1,26 +0,0 @@
-# Default endpoint address for local testing
-@authority=http://localhost:7071
-
-### Cancel an order
-POST {{authority}}/api/workflows/CancelOrder/run
-Content-Type: text/plain
-
-12345
-
-### Cancel an order with a custom run ID
-POST {{authority}}/api/workflows/CancelOrder/run?runId=my-custom-id-123
-Content-Type: text/plain
-
-99999
-
-### Get order status (shares OrderLookup executor with CancelOrder)
-POST {{authority}}/api/workflows/OrderStatus/run
-Content-Type: text/plain
-
-12345
-
-### Batch cancel orders with a complex JSON input
-POST {{authority}}/api/workflows/BatchCancelOrders/run
-Content-Type: application/json
-
-{"orderIds": ["1001", "1002", "1003"], "reason": "Customer requested cancellation", "notifyCustomers": true}

dotnet/samples/Durable/Workflow/AzureFunctions/01_SequentialWorkflow/host.json

@@ -1,20 +0,0 @@
-{
-  "version": "2.0",
-  "logging": {
-    "logLevel": {
-      "Microsoft.Agents.AI.DurableTask": "Information",
-      "Microsoft.Agents.AI.Hosting.AzureFunctions": "Information",
-      "DurableTask": "Information",
-      "Microsoft.DurableTask": "Information"
-    }
-  },
-  "extensions": {
-    "durableTask": {
-      "hubName": "default",
-      "storageProvider": {
-        "type": "AzureManaged",
-        "connectionStringName": "DURABLE_TASK_SCHEDULER_CONNECTION_STRING"
-      }
-    }
-  }
-}

dotnet/samples/Durable/Workflow/AzureFunctions/02_ConcurrentWorkflow/02_ConcurrentWorkflow.csproj

@@ -1,42 +0,0 @@
-<Project Sdk="Microsoft.NET.Sdk">
-  <PropertyGroup>
-    <TargetFrameworks>net10.0</TargetFrameworks>
-    <AzureFunctionsVersion>v4</AzureFunctionsVersion>
-    <OutputType>Exe</OutputType>
-    <ImplicitUsings>enable</ImplicitUsings>
-    <Nullable>enable</Nullable>
-    <!-- The Functions build tools don't like namespaces that start with a number -->
-    <AssemblyName>SingleAgent</AssemblyName>
-    <RootNamespace>SingleAgent</RootNamespace>
-  </PropertyGroup>
-
-  <ItemGroup>
-    <FrameworkReference Include="Microsoft.AspNetCore.App" />
-  </ItemGroup>
-
-  <!-- Azure Functions packages -->
-  <ItemGroup>
-    <PackageReference Include="Microsoft.Azure.Functions.Worker" />
-    <PackageReference Include="Microsoft.Azure.Functions.Worker.Extensions.DurableTask" />
-    <PackageReference Include="Microsoft.Azure.Functions.Worker.Extensions.DurableTask.AzureManaged" />
-    <PackageReference Include="Microsoft.Azure.Functions.Worker.Extensions.Http.AspNetCore" />
-    <PackageReference Include="Microsoft.Azure.Functions.Worker.Sdk" />
-  </ItemGroup>
-
-  <ItemGroup>
-    <PackageReference Include="Azure.AI.OpenAI" />
-    <PackageReference Include="Azure.Identity" />
-  </ItemGroup>
-
-  <!-- Local projects that should be switched to package references when using the sample outside of this MAF repo -->
-  <!--
-  <ItemGroup>
-    <PackageReference Include="Microsoft.Agents.AI.Hosting.AzureFunctions" />
-    <PackageReference Include="Microsoft.Agents.AI.OpenAI" />
-  </ItemGroup>
-  -->
-  <ItemGroup>
-    <ProjectReference Include="..\..\..\..\..\src\Microsoft.Agents.AI.Hosting.AzureFunctions\Microsoft.Agents.AI.Hosting.AzureFunctions.csproj" />
-    <ProjectReference Include="..\..\..\..\..\src\Microsoft.Agents.AI.OpenAI\Microsoft.Agents.AI.OpenAI.csproj" />
-  </ItemGroup>
-</Project>

dotnet/samples/Durable/Workflow/AzureFunctions/02_ConcurrentWorkflow/ExpertExecutors.cs

@@ -1,73 +0,0 @@
-// Copyright (c) Microsoft. All rights reserved.
-
-using Microsoft.Agents.AI.Workflows;
-
-namespace WorkflowConcurrency;
-
-/// <summary>
-/// Parses and validates the incoming question before sending to AI agents.
-/// </summary>
-internal sealed class ParseQuestionExecutor() : Executor<string, string>("ParseQuestion")
-{
-    public override ValueTask<string> HandleAsync(
-        string message,
-        IWorkflowContext context,
-        CancellationToken cancellationToken = default)
-    {
-        Console.WriteLine();
-        Console.ForegroundColor = ConsoleColor.Magenta;
-        Console.WriteLine("┌─────────────────────────────────────────────────────────────────┐");
-        Console.WriteLine("│ [ParseQuestion] Preparing question for AI agents...");
-
-        string formattedQuestion = message.Trim();
-        if (!formattedQuestion.EndsWith('?'))
-        {
-            formattedQuestion += "?";
-        }
-
-        Console.WriteLine($"│ [ParseQuestion] Question: \"{formattedQuestion}\"");
-        Console.WriteLine("│ [ParseQuestion] → Sending to Physicist and Chemist in PARALLEL...");
-        Console.WriteLine("└─────────────────────────────────────────────────────────────────┘");
-        Console.ResetColor();
-
-        return ValueTask.FromResult(formattedQuestion);
-    }
-}
-
-/// <summary>
-/// Aggregates responses from all AI agents into a comprehensive answer.
-/// This is the Fan-in point where parallel results are collected.
-/// </summary>
-internal sealed class AggregatorExecutor() : Executor<string[], string>("Aggregator")
-{
-    public override ValueTask<string> HandleAsync(
-        string[] message,
-        IWorkflowContext context,
-        CancellationToken cancellationToken = default)
-    {
-        Console.WriteLine();
-        Console.ForegroundColor = ConsoleColor.Cyan;
-        Console.WriteLine("┌─────────────────────────────────────────────────────────────────┐");
-        Console.WriteLine($"│ [Aggregator] 📋 Received {message.Length} AI agent responses");
-        Console.WriteLine("│ [Aggregator] Combining into comprehensive answer...");
-        Console.WriteLine("│ [Aggregator] ✓ Aggregation complete!");
-        Console.WriteLine("└─────────────────────────────────────────────────────────────────┘");
-        Console.ResetColor();
-
-        string aggregatedResult = "═══════════════════════════════════════════════════════════════\n" +
-                                 "                    AI EXPERT PANEL RESPONSES\n" +
-                                 "═══════════════════════════════════════════════════════════════\n\n";
-
-        for (int i = 0; i < message.Length; i++)
-        {
-            string expertLabel = i == 0 ? "⚛️ PHYSICIST" : "🧪 CHEMIST";
-            aggregatedResult += $"{expertLabel}:\n{message[i]}\n\n";
-        }
-
-        aggregatedResult += "═══════════════════════════════════════════════════════════════\n" +
-                          $"Summary: Received perspectives from {message.Length} AI experts.\n" +
-                          "═══════════════════════════════════════════════════════════════";
-
-        return ValueTask.FromResult(aggregatedResult);
-    }
-}

dotnet/samples/Durable/Workflow/AzureFunctions/02_ConcurrentWorkflow/Program.cs

@@ -1,45 +0,0 @@
-// Copyright (c) Microsoft. All rights reserved.
-
-using Azure;
-using Azure.AI.OpenAI;
-using Azure.Identity;
-using Microsoft.Agents.AI;
-using Microsoft.Agents.AI.DurableTask;
-using Microsoft.Agents.AI.Hosting.AzureFunctions;
-using Microsoft.Agents.AI.Workflows;
-using Microsoft.Azure.Functions.Worker.Builder;
-using Microsoft.Extensions.Hosting;
-using OpenAI.Chat;
-using WorkflowConcurrency;
-
-string endpoint = Environment.GetEnvironmentVariable("AZURE_OPENAI_ENDPOINT")
-    ?? throw new InvalidOperationException("AZURE_OPENAI_ENDPOINT is not set.");
-string deploymentName = Environment.GetEnvironmentVariable("AZURE_OPENAI_DEPLOYMENT")
-    ?? throw new InvalidOperationException("AZURE_OPENAI_DEPLOYMENT is not set.");
-string? azureOpenAiKey = Environment.GetEnvironmentVariable("AZURE_OPENAI_KEY");
-
-// Create Azure OpenAI client
-AzureOpenAIClient openAiClient = !string.IsNullOrEmpty(azureOpenAiKey)
-    ? new AzureOpenAIClient(new Uri(endpoint), new AzureKeyCredential(azureOpenAiKey))
-    : new AzureOpenAIClient(new Uri(endpoint), new AzureCliCredential());
-ChatClient chatClient = openAiClient.GetChatClient(deploymentName);
-
-// Define the 4 executors for the workflow
-ParseQuestionExecutor parseQuestion = new();
-AIAgent physicist = chatClient.AsAIAgent("You are a physics expert. Be concise (2-3 sentences).", "Physicist");
-AIAgent chemist = chatClient.AsAIAgent("You are a chemistry expert. Be concise (2-3 sentences).", "Chemist");
-AggregatorExecutor aggregator = new();
-
-// Build workflow: ParseQuestion -> [Physicist, Chemist] (parallel) -> Aggregator
-Workflow workflow = new WorkflowBuilder(parseQuestion)
-    .WithName("ExpertReview")
-    .AddFanOutEdge(parseQuestion, [physicist, chemist])
-    .AddFanInEdge([physicist, chemist], aggregator)
-    .Build();
-
-using IHost app = FunctionsApplication
-    .CreateBuilder(args)
-    .ConfigureFunctionsWebApplication()
-    .ConfigureDurableWorkflows(workflows => workflows.AddWorkflows(workflow))
-    .Build();
-app.Run();

dotnet/samples/Durable/Workflow/AzureFunctions/02_ConcurrentWorkflow/README.md

@@ -1,90 +0,0 @@
-# Concurrent Workflow Sample
-
-This sample demonstrates how to use the Microsoft Agent Framework to create an Azure Functions app that orchestrates concurrent execution of multiple AI agents using the fan-out/fan-in pattern within a durable workflow.
-
-## Key Concepts Demonstrated
-
-- Defining workflows with fan-out/fan-in edges for parallel execution using `WorkflowBuilder`
-- Mixing custom executors with AI agents in a single workflow
-- Concurrent execution of multiple AI agents (physics and chemistry experts)
-- Response aggregation from parallel branches into a unified result
-- Durable orchestration with automatic checkpointing and resumption from failures
-- Viewing workflow execution history and status in the Durable Task Scheduler (DTS) dashboard
-
-## Workflow
-
-This sample defines a single workflow:
-
-**ExpertReview**: `ParseQuestion` → [`Physicist`, `Chemist`] (parallel) → `Aggregator`
-
-1. **ParseQuestion** — A custom executor that validates and formats the incoming question.
-2. **Physicist** and **Chemist** — AI agents that run concurrently, each providing an expert perspective.
-3. **Aggregator** — A custom executor that combines the parallel responses into a comprehensive answer.
-
-## Environment Setup
-
-See the [README.md](../../README.md) file in the parent directory for more information on how to configure the environment, including how to install and run common sample dependencies.
-
-This sample requires Azure OpenAI. Set the following environment variables:
-
-- `AZURE_OPENAI_ENDPOINT` — Your Azure OpenAI endpoint URL.
-- `AZURE_OPENAI_DEPLOYMENT` — The name of your chat model deployment.
-- `AZURE_OPENAI_KEY` (optional) — Your Azure OpenAI API key. If not set, Azure CLI credentials are used.
-
-## Running the Sample
-
-With the environment setup and function app running, you can test the sample by sending an HTTP request with a science question to the workflow endpoint.
-
-You can use the `demo.http` file to trigger the workflow, or a command line tool like `curl` as shown below:
-
-Bash (Linux/macOS/WSL):
-
-```bash
-curl -X POST http://localhost:7071/api/workflows/ExpertReview/run \
-    -H "Content-Type: text/plain" \
-    -d "What is temperature?"
-```
-
-PowerShell:
-
-```powershell
-Invoke-RestMethod -Method Post `
-    -Uri http://localhost:7071/api/workflows/ExpertReview/run `
-    -ContentType text/plain `
-    -Body "What is temperature?"
-```
-
-The response will confirm the workflow orchestration has started:
-
-```text
-Workflow orchestration started for ExpertReview. Orchestration runId: abc123def456
-```
-
-> **Tip:** You can provide a custom run ID by appending a `runId` query parameter:
->
-> ```bash
-> curl -X POST "http://localhost:7071/api/workflows/ExpertReview/run?runId=my-review-123" \
->     -H "Content-Type: text/plain" \
->     -d "What is temperature?"
-> ```
->
-> If not provided, a unique run ID is auto-generated.
-
-In the function app logs, you will see the fan-out/fan-in execution pattern:
-
-```text
-│ [ParseQuestion] Preparing question for AI agents...
-│ [ParseQuestion] Question: "What is temperature?"
-│ [ParseQuestion] → Sending to Physicist and Chemist in PARALLEL...
-│ [Aggregator] 📋 Received 2 AI agent responses
-│ [Aggregator] Combining into comprehensive answer...
-│ [Aggregator] ✓ Aggregation complete!
-```
-
-The Physicist and Chemist AI agents execute concurrently, and the Aggregator combines their responses into a formatted expert panel result.
-
-### Viewing Workflows in the DTS Dashboard
-
-After running a workflow, you can navigate to the Durable Task Scheduler (DTS) dashboard to visualize the completed orchestration, inspect inputs/outputs for each step, and view execution history.
-
-If you are using the DTS emulator, the dashboard is available at `http://localhost:8082`.

dotnet/samples/Durable/Workflow/AzureFunctions/02_ConcurrentWorkflow/demo.http

@@ -1,14 +0,0 @@
-# Default endpoint address for local testing
-@authority=http://localhost:7071
-
-### Prompt the agent
-POST {{authority}}/api/workflows/ExpertReview/run
-Content-Type: text/plain
-
-What is temperature?
-
-### Start with a custom run ID
-POST {{authority}}/api/workflows/ExpertReview/run?runId=my-review-123
-Content-Type: text/plain
-
-What is gravity?

dotnet/samples/Durable/Workflow/AzureFunctions/02_ConcurrentWorkflow/host.json

@@ -1,20 +0,0 @@
-{
-  "version": "2.0",
-  "logging": {
-    "logLevel": {
-      "Microsoft.Agents.AI.DurableTask": "Information",
-      "Microsoft.Agents.AI.Hosting.AzureFunctions": "Information",
-      "DurableTask": "Information",
-      "Microsoft.DurableTask": "Information"
-    }
-  },
-  "extensions": {
-    "durableTask": {
-      "hubName": "default",
-      "storageProvider": {
-        "type": "AzureManaged",
-        "connectionStringName": "DURABLE_TASK_SCHEDULER_CONNECTION_STRING"
-      }
-    }
-  }
-}

dotnet/samples/Durable/Workflow/ConsoleApps/01_SequentialWorkflow/01_SequentialWorkflow.csproj

@@ -1,29 +0,0 @@
-<Project Sdk="Microsoft.NET.Sdk">
-  <PropertyGroup>
-    <TargetFrameworks>net10.0</TargetFrameworks>
-    <OutputType>Exe</OutputType>
-    <ImplicitUsings>enable</ImplicitUsings>
-    <Nullable>enable</Nullable>
-    <AssemblyName>SequentialWorkflow</AssemblyName>
-    <RootNamespace>SequentialWorkflow</RootNamespace>
-  </PropertyGroup>
-
-  <ItemGroup>
-    <PackageReference Include="Azure.Identity" />
-    <PackageReference Include="Microsoft.DurableTask.Client.AzureManaged" />
-    <PackageReference Include="Microsoft.DurableTask.Worker.AzureManaged" />
-    <PackageReference Include="Microsoft.Extensions.Hosting" />
-  </ItemGroup>
-
-  <!-- Local projects that should be switched to package references when using the sample outside of this MAF repo -->
-  <!--
-  <ItemGroup>
-    <PackageReference Include="Microsoft.Agents.AI.DurableTask" />
-    <PackageReference Include="Microsoft.Agents.AI.Workflows" />
-  </ItemGroup>
-  -->
-  <ItemGroup>
-    <ProjectReference Include="..\..\..\..\..\src\Microsoft.Agents.AI.DurableTask\Microsoft.Agents.AI.DurableTask.csproj" />
-    <ProjectReference Include="..\..\..\..\..\src\Microsoft.Agents.AI.OpenAI\Microsoft.Agents.AI.OpenAI.csproj" />
-  </ItemGroup>
-</Project>

dotnet/samples/Durable/Workflow/ConsoleApps/01_SequentialWorkflow/OrderCancelExecutors.cs

@@ -1,116 +0,0 @@
-// Copyright (c) Microsoft. All rights reserved.
-
-using Microsoft.Agents.AI.Workflows;
-
-namespace SequentialWorkflow;
-
-/// <summary>
-/// Represents a request to cancel an order.
-/// </summary>
-/// <param name="OrderId">The ID of the order to cancel.</param>
-/// <param name="Reason">The reason for cancellation.</param>
-internal sealed record OrderCancelRequest(string OrderId, string Reason);
-
-/// <summary>
-/// Looks up an order by its ID and return an Order object.
-/// </summary>
-internal sealed class OrderLookup() : Executor<OrderCancelRequest, Order>("OrderLookup")
-{
-    public override async ValueTask<Order> HandleAsync(
-        OrderCancelRequest message,
-        IWorkflowContext context,
-        CancellationToken cancellationToken = default)
-    {
-        Console.WriteLine();
-        Console.ForegroundColor = ConsoleColor.Magenta;
-        Console.WriteLine("┌─────────────────────────────────────────────────────────────────┐");
-        Console.WriteLine($"│ [Activity] OrderLookup: Starting lookup for order '{message.OrderId}'");
-        Console.WriteLine($"│ [Activity] OrderLookup: Cancellation reason: '{message.Reason}'");
-        Console.ResetColor();
-
-        // Simulate database lookup with delay
-        await Task.Delay(TimeSpan.FromMicroseconds(100), cancellationToken);
-
-        Order order = new(
-            Id: message.OrderId,
-            OrderDate: DateTime.UtcNow.AddDays(-1),
-            IsCancelled: false,
-            CancelReason: message.Reason,
-            Customer: new Customer(Name: "Jerry", Email: "jerry@example.com"));
-
-        Console.ForegroundColor = ConsoleColor.Magenta;
-        Console.WriteLine($"│ [Activity] OrderLookup: Found order '{message.OrderId}' for customer '{order.Customer.Name}'");
-        Console.WriteLine("└─────────────────────────────────────────────────────────────────┘");
-        Console.ResetColor();
-
-        return order;
-    }
-}
-
-/// <summary>
-/// Cancels an order.
-/// </summary>
-internal sealed class OrderCancel() : Executor<Order, Order>("OrderCancel")
-{
-    public override async ValueTask<Order> HandleAsync(
-        Order message,
-        IWorkflowContext context,
-        CancellationToken cancellationToken = default)
-    {
-        // Log that this activity is executing (not replaying)
-        Console.WriteLine();
-        Console.ForegroundColor = ConsoleColor.Yellow;
-        Console.WriteLine("┌─────────────────────────────────────────────────────────────────┐");
-        Console.WriteLine($"│ [Activity] OrderCancel: Starting cancellation for order '{message.Id}'");
-        Console.ResetColor();
-
-        // Simulate a slow cancellation process (e.g., calling external payment system)
-        for (int i = 1; i <= 3; i++)
-        {
-            await Task.Delay(TimeSpan.FromMilliseconds(100), cancellationToken);
-            Console.ForegroundColor = ConsoleColor.DarkYellow;
-            Console.WriteLine("│ [Activity] OrderCancel: Processing...");
-            Console.ResetColor();
-        }
-
-        Order cancelledOrder = message with { IsCancelled = true };
-
-        Console.ForegroundColor = ConsoleColor.Yellow;
-        Console.WriteLine($"│ [Activity] OrderCancel: ✓ Order '{cancelledOrder.Id}' has been cancelled");
-        Console.WriteLine("└─────────────────────────────────────────────────────────────────┘");
-        Console.ResetColor();
-
-        return cancelledOrder;
-    }
-}
-
-/// <summary>
-/// Sends a cancellation confirmation email to the customer.
-/// </summary>
-internal sealed class SendEmail() : Executor<Order, string>("SendEmail")
-{
-    public override ValueTask<string> HandleAsync(
-        Order message,
-        IWorkflowContext context,
-        CancellationToken cancellationToken = default)
-    {
-        Console.WriteLine();
-        Console.ForegroundColor = ConsoleColor.Cyan;
-        Console.WriteLine("┌─────────────────────────────────────────────────────────────────┐");
-        Console.WriteLine($"│ [Activity] SendEmail: Sending email to '{message.Customer.Email}'...");
-        Console.ResetColor();
-
-        string result = $"Cancellation email sent for order {message.Id} to {message.Customer.Email}.";
-
-        Console.ForegroundColor = ConsoleColor.Cyan;
-        Console.WriteLine("│ [Activity] SendEmail: ✓ Email sent successfully!");
-        Console.WriteLine("└─────────────────────────────────────────────────────────────────┘");
-        Console.ResetColor();
-
-        return ValueTask.FromResult(result);
-    }
-}
-
-internal sealed record Order(string Id, DateTime OrderDate, bool IsCancelled, string? CancelReason, Customer Customer);
-
-internal sealed record Customer(string Name, string Email);

dotnet/samples/Durable/Workflow/ConsoleApps/01_SequentialWorkflow/Program.cs

@@ -1,93 +0,0 @@
-// Copyright (c) Microsoft. All rights reserved.
-
-using Microsoft.Agents.AI.DurableTask;
-using Microsoft.Agents.AI.DurableTask.Workflows;
-using Microsoft.Agents.AI.Workflows;
-using Microsoft.DurableTask.Client.AzureManaged;
-using Microsoft.DurableTask.Worker.AzureManaged;
-using Microsoft.Extensions.DependencyInjection;
-using Microsoft.Extensions.Hosting;
-using Microsoft.Extensions.Logging;
-using SequentialWorkflow;
-
-// Get DTS connection string from environment variable
-string dtsConnectionString = Environment.GetEnvironmentVariable("DURABLE_TASK_SCHEDULER_CONNECTION_STRING")
-    ?? "Endpoint=http://localhost:8080;TaskHub=default;Authentication=None";
-
-// Define executors for the workflow
-OrderLookup orderLookup = new();
-OrderCancel orderCancel = new();
-SendEmail sendEmail = new();
-
-// Build the CancelOrder workflow: OrderLookup -> OrderCancel -> SendEmail
-Workflow cancelOrder = new WorkflowBuilder(orderLookup)
-    .WithName("CancelOrder")
-    .WithDescription("Cancel an order and notify the customer")
-    .AddEdge(orderLookup, orderCancel)
-    .AddEdge(orderCancel, sendEmail)
-    .Build();
-
-IHost host = Host.CreateDefaultBuilder(args)
-.ConfigureLogging(logging => logging.SetMinimumLevel(LogLevel.Warning))
-.ConfigureServices(services =>
-{
-    services.ConfigureDurableWorkflows(
-        workflowOptions => workflowOptions.AddWorkflow(cancelOrder),
-        workerBuilder: builder => builder.UseDurableTaskScheduler(dtsConnectionString),
-        clientBuilder: builder => builder.UseDurableTaskScheduler(dtsConnectionString));
-})
-.Build();
-
-await host.StartAsync();
-
-IWorkflowClient workflowClient = host.Services.GetRequiredService<IWorkflowClient>();
-
-Console.WriteLine("Durable Workflow Sample");
-Console.WriteLine("Workflow: OrderLookup -> OrderCancel -> SendEmail");
-Console.WriteLine();
-Console.WriteLine("Enter an order ID (or 'exit'):");
-
-while (true)
-{
-    Console.Write("> ");
-    string? input = Console.ReadLine();
-    if (string.IsNullOrWhiteSpace(input) || input.Equals("exit", StringComparison.OrdinalIgnoreCase))
-    {
-        break;
-    }
-
-    try
-    {
-        OrderCancelRequest request = new(OrderId: input, Reason: "Customer requested cancellation");
-        await StartNewWorkflowAsync(request, cancelOrder, workflowClient);
-    }
-    catch (Exception ex)
-    {
-        Console.WriteLine($"Error: {ex.Message}");
-    }
-
-    Console.WriteLine();
-}
-
-await host.StopAsync();
-
-// Start a new workflow using IWorkflowClient with typed input
-static async Task StartNewWorkflowAsync(OrderCancelRequest request, Workflow workflow, IWorkflowClient client)
-{
-    Console.WriteLine($"Starting workflow for order '{request.OrderId}' (Reason: {request.Reason})...");
-
-    // RunAsync returns IWorkflowRun, cast to IAwaitableWorkflowRun for completion waiting
-    IAwaitableWorkflowRun run = (IAwaitableWorkflowRun)await client.RunAsync(workflow, request);
-    Console.WriteLine($"Run ID: {run.RunId}");
-
-    try
-    {
-        Console.WriteLine("Waiting for workflow to complete...");
-        string? result = await run.WaitForCompletionAsync<string>();
-        Console.WriteLine($"Workflow completed. {result}");
-    }
-    catch (InvalidOperationException ex)
-    {
-        Console.WriteLine($"Failed: {ex.Message}");
-    }
-}

dotnet/samples/Durable/Workflow/ConsoleApps/01_SequentialWorkflow/README.md

@@ -1,83 +0,0 @@
-# Sequential Workflow Sample
-
-This sample demonstrates how to run a sequential workflow as a durable orchestration from a console application using the Durable Task Framework. It showcases the **durability** aspect - if the process crashes mid-execution, the workflow automatically resumes without re-executing completed activities.
-
-## Key Concepts Demonstrated
-
-- Building a sequential workflow with the `WorkflowBuilder` API
-- Using `ConfigureDurableWorkflows` to register workflows with dependency injection
-- Running workflows with `IWorkflowClient`
-- **Durability**: Automatic resume of interrupted workflows
-- **Activity caching**: Completed activities are not re-executed on replay
-
-## Overview
-
-The sample implements an order cancellation workflow with three executors:
-
-```
-OrderLookup --> OrderCancel --> SendEmail
-```
-
-| Executor | Description |
-|----------|-------------|
-| OrderLookup | Looks up an order by ID |
-| OrderCancel | Marks the order as cancelled |
-| SendEmail | Sends a cancellation confirmation email |
-
-## Durability Demonstration
-
-The key feature of Durable Task Framework is **durability**:
-
-- **Activity results are persisted**: When an activity completes, its result is saved
-- **Orchestrations replay**: On restart, the orchestration replays from the beginning
-- **Completed activities skip execution**: The framework uses cached results
-- **Automatic resume**: The worker automatically picks up pending work on startup
-
-### Try It Yourself
-
-> **Tip:** To give yourself more time to stop the application during `OrderCancel`, consider increasing the loop iteration count or `Task.Delay` duration in the `OrderCancel` executor in `OrderCancelExecutors.cs`.
-
-1. Start the application and enter an order ID (e.g., `12345`)
-2. Wait for `OrderLookup` to complete, then stop the app (Ctrl+C) during `OrderCancel`
-3. Restart the application
-4. Observe:
-   - `OrderLookup` is **NOT** re-executed (result was cached)
-   - `OrderCancel` **restarts** (it didn't complete before the interruption)
-   - `SendEmail` runs after `OrderCancel` completes
-
-## Environment Setup
-
-See the [README.md](../README.md) file in the parent directory for information on configuring the environment, including how to install and run the Durable Task Scheduler.
-
-## Running the Sample
-
-```bash
-cd dotnet/samples/Durable/Workflow/ConsoleApps/01_SequentialWorkflow
-dotnet run --framework net10.0
-```
-
-### Sample Output
-
-```text
-Durable Workflow Sample
-Workflow: OrderLookup -> OrderCancel -> SendEmail
-
-Enter an order ID (or 'exit'):
-> 12345
-Starting workflow for order: 12345
-Run ID: abc123...
-
-[OrderLookup] Looking up order '12345'...
-[OrderLookup] Found order for customer 'Jerry'
-
-[OrderCancel] Cancelling order '12345'...
-[OrderCancel] Order cancelled successfully
-
-[SendEmail] Sending email to 'jerry@example.com'...
-[SendEmail] Email sent successfully
-
-Workflow completed!
-
-> exit
-```
-

dotnet/samples/Durable/Workflow/ConsoleApps/02_ConcurrentWorkflow/02_ConcurrentWorkflow.csproj

@@ -1,30 +0,0 @@
-<Project Sdk="Microsoft.NET.Sdk">
-  <PropertyGroup>
-    <TargetFrameworks>net10.0</TargetFrameworks>
-    <OutputType>Exe</OutputType>
-    <ImplicitUsings>enable</ImplicitUsings>
-    <Nullable>enable</Nullable>
-    <AssemblyName>WorkflowConcurrency</AssemblyName>
-    <RootNamespace>WorkflowConcurrency</RootNamespace>
-  </PropertyGroup>
-
-  <ItemGroup>
-    <PackageReference Include="Azure.Identity" />
-    <PackageReference Include="Microsoft.DurableTask.Client.AzureManaged" />
-    <PackageReference Include="Microsoft.DurableTask.Worker.AzureManaged" />
-    <PackageReference Include="Microsoft.Extensions.Hosting" />
-    <PackageReference Include="Azure.AI.OpenAI" />
-  </ItemGroup>
-
-  <!-- Local projects that should be switched to package references when using the sample outside of this MAF repo -->
-  <!--
-  <ItemGroup>
-    <PackageReference Include="Microsoft.Agents.AI.DurableTask" />
-    <PackageReference Include="Microsoft.Agents.AI.Workflows" />
-  </ItemGroup>
-  -->
-  <ItemGroup>
-    <ProjectReference Include="..\..\..\..\..\src\Microsoft.Agents.AI.DurableTask\Microsoft.Agents.AI.DurableTask.csproj" />
-    <ProjectReference Include="..\..\..\..\..\src\Microsoft.Agents.AI.OpenAI\Microsoft.Agents.AI.OpenAI.csproj" />
-  </ItemGroup>
-</Project>

dotnet/samples/Durable/Workflow/ConsoleApps/02_ConcurrentWorkflow/ExpertExecutors.cs

@@ -1,73 +0,0 @@
-// Copyright (c) Microsoft. All rights reserved.
-
-using Microsoft.Agents.AI.Workflows;
-
-namespace WorkflowConcurrency;
-
-/// <summary>
-/// Parses and validates the incoming question before sending to AI agents.
-/// </summary>
-internal sealed class ParseQuestionExecutor() : Executor<string, string>("ParseQuestion")
-{
-    public override ValueTask<string> HandleAsync(
-        string message,
-        IWorkflowContext context,
-        CancellationToken cancellationToken = default)
-    {
-        Console.WriteLine();
-        Console.ForegroundColor = ConsoleColor.Magenta;
-        Console.WriteLine("┌─────────────────────────────────────────────────────────────────┐");
-        Console.WriteLine("│ [ParseQuestion] Preparing question for AI agents...");
-
-        string formattedQuestion = message.Trim();
-        if (!formattedQuestion.EndsWith('?'))
-        {
-            formattedQuestion += "?";
-        }
-
-        Console.WriteLine($"│ [ParseQuestion] Question: \"{formattedQuestion}\"");
-        Console.WriteLine("│ [ParseQuestion] → Sending to Physicist and Chemist in PARALLEL...");
-        Console.WriteLine("└─────────────────────────────────────────────────────────────────┘");
-        Console.ResetColor();
-
-        return ValueTask.FromResult(formattedQuestion);
-    }
-}
-
-/// <summary>
-/// Aggregates responses from all AI agents into a comprehensive answer.
-/// This is the Fan-in point where parallel results are collected.
-/// </summary>
-internal sealed class AggregatorExecutor() : Executor<string[], string>("Aggregator")
-{
-    public override ValueTask<string> HandleAsync(
-        string[] message,
-        IWorkflowContext context,
-        CancellationToken cancellationToken = default)
-    {
-        Console.WriteLine();
-        Console.ForegroundColor = ConsoleColor.Cyan;
-        Console.WriteLine("┌─────────────────────────────────────────────────────────────────┐");
-        Console.WriteLine($"│ [Aggregator] 📋 Received {message.Length} AI agent responses");
-        Console.WriteLine("│ [Aggregator] Combining into comprehensive answer...");
-        Console.WriteLine("│ [Aggregator] ✓ Aggregation complete!");
-        Console.WriteLine("└─────────────────────────────────────────────────────────────────┘");
-        Console.ResetColor();
-
-        string aggregatedResult = "═══════════════════════════════════════════════════════════════\n" +
-                                 "                    AI EXPERT PANEL RESPONSES\n" +
-                                 "═══════════════════════════════════════════════════════════════\n\n";
-
-        for (int i = 0; i < message.Length; i++)
-        {
-            string expertLabel = i == 0 ? "⚛️ PHYSICIST" : "🧪 CHEMIST";
-            aggregatedResult += $"{expertLabel}:\n{message[i]}\n\n";
-        }
-
-        aggregatedResult += "═══════════════════════════════════════════════════════════════\n" +
-                          $"Summary: Received perspectives from {message.Length} AI experts.\n" +
-                          "═══════════════════════════════════════════════════════════════";
-
-        return ValueTask.FromResult(aggregatedResult);
-    }
-}

dotnet/samples/Durable/Workflow/ConsoleApps/02_ConcurrentWorkflow/Program.cs

@@ -1,114 +0,0 @@
-// Copyright (c) Microsoft. All rights reserved.
-
-// This sample demonstrates the Fan-out/Fan-in pattern in a durable workflow.
-// The workflow uses 4 executors: 2 class-based executors and 2 AI agents.
-//
-// WORKFLOW PATTERN:
-//
-//                  ParseQuestion (class-based)
-//                         |
-//              +----------+----------+
-//              |                     |
-//          Physicist              Chemist
-//          (AI Agent)            (AI Agent)
-//              |                     |
-//              +----------+----------+
-//                         |
-//                    Aggregator (class-based)
-
-using Azure;
-using Azure.AI.OpenAI;
-using Azure.Identity;
-using Microsoft.Agents.AI;
-using Microsoft.Agents.AI.DurableTask;
-using Microsoft.Agents.AI.DurableTask.Workflows;
-using Microsoft.Agents.AI.Workflows;
-using Microsoft.DurableTask.Client.AzureManaged;
-using Microsoft.DurableTask.Worker.AzureManaged;
-using Microsoft.Extensions.DependencyInjection;
-using Microsoft.Extensions.Hosting;
-using Microsoft.Extensions.Logging;
-using OpenAI.Chat;
-using WorkflowConcurrency;
-
-// Configuration
-string dtsConnectionString = Environment.GetEnvironmentVariable("DURABLE_TASK_SCHEDULER_CONNECTION_STRING")
-    ?? "Endpoint=http://localhost:8080;TaskHub=default;Authentication=None";
-string endpoint = Environment.GetEnvironmentVariable("AZURE_OPENAI_ENDPOINT")
-    ?? throw new InvalidOperationException("AZURE_OPENAI_ENDPOINT is not set.");
-string deploymentName = Environment.GetEnvironmentVariable("AZURE_OPENAI_DEPLOYMENT")
-    ?? throw new InvalidOperationException("AZURE_OPENAI_DEPLOYMENT is not set.");
-string? azureOpenAiKey = Environment.GetEnvironmentVariable("AZURE_OPENAI_KEY");
-
-// Create Azure OpenAI client
-AzureOpenAIClient openAiClient = !string.IsNullOrEmpty(azureOpenAiKey)
-    ? new AzureOpenAIClient(new Uri(endpoint), new AzureKeyCredential(azureOpenAiKey))
-    : new AzureOpenAIClient(new Uri(endpoint), new AzureCliCredential());
-ChatClient chatClient = openAiClient.GetChatClient(deploymentName);
-
-// Define the 4 executors for the workflow
-ParseQuestionExecutor parseQuestion = new();
-AIAgent physicist = chatClient.AsAIAgent("You are a physics expert. Be concise (2-3 sentences).", "Physicist");
-AIAgent chemist = chatClient.AsAIAgent("You are a chemistry expert. Be concise (2-3 sentences).", "Chemist");
-AggregatorExecutor aggregator = new();
-
-// Build workflow: ParseQuestion -> [Physicist, Chemist] (parallel) -> Aggregator
-Workflow workflow = new WorkflowBuilder(parseQuestion)
-    .WithName("ExpertReview")
-    .AddFanOutEdge(parseQuestion, [physicist, chemist])
-    .AddFanInEdge([physicist, chemist], aggregator)
-    .Build();
-
-// Configure and start the host
-IHost host = Host.CreateDefaultBuilder(args)
-    .ConfigureLogging(logging => logging.SetMinimumLevel(LogLevel.Warning))
-    .ConfigureServices(services =>
-    {
-        services.ConfigureDurableOptions(
-            options => options.Workflows.AddWorkflow(workflow),
-            workerBuilder: builder => builder.UseDurableTaskScheduler(dtsConnectionString),
-            clientBuilder: builder => builder.UseDurableTaskScheduler(dtsConnectionString));
-    })
-    .Build();
-
-await host.StartAsync();
-
-IWorkflowClient workflowClient = host.Services.GetRequiredService<IWorkflowClient>();
-
-Console.WriteLine("Fan-out/Fan-in Workflow Sample");
-Console.WriteLine("ParseQuestion -> [Physicist, Chemist] -> Aggregator");
-Console.WriteLine();
-Console.WriteLine("Enter a science question (or 'exit' to quit):");
-
-while (true)
-{
-    Console.Write("> ");
-    string? input = Console.ReadLine();
-
-    if (string.IsNullOrWhiteSpace(input) || input.Equals("exit", StringComparison.OrdinalIgnoreCase))
-    {
-        break;
-    }
-
-    try
-    {
-        IWorkflowRun run = await workflowClient.RunAsync(workflow, input);
-        Console.WriteLine($"Run ID: {run.RunId}");
-
-        if (run is IAwaitableWorkflowRun awaitableRun)
-        {
-            string? result = await awaitableRun.WaitForCompletionAsync<string>();
-
-            Console.WriteLine("Workflow completed!");
-            Console.WriteLine(result);
-        }
-    }
-    catch (Exception ex)
-    {
-        Console.WriteLine($"Error: {ex.Message}");
-    }
-
-    Console.WriteLine();
-}
-
-await host.StopAsync();

dotnet/samples/Durable/Workflow/ConsoleApps/02_ConcurrentWorkflow/README.md

@@ -1,100 +0,0 @@
-# Concurrent Workflow Sample (Fan-Out/Fan-In)
-
-This sample demonstrates the **fan-out/fan-in** pattern in a durable workflow, combining class-based executors with AI agents running in parallel.
-
-## Key Concepts Demonstrated
-
-- **Fan-out/Fan-in pattern**: Parallel execution with result aggregation
-- **Mixed executor types**: Class-based executors and AI agents in the same workflow
-- **AI agents as executors**: Using `ChatClient.AsAIAgent()` to create workflow-compatible agents
-- **Workflow registration**: Auto-registration of agents used within workflows
-- **Standalone agents**: Registering agents outside of workflows
-
-## Overview
-
-The sample implements an expert review workflow with four executors:
-
-```
-                    ParseQuestion
-                         |
-              +----------+----------+
-              |                     |
-          Physicist              Chemist
-          (AI Agent)            (AI Agent)
-              |                     |
-              +----------+----------+
-                         |
-                    Aggregator
-```
-
-| Executor | Type | Description |
-|----------|------|-------------|
-| ParseQuestion | Class-based | Parses the user's question for expert review |
-| Physicist | AI Agent | Provides physics perspective (runs in parallel) |
-| Chemist | AI Agent | Provides chemistry perspective (runs in parallel) |
-| Aggregator | Class-based | Combines expert responses into a final answer |
-
-## Fan-Out/Fan-In Pattern
-
-The workflow demonstrates the fan-out/fan-in pattern:
-
-1. **Fan-out**: `ParseQuestion` sends the question to both `Physicist` and `Chemist` simultaneously
-2. **Parallel execution**: Both AI agents process the question concurrently
-3. **Fan-in**: `Aggregator` waits for both agents to complete, then combines their responses
-
-This pattern is useful for:
-- Gathering multiple perspectives on a problem
-- Parallel processing of independent tasks
-- Reducing overall execution time through concurrency
-
-## Environment Setup
-
-See the [README.md](../README.md) file in the parent directory for information on configuring the environment.
-
-### Required Environment Variables
-
-```bash
-# Durable Task Scheduler (optional, defaults to localhost)
-DURABLE_TASK_SCHEDULER_CONNECTION_STRING="Endpoint=http://localhost:8080;TaskHub=default;Authentication=None"
-
-# Azure OpenAI (required)
-AZURE_OPENAI_ENDPOINT="https://your-resource.openai.azure.com/"
-AZURE_OPENAI_DEPLOYMENT="gpt-4o"
-AZURE_OPENAI_KEY="your-key"  # Optional if using Azure CLI credentials
-```
-
-## Running the Sample
-
-```bash
-cd dotnet/samples/Durable/Workflow/ConsoleApps/02_ConcurrentWorkflow
-dotnet run --framework net10.0
-```
-
-### Sample Output
-
-```text
-+-----------------------------------------------------------------------+
-|  Fan-out/Fan-in Workflow Sample (4 Executors)                         |
-|                                                                       |
-|  ParseQuestion -> [Physicist, Chemist] -> Aggregator                  |
-|  (class-based)    (AI agents, parallel)  (class-based)                |
-+-----------------------------------------------------------------------+
-
-Enter a science question (or 'exit' to quit):
-
-Question: Why is the sky blue?
-Instance: abc123...
-
-[ParseQuestion] Parsing question for expert review...
-[Physicist] Analyzing from physics perspective...
-[Chemist] Analyzing from chemistry perspective...
-[Aggregator] Combining expert responses...
-
-Workflow completed!
-
-Physics perspective: The sky appears blue due to Rayleigh scattering...
-Chemistry perspective: The molecular composition of our atmosphere...
-Combined answer: ...
-
-Question: exit
-```

dotnet/samples/Durable/Workflow/ConsoleApps/03_ConditionalEdges/03_ConditionalEdges.csproj

@@ -1,29 +0,0 @@
-<Project Sdk="Microsoft.NET.Sdk">
-  <PropertyGroup>
-    <TargetFrameworks>net10.0</TargetFrameworks>
-    <OutputType>Exe</OutputType>
-    <ImplicitUsings>enable</ImplicitUsings>
-    <Nullable>enable</Nullable>
-    <AssemblyName>ConditionalEdges</AssemblyName>
-    <RootNamespace>ConditionalEdges</RootNamespace>
-  </PropertyGroup>
-
-  <ItemGroup>
-    <PackageReference Include="Azure.Identity" />
-    <PackageReference Include="Microsoft.DurableTask.Client.AzureManaged" />
-    <PackageReference Include="Microsoft.DurableTask.Worker.AzureManaged" />
-    <PackageReference Include="Microsoft.Extensions.Hosting" />
-  </ItemGroup>
-
-  <!-- Local projects that should be switched to package references when using the sample outside of this MAF repo -->
-  <!--
-  <ItemGroup>
-    <PackageReference Include="Microsoft.Agents.AI.DurableTask" />
-    <PackageReference Include="Microsoft.Agents.AI.Workflows" />
-  </ItemGroup>
-  -->
-  <ItemGroup>
-    <ProjectReference Include="..\..\..\..\..\src\Microsoft.Agents.AI.DurableTask\Microsoft.Agents.AI.DurableTask.csproj" />
-    <ProjectReference Include="..\..\..\..\..\src\Microsoft.Agents.AI.OpenAI\Microsoft.Agents.AI.OpenAI.csproj" />
-  </ItemGroup>
-</Project>

dotnet/samples/Durable/Workflow/ConsoleApps/03_ConditionalEdges/NotifyFraud.cs

@@ -1,85 +0,0 @@
-// Copyright (c) Microsoft. All rights reserved.
-
-using Microsoft.Agents.AI.Workflows;
-
-namespace ConditionalEdges;
-
-internal sealed class Order
-{
-    public Order(string id, decimal amount)
-    {
-        this.Id = id;
-        this.Amount = amount;
-    }
-    public string Id { get; }
-    public decimal Amount { get; }
-    public Customer? Customer { get; set; }
-    public string? PaymentReferenceNumber { get; set; }
-}
-
-public sealed record Customer(int Id, string Name, bool IsBlocked);
-
-internal sealed class OrderIdParser() : Executor<string, Order>("OrderIdParser")
-{
-    public override async ValueTask<Order> HandleAsync(string message, IWorkflowContext context, CancellationToken cancellationToken = default)
-    {
-        return GetOrder(message);
-    }
-
-    private static Order GetOrder(string id)
-    {
-        // Simulate fetching order details
-        return new Order(id, 100.0m);
-    }
-}
-
-internal sealed class OrderEnrich() : Executor<Order, Order>("EnrichOrder")
-{
-    public override async ValueTask<Order> HandleAsync(Order message, IWorkflowContext context, CancellationToken cancellationToken = default)
-    {
-        message.Customer = GetCustomerForOrder(message.Id);
-        return message;
-    }
-
-    private static Customer GetCustomerForOrder(string orderId)
-    {
-        if (orderId.Contains('B'))
-        {
-            return new Customer(101, "George", true);
-        }
-
-        return new Customer(201, "Jerry", false);
-    }
-}
-
-internal sealed class PaymentProcesser() : Executor<Order, Order>("PaymentProcesser")
-{
-    public override async ValueTask<Order> HandleAsync(Order message, IWorkflowContext context, CancellationToken cancellationToken = default)
-    {
-        // Call payment gateway.
-        message.PaymentReferenceNumber = Guid.NewGuid().ToString().Substring(0, 4);
-        return message;
-    }
-}
-
-internal sealed class NotifyFraud() : Executor<Order, string>("NotifyFraud")
-{
-    public override async ValueTask<string> HandleAsync(Order message, IWorkflowContext context, CancellationToken cancellationToken = default)
-    {
-        // Notify fraud team.
-        return $"Order {message.Id} flagged as fraudulent for customer {message.Customer?.Name}.";
-    }
-}
-
-internal static class OrderRouteConditions
-{
-    /// <summary>
-    /// Returns a condition that evaluates to true when the customer is blocked.
-    /// </summary>
-    internal static Func<Order?, bool> WhenBlocked() => order => order?.Customer?.IsBlocked == true;
-
-    /// <summary>
-    /// Returns a condition that evaluates to true when the customer is not blocked.
-    /// </summary>
-    internal static Func<Order?, bool> WhenNotBlocked() => order => order?.Customer?.IsBlocked == false;
-}

dotnet/samples/Durable/Workflow/ConsoleApps/03_ConditionalEdges/Program.cs

@@ -1,97 +0,0 @@
-// Copyright (c) Microsoft. All rights reserved.
-
-// This sample demonstrates conditional edges in a workflow.
-// Orders are routed to different executors based on customer status:
-// - Blocked customers → NotifyFraud
-// - Valid customers → PaymentProcessor
-
-using ConditionalEdges;
-using Microsoft.Agents.AI.DurableTask;
-using Microsoft.Agents.AI.DurableTask.Workflows;
-using Microsoft.Agents.AI.Workflows;
-using Microsoft.DurableTask.Client.AzureManaged;
-using Microsoft.DurableTask.Worker.AzureManaged;
-using Microsoft.Extensions.DependencyInjection;
-using Microsoft.Extensions.Hosting;
-using Microsoft.Extensions.Logging;
-
-string dtsConnectionString = Environment.GetEnvironmentVariable("DURABLE_TASK_SCHEDULER_CONNECTION_STRING")
-    ?? "Endpoint=http://localhost:8080;TaskHub=default;Authentication=None";
-
-// Create executor instances
-OrderIdParser orderParser = new();
-OrderEnrich orderEnrich = new();
-PaymentProcesser paymentProcessor = new();
-NotifyFraud notifyFraud = new();
-
-// Build workflow with conditional edges
-// The condition functions evaluate the Order output from OrderEnrich
-WorkflowBuilder builder = new(orderParser);
-builder
-    .AddEdge(orderParser, orderEnrich)
-    .AddEdge(orderEnrich, notifyFraud, condition: OrderRouteConditions.WhenBlocked())
-    .AddEdge(orderEnrich, paymentProcessor, condition: OrderRouteConditions.WhenNotBlocked());
-
-Workflow auditOrder = builder.WithName("AuditOrder").Build();
-
-IHost host = Host.CreateDefaultBuilder(args)
-.ConfigureLogging(logging => logging.SetMinimumLevel(LogLevel.Warning))
-.ConfigureServices(services =>
-{
-    services.ConfigureDurableWorkflows(
-        workflowOptions => workflowOptions.AddWorkflow(auditOrder),
-        workerBuilder: builder => builder.UseDurableTaskScheduler(dtsConnectionString),
-        clientBuilder: builder => builder.UseDurableTaskScheduler(dtsConnectionString));
-})
-.Build();
-
-await host.StartAsync();
-
-IWorkflowClient workflowClient = host.Services.GetRequiredService<IWorkflowClient>();
-
-Console.WriteLine("Enter an order ID (or 'exit'):");
-Console.WriteLine("Tip: Order IDs containing 'B' are flagged as blocked customers.\n");
-
-while (true)
-{
-    Console.Write("> ");
-    string? input = Console.ReadLine();
-    if (string.IsNullOrWhiteSpace(input) || input.Equals("exit", StringComparison.OrdinalIgnoreCase))
-    {
-        break;
-    }
-
-    try
-    {
-        await StartNewWorkflowAsync(input, auditOrder, workflowClient);
-    }
-    catch (Exception ex)
-    {
-        Console.WriteLine($"Error: {ex.Message}");
-    }
-
-    Console.WriteLine();
-}
-
-await host.StopAsync();
-
-// Start a new workflow and wait for completion
-static async Task StartNewWorkflowAsync(string orderId, Workflow workflow, IWorkflowClient client)
-{
-    Console.WriteLine($"Starting workflow for order '{orderId}'...");
-
-    // Cast to IAwaitableWorkflowRun to access WaitForCompletionAsync
-    IAwaitableWorkflowRun run = (IAwaitableWorkflowRun)await client.RunAsync(workflow, orderId);
-    Console.WriteLine($"Run ID: {run.RunId}");
-
-    try
-    {
-        Console.WriteLine("Waiting for workflow to complete...");
-        string? result = await run.WaitForCompletionAsync<string>();
-        Console.WriteLine($"Workflow completed. {result}");
-    }
-    catch (InvalidOperationException ex)
-    {
-        Console.WriteLine($"Failed: {ex.Message}");
-    }
-}

dotnet/samples/Durable/Workflow/ConsoleApps/03_ConditionalEdges/README.md

@@ -1,92 +0,0 @@
-# Conditional Edges Workflow Sample
-
-This sample demonstrates how to build a workflow with **conditional edges** that route execution to different paths based on runtime conditions. The workflow evaluates conditions on the output of an executor to determine which downstream executor to run.
-
-## Key Concepts Demonstrated
-
-- Building workflows with **conditional edges** using `AddEdge` with a `condition` parameter
-- Defining reusable condition functions for routing logic
-- Branching workflow execution based on data-driven decisions
-- Using `ConfigureDurableWorkflows` to register workflows with dependency injection
-
-## Overview
-
-The sample implements an order audit workflow that routes orders differently based on whether the customer is blocked (flagged for fraud):
-
-```
-OrderIdParser --> OrderEnrich --[IsBlocked]--> NotifyFraud
-                              |
-                              +--[NotBlocked]--> PaymentProcessor
-```
-
-| Executor | Description |
-|----------|-------------|
-| OrderIdParser | Parses the order ID and retrieves order details |
-| OrderEnrich | Enriches the order with customer information |
-| PaymentProcessor | Processes payment for valid orders |
-| NotifyFraud | Notifies the fraud team for blocked customers |
-
-## How Conditional Edges Work
-
-Conditional edges allow you to specify a condition function that determines whether the edge should be traversed:
-
-```csharp
-builder
-    .AddEdge(orderParser, orderEnrich)
-    .AddEdge(orderEnrich, notifyFraud, condition: OrderRouteConditions.WhenBlocked())
-    .AddEdge(orderEnrich, paymentProcessor, condition: OrderRouteConditions.WhenNotBlocked());
-```
-
-The condition functions receive the output of the source executor and return a boolean:
-
-```csharp
-internal static class OrderRouteConditions
-{
-    // Routes to NotifyFraud when customer is blocked
-    internal static Func<Order?, bool> WhenBlocked() => 
-        order => order?.Customer?.IsBlocked == true;
-
-    // Routes to PaymentProcessor when customer is not blocked
-    internal static Func<Order?, bool> WhenNotBlocked() => 
-        order => order?.Customer?.IsBlocked == false;
-}
-```
-
-### Routing Logic
-
-In this sample, the routing is based on the order ID:
-- Order IDs containing the letter **'B'** are associated with blocked customers ? routed to `NotifyFraud`
-- All other order IDs are associated with valid customers ? routed to `PaymentProcessor`
-
-## Environment Setup
-
-See the [README.md](../README.md) file in the parent directory for information on configuring the environment, including how to install and run the Durable Task Scheduler.
-
-## Running the Sample
-
-```bash
-cd dotnet/samples/Durable/Workflow/ConsoleApps/03_ConditionalEdges
-dotnet run --framework net10.0
-```
-
-### Sample Output
-
-**Valid order (routes to PaymentProcessor):**
-```text
-Enter an order ID (or 'exit'):
-> 12345
-Starting workflow for order '12345'...
-Run ID: abc123...
-Waiting for workflow to complete...
-Workflow completed. {"Id":"12345","Amount":100.0,"Customer":{"Id":201,"Name":"Jerry","IsBlocked":false},"PaymentReferenceNumber":"a1b2"}
-```
-
-**Blocked order (routes to NotifyFraud):**
-```text
-Enter an order ID (or 'exit'):
-> 12345B
-Starting workflow for order '12345B'...
-Run ID: def456...
-Waiting for workflow to complete...
-Workflow completed. Order 12345B flagged as fraudulent for customer George.
-```

dotnet/samples/Durable/Workflow/ConsoleApps/04_WorkflowAndAgents/04_WorkflowAndAgents.csproj

@@ -1,30 +0,0 @@
-<Project Sdk="Microsoft.NET.Sdk">
-  <PropertyGroup>
-    <TargetFrameworks>net10.0</TargetFrameworks>
-    <OutputType>Exe</OutputType>
-    <ImplicitUsings>enable</ImplicitUsings>
-    <Nullable>enable</Nullable>
-    <AssemblyName>WorkflowConcurrency</AssemblyName>
-    <RootNamespace>WorkflowConcurrency</RootNamespace>
-  </PropertyGroup>
-
-  <ItemGroup>
-    <PackageReference Include="Azure.Identity" />
-    <PackageReference Include="Microsoft.DurableTask.Client.AzureManaged" />
-    <PackageReference Include="Microsoft.DurableTask.Worker.AzureManaged" />
-    <PackageReference Include="Microsoft.Extensions.Hosting" />
-    <PackageReference Include="Azure.AI.OpenAI" />
-  </ItemGroup>
-
-  <!-- Local projects that should be switched to package references when using the sample outside of this MAF repo -->
-  <!--
-  <ItemGroup>
-    <PackageReference Include="Microsoft.Agents.AI.DurableTask" />
-    <PackageReference Include="Microsoft.Agents.AI.Workflows" />
-  </ItemGroup>
-  -->
-  <ItemGroup>
-    <ProjectReference Include="..\..\..\..\..\src\Microsoft.Agents.AI.DurableTask\Microsoft.Agents.AI.DurableTask.csproj" />
-    <ProjectReference Include="..\..\..\..\..\src\Microsoft.Agents.AI.OpenAI\Microsoft.Agents.AI.OpenAI.csproj" />
-  </ItemGroup>
-</Project>

dotnet/samples/Durable/Workflow/ConsoleApps/04_WorkflowAndAgents/ParseQuestionExecutor.cs

@@ -1,73 +0,0 @@
-// Copyright (c) Microsoft. All rights reserved.
-
-using Microsoft.Agents.AI.Workflows;
-
-namespace WorkflowConcurrency;
-
-/// <summary>
-/// Parses and validates the incoming question before sending to AI agents.
-/// </summary>
-internal sealed class ParseQuestionExecutor() : Executor<string, string>("ParseQuestion")
-{
-    public override ValueTask<string> HandleAsync(
-        string message,
-        IWorkflowContext context,
-        CancellationToken cancellationToken = default)
-    {
-        Console.WriteLine();
-        Console.ForegroundColor = ConsoleColor.Magenta;
-        Console.WriteLine("┌─────────────────────────────────────────────────────────────────┐");
-        Console.WriteLine("│ [ParseQuestion] Preparing question for AI agents...");
-
-        string formattedQuestion = message.Trim();
-        if (!formattedQuestion.EndsWith('?'))
-        {
-            formattedQuestion += "?";
-        }
-
-        Console.WriteLine($"│ [ParseQuestion] Question: \"{formattedQuestion}\"");
-        Console.WriteLine("│ [ParseQuestion] → Sending to experts...");
-        Console.WriteLine("└─────────────────────────────────────────────────────────────────┘");
-        Console.ResetColor();
-
-        return ValueTask.FromResult(formattedQuestion);
-    }
-}
-
-/// <summary>
-/// Aggregates responses from multiple AI agents into a unified response.
-/// This executor collects all expert opinions and synthesizes them.
-/// </summary>
-internal sealed class ResponseAggregatorExecutor() : Executor<string[], string>("ResponseAggregator")
-{
-    public override ValueTask<string> HandleAsync(
-        string[] message,
-        IWorkflowContext context,
-        CancellationToken cancellationToken = default)
-    {
-        Console.WriteLine();
-        Console.ForegroundColor = ConsoleColor.Cyan;
-        Console.WriteLine("┌─────────────────────────────────────────────────────────────────┐");
-        Console.WriteLine($"│ [Aggregator] 📋 Received {message.Length} AI agent responses");
-        Console.WriteLine("│ [Aggregator] Combining into comprehensive answer...");
-        Console.WriteLine("│ [Aggregator] ✓ Aggregation complete!");
-        Console.WriteLine("└─────────────────────────────────────────────────────────────────┘");
-        Console.ResetColor();
-
-        string aggregatedResult = "═══════════════════════════════════════════════════════════════\n" +
-                                 "                    AI EXPERT PANEL RESPONSES\n" +
-                                 "═══════════════════════════════════════════════════════════════\n\n";
-
-        for (int i = 0; i < message.Length; i++)
-        {
-            string expertLabel = i == 0 ? "⚛️ PHYSICIST" : "🧪 CHEMIST";
-            aggregatedResult += $"{expertLabel}:\n{message[i]}\n\n";
-        }
-
-        aggregatedResult += "═══════════════════════════════════════════════════════════════\n" +
-                          $"Summary: Received perspectives from {message.Length} AI experts.\n" +
-                          "═══════════════════════════════════════════════════════════════";
-
-        return ValueTask.FromResult(aggregatedResult);
-    }
-}

dotnet/samples/Durable/Workflow/ConsoleApps/04_WorkflowAndAgents/Program.cs

@@ -1,133 +0,0 @@
-// Copyright (c) Microsoft. All rights reserved.
-
-// This sample demonstrates the THREE ways to configure durable agents and workflows:
-//
-// 1. ConfigureDurableAgents()   - For standalone agents only
-// 2. ConfigureDurableWorkflows() - For workflows only
-// 3. ConfigureDurableOptions()   - For both agents AND workflows
-//
-// KEY: All methods can be called MULTIPLE times - configurations are ADDITIVE.
-
-using Azure;
-using Azure.AI.OpenAI;
-using Azure.Identity;
-using Microsoft.Agents.AI;
-using Microsoft.Agents.AI.DurableTask;
-using Microsoft.Agents.AI.DurableTask.Workflows;
-using Microsoft.Agents.AI.Workflows;
-using Microsoft.DurableTask.Client.AzureManaged;
-using Microsoft.DurableTask.Worker.AzureManaged;
-using Microsoft.Extensions.DependencyInjection;
-using Microsoft.Extensions.Hosting;
-using Microsoft.Extensions.Logging;
-using OpenAI.Chat;
-using WorkflowConcurrency;
-
-// Configuration
-string dtsConnectionString = Environment.GetEnvironmentVariable("DURABLE_TASK_SCHEDULER_CONNECTION_STRING")
-    ?? "Endpoint=http://localhost:8080;TaskHub=default;Authentication=None";
-string endpoint = Environment.GetEnvironmentVariable("AZURE_OPENAI_ENDPOINT")
-    ?? throw new InvalidOperationException("AZURE_OPENAI_ENDPOINT is not set.");
-string deploymentName = Environment.GetEnvironmentVariable("AZURE_OPENAI_DEPLOYMENT")
-    ?? throw new InvalidOperationException("AZURE_OPENAI_DEPLOYMENT is not set.");
-string? azureOpenAiKey = Environment.GetEnvironmentVariable("AZURE_OPENAI_KEY");
-
-// Create AI agents
-AzureOpenAIClient openAiClient = !string.IsNullOrEmpty(azureOpenAiKey)
-    ? new AzureOpenAIClient(new Uri(endpoint), new AzureKeyCredential(azureOpenAiKey))
-    : new AzureOpenAIClient(new Uri(endpoint), new AzureCliCredential());
-ChatClient chatClient = openAiClient.GetChatClient(deploymentName);
-
-AIAgent biologist = chatClient.AsAIAgent("You are a biology expert. Explain concepts clearly in 2-3 sentences.", "Biologist");
-AIAgent physicist = chatClient.AsAIAgent("You are a physics expert. Explain concepts clearly in 2-3 sentences.", "Physicist");
-AIAgent chemist = chatClient.AsAIAgent("You are a chemistry expert. Explain concepts clearly in 2-3 sentences.", "Chemist");
-
-// Create workflows
-ParseQuestionExecutor questionParser = new();
-ResponseAggregatorExecutor responseAggregator = new();
-
-Workflow physicsWorkflow = new WorkflowBuilder(questionParser)
-    .WithName("PhysicsExpertReview")
-    .AddEdge(questionParser, physicist)
-    .Build();
-
-Workflow expertTeamWorkflow = new WorkflowBuilder(questionParser)
-.WithName("ExpertTeamReview")
-.AddFanOutEdge(questionParser, [biologist, physicist])
-.AddFanInEdge([biologist, physicist], responseAggregator)
-.Build();
-
-Workflow chemistryWorkflow = new WorkflowBuilder(questionParser)
-    .WithName("ChemistryExpertReview")
-    .AddEdge(questionParser, chemist)
-    .Build();
-
-// Configure services - demonstrating all 3 methods (each can be called multiple times)
-IHost host = Host.CreateDefaultBuilder(args)
-    .ConfigureLogging(logging => logging.SetMinimumLevel(LogLevel.Warning))
-    .ConfigureServices(services =>
-    {
-        // METHOD 1: ConfigureDurableAgents - for standalone agents only
-        services.ConfigureDurableAgents(
-            options => options.AddAIAgent(biologist),
-            workerBuilder: builder => builder.UseDurableTaskScheduler(dtsConnectionString),
-            clientBuilder: builder => builder.UseDurableTaskScheduler(dtsConnectionString));
-
-        // METHOD 2: ConfigureDurableWorkflows - for workflows only
-        services.ConfigureDurableWorkflows(options => options.AddWorkflow(physicsWorkflow));
-
-        // METHOD 3: ConfigureDurableOptions - for both agents AND workflows
-        services.ConfigureDurableOptions(options =>
-        {
-            options.Agents.AddAIAgent(chemist);
-            options.Workflows.AddWorkflow(expertTeamWorkflow);
-        });
-
-        // Second call to ConfigureDurableOptions (additive - adds to existing config)
-        services.ConfigureDurableOptions(options => options.Workflows.AddWorkflow(chemistryWorkflow));
-    })
-    .Build();
-
-await host.StartAsync();
-IServiceProvider services = host.Services;
-IWorkflowClient workflowClient = services.GetRequiredService<IWorkflowClient>();
-
-// DEMO 1: Direct agent conversation (standalone agents)
-Console.WriteLine("\n═══ DEMO 1: Direct Agent Conversation ═══\n");
-
-AIAgent biologistProxy = services.GetRequiredKeyedService<AIAgent>("Biologist");
-AgentSession session = await biologistProxy.GetNewSessionAsync();
-AgentResponse response = await biologistProxy.RunAsync("What is photosynthesis?", session);
-Console.WriteLine($"🧬 Biologist: {response.Text}\n");
-
-AIAgent chemistProxy = services.GetRequiredKeyedService<AIAgent>("Chemist");
-session = await chemistProxy.GetNewSessionAsync();
-response = await chemistProxy.RunAsync("What is a chemical bond?", session);
-Console.WriteLine($"🧪 Chemist: {response.Text}\n");
-
-// DEMO 2: Single-agent workflow
-Console.WriteLine("═══ DEMO 2: Single-Agent Workflow ═══\n");
-await RunWorkflowAsync(workflowClient, physicsWorkflow, "What is the relationship between energy and mass?");
-
-// DEMO 3: Multi-agent workflow
-Console.WriteLine("═══ DEMO 3: Multi-Agent Workflow ═══\n");
-await RunWorkflowAsync(workflowClient, expertTeamWorkflow, "How does radiation affect living cells?");
-
-// DEMO 4: Workflow from second ConfigureDurableOptions call
-Console.WriteLine("═══ DEMO 4: Workflow (added via 2nd ConfigureDurableOptions) ═══\n");
-await RunWorkflowAsync(workflowClient, chemistryWorkflow, "What happens during combustion?");
-
-Console.WriteLine("\n✅ All demos completed!");
-await host.StopAsync();
-
-// Helper method
-static async Task RunWorkflowAsync(IWorkflowClient client, Workflow workflow, string question)
-{
-    Console.WriteLine($"📋 {workflow.Name}: \"{question}\"");
-    IWorkflowRun run = await client.RunAsync(workflow, question);
-    if (run is IAwaitableWorkflowRun awaitable)
-    {
-        string? result = await awaitable.WaitForCompletionAsync<string>();
-        Console.WriteLine($"✅ {result}\n");
-    }
-}

dotnet/samples/Durable/Workflow/ConsoleApps/05_WorkflowEvents/05_WorkflowEvents.csproj

@@ -1,28 +0,0 @@
-<Project Sdk="Microsoft.NET.Sdk">
-  <PropertyGroup>
-    <TargetFrameworks>net10.0</TargetFrameworks>
-    <OutputType>Exe</OutputType>
-    <ImplicitUsings>enable</ImplicitUsings>
-    <Nullable>enable</Nullable>
-    <AssemblyName>WorkflowEvents</AssemblyName>
-    <RootNamespace>WorkflowEvents</RootNamespace>
-  </PropertyGroup>
-
-  <ItemGroup>
-    <PackageReference Include="Azure.Identity" />
-    <PackageReference Include="Microsoft.DurableTask.Client.AzureManaged" />
-    <PackageReference Include="Microsoft.DurableTask.Worker.AzureManaged" />
-    <PackageReference Include="Microsoft.Extensions.Hosting" />
-  </ItemGroup>
-
-  <!-- Local projects that should be switched to package references when using the sample outside of this MAF repo -->
-  <!--
-  <ItemGroup>
-    <PackageReference Include="Microsoft.Agents.AI.DurableTask" />
-    <PackageReference Include="Microsoft.Agents.AI.Workflows" />
-  </ItemGroup>
-  -->
-  <ItemGroup>
-    <ProjectReference Include="..\..\..\..\..\src\Microsoft.Agents.AI.DurableTask\Microsoft.Agents.AI.DurableTask.csproj" />
-  </ItemGroup>
-</Project>

dotnet/samples/Durable/Workflow/ConsoleApps/05_WorkflowEvents/Executors.cs

@@ -1,129 +0,0 @@
-// Copyright (c) Microsoft. All rights reserved.
-
-using Microsoft.Agents.AI.Workflows;
-
-namespace WorkflowEvents;
-
-// ═══════════════════════════════════════════════════════════════════════════════
-// Custom event types - callers observe these via WatchStreamAsync
-// ═══════════════════════════════════════════════════════════════════════════════
-
-internal sealed class OrderLookupStartedEvent(string orderId) : WorkflowEvent(orderId)
-{
-    public string OrderId { get; } = orderId;
-}
-
-internal sealed class OrderFoundEvent(string customerName) : WorkflowEvent(customerName)
-{
-    public string CustomerName { get; } = customerName;
-}
-
-internal sealed class CancellationProgressEvent(int percentComplete, string status) : WorkflowEvent(status)
-{
-    public int PercentComplete { get; } = percentComplete;
-    public string Status { get; } = status;
-}
-
-internal sealed class OrderCancelledEvent() : WorkflowEvent("Order cancelled");
-
-internal sealed class EmailSentEvent(string email) : WorkflowEvent(email)
-{
-    public string Email { get; } = email;
-}
-
-// ═══════════════════════════════════════════════════════════════════════════════
-// Domain models
-// ═══════════════════════════════════════════════════════════════════════════════
-
-internal sealed record Order(string Id, DateTime OrderDate, bool IsCancelled, string? CancelReason, Customer Customer);
-
-internal sealed record Customer(string Name, string Email);
-
-// ═══════════════════════════════════════════════════════════════════════════════
-// Executors - emit events via AddEventAsync and YieldOutputAsync
-// ═══════════════════════════════════════════════════════════════════════════════
-
-/// <summary>
-/// Looks up an order by ID, emitting progress events.
-/// </summary>
-internal sealed class OrderLookup() : Executor<string, Order>("OrderLookup")
-{
-    public override async ValueTask<Order> HandleAsync(
-        string message,
-        IWorkflowContext context,
-        CancellationToken cancellationToken = default)
-    {
-        await context.AddEventAsync(new OrderLookupStartedEvent(message), cancellationToken);
-
-        // Simulate database lookup
-        await Task.Delay(TimeSpan.FromSeconds(1), cancellationToken);
-
-        Order order = new(
-            Id: message,
-            OrderDate: DateTime.UtcNow.AddDays(-1),
-            IsCancelled: false,
-            CancelReason: "Customer requested cancellation",
-            Customer: new Customer(Name: "Jerry", Email: "jerry@example.com"));
-
-        await context.AddEventAsync(new OrderFoundEvent(order.Customer.Name), cancellationToken);
-
-        // YieldOutputAsync emits a WorkflowOutputEvent observable via streaming
-        await context.YieldOutputAsync(order, cancellationToken);
-
-        return order;
-    }
-}
-
-/// <summary>
-/// Cancels an order, emitting progress events during the multi-step process.
-/// </summary>
-internal sealed class OrderCancel() : Executor<Order, Order>("OrderCancel")
-{
-    public override async ValueTask<Order> HandleAsync(
-        Order message,
-        IWorkflowContext context,
-        CancellationToken cancellationToken = default)
-    {
-        await context.AddEventAsync(new CancellationProgressEvent(0, "Starting cancellation"), cancellationToken);
-
-        // Simulate a multi-step cancellation process
-        await Task.Delay(TimeSpan.FromMilliseconds(500), cancellationToken);
-        await context.AddEventAsync(new CancellationProgressEvent(33, "Contacting payment provider"), cancellationToken);
-
-        await Task.Delay(TimeSpan.FromMilliseconds(500), cancellationToken);
-        await context.AddEventAsync(new CancellationProgressEvent(66, "Processing refund"), cancellationToken);
-
-        await Task.Delay(TimeSpan.FromMilliseconds(500), cancellationToken);
-
-        Order cancelledOrder = message with { IsCancelled = true };
-        await context.AddEventAsync(new CancellationProgressEvent(100, "Complete"), cancellationToken);
-        await context.AddEventAsync(new OrderCancelledEvent(), cancellationToken);
-
-        await context.YieldOutputAsync(cancelledOrder, cancellationToken);
-
-        return cancelledOrder;
-    }
-}
-
-/// <summary>
-/// Sends a cancellation confirmation email, emitting an event on completion.
-/// </summary>
-internal sealed class SendEmail() : Executor<Order, string>("SendEmail")
-{
-    public override async ValueTask<string> HandleAsync(
-        Order message,
-        IWorkflowContext context,
-        CancellationToken cancellationToken = default)
-    {
-        // Simulate sending email
-        await Task.Delay(TimeSpan.FromMilliseconds(500), cancellationToken);
-
-        string result = $"Cancellation email sent for order {message.Id} to {message.Customer.Email}.";
-
-        await context.AddEventAsync(new EmailSentEvent(message.Customer.Email), cancellationToken);
-
-        await context.YieldOutputAsync(result, cancellationToken);
-
-        return result;
-    }
-}

dotnet/samples/Durable/Workflow/ConsoleApps/05_WorkflowEvents/Program.cs

@@ -1,138 +0,0 @@
-// Copyright (c) Microsoft. All rights reserved.
-
-// ═══════════════════════════════════════════════════════════════════════════════
-// SAMPLE: Workflow Events and Streaming
-// ═══════════════════════════════════════════════════════════════════════════════
-//
-// This sample demonstrates how to use IWorkflowContext event methods in executors
-// and stream events from the caller side:
-//
-// 1. AddEventAsync     - Emit custom events that callers can observe in real-time
-// 2. StreamAsync       - Start a workflow and obtain a streaming handle
-// 3. WatchStreamAsync  - Observe events as they occur (custom, framework, and terminal)
-//
-// The sample uses IWorkflowClient.StreamAsync to start a workflow and
-// WatchStreamAsync to observe events as they occur in real-time.
-//
-// Workflow: OrderLookup -> OrderCancel -> SendEmail
-// ═══════════════════════════════════════════════════════════════════════════════
-
-using Microsoft.Agents.AI.DurableTask;
-using Microsoft.Agents.AI.DurableTask.Workflows;
-using Microsoft.Agents.AI.Workflows;
-using Microsoft.DurableTask.Client.AzureManaged;
-using Microsoft.DurableTask.Worker.AzureManaged;
-using Microsoft.Extensions.DependencyInjection;
-using Microsoft.Extensions.Hosting;
-using Microsoft.Extensions.Logging;
-using WorkflowEvents;
-
-// Get DTS connection string from environment variable
-string dtsConnectionString = Environment.GetEnvironmentVariable("DURABLE_TASK_SCHEDULER_CONNECTION_STRING")
-    ?? "Endpoint=http://localhost:8080;TaskHub=default;Authentication=None";
-
-// Define executors and build workflow
-OrderLookup orderLookup = new();
-OrderCancel orderCancel = new();
-SendEmail sendEmail = new();
-
-Workflow cancelOrder = new WorkflowBuilder(orderLookup)
-    .WithName("CancelOrder")
-    .WithDescription("Cancel an order and notify the customer")
-    .AddEdge(orderLookup, orderCancel)
-    .AddEdge(orderCancel, sendEmail)
-    .Build();
-
-// Configure host with durable workflow support
-IHost host = Host.CreateDefaultBuilder(args)
-    .ConfigureLogging(logging => logging.SetMinimumLevel(LogLevel.Warning))
-    .ConfigureServices(services =>
-    {
-        services.ConfigureDurableWorkflows(
-            workflowOptions => workflowOptions.AddWorkflow(cancelOrder),
-            workerBuilder: builder => builder.UseDurableTaskScheduler(dtsConnectionString),
-            clientBuilder: builder => builder.UseDurableTaskScheduler(dtsConnectionString));
-    })
-    .Build();
-
-await host.StartAsync();
-
-IWorkflowClient workflowClient = host.Services.GetRequiredService<IWorkflowClient>();
-
-Console.WriteLine("Workflow Events Demo - Enter order ID (or 'exit'):");
-
-while (true)
-{
-    Console.Write("> ");
-    string? input = Console.ReadLine();
-    if (string.IsNullOrWhiteSpace(input) || input.Equals("exit", StringComparison.OrdinalIgnoreCase))
-    {
-        break;
-    }
-
-    try
-    {
-        await RunWorkflowWithStreamingAsync(input, cancelOrder, workflowClient);
-    }
-    catch (Exception ex)
-    {
-        Console.WriteLine($"Error: {ex.Message}");
-    }
-
-    Console.WriteLine();
-}
-
-await host.StopAsync();
-
-// Runs a workflow and streams events as they occur
-static async Task RunWorkflowWithStreamingAsync(string orderId, Workflow workflow, IWorkflowClient client)
-{
-    // StreamAsync starts the workflow and returns a streaming handle for observing events
-    IStreamingWorkflowRun run = await client.StreamAsync(workflow, orderId);
-    Console.WriteLine($"Started run: {run.RunId}");
-
-    // WatchStreamAsync yields events as they're emitted by executors
-    await foreach (WorkflowEvent evt in run.WatchStreamAsync())
-    {
-        Console.WriteLine($"  New event received at {DateTime.Now:HH:mm:ss.ffff} ({evt.GetType().Name})");
-
-        switch (evt)
-        {
-            // Custom domain events (emitted via AddEventAsync)
-            case OrderLookupStartedEvent e:
-                WriteColored($"    [Lookup] Looking up order {e.OrderId}", ConsoleColor.Cyan);
-                break;
-            case OrderFoundEvent e:
-                WriteColored($"    [Lookup] Found: {e.CustomerName}", ConsoleColor.Cyan);
-                break;
-            case CancellationProgressEvent e:
-                WriteColored($"    [Cancel] {e.PercentComplete}% - {e.Status}", ConsoleColor.Yellow);
-                break;
-            case OrderCancelledEvent:
-                WriteColored("    [Cancel] Done", ConsoleColor.Yellow);
-                break;
-            case EmailSentEvent e:
-                WriteColored($"    [Email] Sent to {e.Email}", ConsoleColor.Magenta);
-                break;
-
-            case WorkflowOutputEvent e:
-                WriteColored($"    [Output] {e.SourceId}", ConsoleColor.DarkGray);
-                break;
-
-            // Workflow completion
-            case DurableWorkflowCompletedEvent e:
-                WriteColored($"  Completed: {e.Result}", ConsoleColor.Green);
-                break;
-            case DurableWorkflowFailedEvent e:
-                WriteColored($"  Failed: {e.ErrorMessage}", ConsoleColor.Red);
-                break;
-        }
-    }
-}
-
-static void WriteColored(string message, ConsoleColor color)
-{
-    Console.ForegroundColor = color;
-    Console.WriteLine(message);
-    Console.ResetColor();
-}

dotnet/samples/Durable/Workflow/ConsoleApps/05_WorkflowEvents/README.md

@@ -1,127 +0,0 @@
-# Workflow Events Sample
-
-This sample demonstrates how to use workflow events and streaming in durable workflows.
-
-## What it demonstrates
-
-1. **Custom Events** (`AddEventAsync`) — Executors emit domain-specific events during execution
-2. **Event Streaming** (`StreamAsync` / `WatchStreamAsync`) — Callers observe events in real-time as the workflow progresses
-3. **Framework Events** — Automatic `ExecutorInvokedEvent`, `ExecutorCompletedEvent`, and `WorkflowOutputEvent` events emitted by the framework
-
-## Emitting Custom Events
-
-Executors can emit custom domain events during execution using the `IWorkflowContext` instance passed to `HandleAsync`. These events are streamed to callers in real-time via `WatchStreamAsync`.
-
-### Defining a custom event
-
-Create a class that inherits from `WorkflowEvent`. Pass any data payload to the base constructor:
-
-```csharp
-public class CancellationProgressEvent(int percentComplete, string status) : WorkflowEvent(status)
-{
-    public int PercentComplete { get; } = percentComplete;
-    public string Status { get; } = status;
-}
-```
-
-### Emitting the event from an executor
-
-Call `AddEventAsync` on the `IWorkflowContext` inside your executor's `HandleAsync` method:
-
-```csharp
-public override async ValueTask<Order> HandleAsync(
-    Order message,
-    IWorkflowContext context,
-    CancellationToken cancellationToken = default)
-{
-    await context.AddEventAsync(new CancellationProgressEvent(33, "Processing refund"), cancellationToken);
-    // ... rest of the executor logic
-}
-```
-
-### Observing events from the caller
-
-Use `StreamAsync` to start the workflow and `WatchStreamAsync` to observe events. Pattern match on your custom event types:
-
-```csharp
-IStreamingWorkflowRun run = await workflowClient.StreamAsync(workflow, input);
-
-await foreach (WorkflowEvent evt in run.WatchStreamAsync())
-{
-    switch (evt)
-    {
-        case CancellationProgressEvent e:
-            Console.WriteLine($"{e.PercentComplete}% - {e.Status}");
-            break;
-    }
-}
-```
-
-## Workflow Structure
-
-```
-OrderLookup → OrderCancel → SendEmail
-```
-
-Each executor emits custom events during execution:
-- `OrderLookup` emits `OrderLookupStartedEvent` and `OrderFoundEvent`
-- `OrderCancel` emits `CancellationProgressEvent` (with percentage) and `OrderCancelledEvent`
-- `SendEmail` emits `EmailSentEvent`
-
-## Prerequisites
-
-- [Durable Task Scheduler](https://learn.microsoft.com/azure/azure-functions/durable/durable-task-scheduler) running locally or in Azure
-- Set the `DURABLE_TASK_SCHEDULER_CONNECTION_STRING` environment variable (defaults to local emulator)
-
-## Environment Setup
-
-See the [README.md](../../README.md) file in the parent directory for more information on how to configure the environment, including how to install and run common sample dependencies.
-
-## Running the sample
-
-```bash
-dotnet run
-```
-
-Enter an order ID at the prompt to start a workflow and watch events stream in real-time:
-
-```text
-> order-42
-Started run: b6ba4d19...
-  New event received at 13:27:41.4956 (ExecutorInvokedEvent)
-  New event received at 13:27:41.5019 (OrderLookupStartedEvent)
-    [Lookup] Looking up order order-42
-  New event received at 13:27:41.5025 (OrderFoundEvent)
-    [Lookup] Found: Jerry
-  New event received at 13:27:41.5026 (ExecutorCompletedEvent)
-  New event received at 13:27:41.5026 (WorkflowOutputEvent)
-    [Output] OrderLookup
-  New event received at 13:27:43.0772 (ExecutorInvokedEvent)
-  New event received at 13:27:43.0773 (CancellationProgressEvent)
-    [Cancel] 0% - Starting cancellation
-  New event received at 13:27:43.0775 (CancellationProgressEvent)
-    [Cancel] 33% - Contacting payment provider
-  New event received at 13:27:43.0776 (CancellationProgressEvent)
-    [Cancel] 66% - Processing refund
-  New event received at 13:27:43.0777 (CancellationProgressEvent)
-    [Cancel] 100% - Complete
-  New event received at 13:27:43.0779 (OrderCancelledEvent)
-    [Cancel] Done
-  New event received at 13:27:43.0780 (ExecutorCompletedEvent)
-  New event received at 13:27:43.0780 (WorkflowOutputEvent)
-    [Output] OrderCancel
-  New event received at 13:27:43.6610 (ExecutorInvokedEvent)
-  New event received at 13:27:43.6611 (EmailSentEvent)
-    [Email] Sent to jerry@example.com
-  New event received at 13:27:43.6613 (ExecutorCompletedEvent)
-  New event received at 13:27:43.6613 (WorkflowOutputEvent)
-    [Output] SendEmail
-  New event received at 13:27:43.6619 (DurableWorkflowCompletedEvent)
-  Completed: Cancellation email sent for order order-42 to jerry@example.com.
-```
-
-### Viewing Workflows in the DTS Dashboard
-
-After running a workflow, you can navigate to the Durable Task Scheduler (DTS) dashboard to inspect the workflow execution and events.
-
-If you are using the DTS emulator, the dashboard is available at `http://localhost:8082`.

dotnet/samples/Durable/Workflow/ConsoleApps/06_WorkflowSharedState/06_WorkflowSharedState.csproj

@@ -1,29 +0,0 @@
-<Project Sdk="Microsoft.NET.Sdk">
-  <PropertyGroup>
-    <TargetFrameworks>net10.0</TargetFrameworks>
-    <OutputType>Exe</OutputType>
-    <ImplicitUsings>enable</ImplicitUsings>
-    <Nullable>enable</Nullable>
-    <AssemblyName>WorkflowSharedState</AssemblyName>
-    <RootNamespace>WorkflowSharedState</RootNamespace>
-  </PropertyGroup>
-
-  <ItemGroup>
-    <PackageReference Include="Azure.Identity" />
-    <PackageReference Include="Microsoft.DurableTask.Client.AzureManaged" />
-    <PackageReference Include="Microsoft.DurableTask.Worker.AzureManaged" />
-    <PackageReference Include="Microsoft.Extensions.Hosting" />
-  </ItemGroup>
-
-  <!-- Local projects that should be switched to package references when using the sample outside of this MAF repo -->
-  <!--
-  <ItemGroup>
-    <PackageReference Include="Microsoft.Agents.AI.DurableTask" />
-    <PackageReference Include="Microsoft.Agents.AI.Workflows" />
-  </ItemGroup>
-  -->
-  <ItemGroup>
-    <ProjectReference Include="..\..\..\..\..\src\Microsoft.Agents.AI.DurableTask\Microsoft.Agents.AI.DurableTask.csproj" />
-    <ProjectReference Include="..\..\..\..\..\src\Microsoft.Agents.AI.OpenAI\Microsoft.Agents.AI.OpenAI.csproj" />
-  </ItemGroup>
-</Project>

dotnet/samples/Durable/Workflow/ConsoleApps/06_WorkflowSharedState/Executors.cs

@@ -1,182 +0,0 @@
-// Copyright (c) Microsoft. All rights reserved.
-
-using Microsoft.Agents.AI.Workflows;
-
-namespace WorkflowSharedState;
-
-// ═══════════════════════════════════════════════════════════════════════════════
-// Domain models
-// ═══════════════════════════════════════════════════════════════════════════════
-
-/// <summary>
-/// The primary order data passed through the pipeline via return values.
-/// </summary>
-internal sealed record OrderDetails(string OrderId, string CustomerName, decimal Amount, DateTime OrderDate);
-
-/// <summary>
-/// Cross-cutting audit trail accumulated in shared state across executors.
-/// Each executor appends its step name and timestamp. This data does not flow
-/// through return values — it lives only in shared state.
-/// </summary>
-internal sealed record AuditEntry(string Step, string Timestamp, string Detail);
-
-// ═══════════════════════════════════════════════════════════════════════════════
-// Executors
-// ═══════════════════════════════════════════════════════════════════════════════
-
-/// <summary>
-/// Validates the order and writes the initial audit entry and tax rate to shared state.
-/// The order details are returned as the executor output (normal message flow),
-/// while the audit trail and tax rate are stored in shared state (side-channel).
-/// If the order ID starts with "INVALID", the executor halts the workflow early
-/// using <see cref="IWorkflowContext.RequestHaltAsync"/>.
-/// </summary>
-internal sealed class ValidateOrder() : Executor<string, OrderDetails>("ValidateOrder")
-{
-    public override async ValueTask<OrderDetails> HandleAsync(
-        string message,
-        IWorkflowContext context,
-        CancellationToken cancellationToken = default)
-    {
-        await Task.Delay(TimeSpan.FromMilliseconds(200), cancellationToken);
-
-        // Halt the workflow early if the order ID is invalid.
-        // No downstream executors will run after this.
-        if (message.StartsWith("INVALID", StringComparison.OrdinalIgnoreCase))
-        {
-            await context.YieldOutputAsync($"Order '{message}' failed validation. Halting workflow.", cancellationToken);
-            await context.RequestHaltAsync();
-            return new OrderDetails(message, "Unknown", 0, DateTime.UtcNow);
-        }
-
-        OrderDetails details = new(message, "Jerry", 249.99m, DateTime.UtcNow);
-
-        // Store the tax rate in shared state — downstream ProcessPayment reads it
-        // without needing it in the message chain.
-        await context.QueueStateUpdateAsync("taxRate", 0.085m, cancellationToken: cancellationToken);
-        Console.WriteLine("    Wrote to shared state: taxRate = 8.5%");
-
-        // Start the audit trail in shared state
-        AuditEntry audit = new("ValidateOrder", DateTime.UtcNow.ToString("o"), $"Validated order {message}");
-        await context.QueueStateUpdateAsync("auditValidate", audit, cancellationToken: cancellationToken);
-        Console.WriteLine("    Wrote to shared state: auditValidate");
-
-        await context.YieldOutputAsync($"Order '{message}' validated. Customer: {details.CustomerName}, Amount: {details.Amount:C}", cancellationToken);
-
-        return details;
-    }
-}
-
-/// <summary>
-/// Enriches the order with shipping information.
-/// Reads the audit trail from shared state and appends its own entry.
-/// Uses ReadOrInitStateAsync to lazily initialize a shipping tier.
-/// Demonstrates custom scopes by writing shipping details under the "shipping" scope.
-/// </summary>
-internal sealed class EnrichOrder() : Executor<OrderDetails, OrderDetails>("EnrichOrder")
-{
-    public override async ValueTask<OrderDetails> HandleAsync(
-        OrderDetails message,
-        IWorkflowContext context,
-        CancellationToken cancellationToken = default)
-    {
-        await Task.Delay(TimeSpan.FromMilliseconds(200), cancellationToken);
-
-        // Use ReadOrInitStateAsync — only initializes if no value exists yet
-        string shippingTier = await context.ReadOrInitStateAsync(
-            "shippingTier",
-            () => "Express",
-            cancellationToken: cancellationToken);
-        Console.WriteLine($"    Read from shared state: shippingTier = {shippingTier}");
-
-        // Write carrier under a custom "shipping" scope.
-        // This keeps the key separate from keys written without a scope,
-        // so "carrier" here won't collide with a "carrier" key written elsewhere.
-        await context.QueueStateUpdateAsync("carrier", "Contoso Express", scopeName: "shipping", cancellationToken: cancellationToken);
-        Console.WriteLine("    Wrote to shared state: carrier = Contoso Express (scope: shipping)");
-
-        // Verify we can read the audit entry from the previous step
-        AuditEntry? previousAudit = await context.ReadStateAsync<AuditEntry>("auditValidate", cancellationToken: cancellationToken);
-        string auditStatus = previousAudit is not null ? $"(previous step: {previousAudit.Step})" : "(no prior audit)";
-        Console.WriteLine($"    Read from shared state: auditValidate {auditStatus}");
-
-        // Append our own audit entry
-        AuditEntry audit = new("EnrichOrder", DateTime.UtcNow.ToString("o"), $"Enriched with {shippingTier} shipping {auditStatus}");
-        await context.QueueStateUpdateAsync("auditEnrich", audit, cancellationToken: cancellationToken);
-        Console.WriteLine("    Wrote to shared state: auditEnrich");
-
-        await context.YieldOutputAsync($"Order enriched. Shipping: {shippingTier} {auditStatus}", cancellationToken);
-
-        return message;
-    }
-}
-
-/// <summary>
-/// Processes payment using the tax rate from shared state (written by ValidateOrder).
-/// The tax rate is side-channel data — it doesn't flow through return values.
-/// </summary>
-internal sealed class ProcessPayment() : Executor<OrderDetails, string>("ProcessPayment")
-{
-    public override async ValueTask<string> HandleAsync(
-        OrderDetails message,
-        IWorkflowContext context,
-        CancellationToken cancellationToken = default)
-    {
-        await Task.Delay(TimeSpan.FromMilliseconds(300), cancellationToken);
-
-        // Read tax rate written by ValidateOrder — not available in the message chain
-        decimal taxRate = await context.ReadOrInitStateAsync("taxRate", () => 0.0m, cancellationToken: cancellationToken);
-        Console.WriteLine($"    Read from shared state: taxRate = {taxRate:P1}");
-
-        decimal tax = message.Amount * taxRate;
-        decimal total = message.Amount + tax;
-        string paymentRef = $"PAY-{Guid.NewGuid():N}"[..16];
-
-        // Append audit entry
-        AuditEntry audit = new("ProcessPayment", DateTime.UtcNow.ToString("o"), $"Charged {total:C} (tax: {tax:C})");
-        await context.QueueStateUpdateAsync("auditPayment", audit, cancellationToken: cancellationToken);
-        Console.WriteLine("    Wrote to shared state: auditPayment");
-
-        await context.YieldOutputAsync($"Payment processed. Total: {total:C} (tax: {tax:C}). Ref: {paymentRef}", cancellationToken);
-
-        return paymentRef;
-    }
-}
-
-/// <summary>
-/// Generates the final invoice by reading the full audit trail from shared state.
-/// Demonstrates reading multiple state entries written by different executors
-/// and clearing a scope with <see cref="IWorkflowContext.QueueClearScopeAsync(string?, CancellationToken)"/>.
-/// </summary>
-internal sealed class GenerateInvoice() : Executor<string, string>("GenerateInvoice")
-{
-    public override async ValueTask<string> HandleAsync(
-        string message,
-        IWorkflowContext context,
-        CancellationToken cancellationToken = default)
-    {
-        await Task.Delay(TimeSpan.FromMilliseconds(100), cancellationToken);
-
-        // Read the full audit trail from shared state — each step wrote its own entry
-        AuditEntry? validateAudit = await context.ReadStateAsync<AuditEntry>("auditValidate", cancellationToken: cancellationToken);
-        AuditEntry? enrichAudit = await context.ReadStateAsync<AuditEntry>("auditEnrich", cancellationToken: cancellationToken);
-        AuditEntry? paymentAudit = await context.ReadStateAsync<AuditEntry>("auditPayment", cancellationToken: cancellationToken);
-        int auditCount = new[] { validateAudit, enrichAudit, paymentAudit }.Count(a => a is not null);
-        Console.WriteLine($"    Read from shared state: {auditCount} audit entries");
-
-        // Read carrier from the "shipping" scope (written by EnrichOrder)
-        string? carrier = await context.ReadStateAsync<string>("carrier", scopeName: "shipping", cancellationToken: cancellationToken);
-        Console.WriteLine($"    Read from shared state: carrier = {carrier} (scope: shipping)");
-
-        // Clear the "shipping" scope — no longer needed after invoice generation.
-        await context.QueueClearScopeAsync("shipping", cancellationToken);
-        Console.WriteLine("    Cleared shared state scope: shipping");
-
-        string auditSummary = string.Join(" → ", new[]
-        {
-            validateAudit?.Step, enrichAudit?.Step, paymentAudit?.Step
-        }.Where(s => s is not null));
-
-        return $"Invoice complete. Payment: {message}. Audit trail: [{auditSummary}]";
-    }
-}

dotnet/samples/Durable/Workflow/ConsoleApps/06_WorkflowSharedState/Program.cs

@@ -1,117 +0,0 @@
-// Copyright (c) Microsoft. All rights reserved.
-
-// ═══════════════════════════════════════════════════════════════════════════════
-// SAMPLE: Shared State During Workflow Execution
-// ═══════════════════════════════════════════════════════════════════════════════
-//
-// This sample demonstrates how executors in a durable workflow can share state
-// via IWorkflowContext. State is persisted across supersteps and survives
-// process restarts because the orchestration passes it to each activity.
-//
-// Key concepts:
-//   1. QueueStateUpdateAsync  - Write a value to shared state
-//   2. ReadStateAsync         - Read a value written by a previous executor
-//   3. ReadOrInitStateAsync   - Read or lazily initialize a state value
-//   4. QueueClearScopeAsync   - Clear all entries under a scope
-//   5. RequestHaltAsync       - Stop the workflow early (e.g., validation failure)
-//
-// Workflow: ValidateOrder -> EnrichOrder -> ProcessPayment -> GenerateInvoice
-//
-// Return values carry primary business data through the pipeline (OrderDetails,
-// payment ref). Shared state carries side-channel data that doesn't belong in
-// the message chain: a tax rate (set by ValidateOrder, read by ProcessPayment)
-// and an audit trail (each executor appends its own entry).
-// ═══════════════════════════════════════════════════════════════════════════════
-
-using Microsoft.Agents.AI.DurableTask;
-using Microsoft.Agents.AI.DurableTask.Workflows;
-using Microsoft.Agents.AI.Workflows;
-using Microsoft.DurableTask.Client.AzureManaged;
-using Microsoft.DurableTask.Worker.AzureManaged;
-using Microsoft.Extensions.DependencyInjection;
-using Microsoft.Extensions.Hosting;
-using Microsoft.Extensions.Logging;
-using WorkflowSharedState;
-
-// Get DTS connection string from environment variable
-string dtsConnectionString = Environment.GetEnvironmentVariable("DURABLE_TASK_SCHEDULER_CONNECTION_STRING")
-    ?? "Endpoint=http://localhost:8080;TaskHub=default;Authentication=None";
-
-// Define executors
-ValidateOrder validateOrder = new();
-EnrichOrder enrichOrder = new();
-ProcessPayment processPayment = new();
-GenerateInvoice generateInvoice = new();
-
-// Build the workflow: ValidateOrder -> EnrichOrder -> ProcessPayment -> GenerateInvoice
-Workflow orderPipeline = new WorkflowBuilder(validateOrder)
-    .WithName("OrderPipeline")
-    .WithDescription("Order processing pipeline with shared state across executors")
-    .AddEdge(validateOrder, enrichOrder)
-    .AddEdge(enrichOrder, processPayment)
-    .AddEdge(processPayment, generateInvoice)
-    .Build();
-
-// Configure host with durable workflow support
-IHost host = Host.CreateDefaultBuilder(args)
-    .ConfigureLogging(logging => logging.SetMinimumLevel(LogLevel.Warning))
-    .ConfigureServices(services =>
-    {
-        services.ConfigureDurableWorkflows(
-            workflowOptions => workflowOptions.AddWorkflow(orderPipeline),
-            workerBuilder: builder => builder.UseDurableTaskScheduler(dtsConnectionString),
-            clientBuilder: builder => builder.UseDurableTaskScheduler(dtsConnectionString));
-    })
-    .Build();
-
-await host.StartAsync();
-
-IWorkflowClient workflowClient = host.Services.GetRequiredService<IWorkflowClient>();
-
-Console.WriteLine("Shared State Workflow Demo");
-Console.WriteLine("Workflow: ValidateOrder -> EnrichOrder -> ProcessPayment -> GenerateInvoice");
-Console.WriteLine();
-Console.WriteLine("Enter an order ID (or 'exit'):");
-
-while (true)
-{
-    Console.Write("> ");
-    string? input = Console.ReadLine();
-    if (string.IsNullOrWhiteSpace(input) || input.Equals("exit", StringComparison.OrdinalIgnoreCase))
-    {
-        break;
-    }
-
-    try
-    {
-        // Start the workflow and stream events to see shared state in action
-        IStreamingWorkflowRun run = await workflowClient.StreamAsync(orderPipeline, input);
-        Console.WriteLine($"Started run: {run.RunId}");
-
-        await foreach (WorkflowEvent evt in run.WatchStreamAsync())
-        {
-            switch (evt)
-            {
-                case WorkflowOutputEvent e:
-                    Console.WriteLine($"  [Output] {e.SourceId}: {e.Data}");
-                    break;
-
-                case DurableWorkflowCompletedEvent e:
-                    Console.WriteLine($"  Completed: {e.Result}");
-                    break;
-
-                case DurableWorkflowFailedEvent e:
-                    Console.WriteLine($"  Failed: {e.ErrorMessage}");
-                    break;
-            }
-        }
-    }
-    catch (Exception ex)
-    {
-        Console.WriteLine($"Error: {ex.Message}");
-    }
-
-    Console.WriteLine();
-}
-
-await host.StopAsync();

dotnet/samples/Durable/Workflow/ConsoleApps/06_WorkflowSharedState/README.md

@@ -1,71 +0,0 @@
-# Shared State Workflow Sample
-
-This sample demonstrates how executors in a durable workflow can share state via `IWorkflowContext`. State written by one executor is accessible to all downstream executors, persisted across supersteps, and survives process restarts.
-
-## Key Concepts Demonstrated
-
-- Writing state with `QueueStateUpdateAsync` — executors store data for downstream executors
-- Reading state with `ReadStateAsync` — executors access data written by earlier executors
-- Lazy initialization with `ReadOrInitStateAsync` — initialize state only if not already present
-- Custom scopes with `scopeName` — partition state into isolated namespaces (e.g., `"shipping"`)
-- Clearing scopes with `QueueClearScopeAsync` — remove all entries under a scope when no longer needed
-- Early termination with `RequestHaltAsync` — halt the workflow when validation fails
-- State persistence across supersteps — the orchestration passes shared state to each executor
-- Event streaming with `IStreamingWorkflowRun` — observe executor progress in real time
-
-## Workflow
-
-**OrderPipeline**: `ValidateOrder` → `EnrichOrder` → `ProcessPayment` → `GenerateInvoice`
-
-Return values carry primary business data through the pipeline (`OrderDetails` → `OrderDetails` → payment ref → invoice string). Shared state carries side-channel data that doesn't belong in the message chain:
-
-| Executor | Returns (message flow) | Reads from State | Writes to State |
-|----------|----------------------|-----------------|-----------------|
-| **ValidateOrder** | `OrderDetails` | — | `taxRate`, `auditValidate` |
-| **EnrichOrder** | `OrderDetails` (pass-through) | `auditValidate` | `shippingTier`, `auditEnrich`, `carrier` (scope: shipping) |
-| **ProcessPayment** | payment ref string | `taxRate` | `auditPayment` |
-| **GenerateInvoice** | invoice string | `auditValidate`, `auditEnrich`, `auditPayment`, `carrier` (scope: shipping) | clears `shipping` scope |
-
-> [!NOTE]
-> `EnrichOrder` writes `carrier` under the `"shipping"` scope using `scopeName: "shipping"`. This keeps the key separate from keys written without a scope, so `"carrier"` in the `"shipping"` scope won't collide with a `"carrier"` key written elsewhere.
-
-## Environment Setup
-
-See the [README.md](../../README.md) file in the parent directory for more information on how to configure the environment, including how to install and run common sample dependencies.
-
-## Running the Sample
-
-```bash
-dotnet run
-```
-
-Enter an order ID when prompted. The workflow will process the order through all four executors, streaming events as they occur:
-
-```text
-> ORD-001
-Started run: abc123
-    Wrote to shared state: taxRate = 8.5%
-    Wrote to shared state: auditValidate
-  [Output] ValidateOrder: Order 'ORD-001' validated. Customer: Jerry, Amount: $249.99
-    Read from shared state: shippingTier = Express
-    Wrote to shared state: carrier = Contoso Express (scope: shipping)
-    Read from shared state: auditValidate (previous step: ValidateOrder)
-    Wrote to shared state: auditEnrich
-  [Output] EnrichOrder: Order enriched. Shipping: Express (previous step: ValidateOrder)
-    Read from shared state: taxRate = 8.5%
-    Wrote to shared state: auditPayment
-  [Output] ProcessPayment: Payment processed. Total: $271.24 (tax: $21.25). Ref: PAY-abc123def456
-    Read from shared state: 3 audit entries
-    Read from shared state: carrier = Contoso Express (scope: shipping)
-    Cleared shared state scope: shipping
-  [Output] GenerateInvoice: Invoice complete. Payment: "PAY-abc123def456". Audit trail: [ValidateOrder → EnrichOrder → ProcessPayment]
-  Completed: Invoice complete. Payment: "PAY-abc123def456". Audit trail: [ValidateOrder → EnrichOrder → ProcessPayment]
-```
-
-### Viewing Workflows in the DTS Dashboard
-
-After running a workflow, you can navigate to the Durable Task Scheduler (DTS) dashboard to inspect the orchestration status, executor inputs/outputs, and events.
-
-If you are using the DTS emulator, the dashboard is available at `http://localhost:8082`.
-
-To inspect shared state in the dashboard, click on an executor to view its input and output. The input contains a snapshot of the shared state the executor ran with, and the output includes any state updates it made (as `stateUpdates` with scoped keys).

dotnet/samples/Durable/Workflow/ConsoleApps/07_SubWorkflows/07_SubWorkflows.csproj

@@ -1,28 +0,0 @@
-<Project Sdk="Microsoft.NET.Sdk">
-  <PropertyGroup>
-    <TargetFrameworks>net10.0</TargetFrameworks>
-    <OutputType>Exe</OutputType>
-    <ImplicitUsings>enable</ImplicitUsings>
-    <Nullable>enable</Nullable>
-    <AssemblyName>SubWorkflows</AssemblyName>
-    <RootNamespace>SubWorkflows</RootNamespace>
-  </PropertyGroup>
-
-  <ItemGroup>
-    <PackageReference Include="Azure.Identity" />
-    <PackageReference Include="Microsoft.DurableTask.Client.AzureManaged" />
-    <PackageReference Include="Microsoft.DurableTask.Worker.AzureManaged" />
-    <PackageReference Include="Microsoft.Extensions.Hosting" />
-  </ItemGroup>
-
-  <!-- Local projects that should be switched to package references when using the sample outside of this MAF repo -->
-  <!--
-  <ItemGroup>
-    <PackageReference Include="Microsoft.Agents.AI.DurableTask" />
-    <PackageReference Include="Microsoft.Agents.AI.Workflows" />
-  </ItemGroup>
-  -->
-  <ItemGroup>
-    <ProjectReference Include="..\..\..\..\..\src\Microsoft.Agents.AI.DurableTask\Microsoft.Agents.AI.DurableTask.csproj" />
-  </ItemGroup>
-</Project>

dotnet/samples/Durable/Workflow/ConsoleApps/07_SubWorkflows/Executors.cs

@@ -1,232 +0,0 @@
-// Copyright (c) Microsoft. All rights reserved.
-
-using Microsoft.Agents.AI.Workflows;
-
-namespace SubWorkflows;
-
-/// <summary>
-/// Event emitted when the fraud check risk score is calculated.
-/// </summary>
-internal sealed class FraudRiskAssessedEvent(int riskScore) : WorkflowEvent($"Risk score: {riskScore}/100")
-{
-    public int RiskScore => riskScore;
-}
-
-/// <summary>
-/// Represents an order being processed through the workflow.
-/// </summary>
-internal sealed class OrderInfo
-{
-    public required string OrderId { get; set; }
-
-    public decimal Amount { get; set; }
-
-    public string? PaymentTransactionId { get; set; }
-
-    public string? TrackingNumber { get; set; }
-
-    public string? Carrier { get; set; }
-}
-
-// Main workflow executors
-
-/// <summary>
-/// Entry point executor that receives the order ID and creates an OrderInfo object.
-/// </summary>
-internal sealed class OrderReceived() : Executor<string, OrderInfo>("OrderReceived")
-{
-    public override ValueTask<OrderInfo> HandleAsync(string message, IWorkflowContext context, CancellationToken cancellationToken = default)
-    {
-        Console.WriteLine();
-        Console.ForegroundColor = ConsoleColor.Cyan;
-        Console.WriteLine($"[OrderReceived] Processing order '{message}'");
-        Console.ResetColor();
-
-        OrderInfo order = new()
-        {
-            OrderId = message,
-            Amount = 99.99m // Simulated order amount
-        };
-
-        return ValueTask.FromResult(order);
-    }
-}
-
-/// <summary>
-/// Final executor that outputs the completed order summary.
-/// </summary>
-internal sealed class OrderCompleted() : Executor<OrderInfo, string>("OrderCompleted")
-{
-    public override ValueTask<string> HandleAsync(OrderInfo message, IWorkflowContext context, CancellationToken cancellationToken = default)
-    {
-        Console.WriteLine();
-        Console.ForegroundColor = ConsoleColor.Green;
-        Console.WriteLine("┌─────────────────────────────────────────────────────────────────┐");
-        Console.WriteLine($"│ [OrderCompleted] Order '{message.OrderId}' successfully processed!");
-        Console.WriteLine($"│   Payment: {message.PaymentTransactionId}");
-        Console.WriteLine($"│   Shipping: {message.Carrier} - {message.TrackingNumber}");
-        Console.WriteLine("└─────────────────────────────────────────────────────────────────┘");
-        Console.ResetColor();
-
-        return ValueTask.FromResult($"Order {message.OrderId} completed. Tracking: {message.TrackingNumber}");
-    }
-}
-
-// Payment sub-workflow executors
-
-/// <summary>
-/// Validates payment information for an order.
-/// </summary>
-internal sealed class ValidatePayment() : Executor<OrderInfo, OrderInfo>("ValidatePayment")
-{
-    public override async ValueTask<OrderInfo> HandleAsync(OrderInfo message, IWorkflowContext context, CancellationToken cancellationToken = default)
-    {
-        Console.WriteLine();
-        Console.ForegroundColor = ConsoleColor.Yellow;
-        Console.WriteLine($"  [Payment/ValidatePayment] Validating payment for order '{message.OrderId}'...");
-        Console.ResetColor();
-
-        await Task.Delay(TimeSpan.FromMilliseconds(100), cancellationToken);
-
-        Console.ForegroundColor = ConsoleColor.Yellow;
-        Console.WriteLine($"  [Payment/ValidatePayment] Payment validated for ${message.Amount}");
-        Console.ResetColor();
-
-        return message;
-    }
-}
-
-/// <summary>
-/// Charges the payment for an order.
-/// </summary>
-internal sealed class ChargePayment() : Executor<OrderInfo, OrderInfo>("ChargePayment")
-{
-    public override async ValueTask<OrderInfo> HandleAsync(OrderInfo message, IWorkflowContext context, CancellationToken cancellationToken = default)
-    {
-        Console.ForegroundColor = ConsoleColor.Yellow;
-        Console.WriteLine($"  [Payment/ChargePayment] Charging ${message.Amount} for order '{message.OrderId}'...");
-        Console.ResetColor();
-
-        await Task.Delay(TimeSpan.FromMilliseconds(100), cancellationToken);
-
-        message.PaymentTransactionId = $"TXN-{Guid.NewGuid().ToString("N")[..8].ToUpperInvariant()}";
-
-        Console.ForegroundColor = ConsoleColor.Yellow;
-        Console.WriteLine($"  [Payment/ChargePayment] ✓ Payment processed: {message.PaymentTransactionId}");
-        Console.ResetColor();
-
-        return message;
-    }
-}
-
-// FraudCheck sub-sub-workflow executors (nested inside Payment)
-
-/// <summary>
-/// Analyzes transaction patterns for potential fraud.
-/// </summary>
-internal sealed class AnalyzePatterns() : Executor<OrderInfo, OrderInfo>("AnalyzePatterns")
-{
-    public override async ValueTask<OrderInfo> HandleAsync(OrderInfo message, IWorkflowContext context, CancellationToken cancellationToken = default)
-    {
-        Console.ForegroundColor = ConsoleColor.DarkYellow;
-        Console.WriteLine($"    [Payment/FraudCheck/AnalyzePatterns] Analyzing patterns for order '{message.OrderId}'...");
-        Console.ResetColor();
-
-        await Task.Delay(TimeSpan.FromMilliseconds(100), cancellationToken);
-
-        // Store analysis results in shared state for the next executor in this sub-workflow
-        int patternsFound = new Random().Next(0, 5);
-        await context.QueueStateUpdateAsync("patternsFound", patternsFound, cancellationToken: cancellationToken);
-
-        Console.ForegroundColor = ConsoleColor.DarkYellow;
-        Console.WriteLine($"    [Payment/FraudCheck/AnalyzePatterns] ✓ Pattern analysis complete ({patternsFound} suspicious patterns)");
-        Console.ResetColor();
-
-        return message;
-    }
-}
-
-/// <summary>
-/// Calculates a risk score for the transaction.
-/// </summary>
-internal sealed class CalculateRiskScore() : Executor<OrderInfo, OrderInfo>("CalculateRiskScore")
-{
-    public override async ValueTask<OrderInfo> HandleAsync(OrderInfo message, IWorkflowContext context, CancellationToken cancellationToken = default)
-    {
-        Console.ForegroundColor = ConsoleColor.DarkYellow;
-        Console.WriteLine($"    [Payment/FraudCheck/CalculateRiskScore] Calculating risk score for order '{message.OrderId}'...");
-        Console.ResetColor();
-
-        await Task.Delay(TimeSpan.FromMilliseconds(100), cancellationToken);
-
-        // Read the pattern count from shared state (written by AnalyzePatterns)
-        int patternsFound = await context.ReadStateAsync<int>("patternsFound", cancellationToken: cancellationToken);
-        int riskScore = Math.Min(patternsFound * 20 + new Random().Next(1, 20), 100);
-
-        // Emit a workflow event from within a nested sub-workflow
-        await context.AddEventAsync(new FraudRiskAssessedEvent(riskScore), cancellationToken);
-
-        Console.ForegroundColor = ConsoleColor.DarkYellow;
-        Console.WriteLine($"    [Payment/FraudCheck/CalculateRiskScore] ✓ Risk score: {riskScore}/100 (based on {patternsFound} patterns)");
-        Console.ResetColor();
-
-        return message;
-    }
-}
-
-// Shipping sub-workflow executors
-
-/// <summary>
-/// Selects a shipping carrier for an order.
-/// </summary>
-/// <remarks>
-/// This executor uses <see cref="Executor{TInput}"/> (void return) combined with
-/// <see cref="IWorkflowContext.SendMessageAsync"/> to forward the order to the next
-/// connected executor (CreateShipment). This demonstrates explicit typed message passing
-/// as an alternative to returning a value from the handler.
-/// </remarks>
-internal sealed class SelectCarrier() : Executor<OrderInfo>("SelectCarrier")
-{
-    public override async ValueTask HandleAsync(OrderInfo message, IWorkflowContext context, CancellationToken cancellationToken = default)
-    {
-        Console.WriteLine();
-        Console.ForegroundColor = ConsoleColor.Blue;
-        Console.WriteLine($"  [Shipping/SelectCarrier] Selecting carrier for order '{message.OrderId}'...");
-        Console.ResetColor();
-
-        await Task.Delay(TimeSpan.FromMilliseconds(100), cancellationToken);
-
-        message.Carrier = message.Amount > 50 ? "Express" : "Standard";
-
-        Console.ForegroundColor = ConsoleColor.Blue;
-        Console.WriteLine($"  [Shipping/SelectCarrier] ✓ Selected carrier: {message.Carrier}");
-        Console.ResetColor();
-
-        // Use SendMessageAsync to forward the updated order to connected executors.
-        // With a void-return executor, this is the mechanism for passing data downstream.
-        await context.SendMessageAsync(message, cancellationToken: cancellationToken);
-    }
-}
-
-/// <summary>
-/// Creates shipment and generates tracking number.
-/// </summary>
-internal sealed class CreateShipment() : Executor<OrderInfo, OrderInfo>("CreateShipment")
-{
-    public override async ValueTask<OrderInfo> HandleAsync(OrderInfo message, IWorkflowContext context, CancellationToken cancellationToken = default)
-    {
-        Console.ForegroundColor = ConsoleColor.Blue;
-        Console.WriteLine($"  [Shipping/CreateShipment] Creating shipment for order '{message.OrderId}'...");
-        Console.ResetColor();
-
-        await Task.Delay(TimeSpan.FromMilliseconds(100), cancellationToken);
-
-        message.TrackingNumber = $"TRACK-{Guid.NewGuid().ToString("N")[..10].ToUpperInvariant()}";
-
-        Console.ForegroundColor = ConsoleColor.Blue;
-        Console.WriteLine($"  [Shipping/CreateShipment] ✓ Shipment created: {message.TrackingNumber}");
-        Console.ResetColor();
-
-        return message;
-    }
-}

dotnet/samples/Durable/Workflow/ConsoleApps/07_SubWorkflows/Program.cs

@@ -1,146 +0,0 @@
-// Copyright (c) Microsoft. All rights reserved.
-
-// This sample demonstrates nested sub-workflows. A sub-workflow can act as an executor
-// within another workflow, including multi-level nesting (sub-workflow within sub-workflow).
-
-using Microsoft.Agents.AI.DurableTask;
-using Microsoft.Agents.AI.DurableTask.Workflows;
-using Microsoft.Agents.AI.Workflows;
-using Microsoft.DurableTask.Client.AzureManaged;
-using Microsoft.DurableTask.Worker.AzureManaged;
-using Microsoft.Extensions.DependencyInjection;
-using Microsoft.Extensions.Hosting;
-using Microsoft.Extensions.Logging;
-using SubWorkflows;
-
-// Get DTS connection string from environment variable
-string dtsConnectionString = Environment.GetEnvironmentVariable("DURABLE_TASK_SCHEDULER_CONNECTION_STRING")
-    ?? "Endpoint=http://localhost:8080;TaskHub=default;Authentication=None";
-
-// Build the FraudCheck sub-workflow (this will be nested inside the Payment sub-workflow)
-AnalyzePatterns analyzePatterns = new();
-CalculateRiskScore calculateRiskScore = new();
-
-Workflow fraudCheckWorkflow = new WorkflowBuilder(analyzePatterns)
-    .WithName("SubFraudCheck")
-    .WithDescription("Analyzes transaction patterns and calculates risk score")
-    .AddEdge(analyzePatterns, calculateRiskScore)
-    .Build();
-
-// Build the Payment sub-workflow: ValidatePayment -> FraudCheck (sub-workflow) -> ChargePayment
-ValidatePayment validatePayment = new();
-ExecutorBinding fraudCheckExecutor = fraudCheckWorkflow.BindAsExecutor("FraudCheck");
-ChargePayment chargePayment = new();
-
-Workflow paymentWorkflow = new WorkflowBuilder(validatePayment)
-    .WithName("SubPaymentProcessing")
-    .WithDescription("Validates and processes payment for an order")
-    .AddEdge(validatePayment, fraudCheckExecutor)
-    .AddEdge(fraudCheckExecutor, chargePayment)
-    .Build();
-
-// Build the Shipping sub-workflow: SelectCarrier -> CreateShipment
-SelectCarrier selectCarrier = new();
-CreateShipment createShipment = new();
-
-Workflow shippingWorkflow = new WorkflowBuilder(selectCarrier)
-    .WithName("SubShippingArrangement")
-    .WithDescription("Selects carrier and creates shipment")
-    .AddEdge(selectCarrier, createShipment)
-    .Build();
-
-// Build the main workflow using sub-workflows as executors
-// OrderReceived -> Payment (sub-workflow) -> Shipping (sub-workflow) -> OrderCompleted
-OrderReceived orderReceived = new();
-OrderCompleted orderCompleted = new();
-ExecutorBinding paymentExecutor = paymentWorkflow.BindAsExecutor("Payment");
-ExecutorBinding shippingExecutor = shippingWorkflow.BindAsExecutor("Shipping");
-
-Workflow orderProcessingWorkflow = new WorkflowBuilder(orderReceived)
-    .WithName("OrderProcessing")
-    .WithDescription("Processes an order through payment and shipping")
-    .AddEdge(orderReceived, paymentExecutor)
-    .AddEdge(paymentExecutor, shippingExecutor)
-    .AddEdge(shippingExecutor, orderCompleted)
-    .Build();
-
-// Configure and start the host
-// Register only the main workflow - sub-workflows are discovered automatically!
-IHost host = Host.CreateDefaultBuilder(args)
-    .ConfigureLogging(logging => logging.SetMinimumLevel(LogLevel.Warning))
-    .ConfigureServices(services =>
-    {
-        services.ConfigureDurableWorkflows(
-            workflowOptions => workflowOptions.AddWorkflow(orderProcessingWorkflow),
-            workerBuilder: builder => builder.UseDurableTaskScheduler(dtsConnectionString),
-            clientBuilder: builder => builder.UseDurableTaskScheduler(dtsConnectionString));
-    })
-    .Build();
-
-await host.StartAsync();
-
-IWorkflowClient workflowClient = host.Services.GetRequiredService<IWorkflowClient>();
-
-Console.WriteLine("Durable Sub-Workflows Sample");
-Console.WriteLine("Workflow: OrderReceived -> Payment(sub) -> Shipping(sub) -> OrderCompleted");
-Console.WriteLine("  Payment contains nested FraudCheck sub-workflow (Level 2 nesting)");
-Console.WriteLine();
-Console.WriteLine("Enter an order ID (or 'exit'):");
-
-while (true)
-{
-    Console.Write("> ");
-    string? input = Console.ReadLine();
-    if (string.IsNullOrWhiteSpace(input) || input.Equals("exit", StringComparison.OrdinalIgnoreCase))
-    {
-        break;
-    }
-
-    try
-    {
-        await StartNewWorkflowAsync(input, orderProcessingWorkflow, workflowClient);
-    }
-    catch (Exception ex)
-    {
-        Console.WriteLine($"Error: {ex.Message}");
-    }
-
-    Console.WriteLine();
-}
-
-await host.StopAsync();
-
-// Start a new workflow using streaming to observe events (including from sub-workflows)
-static async Task StartNewWorkflowAsync(string orderId, Workflow workflow, IWorkflowClient client)
-{
-    Console.WriteLine($"\nStarting order processing for '{orderId}'...");
-
-    IStreamingWorkflowRun run = await client.StreamAsync(workflow, orderId);
-    Console.WriteLine($"Run ID: {run.RunId}");
-    Console.WriteLine();
-
-    await foreach (WorkflowEvent evt in run.WatchStreamAsync())
-    {
-        switch (evt)
-        {
-            // Custom event emitted from the FraudCheck sub-sub-workflow
-            case FraudRiskAssessedEvent e:
-                Console.ForegroundColor = ConsoleColor.DarkYellow;
-                Console.WriteLine($"  [Event from sub-workflow] {e.GetType().Name}: Risk score {e.RiskScore}/100");
-                Console.ResetColor();
-                break;
-
-            case DurableWorkflowCompletedEvent e:
-                Console.ForegroundColor = ConsoleColor.Green;
-                Console.WriteLine($"✓ Order completed: {e.Result}");
-                Console.ResetColor();
-                break;
-
-            case DurableWorkflowFailedEvent e:
-                Console.ForegroundColor = ConsoleColor.Red;
-                Console.WriteLine($"✗ Failed: {e.ErrorMessage}");
-                Console.ResetColor();
-                break;
-        }
-    }
-}

dotnet/samples/Durable/Workflow/ConsoleApps/07_SubWorkflows/README.md

@@ -1,123 +0,0 @@
-# Sub-Workflows Sample (Nested Workflows)
-
-This sample demonstrates how to compose complex workflows from simpler, reusable sub-workflows. Sub-workflows are built using `WorkflowBuilder` and embedded as executors via `BindAsExecutor()`. Unlike the in-process workflow runner, the durable workflow backend persists execution state across process restarts — each sub-workflow runs as a separate orchestration instance on the Durable Task Scheduler, providing independent checkpointing, fault tolerance, and hierarchical visualization in the DTS dashboard.
-
-## Key Concepts Demonstrated
-
-- **Sub-workflows**: Using `Workflow.BindAsExecutor()` to embed a workflow as an executor in another workflow
-- **Multi-level nesting**: Sub-workflows within sub-workflows (Level 2 nesting)
-- **Automatic discovery**: Registering only the main workflow; sub-workflows are discovered automatically
-- **Failure isolation**: Each sub-workflow runs as a separate orchestration instance on the DTS backend
-- **Hierarchical visualization**: Parent-child orchestration hierarchy visible in the DTS dashboard
-- **Event propagation**: Custom workflow events (`FraudRiskAssessedEvent`) bubble up from nested sub-workflows to the streaming client
-- **Message passing**: Using `Executor<TInput>` (void return) with `SendMessageAsync` to forward typed messages to connected executors (`SelectCarrier`)
-- **Shared state within sub-workflows**: Using `QueueStateUpdateAsync`/`ReadStateAsync` to share data between executors within a sub-workflow (`AnalyzePatterns` → `CalculateRiskScore`)
-
-## Overview
-
-The sample implements an order processing workflow composed of two sub-workflows, one of which contains its own nested sub-workflow:
-
-```
-OrderProcessing (main workflow)
-├── OrderReceived
-├── Payment (sub-workflow)
-│   ├── ValidatePayment
-│   ├── FraudCheck (sub-sub-workflow) ← Level 2 nesting!
-│   │   ├── AnalyzePatterns
-│   │   └── CalculateRiskScore
-│   └── ChargePayment
-├── Shipping (sub-workflow)
-│   ├── SelectCarrier ← Uses SendMessageAsync (void-return executor)
-│   └── CreateShipment
-└── OrderCompleted
-```
-
-| Executor | Sub-Workflow | Description |
-|----------|-------------|-------------|
-| OrderReceived | Main | Receives order ID and creates order info |
-| ValidatePayment | Payment | Validates payment information |
-| AnalyzePatterns | FraudCheck (nested in Payment) | Analyzes transaction patterns, stores results in shared state |
-| CalculateRiskScore | FraudCheck (nested in Payment) | Reads shared state, calculates risk score, emits `FraudRiskAssessedEvent` |
-| ChargePayment | Payment | Charges payment amount |
-| SelectCarrier | Shipping | Selects carrier using `SendMessageAsync` (void-return executor) |
-| CreateShipment | Shipping | Creates shipment with tracking |
-| OrderCompleted | Main | Outputs completed order summary |
-
-## How Sub-Workflows Work
-
-1. **Build** each sub-workflow as a standalone `Workflow` using `WorkflowBuilder`
-2. **Bind** a workflow as an executor using `workflow.BindAsExecutor("name")`
-3. **Add** the bound executor as a node in the parent workflow's graph
-4. **Register** only the top-level workflow — sub-workflows are discovered and registered automatically
-
-```csharp
-// Build a sub-workflow
-Workflow fraudCheckWorkflow = new WorkflowBuilder(analyzePatterns)
-    .WithName("SubFraudCheck")
-    .AddEdge(analyzePatterns, calculateRiskScore)
-    .Build();
-
-// Nest it inside another sub-workflow using BindAsExecutor
-ExecutorBinding fraudCheckExecutor = fraudCheckWorkflow.BindAsExecutor("FraudCheck");
-
-Workflow paymentWorkflow = new WorkflowBuilder(validatePayment)
-    .WithName("SubPaymentProcessing")
-    .AddEdge(validatePayment, fraudCheckExecutor)
-    .AddEdge(fraudCheckExecutor, chargePayment)
-    .Build();
-
-// Use the Payment sub-workflow in the main workflow
-ExecutorBinding paymentExecutor = paymentWorkflow.BindAsExecutor("Payment");
-
-Workflow mainWorkflow = new WorkflowBuilder(orderReceived)
-    .AddEdge(orderReceived, paymentExecutor)
-    .AddEdge(paymentExecutor, orderCompleted)
-    .Build();
-```
-
-## Environment Setup
-
-See the [README.md](../README.md) file in the parent directory for information on configuring the environment, including how to install and run the Durable Task Scheduler.
-
-## Running the Sample
-
-```bash
-cd dotnet/samples/Durable/Workflow/ConsoleApps/07_SubWorkflows
-dotnet run --framework net10.0
-```
-
-### Sample Output
-
-```text
-Durable Sub-Workflows Sample
-Workflow: OrderReceived -> Payment(sub) -> Shipping(sub) -> OrderCompleted
-  Payment contains nested FraudCheck sub-workflow (Level 2 nesting)
-
-Enter an order ID (or 'exit'):
-> ORD-001
-Starting order processing for 'ORD-001'...
-Run ID: abc123...
-
-[OrderReceived] Processing order 'ORD-001'
-  [Payment/ValidatePayment] Validating payment for order 'ORD-001'...
-  [Payment/ValidatePayment] Payment validated for $99.99
-    [Payment/FraudCheck/AnalyzePatterns] Analyzing patterns for order 'ORD-001'...
-    [Payment/FraudCheck/AnalyzePatterns] ✓ Pattern analysis complete (2 suspicious patterns)
-    [Payment/FraudCheck/CalculateRiskScore] Calculating risk score for order 'ORD-001'...
-    [Payment/FraudCheck/CalculateRiskScore] ✓ Risk score: 53/100 (based on 2 patterns)
-  [Event from sub-workflow] FraudRiskAssessedEvent: Risk score 53/100
-  [Payment/ChargePayment] Charging $99.99 for order 'ORD-001'...
-  [Payment/ChargePayment] ✓ Payment processed: TXN-A1B2C3D4
-  [Shipping/SelectCarrier] Selecting carrier for order 'ORD-001'...
-  [Shipping/SelectCarrier] ✓ Selected carrier: Express
-  [Shipping/CreateShipment] Creating shipment for order 'ORD-001'...
-  [Shipping/CreateShipment] ✓ Shipment created: TRACK-I9J0K1L2M3
-┌─────────────────────────────────────────────────────────────────┐
-│ [OrderCompleted] Order 'ORD-001' successfully processed!
-│   Payment: TXN-A1B2C3D4
-│   Shipping: Express - TRACK-I9J0K1L2M3
-└─────────────────────────────────────────────────────────────────┘
-✓ Order completed: Order ORD-001 completed. Tracking: TRACK-I9J0K1L2M3
-
-> exit
-```

dotnet/samples/Durable/Workflow/ConsoleApps/08_WorkflowLoop/08_WorkflowLoop.csproj

@@ -1,30 +0,0 @@
-<Project Sdk="Microsoft.NET.Sdk">
-  <PropertyGroup>
-    <TargetFrameworks>net10.0</TargetFrameworks>
-    <OutputType>Exe</OutputType>
-    <ImplicitUsings>enable</ImplicitUsings>
-    <Nullable>enable</Nullable>
-    <AssemblyName>WorkflowLoop</AssemblyName>
-    <RootNamespace>WorkflowLoop</RootNamespace>
-  </PropertyGroup>
-
-  <ItemGroup>
-    <PackageReference Include="Azure.Identity" />
-    <PackageReference Include="Microsoft.DurableTask.Client.AzureManaged" />
-    <PackageReference Include="Microsoft.DurableTask.Worker.AzureManaged" />
-    <PackageReference Include="Microsoft.Extensions.Hosting" />
-    <PackageReference Include="Azure.AI.OpenAI" />
-  </ItemGroup>
-
-  <!-- Local projects that should be switched to package references when using the sample outside of this MAF repo -->
-  <!--
-  <ItemGroup>
-    <PackageReference Include="Microsoft.Agents.AI.DurableTask" />
-    <PackageReference Include="Microsoft.Agents.AI.Workflows" />
-  </ItemGroup>
-  -->
-  <ItemGroup>
-    <ProjectReference Include="..\..\..\..\..\src\Microsoft.Agents.AI.DurableTask\Microsoft.Agents.AI.DurableTask.csproj" />
-    <ProjectReference Include="..\..\..\..\..\src\Microsoft.Agents.AI.OpenAI\Microsoft.Agents.AI.OpenAI.csproj" />
-  </ItemGroup>
-</Project>

dotnet/samples/Durable/Workflow/ConsoleApps/08_WorkflowLoop/FeedbackExecutor.cs

@@ -1,88 +0,0 @@
-// Copyright (c) Microsoft. All rights reserved.
-
-using System.Text.Json;
-using Microsoft.Agents.AI;
-using Microsoft.Agents.AI.Workflows;
-using Microsoft.Extensions.AI;
-
-namespace WorkflowLoop;
-
-/// <summary>
-/// Evaluates slogans and either accepts them or sends feedback back for refinement.
-/// Uses SendMessageAsync to loop back to SloganWriter and YieldOutputAsync to end the workflow.
-/// </summary>
-internal sealed class FeedbackExecutor : Executor<SloganResult>
-{
-    private readonly AIAgent _agent;
-    private AgentSession? _session;
-
-    /// <summary>
-    /// Gets or sets the minimum rating required to accept a slogan.
-    /// </summary>
-    public int MinimumRating { get; init; } = 9;
-
-    /// <summary>
-    /// Gets or sets the maximum number of refinement attempts before accepting the slogan.
-    /// </summary>
-    public int MaxAttempts { get; init; } = 3;
-
-    private int _attempts;
-
-    /// <summary>
-    /// Initializes a new instance of the <see cref="FeedbackExecutor"/> class.
-    /// </summary>
-    /// <param name="id">A unique identifier for the executor.</param>
-    /// <param name="chatClient">The chat client to use for the AI agent.</param>
-    public FeedbackExecutor(string id, IChatClient chatClient) : base(id)
-    {
-        ChatClientAgentOptions agentOptions = new()
-        {
-            ChatOptions = new()
-            {
-                Instructions = "You are a professional editor. You will be given a slogan and the task it is meant to accomplish.",
-                ResponseFormat = ChatResponseFormat.ForJsonSchema<FeedbackResult>()
-            }
-        };
-
-        this._agent = new ChatClientAgent(chatClient, agentOptions);
-    }
-
-    /// <inheritdoc/>
-    public override async ValueTask HandleAsync(SloganResult message, IWorkflowContext context, CancellationToken cancellationToken = default)
-    {
-        Console.WriteLine($"  [FeedbackProvider] Evaluating slogan: \"{message.Slogan}\"");
-        this._session ??= await this._agent.GetNewSessionAsync(cancellationToken);
-
-        string sloganMessage = $"""
-            Here is a slogan for the task '{message.Task}':
-            Slogan: {message.Slogan}
-            Please provide feedback on this slogan, including comments, a rating from 1 to 10, and suggested actions for improvement.
-            """;
-
-        AgentResponse response = await this._agent.RunAsync(sloganMessage, this._session, cancellationToken: cancellationToken);
-        FeedbackResult feedback = JsonSerializer.Deserialize<FeedbackResult>(response.Text) ?? throw new InvalidOperationException("Failed to deserialize feedback.");
-
-        Console.WriteLine($"  [FeedbackProvider] Rating: {feedback.Rating}/{this.MinimumRating} - {feedback.Comments}");
-
-        // If the rating meets the threshold, accept the slogan and end the workflow
-        if (feedback.Rating >= this.MinimumRating)
-        {
-            Console.WriteLine("  [FeedbackProvider] Accepted!");
-            await context.YieldOutputAsync($"The following slogan was accepted:\n\n{message.Slogan}", cancellationToken);
-            return;
-        }
-
-        // If we've exceeded max attempts, accept the slogan anyway
-        if (this._attempts >= this.MaxAttempts)
-        {
-            Console.WriteLine("  [FeedbackProvider] Max attempts reached, accepting final slogan.");
-            await context.YieldOutputAsync($"The slogan was accepted after {this.MaxAttempts} attempts. Final slogan:\n\n{message.Slogan}", cancellationToken);
-            return;
-        }
-
-        // Otherwise, send feedback back to the slogan writer for refinement (circular edge)
-        Console.WriteLine($"  [FeedbackProvider] Sending back for refinement (attempt {this._attempts + 1}/{this.MaxAttempts})...");
-        await context.SendMessageAsync(feedback, cancellationToken: cancellationToken);
-        this._attempts++;
-    }
-}

dotnet/samples/Durable/Workflow/ConsoleApps/08_WorkflowLoop/Program.cs

@@ -1,91 +0,0 @@
-// Copyright (c) Microsoft. All rights reserved.
-
-// This sample demonstrates a CYCLIC WORKFLOW (back-edges in the graph).
-// SloganWriter and FeedbackProvider loop until the slogan meets quality criteria.
-
-using Azure;
-using Azure.AI.OpenAI;
-using Azure.Identity;
-using Microsoft.Agents.AI.DurableTask;
-using Microsoft.Agents.AI.DurableTask.Workflows;
-using Microsoft.Agents.AI.Workflows;
-using Microsoft.DurableTask.Client.AzureManaged;
-using Microsoft.DurableTask.Worker.AzureManaged;
-using Microsoft.Extensions.AI;
-using Microsoft.Extensions.DependencyInjection;
-using Microsoft.Extensions.Hosting;
-using Microsoft.Extensions.Logging;
-using WorkflowLoop;
-
-// Get DTS connection string from environment variable
-string dtsConnectionString = Environment.GetEnvironmentVariable("DURABLE_TASK_SCHEDULER_CONNECTION_STRING")
-    ?? "Endpoint=http://localhost:8080;TaskHub=default;Authentication=None";
-
-string endpoint = Environment.GetEnvironmentVariable("AZURE_OPENAI_ENDPOINT")
-    ?? throw new InvalidOperationException("AZURE_OPENAI_ENDPOINT is not set.");
-string deploymentName = Environment.GetEnvironmentVariable("AZURE_OPENAI_DEPLOYMENT")
-    ?? throw new InvalidOperationException("AZURE_OPENAI_DEPLOYMENT is not set.");
-string? azureOpenAiKey = Environment.GetEnvironmentVariable("AZURE_OPENAI_KEY");
-
-// Create the chat client using key-based or Azure CLI credential authentication
-AzureOpenAIClient openAiClient = !string.IsNullOrEmpty(azureOpenAiKey)
-    ? new AzureOpenAIClient(new Uri(endpoint), new AzureKeyCredential(azureOpenAiKey))
-    : new AzureOpenAIClient(new Uri(endpoint), new AzureCliCredential());
-IChatClient chatClient = openAiClient.GetChatClient(deploymentName).AsIChatClient();
-
-// Define executors for the workflow
-SloganWriterExecutor sloganWriter = new("SloganWriter", chatClient);
-FeedbackExecutor feedbackProvider = new("FeedbackProvider", chatClient);
-
-// Build the workflow with a circular edge: SloganWriter → FeedbackProvider → SloganWriter
-Workflow workflow = new WorkflowBuilder(sloganWriter)
-    .WithName("SloganCreationWorkflow")
-    .AddEdge(sloganWriter, feedbackProvider)
-    .AddEdge(feedbackProvider, sloganWriter)
-    .WithOutputFrom(feedbackProvider)
-    .Build();
-
-IHost host = Host.CreateDefaultBuilder(args)
-    .ConfigureLogging(logging => logging.SetMinimumLevel(LogLevel.Warning))
-    .ConfigureServices(services =>
-    {
-        services.ConfigureDurableWorkflows(
-            workflowOptions => workflowOptions.AddWorkflow(workflow),
-            workerBuilder: builder => builder.UseDurableTaskScheduler(dtsConnectionString),
-            clientBuilder: builder => builder.UseDurableTaskScheduler(dtsConnectionString));
-    })
-    .Build();
-
-await host.StartAsync();
-
-IWorkflowClient workflowClient = host.Services.GetRequiredService<IWorkflowClient>();
-
-Console.WriteLine("Workflow Loop Demo - Enter a topic for slogan generation (or 'exit'):");
-
-while (true)
-{
-    Console.Write("> ");
-    string? input = Console.ReadLine();
-    if (string.IsNullOrWhiteSpace(input) || input.Equals("exit", StringComparison.OrdinalIgnoreCase))
-    {
-        break;
-    }
-
-    try
-    {
-        // RunAsync starts the workflow; cast to IAwaitableWorkflowRun to wait for the result
-        IAwaitableWorkflowRun run = (IAwaitableWorkflowRun)await workflowClient.RunAsync(workflow, input);
-        Console.WriteLine($"Started run: {run.RunId}");
-
-        string? result = await run.WaitForCompletionAsync<string>();
-        Console.WriteLine($"Result: {result}");
-    }
-    catch (Exception ex)
-    {
-        Console.WriteLine($"Error: {ex.Message}");
-    }
-
-    Console.WriteLine();
-}
-
-await host.StopAsync();

dotnet/samples/Durable/Workflow/ConsoleApps/08_WorkflowLoop/README.md

@@ -1,69 +0,0 @@
-# Workflow Loop Sample
-
-This sample demonstrates how to run a **cyclic workflow** (containing loops / back-edges) as a durable orchestration. The workflow iteratively improves a slogan based on AI feedback until it meets quality criteria.
-
-## Key Concepts Demonstrated
-
-- **Cyclic workflow support** — back-edges in the graph (A → B → A)
-- **Multi-type executor handlers** — SloganWriter handles both `string` and `FeedbackResult` inputs
-- **Message routing via `SendMessageAsync`** — FeedbackProvider sends messages back to SloganWriter
-- **Workflow termination via `YieldOutputAsync`** — FeedbackProvider yields output when the slogan is accepted
-
-## Overview
-
-```
-                  ┌──────────────────────┐
-                  │                      │
-     input ──→ SloganWriter ──→ FeedbackProvider
-                  ▲                      │
-                  │    (FeedbackResult)   │
-                  └──────────────────────┘
-                       back-edge
-```
-
-| Executor | Description |
-|----------|-------------|
-| SloganWriter | Generates slogans from user input; refines them based on feedback |
-| FeedbackProvider | Evaluates slogans — accepts (YieldOutput) or loops (SendMessage) |
-
-### Loop Behavior
-
-1. **SloganWriter** generates a slogan based on user input
-2. **FeedbackProvider** evaluates the slogan and provides a rating
-3. If the rating is below the threshold (default: 9), feedback is sent back to SloganWriter
-4. SloganWriter improves the slogan based on feedback
-5. The loop continues until the slogan is accepted or max attempts (default: 3) are reached
-
-## Environment Setup
-
-See the [README.md](../README.md) file in the parent directory for information on configuring the environment, including how to install and run the Durable Task Scheduler.
-
-### Required Environment Variables
-
-| Variable | Description |
-|----------|-------------|
-| `AZURE_OPENAI_ENDPOINT` | Azure OpenAI endpoint URL |
-| `AZURE_OPENAI_DEPLOYMENT` | Azure OpenAI deployment name |
-| `AZURE_OPENAI_KEY` | (Optional) Azure OpenAI API key. If not set, uses Azure CLI credential |
-| `DURABLE_TASK_SCHEDULER_CONNECTION_STRING` | (Optional) DTS connection string. Defaults to local emulator |
-
-## Running the Sample
-
-```bash
-cd dotnet/samples/Durable/Workflow/ConsoleApps/08_WorkflowLoop
-dotnet run --framework net10.0
-```
-
-### Sample Output
-
-```text
-Workflow Loop Demo - Enter a topic for slogan generation (or 'exit'):
-> sustainable energy
-Started run: abc123...
-  [FeedbackProvider] Rating 6/9 - sending back for refinement (attempt 1/3)
-  [FeedbackProvider] Rating 8/9 - sending back for refinement (attempt 2/3)
-  Event: WorkflowOutputEvent
-  Completed: The following slogan was accepted:
-
-Power the future, preserve the planet.
-```

dotnet/samples/Durable/Workflow/ConsoleApps/08_WorkflowLoop/SloganResult.cs

@@ -1,32 +0,0 @@
-// Copyright (c) Microsoft. All rights reserved.
-
-using System.Text.Json.Serialization;
-
-namespace WorkflowLoop;
-
-/// <summary>
-/// Represents the result produced by the slogan writer executor.
-/// </summary>
-public sealed class SloganResult
-{
-    [JsonPropertyName("task")]
-    public required string Task { get; set; }
-
-    [JsonPropertyName("slogan")]
-    public required string Slogan { get; set; }
-}
-
-/// <summary>
-/// Represents feedback from the feedback executor, including comments, rating, and improvement actions.
-/// </summary>
-public sealed class FeedbackResult
-{
-    [JsonPropertyName("comments")]
-    public string Comments { get; set; } = string.Empty;
-
-    [JsonPropertyName("rating")]
-    public int Rating { get; set; }
-
-    [JsonPropertyName("actions")]
-    public string Actions { get; set; } = string.Empty;
-}

dotnet/samples/Durable/Workflow/ConsoleApps/08_WorkflowLoop/SloganWriterExecutor.cs

@@ -1,80 +0,0 @@
-// Copyright (c) Microsoft. All rights reserved.
-
-using System.Text.Json;
-using Microsoft.Agents.AI;
-using Microsoft.Agents.AI.Workflows;
-using Microsoft.Extensions.AI;
-
-namespace WorkflowLoop;
-
-/// <summary>
-/// Generates slogans based on user input or refines them based on feedback.
-/// This executor handles two input types: string (initial request) and FeedbackResult (refinement loop).
-/// </summary>
-internal sealed class SloganWriterExecutor : Executor
-{
-    private readonly AIAgent _agent;
-    private AgentSession? _session;
-
-    /// <summary>
-    /// Initializes a new instance of the <see cref="SloganWriterExecutor"/> class.
-    /// </summary>
-    /// <param name="id">A unique identifier for the executor.</param>
-    /// <param name="chatClient">The chat client to use for the AI agent.</param>
-    public SloganWriterExecutor(string id, IChatClient chatClient) : base(id)
-    {
-        ChatClientAgentOptions agentOptions = new()
-        {
-            ChatOptions = new()
-            {
-                Instructions = "You are a professional slogan writer. You will be given a task to create a slogan.",
-                ResponseFormat = ChatResponseFormat.ForJsonSchema<SloganResult>()
-            }
-        };
-
-        this._agent = new ChatClientAgent(chatClient, agentOptions);
-    }
-
-    /// <summary>
-    /// Configures two routes: one for initial string input and one for feedback-based refinement.
-    /// </summary>
-    protected override RouteBuilder ConfigureRoutes(RouteBuilder routeBuilder) =>
-        routeBuilder.AddHandler<string, SloganResult>(this.HandleAsync)
-                    .AddHandler<FeedbackResult, SloganResult>(this.HandleFeedbackAsync);
-
-    /// <summary>
-    /// Handles the initial slogan generation request.
-    /// </summary>
-    public async ValueTask<SloganResult> HandleAsync(string message, IWorkflowContext context, CancellationToken cancellationToken = default)
-    {
-        Console.WriteLine($"  [SloganWriter] Generating slogan for: {message}");
-        this._session ??= await this._agent.GetNewSessionAsync(cancellationToken);
-
-        AgentResponse result = await this._agent.RunAsync(message, this._session, cancellationToken: cancellationToken);
-        SloganResult slogan = JsonSerializer.Deserialize<SloganResult>(result.Text) ?? throw new InvalidOperationException("Failed to deserialize slogan result.");
-        Console.WriteLine($"  [SloganWriter] Generated: \"{slogan.Slogan}\"");
-        return slogan;
-    }
-
-    /// <summary>
-    /// Handles feedback from the feedback executor to refine the slogan.
-    /// </summary>
-    public async ValueTask<SloganResult> HandleFeedbackAsync(FeedbackResult message, IWorkflowContext context, CancellationToken cancellationToken = default)
-    {
-        Console.WriteLine($"  [SloganWriter] Refining slogan based on feedback (rating was {message.Rating})...");
-
-        string feedbackMessage = $"""
-            Here is the feedback on your previous slogan:
-            Comments: {message.Comments}
-            Rating: {message.Rating}
-            Suggested Actions: {message.Actions}
-
-            Please use this feedback to improve your slogan.
-            """;
-
-        AgentResponse result = await this._agent.RunAsync(feedbackMessage, this._session, cancellationToken: cancellationToken);
-        SloganResult slogan = JsonSerializer.Deserialize<SloganResult>(result.Text) ?? throw new InvalidOperationException("Failed to deserialize slogan result.");
-        Console.WriteLine($"  [SloganWriter] Refined: \"{slogan.Slogan}\"");
-        return slogan;
-    }
-}

dotnet/samples/GettingStarted/A2A/A2AAgent_PollingForTaskCompletion/Program.cs

@@ -16,7 +16,7 @@ AgentCard agentCard = await agentCardResolver.GetAgentCardAsync();
 // Create an instance of the AIAgent for an existing A2A agent specified by the agent card.
 AIAgent agent = agentCard.AsAIAgent();
 
-AgentSession session = await agent.GetNewSessionAsync();
+AgentSession session = await agent.CreateSessionAsync();
 
 // Start the initial run with a long-running task.
 AgentResponse response = await agent.RunAsync("Conduct a comprehensive analysis of quantum computing applications in cryptography, including recent breakthroughs, implementation challenges, and future roadmap. Please include diagrams and visual representations to illustrate complex concepts.", session);

dotnet/samples/GettingStarted/AGUI/Step01_GettingStarted/Client/Program.cs

@@ -20,7 +20,7 @@ AIAgent agent = chatClient.AsAIAgent(
     name: "agui-client",
     description: "AG-UI Client Agent");
 
-AgentSession session = await agent.GetNewSessionAsync();
+AgentSession session = await agent.CreateSessionAsync();
 List<ChatMessage> messages =
 [
     new(ChatRole.System, "You are a helpful assistant.")

dotnet/samples/GettingStarted/AGUI/Step02_BackendTools/Client/Program.cs

@@ -20,7 +20,7 @@ AIAgent agent = chatClient.AsAIAgent(
     name: "agui-client",
     description: "AG-UI Client Agent");
 
-AgentSession session = await agent.GetNewSessionAsync();
+AgentSession session = await agent.CreateSessionAsync();
 List<ChatMessage> messages =
 [
     new(ChatRole.System, "You are a helpful assistant.")

dotnet/samples/GettingStarted/AGUI/Step03_FrontendTools/Client/Program.cs

@@ -33,7 +33,7 @@ AIAgent agent = chatClient.AsAIAgent(
     description: "AG-UI Client Agent",
     tools: frontendTools);
 
-AgentSession session = await agent.GetNewSessionAsync();
+AgentSession session = await agent.CreateSessionAsync();
 List<ChatMessage> messages =
 [
     new(ChatRole.System, "You are a helpful assistant.")

dotnet/samples/GettingStarted/AGUI/Step05_StateManagement/Client/Program.cs

@@ -30,7 +30,7 @@ JsonSerializerOptions jsonOptions = new(JsonSerializerDefaults.Web)
 };
 StatefulAgent<AgentState> agent = new(baseAgent, jsonOptions, new AgentState());
 
-AgentSession session = await agent.GetNewSessionAsync();
+AgentSession session = await agent.CreateSessionAsync();
 List<ChatMessage> messages =
 [
     new(ChatRole.System, "You are a helpful recipe assistant.")

dotnet/samples/GettingStarted/AgentOpenTelemetry/Program.cs

@@ -128,7 +128,7 @@ var agent = new ChatClientAgent(instrumentedChatClient,
     .UseOpenTelemetry(SourceName, configure: (cfg) => cfg.EnableSensitiveData = true) // enable telemetry at the agent level
     .Build();
 
-var session = await agent.GetNewSessionAsync();
+var session = await agent.CreateSessionAsync();
 
 appLogger.LogInformation("Agent created successfully with ID: {AgentId}", agent.Id);
 

dotnet/samples/GettingStarted/AgentProviders/Agent_With_AzureAIAgentsPersistent/Program.cs

@@ -31,7 +31,7 @@ AIAgent agent2 = await persistentAgentsClient.CreateAIAgentAsync(
     instructions: JokerInstructions);
 
 // You can then invoke the agent like any other AIAgent.
-AgentSession session = await agent1.GetNewSessionAsync();
+AgentSession session = await agent1.CreateSessionAsync();
 Console.WriteLine(await agent1.RunAsync("Tell me a joke about a pirate.", session));
 
 // Cleanup for sample purposes.

dotnet/samples/GettingStarted/AgentProviders/Agent_With_AzureAIProject/Program.cs

@@ -40,7 +40,7 @@ var latestAgentVersion = jokerAgentLatest.GetService<AgentVersion>()!;
 Console.WriteLine($"Latest agent version id: {latestAgentVersion.Id}");
 
 // Once you have the AIAgent, you can invoke it like any other AIAgent.
-AgentSession session = await jokerAgentLatest.GetNewSessionAsync();
+AgentSession session = await jokerAgentLatest.CreateSessionAsync();
 Console.WriteLine(await jokerAgentLatest.RunAsync("Tell me a joke about a pirate.", session));
 
 // This will use the same session to continue the conversation.

dotnet/samples/GettingStarted/AgentProviders/Agent_With_CustomImplementation/Program.cs

@@ -28,16 +28,26 @@ namespace SampleApp
     {
         public override string? Name => "UpperCaseParrotAgent";
 
-        public override ValueTask<AgentSession> GetNewSessionAsync(CancellationToken cancellationToken = default)
+        protected override ValueTask<AgentSession> CreateSessionCoreAsync(CancellationToken cancellationToken = default)
             => new(new CustomAgentSession());
 
-        public override ValueTask<AgentSession> DeserializeSessionAsync(JsonElement serializedSession, JsonSerializerOptions? jsonSerializerOptions = null, CancellationToken cancellationToken = default)
-            => new(new CustomAgentSession(serializedSession, jsonSerializerOptions));
+        protected override JsonElement SerializeSessionCore(AgentSession session, JsonSerializerOptions? jsonSerializerOptions = null)
+        {
+            if (session is not CustomAgentSession typedSession)
+            {
+                throw new ArgumentException($"The provided session is not of type {nameof(CustomAgentSession)}.", nameof(session));
+            }
+
+            return typedSession.Serialize(jsonSerializerOptions);
+        }
+
+        protected override ValueTask<AgentSession> DeserializeSessionCoreAsync(JsonElement serializedState, JsonSerializerOptions? jsonSerializerOptions = null, CancellationToken cancellationToken = default)
+            => new(new CustomAgentSession(serializedState, jsonSerializerOptions));
 
         protected override async Task<AgentResponse> RunCoreAsync(IEnumerable<ChatMessage> messages, AgentSession? session = null, AgentRunOptions? options = null, CancellationToken cancellationToken = default)
         {
             // Create a session if the user didn't supply one.
-            session ??= await this.GetNewSessionAsync(cancellationToken);
+            session ??= await this.CreateSessionAsync(cancellationToken);
 
             if (session is not CustomAgentSession typedSession)
             {
@@ -45,14 +55,14 @@ namespace SampleApp
             }
 
             // Get existing messages from the store
-            var invokingContext = new ChatHistoryProvider.InvokingContext(messages);
+            var invokingContext = new ChatHistoryProvider.InvokingContext(this, session, messages);
             var storeMessages = await typedSession.ChatHistoryProvider.InvokingAsync(invokingContext, cancellationToken);
 
             // Clone the input messages and turn them into response messages with upper case text.
             List<ChatMessage> responseMessages = CloneAndToUpperCase(messages, this.Name).ToList();
 
             // Notify the session of the input and output messages.
-            var invokedContext = new ChatHistoryProvider.InvokedContext(messages, storeMessages)
+            var invokedContext = new ChatHistoryProvider.InvokedContext(this, session, messages)
             {
                 ResponseMessages = responseMessages
             };
@@ -69,7 +79,7 @@ namespace SampleApp
         protected override async IAsyncEnumerable<AgentResponseUpdate> RunCoreStreamingAsync(IEnumerable<ChatMessage> messages, AgentSession? session = null, AgentRunOptions? options = null, [EnumeratorCancellation] CancellationToken cancellationToken = default)
         {
             // Create a session if the user didn't supply one.
-            session ??= await this.GetNewSessionAsync(cancellationToken);
+            session ??= await this.CreateSessionAsync(cancellationToken);
 
             if (session is not CustomAgentSession typedSession)
             {
@@ -77,14 +87,14 @@ namespace SampleApp
             }
 
             // Get existing messages from the store
-            var invokingContext = new ChatHistoryProvider.InvokingContext(messages);
+            var invokingContext = new ChatHistoryProvider.InvokingContext(this, session, messages);
             var storeMessages = await typedSession.ChatHistoryProvider.InvokingAsync(invokingContext, cancellationToken);
 
             // Clone the input messages and turn them into response messages with upper case text.
             List<ChatMessage> responseMessages = CloneAndToUpperCase(messages, this.Name).ToList();
 
             // Notify the session of the input and output messages.
-            var invokedContext = new ChatHistoryProvider.InvokedContext(messages, storeMessages)
+            var invokedContext = new ChatHistoryProvider.InvokedContext(this, session, messages)
             {
                 ResponseMessages = responseMessages
             };
@@ -136,6 +146,9 @@ namespace SampleApp
 
             internal CustomAgentSession(JsonElement serializedSessionState, JsonSerializerOptions? jsonSerializerOptions = null)
                 : base(serializedSessionState, jsonSerializerOptions) { }
+
+            internal new JsonElement Serialize(JsonSerializerOptions? jsonSerializerOptions = null)
+                => base.Serialize(jsonSerializerOptions);
         }
     }
 }

dotnet/samples/GettingStarted/AgentProviders/Agent_With_OpenAIAssistants/Program.cs

@@ -33,7 +33,7 @@ AIAgent agent2 = await assistantClient.CreateAIAgentAsync(
     instructions: JokerInstructions);
 
 // You can invoke the agent like any other AIAgent.
-AgentSession session = await agent1.GetNewSessionAsync();
+AgentSession session = await agent1.CreateSessionAsync();
 Console.WriteLine(await agent1.RunAsync("Tell me a joke about a pirate.", session));
 
 // Cleanup for sample purposes.

dotnet/samples/GettingStarted/AgentWithAnthropic/Agent_Anthropic_Step03_UsingFunctionTools/Program.cs

@@ -26,11 +26,11 @@ AIAgent agent = new AnthropicClient { ApiKey = apiKey }
     .AsAIAgent(model: model, instructions: AssistantInstructions, name: AssistantName, tools: [tool]);
 
 // Non-streaming agent interaction with function tools.
-AgentSession session = await agent.GetNewSessionAsync();
+AgentSession session = await agent.CreateSessionAsync();
 Console.WriteLine(await agent.RunAsync("What is the weather like in Amsterdam?", session));
 
 // Streaming agent interaction with function tools.
-session = await agent.GetNewSessionAsync();
+session = await agent.CreateSessionAsync();
 await foreach (AgentResponseUpdate update in agent.RunStreamingAsync("What is the weather like in Amsterdam?", session))
 {
     Console.WriteLine(update);

dotnet/samples/GettingStarted/AgentWithAnthropic/Agent_Anthropic_Step04_UsingSkills/Agent_Anthropic_Step04_UsingSkills.csproj

@@ -0,0 +1,15 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net10.0</TargetFramework>
+
+    <Nullable>enable</Nullable>
+    <ImplicitUsings>enable</ImplicitUsings>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\..\..\..\src\Microsoft.Agents.AI.Anthropic\Microsoft.Agents.AI.Anthropic.csproj" />
+  </ItemGroup>
+
+</Project>

dotnet/samples/GettingStarted/AgentWithAnthropic/Agent_Anthropic_Step04_UsingSkills/Program.cs

@@ -0,0 +1,127 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+// This sample demonstrates how to use Anthropic-managed Skills with an AI agent.
+// Skills are pre-built capabilities provided by Anthropic that can be used with the Claude API.
+// This sample shows how to:
+// 1. List available Anthropic-managed skills
+// 2. Use the pptx skill to create PowerPoint presentations
+// 3. Download and save generated files
+
+using Anthropic;
+using Anthropic.Core;
+using Anthropic.Models.Beta;
+using Anthropic.Models.Beta.Files;
+using Anthropic.Models.Beta.Messages;
+using Anthropic.Models.Beta.Skills;
+using Anthropic.Services;
+using Microsoft.Agents.AI;
+using Microsoft.Extensions.AI;
+
+string apiKey = Environment.GetEnvironmentVariable("ANTHROPIC_API_KEY") ?? throw new InvalidOperationException("ANTHROPIC_API_KEY is not set.");
+// Skills require Claude 4.5 models (Sonnet 4.5, Haiku 4.5, or Opus 4.5)
+string model = Environment.GetEnvironmentVariable("ANTHROPIC_MODEL") ?? "claude-sonnet-4-5-20250929";
+
+// Create the Anthropic client
+AnthropicClient anthropicClient = new() { ApiKey = apiKey };
+
+// List available Anthropic-managed skills (optional - API may not be available in all regions)
+Console.WriteLine("Available Anthropic-managed skills:");
+try
+{
+    SkillListPage skills = await anthropicClient.Beta.Skills.List(
+        new SkillListParams { Source = "anthropic", Betas = [AnthropicBeta.Skills2025_10_02] });
+
+    foreach (var skill in skills.Items)
+    {
+        Console.WriteLine($"  {skill.Source}: {skill.ID} (version: {skill.LatestVersion})");
+    }
+}
+catch (Exception ex)
+{
+    Console.WriteLine($"  (Skills listing not available: {ex.Message})");
+}
+
+Console.WriteLine();
+
+// Define the pptx skill - the SDK handles all beta flags and container configuration automatically
+// when using AsAITool(), so no manual RawRepresentationFactory configuration is needed.
+BetaSkillParams pptxSkill = new()
+{
+    Type = BetaSkillParamsType.Anthropic,
+    SkillID = "pptx",
+    Version = "latest"
+};
+
+// Create an agent with the pptx skill enabled.
+// Skills require extended thinking and higher max tokens for complex file generation.
+// The SDK's AsAITool() handles beta flags and container config automatically.
+ChatClientAgent agent = anthropicClient.Beta.AsAIAgent(
+    model: model,
+    instructions: "You are a helpful agent for creating PowerPoint presentations.",
+    tools: [pptxSkill.AsAITool()],
+    clientFactory: (chatClient) => chatClient
+        .AsBuilder()
+        .ConfigureOptions(options =>
+        {
+            options.RawRepresentationFactory = (_) => new MessageCreateParams()
+            {
+                Model = model,
+                MaxTokens = 20000,
+                Messages = [],
+                Thinking = new BetaThinkingConfigParam(
+                    new BetaThinkingConfigEnabled(budgetTokens: 10000))
+            };
+        })
+        .Build());
+
+Console.WriteLine("Creating a presentation about renewable energy...\n");
+
+// Run the agent with a request to create a presentation
+AgentResponse response = await agent.RunAsync("Create a simple 3-slide presentation about renewable energy sources. Include a title slide, a slide about solar energy, and a slide about wind energy.");
+
+Console.WriteLine("#### Agent Response ####");
+Console.WriteLine(response.Text);
+
+// Display any reasoning/thinking content
+List<TextReasoningContent> reasoningContents = response.Messages.SelectMany(m => m.Contents.OfType<TextReasoningContent>()).ToList();
+if (reasoningContents.Count > 0)
+{
+    Console.WriteLine("\n#### Agent Reasoning ####");
+    Console.WriteLine($"\e[92m{string.Join("\n", reasoningContents.Select(c => c.Text))}\e[0m");
+}
+
+// Collect generated files from CodeInterpreterToolResultContent outputs
+List<HostedFileContent> hostedFiles = response.Messages
+    .SelectMany(m => m.Contents.OfType<CodeInterpreterToolResultContent>())
+    .Where(c => c.Outputs is not null)
+    .SelectMany(c => c.Outputs!.OfType<HostedFileContent>())
+    .ToList();
+
+if (hostedFiles.Count > 0)
+{
+    Console.WriteLine("\n#### Generated Files ####");
+    foreach (HostedFileContent file in hostedFiles)
+    {
+        Console.WriteLine($"  FileId: {file.FileId}");
+
+        // Download the file using the Anthropic Files API
+        using HttpResponse fileResponse = await anthropicClient.Beta.Files.Download(
+            file.FileId,
+            new FileDownloadParams { Betas = ["files-api-2025-04-14"] });
+
+        // Save the file to disk
+        string fileName = $"presentation_{file.FileId.Substring(0, 8)}.pptx";
+        using FileStream fileStream = File.Create(fileName);
+        Stream contentStream = await fileResponse.ReadAsStream();
+        await contentStream.CopyToAsync(fileStream);
+
+        Console.WriteLine($"  Saved to: {fileName}");
+    }
+}
+
+Console.WriteLine("\nToken usage:");
+Console.WriteLine($"Input: {response.Usage?.InputTokenCount}, Output: {response.Usage?.OutputTokenCount}");
+if (response.Usage?.AdditionalCounts is not null)
+{
+    Console.WriteLine($"Additional: {string.Join(", ", response.Usage.AdditionalCounts)}");
+}

dotnet/samples/GettingStarted/AgentWithAnthropic/Agent_Anthropic_Step04_UsingSkills/README.md

@@ -0,0 +1,119 @@
+# Using Anthropic Skills with agents
+
+This sample demonstrates how to use Anthropic-managed Skills with AI agents. Skills are pre-built capabilities provided by Anthropic that can be used with the Claude API.
+
+## What this sample demonstrates
+
+- Listing available Anthropic-managed skills
+- Creating an AI agent with Anthropic Claude Skills support using the simplified `AsAITool()` approach
+- Using the pptx skill to create PowerPoint presentations
+- Downloading and saving generated files to disk
+- Handling agent responses with generated content
+
+## Prerequisites
+
+Before you begin, ensure you have the following prerequisites:
+
+- .NET 10.0 SDK or later
+- Anthropic API key configured
+- Access to Anthropic Claude models with Skills support
+
+**Note**: This sample uses Anthropic Claude models with Skills. Skills are a beta feature. For more information, see [Anthropic documentation](https://docs.anthropic.com/).
+
+Set the following environment variables:
+
+```powershell
+$env:ANTHROPIC_API_KEY="your-anthropic-api-key"  # Replace with your Anthropic API key
+$env:ANTHROPIC_MODEL="your-anthropic-model"  # Replace with your Anthropic model (e.g., claude-sonnet-4-5-20250929)
+```
+
+## Run the sample
+
+Navigate to the AgentWithAnthropic sample directory and run:
+
+```powershell
+cd dotnet\samples\GettingStarted\AgentWithAnthropic
+dotnet run --project .\Agent_Anthropic_Step04_UsingSkills
+```
+
+## Available Anthropic Skills
+
+Anthropic provides several managed skills that can be used with the Claude API:
+
+- `pptx` - Create PowerPoint presentations
+- `xlsx` - Create Excel spreadsheets
+- `docx` - Create Word documents
+- `pdf` - Create and analyze PDF documents
+
+You can list available skills using the Anthropic SDK:
+
+```csharp
+SkillListPage skills = await anthropicClient.Beta.Skills.List(
+    new SkillListParams { Source = "anthropic", Betas = [AnthropicBeta.Skills2025_10_02] });
+
+foreach (var skill in skills.Items)
+{
+    Console.WriteLine($"{skill.Source}: {skill.ID} (version: {skill.LatestVersion})");
+}
+```
+
+## Expected behavior
+
+The sample will:
+
+1. List all available Anthropic-managed skills
+2. Create an agent with the pptx skill enabled
+3. Run the agent with a request to create a presentation
+4. Display the agent's response text
+5. Download any generated files and save them to disk
+6. Display token usage statistics
+
+## Code highlights
+
+### Simplified skill configuration
+
+The Anthropic SDK handles all beta flags and container configuration automatically when using `AsAITool()`:
+
+```csharp
+// Define the pptx skill
+BetaSkillParams pptxSkill = new()
+{
+    Type = BetaSkillParamsType.Anthropic,
+    SkillID = "pptx",
+    Version = "latest"
+};
+
+// Create an agent - the SDK handles beta flags automatically!
+ChatClientAgent agent = anthropicClient.Beta.AsAIAgent(
+    model: model,
+    instructions: "You are a helpful agent for creating PowerPoint presentations.",
+    tools: [pptxSkill.AsAITool()]);
+```
+
+**Note**: No manual `RawRepresentationFactory`, `Betas`, or `Container` configuration is needed. The SDK automatically adds the required beta headers (`skills-2025-10-02`, `code-execution-2025-08-25`) and configures the container with the skill.
+
+### Handling generated files
+
+Generated files are returned as `HostedFileContent` within `CodeInterpreterToolResultContent`:
+
+```csharp
+// Collect generated files from response
+List<HostedFileContent> hostedFiles = response.Messages
+    .SelectMany(m => m.Contents.OfType<CodeInterpreterToolResultContent>())
+    .Where(c => c.Outputs is not null)
+    .SelectMany(c => c.Outputs!.OfType<HostedFileContent>())
+    .ToList();
+
+// Download and save each file
+foreach (HostedFileContent file in hostedFiles)
+{
+    using HttpResponse fileResponse = await anthropicClient.Beta.Files.Download(
+        file.FileId,
+        new FileDownloadParams { Betas = ["files-api-2025-04-14"] });
+
+    string fileName = $"presentation_{file.FileId.Substring(0, 8)}.pptx";
+    await using FileStream fileStream = File.Create(fileName);
+    Stream contentStream = await fileResponse.ReadAsStream();
+    await contentStream.CopyToAsync(fileStream);
+}
+```

dotnet/samples/GettingStarted/AgentWithAnthropic/README.md

@@ -29,6 +29,7 @@ To use Anthropic with Azure Foundry, you can check the sample [AgentProviders/Ag
 |[Running a simple agent](./Agent_Anthropic_Step01_Running/)|This sample demonstrates how to create and run a basic agent with Anthropic Claude|
 |[Using reasoning with an agent](./Agent_Anthropic_Step02_Reasoning/)|This sample demonstrates how to use extended thinking/reasoning capabilities with Anthropic Claude agents|
 |[Using function tools with an agent](./Agent_Anthropic_Step03_UsingFunctionTools/)|This sample demonstrates how to use function tools with an Anthropic Claude agent|
+|[Using Skills with an agent](./Agent_Anthropic_Step04_UsingSkills/)|This sample demonstrates how to use Anthropic-managed Skills (e.g., pptx) with an Anthropic Claude agent|
 
 ## Running the samples from the console
 

dotnet/samples/GettingStarted/AgentWithMemory/AgentWithMemory_Step01_ChatHistoryMemory/Program.cs

@@ -47,14 +47,14 @@ AIAgent agent = new AzureOpenAIClient(
     });
 
 // Start a new session for the agent conversation.
-AgentSession session = await agent.GetNewSessionAsync();
+AgentSession session = await agent.CreateSessionAsync();
 
 // Run the agent with the session that stores conversation history in the vector store.
 Console.WriteLine(await agent.RunAsync("I like jokes about Pirates. Tell me a joke about a pirate.", session));
 
 // Start a second session. Since we configured the search scope to be across all sessions for the user,
 // the agent should remember that the user likes pirate jokes.
-AgentSession? session2 = await agent.GetNewSessionAsync();
+AgentSession? session2 = await agent.CreateSessionAsync();
 
 // Run the agent with the second session.
 Console.WriteLine(await agent.RunAsync("Tell me a joke that I might like.", session2));

dotnet/samples/GettingStarted/AgentWithMemory/AgentWithMemory_Step02_MemoryUsingMem0/Program.cs

@@ -40,7 +40,7 @@ AIAgent agent = new AzureOpenAIClient(
             : new Mem0Provider(mem0HttpClient, ctx.SerializedState, ctx.JsonSerializerOptions))
     });
 
-AgentSession session = await agent.GetNewSessionAsync();
+AgentSession session = await agent.CreateSessionAsync();
 
 // Clear any existing memories for this scope to demonstrate fresh behavior.
 Mem0Provider mem0Provider = session.GetService<Mem0Provider>()!;
@@ -55,10 +55,10 @@ await Task.Delay(TimeSpan.FromSeconds(2));
 Console.WriteLine(await agent.RunAsync("What do you already know about my upcoming trip?", session));
 
 Console.WriteLine("\n>> Serialize and deserialize the session to demonstrate persisted state\n");
-JsonElement serializedSession = session.Serialize();
+JsonElement serializedSession = agent.SerializeSession(session);
 AgentSession restoredSession = await agent.DeserializeSessionAsync(serializedSession);
 Console.WriteLine(await agent.RunAsync("Can you recap the personal details you remember?", restoredSession));
 
 Console.WriteLine("\n>> Start a new session that shares the same Mem0 scope\n");
-AgentSession newSession = await agent.GetNewSessionAsync();
+AgentSession newSession = await agent.CreateSessionAsync();
 Console.WriteLine(await agent.RunAsync("Summarize what you already know about me.", newSession));

dotnet/samples/GettingStarted/AgentWithMemory/AgentWithMemory_Step03_CustomMemory/Program.cs

@@ -37,7 +37,7 @@ AIAgent agent = chatClient.AsAIAgent(new ChatClientAgentOptions()
 });
 
 // Create a new session for the conversation.
-AgentSession session = await agent.GetNewSessionAsync();
+AgentSession session = await agent.CreateSessionAsync();
 
 Console.WriteLine(">> Use session with blank memory\n");
 
@@ -47,7 +47,7 @@ Console.WriteLine(await agent.RunAsync("My name is Ruaidhrí", session));
 Console.WriteLine(await agent.RunAsync("I am 20 years old", session));
 
 // We can serialize the session. The serialized state will include the state of the memory component.
-var sesionElement = session.Serialize();
+JsonElement sesionElement = agent.SerializeSession(session);
 
 Console.WriteLine("\n>> Use deserialized session with previously created memories\n");
 
@@ -68,7 +68,7 @@ Console.WriteLine("\n>> Use new session with previously created memories\n");
 
 // It is also possible to set the memories in a memory component on an individual session.
 // This is useful if we want to start a new session, but have it share the same memories as a previous session.
-var newSession = await agent.GetNewSessionAsync();
+var newSession = await agent.CreateSessionAsync();
 if (userInfo is not null && newSession.GetService<UserInfoMemory>() is UserInfoMemory newSessionMemory)
 {
     newSessionMemory.UserInfo = userInfo;
@@ -104,7 +104,7 @@ namespace SampleApp
 
         public UserInfo UserInfo { get; set; }
 
-        public override async ValueTask InvokedAsync(InvokedContext context, CancellationToken cancellationToken = default)
+        protected override async ValueTask InvokedCoreAsync(InvokedContext context, CancellationToken cancellationToken = default)
         {
             // Try and extract the user name and age from the message if we don't have it already and it's a user message.
             if ((this.UserInfo.UserName is null || this.UserInfo.UserAge is null) && context.RequestMessages.Any(x => x.Role == ChatRole.User))
@@ -122,7 +122,7 @@ namespace SampleApp
             }
         }
 
-        public override ValueTask<AIContext> InvokingAsync(InvokingContext context, CancellationToken cancellationToken = default)
+        protected override ValueTask<AIContext> InvokingCoreAsync(InvokingContext context, CancellationToken cancellationToken = default)
         {
             StringBuilder instructions = new();
 

dotnet/samples/GettingStarted/AgentWithOpenAI/Agent_OpenAI_Step05_Conversation/Program.cs

@@ -30,7 +30,7 @@ using JsonDocument createConversationResultAsJson = JsonDocument.Parse(createCon
 string conversationId = createConversationResultAsJson.RootElement.GetProperty("id"u8)!.GetString()!;
 
 // Create a session for the conversation - this enables conversation state management for subsequent turns
-AgentSession session = await agent.GetNewSessionAsync(conversationId);
+AgentSession session = await agent.CreateSessionAsync(conversationId);
 
 Console.WriteLine("=== Multi-turn Conversation Demo ===\n");
 

dotnet/samples/GettingStarted/AgentWithOpenAI/Agent_OpenAI_Step05_Conversation/README.md

@@ -33,7 +33,7 @@ The `AgentSession` works with `ChatClientAgentRunOptions` to link the agent to a
 ChatClientAgentRunOptions agentRunOptions = new() { ChatOptions = new ChatOptions() { ConversationId = conversationId } };
 
 // Create a session for the conversation
-AgentSession session = await agent.GetNewSessionAsync();
+AgentSession session = await agent.CreateSessionAsync();
 
 // First call links the session to the conversation
 ChatCompletion firstResponse = await agent.RunAsync([firstMessage], session, agentRunOptions);
@@ -59,7 +59,7 @@ foreach (ClientResult result in getConversationItemsResults.GetRawPages())
 1. **Create an OpenAI Client**: Initialize an `OpenAIClient` with your API key
 2. **Create a Conversation**: Use `ConversationClient` to create a server-side conversation
 3. **Create an Agent**: Initialize an `OpenAIResponseClientAgent` with the desired model and instructions
-4. **Create a Session**: Call `agent.GetNewSessionAsync()` to create a new conversation session
+4. **Create a Session**: Call `agent.CreateSessionAsync()` to create a new conversation session
 5. **Link Session to Conversation**: Pass `ChatClientAgentRunOptions` with the `ConversationId` on the first call
 6. **Send Messages**: Subsequent calls to `agent.RunAsync()` only need the session - context is maintained
 7. **Cleanup**: Delete the conversation when done using `conversationClient.DeleteConversation()`

dotnet/samples/GettingStarted/AgentWithRAG/AgentWithRAG_Step01_BasicTextRAG/Program.cs

@@ -70,7 +70,7 @@ AIAgent agent = azureOpenAIClient
             .WithAIContextProviderMessageRemoval()),
     });
 
-AgentSession session = await agent.GetNewSessionAsync();
+AgentSession session = await agent.CreateSessionAsync();
 
 Console.WriteLine(">> Asking about returns\n");
 Console.WriteLine(await agent.RunAsync("Hi! I need help understanding the return policy.", session));

dotnet/samples/GettingStarted/AgentWithRAG/AgentWithRAG_Step02_CustomVectorStoreRAG/Program.cs

@@ -74,7 +74,7 @@ AIAgent agent = azureOpenAIClient
         AIContextProviderFactory = (ctx, ct) => new ValueTask<AIContextProvider>(new TextSearchProvider(SearchAdapter, ctx.SerializedState, ctx.JsonSerializerOptions, textSearchOptions))
     });
 
-AgentSession session = await agent.GetNewSessionAsync();
+AgentSession session = await agent.CreateSessionAsync();
 
 Console.WriteLine(">> Asking about SK sessions\n");
 Console.WriteLine(await agent.RunAsync("Hi! How do I create a thread/session in Semantic Kernel?", session));

dotnet/samples/GettingStarted/AgentWithRAG/AgentWithRAG_Step03_CustomRAGDataSource/Program.cs

@@ -32,7 +32,7 @@ AIAgent agent = new AzureOpenAIClient(
         AIContextProviderFactory = (ctx, ct) => new ValueTask<AIContextProvider>(new TextSearchProvider(MockSearchAsync, ctx.SerializedState, ctx.JsonSerializerOptions, textSearchOptions))
     });
 
-AgentSession session = await agent.GetNewSessionAsync();
+AgentSession session = await agent.CreateSessionAsync();
 
 Console.WriteLine(">> Asking about returns\n");
 Console.WriteLine(await agent.RunAsync("Hi! I need help understanding the return policy.", session));