Skip to content

Commit

Permalink
remove debug prints
Browse files Browse the repository at this point in the history
  • Loading branch information
EddyCMWF committed Feb 12, 2024
1 parent 5aae0f8 commit 015e0c2
Showing 1 changed file with 0 additions and 4 deletions.
4 changes: 0 additions & 4 deletions earthkit/data/sources/cds.py
Original file line number Diff line number Diff line change
Expand Up @@ -111,7 +111,6 @@ def __init__(self, dataset, *args, **kwargs):
self.client() # Trigger password prompt before thraeding

nthreads = min(self.settings("number-of-download-threads"), len(self.requests))
print(2, self.source_filename)

if nthreads < 2:
self.path = [self._retrieve(dataset, r) for r in self.requests]
Expand All @@ -123,21 +122,18 @@ def __init__(self, dataset, *args, **kwargs):

iterator = (f.result() for f in futures)
self.path = list(tqdm(iterator, leave=True, total=len(self.requests)))
print(5, self.source_filename)

def _retrieve(self, dataset, request):
def retrieve(target, args):
cds_result = self.client().retrieve(args[0], args[1])
self.source_filename = cds_result.location.split("/")[-1]
cds_result.download(target=target)

print(3, self.source_filename)
return_object = self.cache_file(
retrieve,
(dataset, request),
extension=EXTENSIONS.get(request.get("format"), ".cache"),
)
print(4, self.source_filename)
return return_object

@staticmethod
Expand Down

0 comments on commit 015e0c2

Please sign in to comment.