add createasync in scheduleclient

Author: YunchuWang

src/ScheduledTasks/Client/ScheduleClient.cs

@@ -22,6 +22,14 @@ protected ScheduleClient(string scheduleId)
     /// </summary>
     public string ScheduleId { get; }
 
+    /// <summary>
+    /// Creates or update a schedule with the specified configuration.
+    /// </summary>
+    /// <param name="creationOptions">The options for creating the schedule.</param>
+    /// <param name="cancellation">The cancellation token that can be used to cancel the operation.</param>
+    /// <returns>A task that completes when the schedule has been created.</returns>
+    public abstract Task CreateAsync(ScheduleCreationOptions creationOptions, CancellationToken cancellation = default);
+
     /// <summary>
     /// Retrieves the current details of this schedule.
     /// </summary>

src/ScheduledTasks/Client/ScheduleClientImpl.cs

@@ -36,6 +36,43 @@ public ScheduleClientImpl(DurableTaskClient client, string scheduleId, ILogger l
     /// </summary>
     EntityInstanceId EntityId { get; }
 
+    /// <inheritdoc/>
+    public override async Task CreateAsync(ScheduleCreationOptions creationOptions, CancellationToken cancellation = default)
+    {
+        try
+        {
+            Check.NotNull(creationOptions, nameof(creationOptions));
+
+            ScheduleOperationRequest request = new ScheduleOperationRequest(this.EntityId, nameof(Schedule.CreateSchedule), creationOptions);
+            string instanceId = await this.durableTaskClient.ScheduleNewOrchestrationInstanceAsync(
+                new TaskName(nameof(ExecuteScheduleOperationOrchestrator)),
+                request,
+                cancellation);
+
+            // Wait for the orchestration to complete
+            OrchestrationMetadata state = await this.durableTaskClient.WaitForInstanceCompletionAsync(instanceId, true, cancellation);
+
+            if (state.RuntimeStatus != OrchestrationRuntimeStatus.Completed)
+            {
+                throw new InvalidOperationException($"Failed to create schedule '{this.ScheduleId}': {state.FailureDetails?.ErrorMessage ?? string.Empty}");
+            }
+        }
+        catch (OperationCanceledException) when (cancellation.IsCancellationRequested)
+        {
+            // the operation was cancelled as requested. No need to log this.
+            throw;
+        }
+        catch (Exception ex)
+        {
+            this.logger.ClientError(
+                nameof(this.CreateAsync),
+                this.ScheduleId,
+                ex);
+
+            throw;
+        }
+    }
+
     /// <inheritdoc/>
     public override async Task<ScheduleDescription> DescribeAsync(CancellationToken cancellation = default)
     {