Remove explicit str concat from Airflow providers package and tests (a…

…pache#33860)
astronomer · Aug 29, 2023 · 3ef770e · 3ef770e
1 parent f9e9222
commit 3ef770e
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/airflow/providers/amazon/aws/sensors/dynamodb.py b/airflow/providers/amazon/aws/sensors/dynamodb.py
@@ -84,7 +84,7 @@ def poke(self, context: Context) -> bool:
         key = {self.partition_key_name: self.partition_key_value}
         msg = (
             f"Checking table {self.table_name} for "
-            + f"item Partition Key: {self.partition_key_name}={self.partition_key_value}"
+            f"item Partition Key: {self.partition_key_name}={self.partition_key_value}"
         )
 
         if self.sort_key_name and self.sort_key_value:

diff --git a/tests/providers/amazon/aws/operators/test_glue.py b/tests/providers/amazon/aws/operators/test_glue.py
@@ -225,7 +225,7 @@ def test_log_correct_url(
         aws_domain = GlueJobRunDetailsLink.get_aws_domain("aws")
         glue_job_run_url = (
             f"https://console.{aws_domain}/gluestudio/home?region="
-            + f"{region}#/job/test_job_name%2Fwith_slash/run/{JOB_RUN_ID}"
+            f"{region}#/job/test_job_name%2Fwith_slash/run/{JOB_RUN_ID}"
         )
 
         with mock.patch.object(glue.log, "info") as mock_log_info:

diff --git a/tests/providers/redis/log/test_redis_task_handler.py b/tests/providers/redis/log/test_redis_task_handler.py
@@ -63,7 +63,7 @@ def test_write(self, ti):
 
         key = (
             "dag_id=dag_for_testing_redis_task_handler/run_id=test"
-            + "/task_id=task_for_testing_redis_log_handler/attempt=1.log"
+            "/task_id=task_for_testing_redis_log_handler/attempt=1.log"
         )
 
         with patch("redis.Redis.pipeline") as pipeline:
@@ -83,7 +83,7 @@ def test_read(self, ti):
 
         key = (
             "dag_id=dag_for_testing_redis_task_handler/run_id=test"
-            + "/task_id=task_for_testing_redis_log_handler/attempt=1.log"
+            "/task_id=task_for_testing_redis_log_handler/attempt=1.log"
         )
 
         with patch("redis.Redis.lrange") as lrange: