using f-string

astronomer · May 16, 2024 · 3e65f75 · 3e65f75
1 parent 0cd28f2
commit 3e65f75
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 6 deletions.
diff --git a/python-sdk/src/astro/databases/base.py b/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

diff --git a/python-sdk/src/astro/databases/duckdb.py b/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,

diff --git a/python-sdk/src/astro/databases/snowflake.py b/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:
         """

diff --git a/python-sdk/src/astro/databases/sqlite.py b/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,