diff --git a/tests/system/providers/google/cloud/dataplex/example_dataplex.py b/tests/system/providers/google/cloud/dataplex/example_dataplex.py index bac7e56ed5b1d..a0ac55e07fc95 100644 --- a/tests/system/providers/google/cloud/dataplex/example_dataplex.py +++ b/tests/system/providers/google/cloud/dataplex/example_dataplex.py @@ -53,7 +53,7 @@ RESOURCE_DATA_BUCKET = "airflow-system-tests-resources" LAKE_ID = f"lake-{DAG_ID}-{ENV_ID}".replace("_", "-") -REGION = "us-central1" +REGION = "us-west1" SERVICE_ACC = f"{PROJECT_ID}@appspot.gserviceaccount.com" diff --git a/tests/system/providers/google/cloud/dataplex/example_dataplex_dp.py b/tests/system/providers/google/cloud/dataplex/example_dataplex_dp.py index 168144a855a3c..bfb187371bc18 100644 --- a/tests/system/providers/google/cloud/dataplex/example_dataplex_dp.py +++ b/tests/system/providers/google/cloud/dataplex/example_dataplex_dp.py @@ -50,11 +50,12 @@ ) from airflow.providers.google.cloud.sensors.dataplex import DataplexDataProfileJobStatusSensor from airflow.utils.trigger_rule import TriggerRule +from tests.system.providers.google import DEFAULT_GCP_SYSTEM_TEST_PROJECT_ID ENV_ID = os.environ.get("SYSTEM_TESTS_ENV_ID") -PROJECT_ID = os.environ.get("SYSTEM_TESTS_GCP_PROJECT", "default") +PROJECT_ID = os.environ.get("SYSTEM_TESTS_GCP_PROJECT") or DEFAULT_GCP_SYSTEM_TEST_PROJECT_ID -DAG_ID = "example_dataplex_data_profile" +DAG_ID = "dataplex_data_profile" LAKE_ID = f"lake-{DAG_ID}-{ENV_ID}".replace("_", "-") REGION = "us-central1" diff --git a/tests/system/providers/google/cloud/dataplex/example_dataplex_dq.py b/tests/system/providers/google/cloud/dataplex/example_dataplex_dq.py index c02756efed30e..668647d9acb31 100644 --- a/tests/system/providers/google/cloud/dataplex/example_dataplex_dq.py +++ b/tests/system/providers/google/cloud/dataplex/example_dataplex_dq.py @@ -50,14 +50,15 @@ ) from airflow.providers.google.cloud.sensors.dataplex import DataplexDataQualityJobStatusSensor from airflow.utils.trigger_rule import TriggerRule +from tests.system.providers.google import DEFAULT_GCP_SYSTEM_TEST_PROJECT_ID ENV_ID = os.environ.get("SYSTEM_TESTS_ENV_ID") -PROJECT_ID = os.environ.get("SYSTEM_TESTS_GCP_PROJECT", "default") +PROJECT_ID = os.environ.get("SYSTEM_TESTS_GCP_PROJECT") or DEFAULT_GCP_SYSTEM_TEST_PROJECT_ID -DAG_ID = "example_dataplex_data_quality" +DAG_ID = "dataplex_data_quality" LAKE_ID = f"lake-{DAG_ID}-{ENV_ID}".replace("_", "-") -REGION = "us-central1" +REGION = "us-west1" DATASET = f"dataset_bq_{DAG_ID}_{ENV_ID}"