--- a/taskcluster/taskgraph/actions/add_talos.py
+++ b/taskcluster/taskgraph/actions/add_talos.py
@@ -18,22 +18,38 @@ logger = logging.getLogger(__name__)
 
 @register_callback_action(
     name='run-all-talos',
     title='Run All Talos Tests',
     symbol='raT',
     description="Add all Talos tasks to a push.",
     order=100,  # Useful for sheriffs, but not top of the list
     context=[],
+    schema={
+        'type': 'object',
+        'properties': {
+            'times': {
+                'type': 'integer',
+                'default': 1,
+                'minimum': 1,
+                'maximum': 6,
+                'title': 'Times',
+                'description': 'How many times to run each task.',
+            }
+        },
+        'additionalProperties': False
+    },
 )
 def add_all_talos(parameters, input, task_group_id, task_id, task):
     decision_task_id = find_decision_task(parameters)
 
     full_task_graph = get_artifact(decision_task_id, "public/full-task-graph.json")
     _, full_task_graph = TaskGraph.from_json(full_task_graph)
     label_to_taskid = get_artifact(decision_task_id, "public/label-to-taskid.json")
 
-    to_run = [label
-              for label, entry
-              in full_task_graph.tasks.iteritems() if 'talos_try_name' in entry.attributes]
+    times = input.get('times', 1)
+    for i in xrange(times):
+        to_run = [label
+                  for label, entry
+                  in full_task_graph.tasks.iteritems() if 'talos_try_name' in entry.attributes]
 
-    create_tasks(to_run, full_task_graph, label_to_taskid, parameters, decision_task_id)
-    logger.info('Scheduled {} talos tasks'.format(len(to_run)))
+        create_tasks(to_run, full_task_graph, label_to_taskid, parameters, decision_task_id)
+        logger.info('Scheduled {} talos tasks (time {}/{})'.format(len(to_run), i+1, times))