Skip to content

Commit

Permalink
Improve log levels and use INFO by default
Browse files Browse the repository at this point in the history
  • Loading branch information
streino committed Oct 25, 2024
1 parent 2210d7f commit 0373a5b
Show file tree
Hide file tree
Showing 2 changed files with 11 additions and 11 deletions.
8 changes: 4 additions & 4 deletions isomorphe/geonetwork.py
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
from lxml import etree
from lxml.builder import E

logging.basicConfig(level=logging.DEBUG)
logging.basicConfig(level=logging.INFO)
log = logging.getLogger(__name__)


Expand Down Expand Up @@ -79,7 +79,7 @@ def __init__(self, url, username: str | None = None, password: str | None = None
self.session = requests.Session()
if username and password:
self.session.auth = (username, password)
log.debug(f"Authenticating as: {username}")
log.info(f"Authenticating as: {username}")
self.authenticate()

def info(self):
Expand Down Expand Up @@ -161,7 +161,7 @@ def get_records(self, query=None) -> list[Record]:
return records

def get_record(self, uuid: str) -> etree._ElementTree:
# log.debug(f"Processing record: {record}")
log.debug(f"Processing record: {uuid}")
r = self.session.get(
f"{self.api}/records/{uuid}/formatters/xml",
headers={"Accept": "application/xml"},
Expand Down Expand Up @@ -305,7 +305,7 @@ def delete_record(self, uuid: str) -> None:
r.raise_for_status()

def add_group(self, name: str, description: str = ""):
log.debug(f"Adding group: {name}")
log.info(f"Adding group: {name}")
r = self.session.put(
f"{self.api}/groups",
headers={"Accept": "application/json"},
Expand Down
14 changes: 7 additions & 7 deletions isomorphe/migrator.py
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@
)
from isomorphe.util import xml_to_string

logging.basicConfig(level=logging.DEBUG)
logging.basicConfig(level=logging.INFO)
log = logging.getLogger(__name__)


Expand Down Expand Up @@ -80,15 +80,15 @@ def select(self, **kwargs) -> list[Record]:
"""
Select data to migrate based on given params
"""
log.debug(f"Selecting with {kwargs}")
log.info(f"Selecting with {kwargs}")

query = {"_isHarvested": "n"}
q = kwargs.get("query", "")
query |= dict(p.split("=") for p in q.split(","))

selection = self.gn.get_records(query=query)

log.debug(f"Selection contains {len(selection)} items")
log.info(f"Selection contains {len(selection)} items")
return selection

def transform(
Expand All @@ -100,7 +100,7 @@ def transform(
"""
Transform data from a selection
"""
log.debug(f"Transforming {selection} via {transformation}")
log.info(f"Transforming {selection} via {transformation}")
sources = self.gn.get_sources()

batch = TransformBatch(transformation=transformation.name)
Expand Down Expand Up @@ -173,7 +173,7 @@ def transform(
)
)

log.debug("Transformation done.")
log.info("Transformation done.")
return batch

def migrate(
Expand All @@ -183,7 +183,7 @@ def migrate(
group: int | None = None,
transform_job_id: str | None = None,
) -> MigrateBatch:
log.debug(f"Migrating batch {batch} for {self.url} (overwrite={overwrite})")
log.info(f"Migrating batch {batch} for {self.url} (overwrite={overwrite})")
migrate_batch = MigrateBatch(
mode=MigrateMode.OVERWRITE if overwrite else MigrateMode.CREATE,
transform_job_id=transform_job_id,
Expand Down Expand Up @@ -224,7 +224,7 @@ def migrate(
error=str(e),
)
)
log.debug("Migration done.")
log.info("Migration done.")
return migrate_batch

@staticmethod
Expand Down

0 comments on commit 0373a5b

Please sign in to comment.