using f-string

Author: pankajastro

python-sdk/src/astro/databases/base.py

@@ -205,8 +205,7 @@ def get_merge_initialization_query(parameters: tuple) -> str:
         it agnostic to database.
         """
         constraints = ",".join(parameters)
-        sql = "ALTER TABLE {{table}} ADD CONSTRAINT airflow UNIQUE ({})".format(constraints)
-        return sql
+        return f"ALTER TABLE {{table}} ADD CONSTRAINT airflow UNIQUE ({constraints})"
 
     @staticmethod
     def get_table_qualified_name(table: BaseTable) -> str:  # skipcq: PYL-R0201

python-sdk/src/astro/databases/duckdb.py

@@ -81,7 +81,7 @@ def get_merge_initialization_query(parameters: tuple) -> str:
         """
         Handles database-specific logic to handle index for DuckDB.
         """
-        return "CREATE UNIQUE INDEX merge_index ON {{table}}({})".format(",".join(parameters))
+        return f"CREATE UNIQUE INDEX merge_index ON {{table}}({','.join(parameters)})"
 
     def merge_table(
         self,

python-sdk/src/astro/databases/snowflake.py

@@ -1059,8 +1059,7 @@ def get_merge_initialization_query(cls, parameters: tuple) -> str:
             identifier_enclosure = '"'
 
         constraints = ",".join([f"{identifier_enclosure}{p}{identifier_enclosure}" for p in parameters])
-        sql = "ALTER TABLE {{table}} ADD CONSTRAINT airflow UNIQUE ({})".format(constraints)
-        return sql
+        return f"ALTER TABLE {{table}} ADD CONSTRAINT airflow UNIQUE ({constraints})"
 
     def openlineage_dataset_name(self, table: BaseTable) -> str:
         """

python-sdk/src/astro/databases/sqlite.py

@@ -90,7 +90,7 @@ def get_merge_initialization_query(parameters: tuple) -> str:
         """
         Handles database-specific logic to handle index for Sqlite.
         """
-        return "CREATE UNIQUE INDEX merge_index ON {{table}}({})".format(",".join(parameters))
+        return f"CREATE UNIQUE INDEX merge_index ON {{table}}({','.join(parameters)})"
 
     def merge_table(
         self,