style: rename timing function to something meaningful

fix: `setLevel` for root logger rather than unassigned/unused `__name__` logger

ingestion/create_cadet_databases_source/source.py

@@ -19,18 +19,18 @@
     get_cadet_manifest,
     validate_fqn,
 )
-from ingestion.utils import st_time
+from ingestion.utils import report_time
 
 logging.basicConfig()
-logging.getLogger(__name__).setLevel(logging.DEBUG)
+logging.getLogger().setLevel(logging.DEBUG)
 
 
 @config_class(CreateCadetDatabasesConfig)
 class CreateCadetDatabases(Source):
     source_config: CreateCadetDatabasesConfig
     report: SourceReport = SourceReport()
 
-    @st_time
+    @report_time
     def __init__(self, config: CreateCadetDatabasesConfig, ctx: PipelineContext):
         super().__init__(ctx)
         self.source_config = config
@@ -94,7 +94,7 @@ def _get_domains(self, manifest) -> set[str]:
             if manifest["nodes"][node]["resource_type"] == "model"
         )
 
-    @st_time
+    @report_time
     def _get_databases_with_domains_and_display_tags(
         self, manifest
     ) -> tuple[set[tuple[str, str]], dict]:

ingestion/ingestion_utils.py

@@ -12,7 +12,7 @@
 from ingestion.config import ENV, INSTANCE, PLATFORM
 
 logging.basicConfig()
-logging.getLogger(__name__).setLevel(logging.DEBUG)
+logging.getLogger().setLevel(logging.DEBUG)
 
 
 def get_cadet_manifest(manifest_s3_uri: str) -> Dict:

ingestion/justice_data_source/source.py

@@ -38,7 +38,7 @@
 )
 
 from ingestion.ingestion_utils import list_datahub_domains
-from ingestion.utils import st_time
+from ingestion.utils import report_time
 
 from .api_client import JusticeDataAPIClient
 from .config import JusticeDataAPIConfig
@@ -73,7 +73,7 @@ def create(cls, config_dict, ctx):
         config = JusticeDataAPIConfig.parse_obj(config_dict)
         return cls(ctx, config)
 
-    @st_time
+    @report_time
     def get_workunits_internal(self) -> Iterable[MetadataWorkUnit]:
         all_chart_data = self.client.list_all(self.config.exclude_id_list)
 
@@ -137,7 +137,7 @@ def _make_dashboard(self, chart_urns):
         dashboard_mce = MetadataChangeEvent(proposedSnapshot=dashboard_snapshot)
         return dashboard_mce
 
-    @st_time
+    @report_time
     def _make_chart(self, chart_data) -> MetadataChangeEvent:
         chart_urn = builder.make_chart_urn(self.platform_name, chart_data["id"])
         chart_snapshot = ChartSnapshot(

ingestion/taggers/display_in_catalogue_tagger.py

@@ -5,7 +5,7 @@
 from datahub.metadata.schema_classes import TagAssociationClass
 
 logging.basicConfig()
-logging.getLogger(__name__).setLevel(logging.DEBUG)
+logging.getLogger().setLevel(logging.DEBUG)
 
 
 def add_display_in_catalogue_tag(entity_urn: str) -> List[TagAssociationClass]:

ingestion/transformers/assign_cadet_databases.py

@@ -17,10 +17,10 @@
     parse_database_and_table_names,
     validate_fqn,
 )
-from ingestion.utils import st_time
+from ingestion.utils import report_time
 
 logging.basicConfig()
-logging.getLogger(__name__).setLevel(logging.DEBUG)
+logging.getLogger().setLevel(logging.DEBUG)
 
 
 class AssignCadetDatabasesConfig(ConfigModel):
@@ -53,7 +53,7 @@ def transform_aspect(
     ) -> Optional[Aspect]:
         return None
 
-    @st_time
+    @report_time
     def handle_end_of_stream(
         self,
     ) -> List[Union[MetadataChangeProposalWrapper, MetadataChangeProposalClass]]:

ingestion/transformers/assign_cadet_domains.py

@@ -14,7 +14,7 @@
     get_cadet_manifest,
     validate_fqn,
 )
-from ingestion.utils import st_time
+from ingestion.utils import report_time
 
 
 class PatternDatasetDomainSemanticsConfig(TransformerSemanticsConfigModel):
@@ -63,7 +63,7 @@ def create(cls, config_dict, ctx: PipelineContext) -> "AssignCadetDomains":
         )
         return cls(config_dict, ctx)
 
-    @st_time
+    @report_time
     def _get_domain_mapping(self, manifest) -> PatternDatasetDomainSemanticsConfig:
         """Map regex patterns for tables to domains"""
         nodes = manifest.get("nodes")

ingestion/utils.py

@@ -3,10 +3,10 @@
 from datetime import timedelta
 
 logging.basicConfig()
-logging.getLogger(__name__).setLevel(logging.DEBUG)
+logging.getLogger().setLevel(logging.DEBUG)
 
 
-def st_time(func):
+def report_time(func):
     """
     st decorator to calculate the total time of a func
     """