diff --git a/airflow/example_dags/example_latest_only.py b/airflow/example_dags/example_latest_only.py index 3dc4e9137e350..52555660be27d 100644 --- a/airflow/example_dags/example_latest_only.py +++ b/airflow/example_dags/example_latest_only.py @@ -18,7 +18,7 @@ """Example of the LatestOnlyOperator""" from __future__ import annotations -import datetime as dt +import datetime from airflow import DAG from airflow.operators.empty import EmptyOperator @@ -26,8 +26,8 @@ with DAG( dag_id="latest_only", - schedule=dt.timedelta(hours=4), - start_date=dt.datetime(2021, 1, 1), + schedule=datetime.timedelta(hours=4), + start_date=datetime.datetime(2021, 1, 1), catchup=False, tags=["example2", "example3"], ) as dag: diff --git a/airflow/providers/cncf/kubernetes/pod_launcher_deprecated.py b/airflow/providers/cncf/kubernetes/pod_launcher_deprecated.py index 95a629af52169..4ddd523e3474d 100644 --- a/airflow/providers/cncf/kubernetes/pod_launcher_deprecated.py +++ b/airflow/providers/cncf/kubernetes/pod_launcher_deprecated.py @@ -21,7 +21,6 @@ import math import time import warnings -from datetime import datetime as dt from typing import TYPE_CHECKING import pendulum @@ -132,12 +131,11 @@ def start_pod(self, pod: V1Pod, startup_timeout: int = 120): :return: """ resp = self.run_pod_async(pod) - curr_time = dt.now() + start_time = time.monotonic() if resp.status.start_time is None: while self.pod_not_started(pod): self.log.warning("Pod not yet started: %s", pod.metadata.name) - delta = dt.now() - curr_time - if delta.total_seconds() >= startup_timeout: + if time.monotonic() >= start_time + startup_timeout: raise AirflowException("Pod took too long to start") time.sleep(1) diff --git a/airflow/www/forms.py b/airflow/www/forms.py index 69559394733f0..9b31290451ac9 100644 --- a/airflow/www/forms.py +++ b/airflow/www/forms.py @@ -17,9 +17,9 @@ # under the License. from __future__ import annotations +import datetime import json import operator -from datetime import datetime as dt from typing import Iterator import pendulum @@ -75,7 +75,7 @@ def process_formdata(self, valuelist): # Check if the datetime string is in the format without timezone, if so convert it to the # default timezone if len(date_str) == 19: - parsed_datetime = dt.strptime(date_str, "%Y-%m-%d %H:%M:%S") + parsed_datetime = datetime.datetime.strptime(date_str, "%Y-%m-%d %H:%M:%S") default_timezone = self._get_default_timezone() self.data = default_timezone.convert(parsed_datetime) else: