This is an automated email from the ASF dual-hosted git repository.
potiuk 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 3ec2faa737 Fix CloudTasksTaskCreateOperator system test (#32643)
3ec2faa737 is described below
commit 3ec2faa737e5e588b6251cf91e1e0185f5b7a356
Author: Beata Kossakowska <[email protected]>
AuthorDate: Thu Aug 3 12:04:10 2023 +0200
Fix CloudTasksTaskCreateOperator system test (#32643)
Co-authored-by: Beata Kossakowska <[email protected]>
---
tests/system/providers/google/cloud/tasks/example_tasks.py | 13 ++++---------
1 file changed, 4 insertions(+), 9 deletions(-)
diff --git a/tests/system/providers/google/cloud/tasks/example_tasks.py
b/tests/system/providers/google/cloud/tasks/example_tasks.py
index 22eb6561a9..1a6acdb250 100644
--- a/tests/system/providers/google/cloud/tasks/example_tasks.py
+++ b/tests/system/providers/google/cloud/tasks/example_tasks.py
@@ -18,9 +18,6 @@
"""
Example Airflow DAG that creates and deletes Queues and creates, gets, lists,
runs and deletes Tasks in the Google Cloud Tasks service in the Google Cloud.
-
-Required setup:
-- GCP_APP_ENGINE_LOCATION: GCP Project's App Engine location `gcloud app
describe | grep locationId`.
"""
from __future__ import annotations
@@ -51,17 +48,15 @@ DAG_ID = "cloud_tasks_tasks"
timestamp = timestamp_pb2.Timestamp()
timestamp.FromDatetime(datetime.now() + timedelta(hours=12))
-LOCATION = os.environ.get("GCP_APP_ENGINE_LOCATION", "europe-west2")
+LOCATION = "us-central1"
# queue cannot use recent names even if queue was removed
QUEUE_ID = f"queue-{ENV_ID}-{DAG_ID.replace('_', '-')}"
TASK_NAME = "task-to-run"
-
-
TASK = {
- "app_engine_http_request": { # Specify the type of request.
+ "http_request": {
"http_method": "POST",
- "relative_uri": "/example_task_handler",
- "body": b"Hello",
+ "url": "http://www.example.com/example";,
+ "body": b"",
},
"schedule_time": timestamp,
}
