From 0e9a36ea4e275ab93841d6a2b9d609645aa0d32b Mon Sep 17 00:00:00 2001
From: Hussein Awala <hussein@awala.fr>
Date: Sat, 26 Aug 2023 02:21:33 +0200
Subject: [PATCH] Use f-string instead of  in Airflow core

---
 airflow/models/baseoperator.py |  2 +-
 airflow/models/dagrun.py       | 11 ++---------
 airflow/www/utils.py           |  2 +-
 3 files changed, 4 insertions(+), 11 deletions(-)

diff --git a/airflow/models/baseoperator.py b/airflow/models/baseoperator.py
index 0c8c3d3149672..7b4979f9f19b2 100644
--- a/airflow/models/baseoperator.py
+++ b/airflow/models/baseoperator.py
@@ -1379,7 +1379,7 @@ def get_direct_relatives(self, upstream: bool = False) -> Iterable[Operator]:
             return self.downstream_list
 
     def __repr__(self):
-        return "<Task({self.task_type}): {self.task_id}>".format(self=self)
+        return f"<Task({self.task_type}): {self.task_id}>"
 
     @property
     def operator_class(self) -> type[BaseOperator]:  # type: ignore[override]
diff --git a/airflow/models/dagrun.py b/airflow/models/dagrun.py
index 113737ffecbc8..98d9b8e781474 100644
--- a/airflow/models/dagrun.py
+++ b/airflow/models/dagrun.py
@@ -232,15 +232,8 @@ def __init__(
 
     def __repr__(self):
         return (
-            "<DagRun {dag_id} @ {execution_date}: {run_id}, state:{state}, "
-            "queued_at: {queued_at}. externally triggered: {external_trigger}>"
-        ).format(
-            dag_id=self.dag_id,
-            execution_date=self.execution_date,
-            run_id=self.run_id,
-            state=self.state,
-            queued_at=self.queued_at,
-            external_trigger=self.external_trigger,
+            f"<DagRun {self.dag_id} @ {self.execution_date}: {self.run_id}, state:{self.state}, "
+            f"queued_at: {self.queued_at}. externally triggered: {self.external_trigger}>"
         )
 
     @validates("run_id")
diff --git a/airflow/www/utils.py b/airflow/www/utils.py
index 7541f6445e580..a8638d328c26f 100644
--- a/airflow/www/utils.py
+++ b/airflow/www/utils.py
@@ -197,7 +197,7 @@ def check_import_errors(fileloc, session):
     ).all()
     if import_errors:
         for import_error in import_errors:
-            flash("Broken DAG: [{ie.filename}] {ie.stacktrace}".format(ie=import_error), "dag_import_error")
+            flash(f"Broken DAG: [{import_error.filename}] {import_error.stacktrace}", "dag_import_error")
 
 
 def check_dag_warnings(dag_id, session):