diff --git a/lib/travis/api/v3/queries/crons.rb b/lib/travis/api/v3/queries/crons.rb
index 9998097e..761da836 100644
--- a/lib/travis/api/v3/queries/crons.rb
+++ b/lib/travis/api/v3/queries/crons.rb
@@ -5,6 +5,19 @@ module Travis::API::V3
       Models::Cron.where(:branch_id => repository.branches)
     end
 
+    def start_all()
+      started = []
+
+      Models::Cron.all.each do |cron|
+        if cron.next_enqueuing <= Time.now
+          start(cron.branch)
+          started.push cron
+        end
+      end
+
+      started
+    end
+
     def start(branch)
       raise ServerError, 'repository does not have a github_id'.freeze unless branch.repository.github_id
 
diff --git a/lib/travis/api/v3/services/crons/start.rb b/lib/travis/api/v3/services/crons/start.rb
index 1bef2f79..104d43f5 100644
--- a/lib/travis/api/v3/services/crons/start.rb
+++ b/lib/travis/api/v3/services/crons/start.rb
@@ -2,16 +2,7 @@ module Travis::API::V3
   class Services::Crons::Start < Service
 
     def run!
-      started = []
-
-      Models::Cron.all.each do |cron|
-        if cron.next_enqueuing <= Time.now
-          query.start(cron.branch)
-          started.push cron
-        end
-      end
-
-      started
+      query.start_all()
     end
 
   end