From a01a94147c2db66a14101768b4bcbf3fad2a9cf0 Mon Sep 17 00:00:00 2001 From: Chenglong Yan Date: Tue, 7 Jun 2022 05:06:19 +0800 Subject: [PATCH] Migrate Apache Beam system tests to new design AIP-47 (#24256) closes: #22427 --- .../apache/beam/operators/test_beam_system.py | 53 ------------------- 1 file changed, 53 deletions(-) delete mode 100644 tests/providers/apache/beam/operators/test_beam_system.py diff --git a/tests/providers/apache/beam/operators/test_beam_system.py b/tests/providers/apache/beam/operators/test_beam_system.py deleted file mode 100644 index a589169d5daf8..0000000000000 --- a/tests/providers/apache/beam/operators/test_beam_system.py +++ /dev/null @@ -1,53 +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. -# - -import os - -import pytest - -from tests.test_utils import AIRFLOW_MAIN_FOLDER -from tests.test_utils.system_tests_class import SystemTest - -BEAM_DAG_FOLDER = os.path.join(AIRFLOW_MAIN_FOLDER, "tests", "system", "providers", "apache", "beam") - - -@pytest.mark.system("apache.beam") -class BeamExampleDagsSystemTest(SystemTest): - def test_run_example_dag_beam_python(self): - self.run_dag('example_beam_native_python', BEAM_DAG_FOLDER) - - def test_run_example_dag_beam_python_dataflow_async(self): - self.run_dag('example_beam_native_python_dataflow_async', BEAM_DAG_FOLDER) - - def test_run_example_dag_beam_java_direct_runner(self): - self.run_dag('example_beam_native_java_direct_runner', BEAM_DAG_FOLDER) - - def test_run_example_dag_beam_java_dataflow_runner(self): - self.run_dag('example_beam_native_java_dataflow_runner', BEAM_DAG_FOLDER) - - def test_run_example_dag_beam_java_spark_runner(self): - self.run_dag('example_beam_native_java_spark_runner', BEAM_DAG_FOLDER) - - def test_run_example_dag_beam_java_flink_runner(self): - self.run_dag('example_beam_native_java_flink_runner', BEAM_DAG_FOLDER) - - def test_run_example_dag_beam_go(self): - self.run_dag('example_beam_native_go', BEAM_DAG_FOLDER) - - def test_run_example_dag_beam_go_dataflow_async(self): - self.run_dag('example_beam_native_go_dataflow_async', BEAM_DAG_FOLDER)