Remove unneeded variable annotation

apache · Jun 23, 2022 · 6eb5286 · 6eb5286
1 parent 8d68822
commit 6eb5286
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/airflow/providers/elasticsearch/log/es_task_handler.py b/airflow/providers/elasticsearch/log/es_task_handler.py
@@ -131,7 +131,7 @@ def _render_log_id(self, ti: TaskInstance, try_number: int) -> str:
             data_interval = (dag_run.data_interval_start, dag_run.data_interval_end)
         else:
             assert dag is not None  # For Mypy.
-            data_interval: Tuple[datetime, datetime] = dag.get_run_data_interval(dag_run)
+            data_interval = dag.get_run_data_interval(dag_run)
 
         if self.json_format:
             data_interval_start = self._clean_date(data_interval[0])

diff --git a/airflow/utils/log/file_task_handler.py b/airflow/utils/log/file_task_handler.py
@@ -19,9 +19,8 @@
 import logging
 import os
 import warnings
-from datetime import datetime
 from pathlib import Path
-from typing import TYPE_CHECKING, Optional, Tuple
+from typing import TYPE_CHECKING, Optional
 
 from airflow.configuration import AirflowConfigException, conf
 from airflow.utils.context import Context
@@ -99,7 +98,7 @@ def _render_filename(self, ti: "TaskInstance", try_number: int) -> str:
                 data_interval = (dag_run.data_interval_start, dag_run.data_interval_end)
             else:
                 assert dag is not None  # For Mypy.
-                data_interval: Tuple[datetime, datetime] = dag.get_run_data_interval(dag_run)
+                data_interval = dag.get_run_data_interval(dag_run)
             if data_interval[0]:
                 data_interval_start = data_interval[0].isoformat()
             else: