diff --git a/taskcluster/taskgraph/create.py b/taskcluster/taskgraph/create.py
index bda9a1498a80..8984e947db6f 100644
--- a/taskcluster/taskgraph/create.py
+++ b/taskcluster/taskgraph/create.py
@@ -7,9 +7,12 @@ from __future__ import absolute_import, print_function, unicode_literals
 import requests
 import json
 import collections
+import logging
 
 from slugid import nice as slugid
 
+logger = logging.getLogger(__name__)
+
 def create_tasks(taskgraph):
     # TODO: use the taskGroupId of the decision task
     task_group_id = slugid()
@@ -33,11 +36,11 @@ def create_tasks(taskgraph):
 def _create_task(session, task_id, label, task_def):
     # create the task using 'http://taskcluster/queue', which is proxied to the queue service
     # with credentials appropriate to this job.
-    print("Creating task with taskId {} for {}".format(task_id, label))
+    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))
     if res.status_code != 200:
         try:
-            print(res.json()['message'])
+            logger.error(res.json()['message'])
         except:
-            print(res.text)
+            logger.error(res.text)
         res.raise_for_status()