fb

Author: YunchuWang

samples/ScheduleConsoleApp/Program.cs

@@ -10,6 +10,7 @@
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
 using Microsoft.Extensions.Logging;
+using ScheduleConsoleApp;
 
 HostApplicationBuilder builder = Host.CreateApplicationBuilder(args);
 
@@ -49,73 +50,9 @@
 IHost host = builder.Build();
 await host.StartAsync();
 
+// Run the schedule operations
 IScheduledTaskClient scheduledTaskClient = host.Services.GetRequiredService<IScheduledTaskClient>();
-
-try
-{
-    // list all schedules
-    // Define the initial query with the desired page size
-    ScheduleQuery query = new ScheduleQuery { PageSize = 100 };
-
-    // Retrieve the pageable collection of schedule IDs
-    AsyncPageable<string> schedules = await scheduledTaskClient.ListScheduleIdsAsync(query);
-
-    // Initialize the continuation token
-    await foreach (string scheduleId in schedules)
-    {
-        // Obtain the schedule handle for the current scheduleId
-        IScheduleHandle handle = scheduledTaskClient.GetScheduleHandle(scheduleId);
-
-        // Delete the schedule
-        await handle.DeleteAsync();
-
-        Console.WriteLine($"Deleted schedule {scheduleId}");
-    }
-
-    // Create schedule options that runs every 4 seconds
-    ScheduleCreationOptions scheduleOptions = new ScheduleCreationOptions("demo-schedule101", nameof(StockPriceOrchestrator), TimeSpan.FromSeconds(4))
-    {
-        StartAt = DateTimeOffset.UtcNow,
-        OrchestrationInput = "MSFT"
-    };
-
-    // Create the schedule and get a handle to it
-    IScheduleHandle scheduleHandle = await scheduledTaskClient.CreateScheduleAsync(scheduleOptions);
-
-    // Get the schedule description
-    ScheduleDescription scheduleDescription = await scheduleHandle.DescribeAsync();
-
-    // print the schedule description
-    Console.WriteLine(scheduleDescription);
-
-    Console.WriteLine("");
-    Console.WriteLine("");
-    Console.WriteLine("");
-
-    // Pause the schedule
-    Console.WriteLine("\nPausing schedule...");
-    await scheduleHandle.PauseAsync();
-    scheduleDescription = await scheduleHandle.DescribeAsync();
-    Console.WriteLine(scheduleDescription);
-    Console.WriteLine("");
-    Console.WriteLine("");
-    Console.WriteLine("");
-
-    // Resume the schedule
-    Console.WriteLine("\nResuming schedule...");
-    await scheduleHandle.ResumeAsync();
-    scheduleDescription = await scheduleHandle.DescribeAsync();
-    Console.WriteLine(scheduleDescription);
-
-    Console.WriteLine("");
-    Console.WriteLine("");
-    Console.WriteLine("");
-
-    await Task.Delay(TimeSpan.FromMinutes(30));
-}
-catch (Exception ex)
-{
-    Console.WriteLine($"One of your schedule operations failed, please fix and rerun: {ex.Message}");
-}
+ScheduleOperations scheduleOperations = new ScheduleOperations(scheduledTaskClient);
+await scheduleOperations.RunAsync();
 
 await host.StopAsync();

samples/ScheduleConsoleApp/ScheduleOperations.cs

@@ -0,0 +1,81 @@
+// Copyright (c) Microsoft Corporation.
+// Licensed under the MIT License.
+
+using Microsoft.DurableTask;
+using Microsoft.DurableTask.ScheduledTasks;
+
+namespace ScheduleConsoleApp;
+
+class ScheduleOperations(IScheduledTaskClient scheduledTaskClient)
+{
+    readonly IScheduledTaskClient scheduledTaskClient = scheduledTaskClient ?? throw new ArgumentNullException(nameof(scheduledTaskClient));
+
+    public async Task RunAsync()
+    {
+        try
+        {
+            await this.DeleteExistingSchedulesAsync();
+            await this.CreateAndManageScheduleAsync();
+        }
+        catch (Exception ex)
+        {
+            Console.WriteLine($"One of your schedule operations failed, please fix and rerun: {ex.Message}");
+        }
+    }
+
+    async Task DeleteExistingSchedulesAsync()
+    {
+        // Define the initial query with the desired page size
+        ScheduleQuery query = new ScheduleQuery { PageSize = 100 };
+
+        // Retrieve the pageable collection of schedule IDs
+        AsyncPageable<string> schedules = await this.scheduledTaskClient.ListScheduleIdsAsync(query);
+
+        // Delete each existing schedule
+        await foreach (string scheduleId in schedules)
+        {
+            IScheduleHandle handle = this.scheduledTaskClient.GetScheduleHandle(scheduleId);
+            await handle.DeleteAsync();
+            Console.WriteLine($"Deleted schedule {scheduleId}");
+        }
+    }
+
+    async Task CreateAndManageScheduleAsync()
+    {
+        // Create schedule options that runs every 4 seconds
+        ScheduleCreationOptions scheduleOptions = new ScheduleCreationOptions(
+            "demo-schedule101",
+            nameof(StockPriceOrchestrator),
+            TimeSpan.FromSeconds(4))
+        {
+            StartAt = DateTimeOffset.UtcNow,
+            OrchestrationInput = "MSFT"
+        };
+
+        // Create the schedule and get a handle to it
+        IScheduleHandle scheduleHandle = await this.scheduledTaskClient.CreateScheduleAsync(scheduleOptions);
+
+        // Get and print the initial schedule description
+        await PrintScheduleDescriptionAsync(scheduleHandle);
+
+        // Pause the schedule
+        Console.WriteLine("\nPausing schedule...");
+        await scheduleHandle.PauseAsync();
+        await PrintScheduleDescriptionAsync(scheduleHandle);
+
+        // Resume the schedule
+        Console.WriteLine("\nResuming schedule...");
+        await scheduleHandle.ResumeAsync();
+        await PrintScheduleDescriptionAsync(scheduleHandle);
+
+        // Wait for a while to let the schedule run
+        await Task.Delay(TimeSpan.FromMinutes(30));
+    }
+
+    static async Task PrintScheduleDescriptionAsync(IScheduleHandle scheduleHandle)
+    {
+        ScheduleDescription scheduleDescription = await scheduleHandle.DescribeAsync();
+        Console.WriteLine(scheduleDescription);
+        Console.WriteLine("\n\n");
+    }
+}