Refactor task enqueuing

appengine/gce-backend/metadata.py

 # Copyright 2016 The LUCI Authors. All rights reserved.
 # Use of this source code is governed under the Apache License, Version 2.0
 # that can be found in the LICENSE file.
 
 """Utilities for operating on instance metadata."""
 
 import json
 import logging
 
 from google.appengine.ext import ndb
 
 from components import gce
 from components import net
-from components import utils
 
 import metrics
 import models
 import utilities
 
 
 def apply_metadata_update(items, metadata):
   """Returns the result of applying the given metadata update.
 
   Args:
@@ skipping 289 matching lines @@
     if instance.active_metadata_update:
       if instance.active_metadata_update.url:
         # Enqueue task to check the in-progress metadata operation.
         queue = 'check-instance-metadata-operation'
       else:
         # Enqueue task to start a metadata operation.
         queue = 'update-instance-metadata'
     elif instance.pending_metadata_updates:
       # Enqueue task to compress a list of desired metadata updates.
       queue = 'compress-instance-metadata-updates'
-    if queue and not utils.enqueue_task(
-        '/internal/queues/%s' % queue,
-        queue,
-        params={
-            'key': instance.key.urlsafe(),
-        },
-    ):
-      logging.warning('Failed to enqueue task for Instance: %s', instance.key)
+    if queue:
+      utilities.enqueue_task(queue, instance.key)