Merge pull request #14 from decodingml/feat/webinar

fix: Replace logs
decodingml · May 3, 2024 · d3d2c71 · d3d2c71
2 parents 77a8273 + bc24c28
commit d3d2c71
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/course/module-3/data_flow/stream_output.py b/course/module-3/data_flow/stream_output.py
@@ -21,7 +21,7 @@ def __init__(self, connection: QdrantDatabaseConnector, sink_type: str):
         try:
             self._connection.get_collection(collection_name="cleaned_posts")
         except UnexpectedResponse:
-            logger.exception(
+            logger.info(
                 "Couldn't access the collection. Creating a new one...",
                 collection_name="cleaned_posts",
             )
@@ -33,7 +33,7 @@ def __init__(self, connection: QdrantDatabaseConnector, sink_type: str):
         try:
             self._connection.get_collection(collection_name="cleaned_articles")
         except UnexpectedResponse:
-            logger.exception(
+            logger.info(
                 "Couldn't access the collection. Creating a new one...",
                 collection_name="cleaned_articles",
             )
@@ -45,7 +45,7 @@ def __init__(self, connection: QdrantDatabaseConnector, sink_type: str):
         try:
             self._connection.get_collection(collection_name="cleaned_repositories")
         except UnexpectedResponse:
-            logger.exception(
+            logger.info(
                 "Couldn't access the collection. Creating a new one...",
                 collection_name="cleaned_repositories",
             )
@@ -57,7 +57,7 @@ def __init__(self, connection: QdrantDatabaseConnector, sink_type: str):
         try:
             self._connection.get_collection(collection_name="vector_posts")
         except UnexpectedResponse:
-            logger.exception(
+            logger.info(
                 "Couldn't access the collection. Creating a new one...",
                 collection_name="vector_posts",
             )
@@ -67,7 +67,7 @@ def __init__(self, connection: QdrantDatabaseConnector, sink_type: str):
         try:
             self._connection.get_collection(collection_name="vector_articles")
         except UnexpectedResponse:
-            logger.exception(
+            logger.info(
                 "Couldn't access the collection. Creating a new one...",
                 collection_name="vector_articles",
             )
@@ -77,7 +77,7 @@ def __init__(self, connection: QdrantDatabaseConnector, sink_type: str):
         try:
             self._connection.get_collection(collection_name="vector_repositories")
         except UnexpectedResponse:
-            logger.exception(
+            logger.info(
                 "Couldn't access the collection. Creating a new one...",
                 collection_name="vector_repositories",
             )