This is an automated email from the ASF dual-hosted git repository.
kaxilnaik 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 7ff86fe9591 Remove unused test file (#54408)
7ff86fe9591 is described below
commit 7ff86fe9591a89af26e499c9a699c633561ee9eb
Author: Kaxil Naik <[email protected]>
AuthorDate: Tue Aug 12 14:09:19 2025 +0100
Remove unused test file (#54408)
This file has no usage and caused mypy failure in
https://github.com/apache/airflow/pull/53223!
---
.../tests/unit/google/cloud/utils/airflow_util.py | 81 ----------------------
1 file changed, 81 deletions(-)
diff --git a/providers/google/tests/unit/google/cloud/utils/airflow_util.py
b/providers/google/tests/unit/google/cloud/utils/airflow_util.py
deleted file mode 100644
index 15a19171507..00000000000
--- a/providers/google/tests/unit/google/cloud/utils/airflow_util.py
+++ /dev/null
@@ -1,81 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing,
-# software distributed under the License is distributed on an
-# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-# KIND, either express or implied. See the License for the
-# specific language governing permissions and limitations
-# under the License.
-from __future__ import annotations
-
-from typing import TYPE_CHECKING
-from unittest import mock
-
-import pendulum
-from uuid6 import uuid7
-
-from airflow.models import DAG, Connection
-from airflow.models.dagrun import DagRun
-from airflow.models.taskinstance import TaskInstance
-from airflow.utils import timezone
-from airflow.utils.types import DagRunType
-
-from tests_common.test_utils.version_compat import AIRFLOW_V_3_0_PLUS
-
-if TYPE_CHECKING:
- from airflow.providers.google.version_compat import BaseOperator
-
-
-def get_dag_run(dag_id: str = "test_dag_id", run_id: str = "test_dag_id") ->
DagRun:
- dag_run = DagRun(
- dag_id=dag_id, run_type="manual", logical_date=timezone.datetime(2022,
1, 1), run_id=run_id
- )
- return dag_run
-
-
-def get_task_instance(task: BaseOperator) -> TaskInstance:
- if AIRFLOW_V_3_0_PLUS:
- return TaskInstance(task=task, run_id=None, dag_version_id=uuid7())
- return TaskInstance(task=task, run_id=None) # type: ignore
-
-
-def get_conn() -> Connection:
- return Connection(
- conn_id="test_conn",
- extra={},
- )
-
-
-def create_context(task, dag=None):
- if dag is None:
- dag = DAG(dag_id="dag")
- tzinfo = pendulum.timezone("UTC")
- logical_date = timezone.datetime(2022, 1, 1, 1, 0, 0, tzinfo=tzinfo)
- dag_run = DagRun(
- dag_id=dag.dag_id,
- logical_date=logical_date,
- run_id=DagRun.generate_run_id(DagRunType.MANUAL, logical_date),
- )
-
- task_instance = TaskInstance(task=task)
- task_instance.dag_run = dag_run
- task_instance.xcom_push = mock.Mock()
- return {
- "dag": dag,
- "ts": logical_date.isoformat(),
- "task": task,
- "ti": task_instance,
- "task_instance": task_instance,
- "run_id": dag_run.run_id,
- "dag_run": dag_run,
- "logical_date": logical_date,
- "data_interval_end": logical_date,
- }
