Azure Resource Manager Durabletask Dotnet

using Azure.Identity;using Azure.ResourceManager;using Azure.ResourceManager.DurableTask;
// Local dev: DefaultAzureCredential. Production: set AZURE_TOKEN_CREDENTIALS=prod or AZURE_TOKEN_CREDENTIALS=<specific_credential>var credential = new DefaultAzureCredential(    DefaultAzureCredential.DefaultEnvironmentVariableName);// Or use a specific credential directly in production:// See https://learn.microsoft.com/dotnet/api/overview/azure/identity-readme?view=azure-dotnet#credential-classes// var credential = new ManagedIdentityCredential();var armClient = new ArmClient(credential);
// Get subscriptionvar subscriptionId = Environment.GetEnvironmentVariable("AZURE_SUBSCRIPTION_ID");var subscription = armClient.GetSubscriptionResource(    new ResourceIdentifier($"/subscriptions/{subscriptionId}"));

using Azure.ResourceManager.DurableTask;using Azure.ResourceManager.DurableTask.Models;
// Get resource groupvar resourceGroup = await subscription    .GetResourceGroupAsync("my-resource-group");
// Define scheduler with Dedicated SKUvar schedulerData = new DurableTaskSchedulerData(AzureLocation.EastUS){    Properties = new DurableTaskSchedulerProperties    {        Sku = new DurableTaskSchedulerSku(DurableTaskSchedulerSkuName.Dedicated)        {            Capacity = 1  // Number of instances        },        // Optional: IP allowlist for network security        IPAllowlist = { "10.0.0.0/24", "192.168.1.0/24" }    }};
// Create scheduler (long-running operation)var schedulerCollection = resourceGroup.Value.GetDurableTaskSchedulers();var operation = await schedulerCollection.CreateOrUpdateAsync(    WaitUntil.Completed,    "my-scheduler",    schedulerData);
DurableTaskSchedulerResource scheduler = operation.Value;Console.WriteLine($"Scheduler created: {scheduler.Data.Name}");Console.WriteLine($"Endpoint: {scheduler.Data.Properties.Endpoint}");

// Consumption SKU (serverless)var consumptionSchedulerData = new DurableTaskSchedulerData(AzureLocation.EastUS){    Properties = new DurableTaskSchedulerProperties    {        Sku = new DurableTaskSchedulerSku(DurableTaskSchedulerSkuName.Consumption)        // No capacity needed for consumption    }};
var operation = await schedulerCollection.CreateOrUpdateAsync(    WaitUntil.Completed,    "my-serverless-scheduler",    consumptionSchedulerData);

// Task hubs are created under a schedulervar taskHubData = new DurableTaskHubData{    // Properties are optional for basic task hub};
var taskHubCollection = scheduler.GetDurableTaskHubs();var hubOperation = await taskHubCollection.CreateOrUpdateAsync(    WaitUntil.Completed,    "my-taskhub",    taskHubData);
DurableTaskHubResource taskHub = hubOperation.Value;Console.WriteLine($"Task Hub created: {taskHub.Data.Name}");

// List all schedulers in subscriptionawait foreach (var sched in subscription.GetDurableTaskSchedulersAsync()){    Console.WriteLine($"Scheduler: {sched.Data.Name}");    Console.WriteLine($"  Location: {sched.Data.Location}");    Console.WriteLine($"  SKU: {sched.Data.Properties.Sku?.Name}");    Console.WriteLine($"  Endpoint: {sched.Data.Properties.Endpoint}");}
// List schedulers in resource groupvar schedulers = resourceGroup.Value.GetDurableTaskSchedulers();await foreach (var sched in schedulers.GetAllAsync()){    Console.WriteLine($"Scheduler: {sched.Data.Name}");}

// Get existing schedulervar existingScheduler = await schedulerCollection.GetAsync("my-scheduler");Console.WriteLine($"Found: {existingScheduler.Value.Data.Name}");
// Or use extension methodvar schedulerResource = armClient.GetDurableTaskSchedulerResource(    DurableTaskSchedulerResource.CreateResourceIdentifier(        subscriptionId,        "my-resource-group",        "my-scheduler"));var scheduler = await schedulerResource.GetAsync();

// Get current schedulervar scheduler = await schedulerCollection.GetAsync("my-scheduler");
// Update with new configurationvar updateData = new DurableTaskSchedulerData(scheduler.Value.Data.Location){    Properties = new DurableTaskSchedulerProperties    {        Sku = new DurableTaskSchedulerSku(DurableTaskSchedulerSkuName.Dedicated)        {            Capacity = 2  // Scale up        },        IPAllowlist = { "10.0.0.0/16" }  // Update IP allowlist    }};
var updateOperation = await schedulerCollection.CreateOrUpdateAsync(    WaitUntil.Completed,    "my-scheduler",    updateData);

// Delete task hub firstvar taskHub = await scheduler.GetDurableTaskHubs().GetAsync("my-taskhub");await taskHub.Value.DeleteAsync(WaitUntil.Completed);
// Then delete schedulerawait scheduler.DeleteAsync(WaitUntil.Completed);

// Get retention policy collectionvar retentionPolicies = scheduler.GetDurableTaskRetentionPolicies();
// Create or update retention policyvar retentionData = new DurableTaskRetentionPolicyData{    Properties = new DurableTaskRetentionPolicyProperties    {        // Configure retention settings    }};
var retentionOperation = await retentionPolicies.CreateOrUpdateAsync(    WaitUntil.Completed,    "default",  // Policy name    retentionData);

// On SubscriptionResourcesubscription.GetDurableTaskSchedulers();           // List all in subscriptionsubscription.GetDurableTaskSchedulersAsync();      // Async enumerable
// On ResourceGroupResource  resourceGroup.GetDurableTaskSchedulers();          // Get collectionresourceGroup.GetDurableTaskSchedulerAsync(name);  // Get by name
// On ArmClientarmClient.GetDurableTaskSchedulerResource(id);     // Get by resource IDarmClient.GetDurableTaskHubResource(id);           // Get task hub by ID

using Azure;
try{    var operation = await schedulerCollection.CreateOrUpdateAsync(        WaitUntil.Completed, schedulerName, schedulerData);}catch (RequestFailedException ex) when (ex.Status == 409){    Console.WriteLine("Scheduler already exists");}catch (RequestFailedException ex) when (ex.Status == 404){    Console.WriteLine("Resource group not found");}catch (RequestFailedException ex){    Console.WriteLine($"ARM Error: {ex.Status} - {ex.ErrorCode}: {ex.Message}");}

using Azure;using Azure.Identity;using Azure.ResourceManager;using Azure.ResourceManager.DurableTask;using Azure.ResourceManager.DurableTask.Models;using Azure.ResourceManager.Resources;
// Setupvar credential = new DefaultAzureCredential();var armClient = new ArmClient(credential);
var subscriptionId = Environment.GetEnvironmentVariable("AZURE_SUBSCRIPTION_ID")!;var resourceGroupName = Environment.GetEnvironmentVariable("AZURE_RESOURCE_GROUP")!;
var subscription = armClient.GetSubscriptionResource(    new ResourceIdentifier($"/subscriptions/{subscriptionId}"));var resourceGroup = await subscription.GetResourceGroupAsync(resourceGroupName);
// Create schedulervar schedulerData = new DurableTaskSchedulerData(AzureLocation.EastUS){    Properties = new DurableTaskSchedulerProperties    {        Sku = new DurableTaskSchedulerSku(DurableTaskSchedulerSkuName.Dedicated)        {            Capacity = 1        }    }};
var schedulerCollection = resourceGroup.Value.GetDurableTaskSchedulers();var schedulerOp = await schedulerCollection.CreateOrUpdateAsync(    WaitUntil.Completed, "my-scheduler", schedulerData);var scheduler = schedulerOp.Value;
Console.WriteLine($"Scheduler endpoint: {scheduler.Data.Properties.Endpoint}");
// Create task hubvar taskHubData = new DurableTaskHubData();var taskHubOp = await scheduler.GetDurableTaskHubs().CreateOrUpdateAsync(    WaitUntil.Completed, "my-taskhub", taskHubData);var taskHub = taskHubOp.Value;
Console.WriteLine($"Task Hub: {taskHub.Data.Name}");
// Cleanupawait taskHub.DeleteAsync(WaitUntil.Completed);await scheduler.DeleteAsync(WaitUntil.Completed);