1 files changed, 22 insertions, 8 deletions
diff --git a/app/graphql/mutations/ci/pipeline_schedule/create.rb b/app/graphql/mutations/ci/pipeline_schedule/create.rb
index 65b355cd80f..71a366ed342 100644
--- a/app/graphql/mutations/ci/pipeline_schedule/create.rb
+++ b/app/graphql/mutations/ci/pipeline_schedule/create.rb
@@ -51,14 +51,28 @@ module Mutations
 
           params = pipeline_schedule_attrs.merge(variables_attributes: variables.map(&:to_h))
 
-          schedule = ::Ci::CreatePipelineScheduleService
-                      .new(project, current_user, params)
-                      .execute
-
-          unless schedule.persisted?
-            return {
-              pipeline_schedule: nil, errors: schedule.errors.full_messages
-            }
+          if ::Feature.enabled?(:ci_refactoring_pipeline_schedule_create_service, project)
+            response = ::Ci::PipelineSchedules::CreateService
+                         .new(project, current_user, params)
+                         .execute
+
+            schedule = response.payload
+
+            unless response.success?
+              return {
+                pipeline_schedule: nil, errors: response.errors
+              }
+            end
+          else
+            schedule = ::Ci::CreatePipelineScheduleService
+                         .new(project, current_user, params)
+                         .execute
+
+            unless schedule.persisted?
+              return {
+                pipeline_schedule: nil, errors: schedule.errors.full_messages
+              }
+            end
           end
 
           {