From b175e40e992469455232fdde7e44b522dcc44a99 Mon Sep 17 00:00:00 2001 From: Pere Miquel Brull Date: Mon, 19 Aug 2024 12:20:29 +0200 Subject: [PATCH] MINOR - Clean DEBUG logs (#17464) Co-authored-by: Suman Maharana --- ingestion/src/metadata/cli/app.py | 1 - ingestion/src/metadata/cli/dataquality.py | 1 - ingestion/src/metadata/cli/ingest.py | 1 - ingestion/src/metadata/cli/profile.py | 1 - ingestion/src/metadata/cli/usage.py | 1 - .../metadata/ingestion/ometa/mixins/ingestion_pipeline_mixin.py | 2 +- 6 files changed, 1 insertion(+), 6 deletions(-) diff --git a/ingestion/src/metadata/cli/app.py b/ingestion/src/metadata/cli/app.py index 4d3ed02d1cd7..7bd888401944 100644 --- a/ingestion/src/metadata/cli/app.py +++ b/ingestion/src/metadata/cli/app.py @@ -33,7 +33,6 @@ def run_app(config_path: Path) -> None: try: config_dict = load_config_file(config_path) workflow = ApplicationWorkflow.create(config_dict) - logger.debug(f"Using config: {workflow.config}") except Exception as exc: logger.error(f"Error running the application {exc}") logger.debug(traceback.format_exc()) diff --git a/ingestion/src/metadata/cli/dataquality.py b/ingestion/src/metadata/cli/dataquality.py index b4b53799008b..4433b274d94b 100644 --- a/ingestion/src/metadata/cli/dataquality.py +++ b/ingestion/src/metadata/cli/dataquality.py @@ -37,7 +37,6 @@ def run_test(config_path: Path) -> None: workflow_config_dict = None try: workflow_config_dict = load_config_file(config_path) - logger.debug(f"Using config: {workflow_config_dict}") workflow = TestSuiteWorkflow.create(workflow_config_dict) except Exception as exc: logger.debug(traceback.format_exc()) diff --git a/ingestion/src/metadata/cli/ingest.py b/ingestion/src/metadata/cli/ingest.py index e9ee62c00af6..e52b7354076b 100644 --- a/ingestion/src/metadata/cli/ingest.py +++ b/ingestion/src/metadata/cli/ingest.py @@ -38,7 +38,6 @@ def run_ingest(config_path: Path) -> None: try: config_dict = load_config_file(config_path) workflow = MetadataWorkflow.create(config_dict) - logger.debug(f"Using config: {workflow.config}") except Exception as exc: logger.debug(traceback.format_exc()) WorkflowInitErrorHandler.print_init_error( diff --git a/ingestion/src/metadata/cli/profile.py b/ingestion/src/metadata/cli/profile.py index 473f35ef983f..51053f8f6311 100644 --- a/ingestion/src/metadata/cli/profile.py +++ b/ingestion/src/metadata/cli/profile.py @@ -37,7 +37,6 @@ def run_profiler(config_path: Path) -> None: workflow_config_dict = None try: workflow_config_dict = load_config_file(config_path) - logger.debug(f"Using config: {workflow_config_dict}") workflow = ProfilerWorkflow.create(workflow_config_dict) except Exception as exc: logger.debug(traceback.format_exc()) diff --git a/ingestion/src/metadata/cli/usage.py b/ingestion/src/metadata/cli/usage.py index 251b67b367c0..b4a969939f2c 100644 --- a/ingestion/src/metadata/cli/usage.py +++ b/ingestion/src/metadata/cli/usage.py @@ -38,7 +38,6 @@ def run_usage(config_path: Path) -> None: try: config_dict = load_config_file(config_path) workflow = UsageWorkflow.create(config_dict) - logger.debug(f"Using config: {workflow.config}") except Exception as exc: logger.debug(traceback.format_exc()) WorkflowInitErrorHandler.print_init_error(exc, config_dict, PipelineType.usage) diff --git a/ingestion/src/metadata/ingestion/ometa/mixins/ingestion_pipeline_mixin.py b/ingestion/src/metadata/ingestion/ometa/mixins/ingestion_pipeline_mixin.py index 970ee1ec16b2..8dda0757a792 100644 --- a/ingestion/src/metadata/ingestion/ometa/mixins/ingestion_pipeline_mixin.py +++ b/ingestion/src/metadata/ingestion/ometa/mixins/ingestion_pipeline_mixin.py @@ -50,7 +50,7 @@ def create_or_update_pipeline_status( data=pipeline_status.model_dump_json(), ) logger.debug( - f"Created Pipeline Status for pipeline {ingestion_pipeline_fqn}: {resp}" + f"Created Pipeline Status for pipeline {ingestion_pipeline_fqn}: {pipeline_status}" ) return resp