diff --git a/ingestion/src/metadata/cli/app.py b/ingestion/src/metadata/cli/app.py index 4d3ed02d1cd..7bd88840194 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 b4b53799008..4433b274d94 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 e9ee62c00af..e52b7354076 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 473f35ef983..51053f8f631 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 251b67b367c..b4a969939f2 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 970ee1ec16b..8dda0757a79 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 @@ class OMetaIngestionPipelineMixin: 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