Test lower concurrency, add extra debug logs DONTBUILD
authorSimon Fraser <sfraser@mozilla.com>
Tue, 12 Sep 2017 11:13:14 +0100
changeset 663933 20250c9450d54b1daf7e872a9efacdce8e69f5f2
parent 663932 686a909e4df3987291031a3736aacf504ce94bbc
child 663934 919619296a08f78ae78fe2412d8f40b9951acc8b
push id79558
push usercatlee@mozilla.com
push dateWed, 13 Sep 2017 13:53:28 +0000
milestone57.0a1
Test lower concurrency, add extra debug logs DONTBUILD
taskcluster/taskgraph/create.py
--- a/taskcluster/taskgraph/create.py
+++ b/taskcluster/taskgraph/create.py
@@ -14,17 +14,17 @@ import logging
 
 from slugid import nice as slugid
 from taskgraph.util.parameterization import resolve_timestamps
 from taskgraph.util.time import current_json_time
 
 logger = logging.getLogger(__name__)
 
 # the maximum number of parallel createTask calls to make
-CONCURRENCY = 100
+CONCURRENCY = 1
 
 # this is set to true for `mach taskgraph action-callback --test`
 testing = False
 
 
 def create_tasks(taskgraph, label_to_taskid, params, decision_task_id=None):
     taskid_to_label = {t: l for l, t in label_to_taskid.iteritems()}
 
@@ -106,14 +106,15 @@ def create_task(session, task_id, label,
     if testing:
         json.dump([task_id, task_def], sys.stdout,
                   sort_keys=True, indent=4, separators=(',', ': '))
         return
 
     logger.debug("Creating task with taskId {} for {}".format(task_id, label))
     res = session.put('http://taskcluster/queue/v1/task/{}'.format(task_id),
                       data=json.dumps(task_def))
+    logger.debug("requests elapsed time for taskId {} is {}".format(task_id, r.elapsed))
     if res.status_code != 200:
         try:
             logger.error(res.json()['message'])
         except:
             logger.error(res.text)
         res.raise_for_status()