Skip to content

Commit

Permalink
Change logging types in docker_pull
Browse files Browse the repository at this point in the history
  • Loading branch information
domwhewell-sage committed Sep 20, 2024
1 parent 074cfa1 commit 4b79a63
Showing 1 changed file with 6 additions and 4 deletions.
10 changes: 6 additions & 4 deletions bbot/modules/docker_pull.py
Original file line number Diff line number Diff line change
Expand Up @@ -86,12 +86,12 @@ async def docker_api_request(self, url: str):
service = www_authenticate_headers.split('service="')[1].split('"')[0]
scope = www_authenticate_headers.split('scope="')[1].split('"')[0]
except (KeyError, IndexError):
self.log.error(f"Could not obtain realm, service or scope from {url}")
self.log.warning(f"Could not obtain realm, service or scope from {url}")
break
auth_url = f"{realm}?service={service}&scope={scope}"
auth_response = await self.helpers.request(auth_url)
if not auth_response:
self.log.error(f"Could not obtain token from {auth_url}")
self.log.warning(f"Could not obtain token from {auth_url}")
break
auth_json = auth_response.json()
token = auth_json["token"]
Expand All @@ -103,6 +103,7 @@ async def get_tags(self, registry, repository):
r = await self.docker_api_request(url)
if r is None or r.status_code != 200:
self.log.warning(f"Could not retrieve all tags for {repository} asuming tag:latest only.")
self.log.debug(f"Response: {r}")
return ["latest"]
try:
tags = r.json().get("tags", ["latest"])
Expand All @@ -115,14 +116,15 @@ async def get_tags(self, registry, repository):
else:
return [tags[-1]]
except (KeyError, IndexError):
self.log.error(f"Could not retrieve tags for {repository}.")
self.log.warning(f"Could not retrieve tags for {repository}.")
return ["latest"]

async def get_manifest(self, registry, repository, tag):
url = f"{registry}/v2/{repository}/manifests/{tag}"
r = await self.docker_api_request(url)
if r is None or r.status_code != 200:
self.log.error(f"Could not retrieve manifest for {repository}:{tag}.")
self.log.warning(f"Could not retrieve manifest for {repository}:{tag}.")
self.log.debug(f"Response: {r}")
return {}
response_json = r.json()
if response_json.get("manifests", []):
Expand Down

0 comments on commit 4b79a63

Please sign in to comment.