Fix #2901: fixed error message (#2917)

* Fix #2901: fixed error message

* moved error message to helper.py

* replaced error to http

ingestion/src/metadata/ingestion/ometa/ometa_api.py

@@ -415,13 +415,24 @@ class OpenMetadata(
                 )
             return entity(**resp)
         except APIError as err:
-            logger.error(
-                "GET %s for %s." "Error %s - %s",
-                entity.__name__,
-                path,
-                err.status_code,
-                err,
-            )
+            if err.status_code == 404:
+                logger.info(
+                    "GET %s for %s. HTTP %s - %s",
+                    entity.__name__,
+                    path,
+                    err.status_code,
+                    err,
+                )
+
+            else:
+                logger.error(
+                    "GET %s for %s." "Error %s - %s",
+                    entity.__name__,
+                    path,
+                    err.status_code,
+                    err,
+                )
+
             return None
 
     def get_entity_reference(

ingestion/src/metadata/utils/helpers.py

@@ -8,7 +8,7 @@
 #  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 #  See the License for the specific language governing permissions and
 #  limitations under the License.
-
+import logging
 from datetime import datetime, timedelta
 from typing import List
 
@@ -34,6 +34,8 @@ from metadata.generated.schema.entity.services.pipelineService import PipelineSe
 from metadata.generated.schema.entity.services.storageService import StorageService
 from metadata.ingestion.ometa.ometa_api import OpenMetadata
 
+logger = logging.getLogger(__name__)
+
 
 def get_start_and_end(duration):
     today = datetime.utcnow()
@@ -83,6 +85,7 @@ def get_database_service_or_create(
             "description": "",
             "serviceType": config.get_service_type(),
         }
+        logger.info(f"Creating DatabaseService instance for {config.service_name}")
         created_service = metadata.create_or_update(
             CreateDatabaseServiceRequest(**service)
         )