add condition based on create_if_not_exists flag to set log level and…

… run black

src/koheesio/integrations/spark/tableau/hyper.py

@@ -301,6 +301,7 @@ class HyperFileDataFrameWriter(HyperFileWriter):
     hw.hyper_path
     ```
     """
+
     df: DataFrame = Field(default=..., description="Spark DataFrame to write to the Hyper file")
     table_definition: Optional[TableDefinition] = None  # table_definition is not required for this class
 

src/koheesio/integrations/spark/tableau/server.py

@@ -23,6 +23,7 @@ class TableauServer(Step):
     """
     Base class for Tableau server interactions. Class provides authentication and project identification functionality.
     """
+
     url: str = Field(
         default=...,
         alias="url",
@@ -190,6 +191,7 @@ class TableauHyperPublisher(TableauServer):
     """
     Publish the given Hyper file to the Tableau server. Hyper file will be treated by Tableau server as a datasource.
     """
+
     datasource_name: str = Field(default=..., description="Name of the datasource to publish")
     hyper_path: PurePath = Field(default=..., description="Path to Hyper file")
     publish_mode: TableauHyperPublishMode = Field(

src/koheesio/spark/delta.py

@@ -295,7 +295,8 @@ def has_change_type(self) -> bool:
 
     @property
     def exists(self) -> bool:
-        """Check if table exists"""
+        """Check if table exists.
+        Depending on the value of the boolean flag `create_if_not_exists` a different logging level is provided."""
         result = False
 
         try:
@@ -304,7 +305,16 @@ def exists(self) -> bool:
         except AnalysisException as e:
             err_msg = str(e).lower()
             if err_msg.startswith("[table_or_view_not_found]") or err_msg.startswith("table or view not found"):
-                self.log.error(f"Table `{self.table}` doesn't exist.")
+                if self.create_if_not_exists:
+                    self.log.info(
+                        f"Table `{self.table}` doesn't exist. "
+                        f"The `create_if_not_exists` flag is set to True, therefore the table will be created."
+                    )
+                else:
+                    self.log.error(
+                        f"Table `{self.table}` doesn't exist. "
+                        f"The `create_if_not_exists` flag is set to False, therefore the table will not be created."
+                    )
             else:
                 raise e
 

tests/spark/integrations/snowflake/test_snowflake.py

@@ -39,6 +39,7 @@
     "warehouse": "warehouse",
 }
 
+
 def test_snowflake_module_import():
     # test that the pass-through imports in the koheesio.spark snowflake modules are working
     from koheesio.spark.writers import snowflake as snowflake_readers