feat(dswx-s1): logging

Refs #787

commons/logger.py

@@ -49,6 +49,17 @@ def filter(self, record):
 logger.addFilter(LogFilter())
 
 
+class NoLogUtilsFilter(logging.Filter):
+
+    """Filters out large JSON output of HySDS internals. Apply to any logger (typically __main__) or its
+    handlers."""
+    def filter(self, record):
+        if not record.filename == "elasticsearch_utils.py":
+            return True
+
+        return record.funcName != "update_document"
+
+
 class NoJobUtilsFilter(logging.Filter):
 
     """Filters out large JSON output of HySDS internals. Apply to the logger named "hysds_commons" or one of its

data_subscriber/daac_data_subscriber.py

@@ -15,7 +15,7 @@
 from more_itertools import first
 from smart_open import open
 
-from commons.logger import NoJobUtilsFilter, NoBaseFilter
+from commons.logger import NoJobUtilsFilter, NoBaseFilter, NoLogUtilsFilter
 from data_subscriber.asf_cslc_download import AsfDaacCslcDownload
 from data_subscriber.asf_rtc_download import AsfDaacRtcDownload
 from data_subscriber.asf_slc_download import AsfDaacSlcDownload
@@ -66,6 +66,8 @@ def configure_logger():
 
     boto3.set_stream_logger(name='botocore.credentials', level=logging.ERROR)
 
+    logger.addFilter(NoLogUtilsFilter())
+
 
 async def run(argv: list[str]):
     logger.info(f"{argv=}")