Bug 1289225: increase createTask concurrency; r=gps,jonasfj

MozReview-Commit-ID: DuIzZUbTsaY

--HG--
extra : rebase_source : a96e52f32edd6cda86db9e0d967820235f3aa7d3
This commit is contained in:
Dustin J. Mitchell 2016-07-25 20:52:43 +00:00
Родитель 6ef6a625d6
Коммит fd3cfffba7
1 изменённых файлов: 4 добавлений и 1 удалений

Просмотреть файл

@ -19,6 +19,9 @@ from taskgraph.util.time import (
logger = logging.getLogger(__name__)
# the maximum number of parallel createTask calls to make
CONCURRENCY = 50
def create_tasks(taskgraph, label_to_taskid):
# TODO: use the taskGroupId of the decision task
@ -29,7 +32,7 @@ def create_tasks(taskgraph, label_to_taskid):
decision_task_id = os.environ.get('TASK_ID')
with futures.ThreadPoolExecutor(requests.adapters.DEFAULT_POOLSIZE) as e:
with futures.ThreadPoolExecutor(CONCURRENCY) as e:
fs = {}
# We can't submit a task until its dependencies have been submitted.