This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 272b40aaad Use f-string instead of in Airflow core (#33753)
272b40aaad is described below
commit 272b40aaad33116bd0b0fdcad15187493d9a44e7
Author: Hussein Awala <[email protected]>
AuthorDate: Sat Aug 26 09:16:24 2023 +0200
Use f-string instead of in Airflow core (#33753)
---
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 0c8c3d3149..7b4979f9f1 100644
--- a/airflow/models/baseoperator.py
+++ b/airflow/models/baseoperator.py
@@ -1379,7 +1379,7 @@ class BaseOperator(AbstractOperator,
metaclass=BaseOperatorMeta):
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 113737ffec..98d9b8e781 100644
--- a/airflow/models/dagrun.py
+++ b/airflow/models/dagrun.py
@@ -232,15 +232,8 @@ class DagRun(Base, LoggingMixin):
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 7541f6445e..a8638d328c 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):
