registrar update logging

core/registrar.py

@@ -98,6 +98,7 @@ def add_mask(product):
     )[0]
     geometry = GEOSGeometry(wkt)
     mask_type = models.MaskType.objects.get(product_type=product.product_type)
+    logger.debug("Adding mask")
     models.Mask.objects.create(
         product=product,
         mask_type=mask_type,
@@ -115,7 +116,7 @@ def get_product_type_and_level(metadata_item):
         xp = '//gml:using/eop:EarthObservationEquipment/eop:platform/eop:Platform/eop:shortName/text()'
         product_type_name = tree.xpath(xp, namespaces=root.nsmap)[0]
     except Exception as e:
-        logger.warning(
+        logger.debug(
             'Failed to determine product type of %s, error was %s'
             % (metadata_item.location, e)
         )
@@ -132,7 +133,7 @@ def get_product_type_and_level(metadata_item):
         else:
             raise Exception('Invalid parent identifier type name %s' % parent_identifier)
     except Exception as e:
-        logger.warning(
+        logger.debug(
             'Failed to determine product level of %s, error was %s'
             % (metadata_item.location, e)
         )
@@ -191,7 +192,7 @@ def registrar(
     metadata_item = models.MetaDataItem(storage=storage, location=metadata_package)
 
     product_type, level = get_product_type_and_level(metadata_item)
-
+    logger.debug("Registering product")
     product, replaced = ProductRegistrator().register(
         metadata_locations=[[upload_container,
                              metadata_package, ], ],
@@ -206,6 +207,7 @@ def registrar(
     collection = models.Collection.objects.get(
         identifier=collection
     )
+    logger.debug("Inserting product into collection")
     models.collection_insert_eo_object(collection, product)
 
     if level == 'Level_1':
@@ -219,6 +221,7 @@ def registrar(
         )
         models.collection_insert_eo_object(collection_level_3, product)
 
+    logger.debug("Registering coverage")
     report = GDALRegistrator().register(
         data_locations=[[upload_container, data_package, ], ],
         metadata_locations=[[upload_container,
@@ -230,14 +233,15 @@ def registrar(
         },
         replace=replace,
     )
+    logger.debug("Adding coverage to product")
     models.product_add_coverage(product, report.coverage)
 
     try:
         add_mask(product)
     except Exception as e:
-        logger.info("Couldn't add mask.")
+        logger.debug("Couldn't add mask.")
         logger.debug(traceback.format_exc())
-        logger.warning("%s: %s\n" % (type(e).__name__, str(e)))
+        logger.debug("%s: %s\n" % (type(e).__name__, str(e)))
 
     if client is not None:
         logger.debug(
@@ -340,8 +344,7 @@ if __name__ == "__main__":
 
     upload_container = os.environ.get('UPLOAD_CONTAINER')
     if upload_container is None:
-        logger.critical("UPLOAD_CONTAINER environment variable not set.")
-        sys.exit(1)
+        logger.warn("UPLOAD_CONTAINER environment variable not set. Assuming part of path bucket/item")
 
     if arg_values.mode == "standard":
         registrar(