Clean up in-line f-string concatenation (#23591)

Author: josh-fell

airflow/providers/amazon/aws/utils/redshift.py

@@ -43,7 +43,7 @@ def build_credentials_block(credentials: ReadOnlyCredentials) -> str:
 
     else:
         credentials_line = (
-            f"aws_access_key_id={credentials.access_key};" f"aws_secret_access_key={credentials.secret_key}"
+            f"aws_access_key_id={credentials.access_key};aws_secret_access_key={credentials.secret_key}"
         )
 
     return credentials_line

airflow/providers/apache/drill/hooks/drill.py

@@ -72,7 +72,7 @@ def get_uri(self) -> str:
         conn_type = 'drill' if not conn_md.conn_type else conn_md.conn_type
         dialect_driver = conn_md.extra_dejson.get('dialect_driver', 'drill+sadrill')
         storage_plugin = conn_md.extra_dejson.get('storage_plugin', 'dfs')
-        return f'{conn_type}://{host}/{storage_plugin}' f'?dialect_driver={dialect_driver}'
+        return f'{conn_type}://{host}/{storage_plugin}?dialect_driver={dialect_driver}'
 
     def set_autocommit(self, conn: Connection, autocommit: bool) -> NotImplementedError:
         raise NotImplementedError("There are no transactions in Drill.")

airflow/providers/databricks/operators/databricks_repos.py

@@ -90,7 +90,7 @@ def __init__(
             self.git_provider = self.__detect_repo_provider__(git_url)
             if self.git_provider is None:
                 raise AirflowException(
-                    "git_provider isn't specified and couldn't be guessed" f" for URL {git_url}"
+                    "git_provider isn't specified and couldn't be guessed for URL {git_url}"
                 )
         else:
             self.git_provider = git_provider

airflow/providers/google/cloud/hooks/datafusion.py

@@ -115,7 +115,7 @@ def wait_for_pipeline_state(
                 return
             if current_state in failure_states:
                 raise AirflowException(
-                    f"Pipeline {pipeline_name} state {current_state} is not " f"one of {success_states}"
+                    f"Pipeline {pipeline_name} state {current_state} is not one of {success_states}"
                 )
             sleep(30)
 

airflow/providers/google/cloud/utils/credentials_provider.py

@@ -369,5 +369,5 @@ def _get_project_id_from_service_account_email(service_account_email: str) -> st
         return service_account_email.split('@')[1].split('.')[0]
     except IndexError:
         raise AirflowException(
-            f"Could not extract project_id from service account's email: " f"{service_account_email}."
+            f"Could not extract project_id from service account's email: {service_account_email}."
         )

airflow/providers/hashicorp/_internal_client/vault_client.py

@@ -123,7 +123,7 @@ def __init__(
             )
         if auth_type not in VALID_AUTH_TYPES:
             raise VaultError(
-                f"The auth_type is not supported: {auth_type}. " f"It should be one of {VALID_AUTH_TYPES}"
+                f"The auth_type is not supported: {auth_type}. It should be one of {VALID_AUTH_TYPES}"
             )
         if auth_type == "token" and not token and not token_path:
             raise VaultError("The 'token' authentication type requires 'token' or 'token_path'")

airflow/utils/cli.py

@@ -49,7 +49,7 @@ def _check_cli_args(args):
         raise ValueError("Args should be set")
     if not isinstance(args[0], Namespace):
         raise ValueError(
-            "1st positional argument should be argparse.Namespace instance," f"but is {type(args[0])}"
+            f"1st positional argument should be argparse.Namespace instance, but is {type(args[0])}"
         )
 
 
@@ -148,7 +148,7 @@ def _build_metrics(func_name, namespace):
 
     if not isinstance(namespace, Namespace):
         raise ValueError(
-            "namespace argument should be argparse.Namespace instance," f"but is {type(namespace)}"
+            f"namespace argument should be argparse.Namespace instance, but is {type(namespace)}"
         )
     tmp_dic = vars(namespace)
     metrics['dag_id'] = tmp_dic.get('dag_id')

dev/assign_cherry_picked_prs_with_milestone.py

@@ -294,7 +294,7 @@ def assign_prs(
             continue
         console.print('-' * 80)
         console.print(
-            f"\n >>>> Retrieving PR#{pr_number}: " f"https://github.com/apache/airflow/pull/{pr_number}"
+            f"\n >>>> Retrieving PR#{pr_number}: https://github.com/apache/airflow/pull/{pr_number}"
         )
         pr: PullRequest
         try:

dev/breeze/src/airflow_breeze/commands/configuration_and_maintenance_commands.py

@@ -305,10 +305,10 @@ def version(verbose: bool, python: str):
             f"{get_installation_sources_config_metadata_hash()}[/]"
         )
         get_console().print(
-            f"[info]Used sources config hash         : " f"{get_used_sources_setup_metadata_hash()}[/]"
+            f"[info]Used sources config hash         : {get_used_sources_setup_metadata_hash()}[/]"
         )
         get_console().print(
-            f"[info]Package config hash              : " f"{(get_package_setup_metadata_hash())}[/]\n"
+            f"[info]Package config hash              : {(get_package_setup_metadata_hash())}[/]\n"
         )
 
 
@@ -497,7 +497,7 @@ def write_to_shell(command_to_execute: str, dry_run: bool, script_path: str, for
     else:
         get_console().print(f"[info]The autocomplete script would be added to {script_path}[/]")
     get_console().print(
-        f"\n[warning]Please exit and re-enter your shell or run:[/]" f"\n\n   source {script_path}\n"
+        f"\n[warning]Please exit and re-enter your shell or run:[/]\n\n   source {script_path}\n"
     )
     return True
 

dev/breeze/src/airflow_breeze/utils/custom_param_types.py

@@ -89,9 +89,7 @@ def convert(self, value, param, ctx):
         if isinstance(value, CacheableDefault):
             is_cached, new_value = read_and_validate_value_from_cache(param_name, value.value)
             if not is_cached:
-                get_console().print(
-                    f"\n[info]Default value of {param.name} " f"parameter {new_value} used.[/]\n"
-                )
+                get_console().print(f"\n[info]Default value of {param.name} parameter {new_value} used.[/]\n")
         else:
             allowed, allowed_values = check_if_values_allowed(param_name, value)
             if allowed: