save

Author: YunchuWang

src/ScheduledTasks/Client/ScheduledTaskClient.cs

@@ -44,14 +44,6 @@ public async Task<IScheduleHandle> CreateScheduleAsync(ScheduleCreationOptions s
 
         EntityInstanceId entityId = new EntityInstanceId(nameof(Schedule), scheduleConfigCreateOptions.ScheduleId);
 
-        // Check if schedule already exists
-        EntityMetadata<ScheduleState>? metadata = await this.durableTaskClient.Entities.GetEntityAsync<ScheduleState>(entityId);
-        if (metadata != null)
-        {
-            this.logger.ClientWarning("Schedule with ID {ScheduleId} already exists. Returning existing handle.", scheduleConfigCreateOptions.ScheduleId);
-            return new ScheduleHandle(this.durableTaskClient, scheduleConfigCreateOptions.ScheduleId, this.logger);
-        }
-
         await this.durableTaskClient.Entities.SignalEntityAsync(entityId, nameof(Schedule.CreateSchedule), scheduleConfigCreateOptions);
 
         return new ScheduleHandle(this.durableTaskClient, scheduleConfigCreateOptions.ScheduleId, this.logger);