Index: tools/telemetry/third_party/gsutilz/gslib/name_expansion.py |
diff --git a/tools/telemetry/third_party/gsutilz/gslib/name_expansion.py b/tools/telemetry/third_party/gsutilz/gslib/name_expansion.py |
index 0d8b6cae9bbb4b1dec88942eeca0ed4c70328497..ee42cde4961926952c4a8aac08533998bb8eb8bc 100644 |
--- a/tools/telemetry/third_party/gsutilz/gslib/name_expansion.py |
+++ b/tools/telemetry/third_party/gsutilz/gslib/name_expansion.py |
@@ -26,10 +26,10 @@ the various rules for determining how these expansions are done. |
from __future__ import absolute_import |
-import multiprocessing |
import os |
import sys |
+import gslib |
from gslib.exception import CommandException |
from gslib.plurality_checkable_iterator import PluralityCheckableIterator |
import gslib.wildcard_iterator |
@@ -70,7 +70,7 @@ class NameExpansionResult(object): |
self.expanded_storage_url = expanded_storage_url |
def __repr__(self): |
- return '%s' % self._expanded_storage_url |
+ return '%s' % self.expanded_storage_url |
class _NameExpansionIterator(object): |
@@ -355,7 +355,7 @@ class NameExpansionIteratorQueue(object): |
def __init__(self, name_expansion_iterator, final_value): |
self.name_expansion_iterator = name_expansion_iterator |
self.final_value = final_value |
- self.lock = multiprocessing.Manager().Lock() |
+ self.lock = gslib.util.manager.Lock() |
def qsize(self): |
raise NotImplementedError( |