| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/tools/ |
| gcs_file_seg_reader.py | 10 # TODO(user): Cleanup imports if/when cloudstorage becomes part of runtime.
12 # Check if the full cloudstorage package exists. The stub part is in runtime.
13 import cloudstorage
14 if hasattr(cloudstorage, "_STUB"):
15 cloudstorage = None variable
17 pass # CloudStorage library not available
89 stat = cloudstorage.stat(filename)
100 self._seg = cloudstorage.open(filename)
|
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/ |
| base_handler.py | 37 # Check if the full cloudstorage package exists. The stub part is in runtime.
38 import cloudstorage
39 if hasattr(cloudstorage, "_STUB"):
40 cloudstorage = None variable
42 cloudstorage = None variable
81 if cloudstorage:
82 cloudstorage.set_default_retry_params(
83 cloudstorage.RetryParams(
|
| output_writers.py | 55 # TODO(user): Cleanup imports if/when cloudstorage becomes part of runtime.
57 # Check if the full cloudstorage package exists. The stub part is in runtime.
58 cloudstorage = None variable
59 import cloudstorage
60 if hasattr(cloudstorage, "_STUB"):
61 cloudstorage = None variable
63 if cloudstorage:
64 from cloudstorage import cloudstorage_api
65 from cloudstorage import errors as cloud_errors
67 pass # CloudStorage library not availabl
[all...] |
| shuffler.py | 52 # TODO(user): Cleanup imports if/when cloudstorage becomes part of runtime.
54 # Check if the full cloudstorage package exists. The stub part is in runtime.
55 import cloudstorage
56 if hasattr(cloudstorage, "_STUB"):
57 cloudstorage = None variable
59 pass # CloudStorage library not available
154 filehandle = cloudstorage.open(full_filename, mode="w")
304 cloudstorage.open(filename, read_buffer_size=self.GCS_BUFFER_SIZE))
485 filehandles.append(cloudstorage.open(full_filename, mode="w"))
729 retry_params = cloudstorage.RetryParams(min_retries=self._MIN_RETRIES
[all...] |
| input_readers.py | 79 # TODO(user): Cleanup imports if/when cloudstorage becomes part of runtime.
81 # Check if the full cloudstorage package exists. The stub part is in runtime.
82 cloudstorage = None variable
83 import cloudstorage
84 if hasattr(cloudstorage, "_STUB"):
85 cloudstorage = None variable
87 pass # CloudStorage library not available
89 # Attempt to load cloudstorage from the bundle (availble in some tests)
90 if cloudstorage is None:
92 import cloudstorage
[all...] |
| handlers.py | 62 import cloudstorage
64 # of cloudstorage. All occurences of the following if condition in MR
67 if hasattr(cloudstorage, "_STUB"):
68 cloudstorage = None variable
70 cloudstorage = None # CloudStorage library not available variable
[all...] |
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/lib/input_reader/ |
| _gcs.py | 23 # TODO(user): Cleanup imports if/when cloudstorage becomes part of runtime.
25 # Check if the full cloudstorage package exists. The stub part is in runtime.
26 import cloudstorage
27 if hasattr(cloudstorage, "_STUB"):
28 cloudstorage = None variable
30 pass # CloudStorage library not available
52 """Input reader from Google Cloud Storage using the cloudstorage library.
110 _account_id: Internal use only. See cloudstorage documentation.
146 self._bucket = cloudstorage.listbucket(filename,
169 cloudstorage.validate_bucket_name
[all...] |
| /external/chromium-trace/catapult/perf_insights/perf_insights/endpoints/ |
| corpus_cleanup.py | 13 import cloudstorage as gcs
|
| upload.py | 15 import cloudstorage as gcs
|
| /external/chromium-trace/catapult/perf_insights/perf_insights/endpoints/cloud_mapper/ |
| cloud_helper.py | 7 import cloudstorage as gcs
|
| /external/chromium-trace/catapult/third_party/pipeline/pipeline/ |
| pipeline.py | 52 # TODO(user): Cleanup imports if/when cloudstorage becomes part of runtime.
54 # Check if the full cloudstorage package exists. The stub part is in runtime.
55 import cloudstorage
56 if hasattr(cloudstorage, "_STUB"):
57 cloudstorage = None variable
59 pass # CloudStorage library not available
[all...] |
