ryanyuan commented on pull request #8575: URL: https://github.com/apache/airflow/pull/8575#issuecomment-646460871
> I saw that a new DAG was not added to the system tests. I prepared change - https://termbin.com/7ezm > To add to your branch, run the following command: > > ```shell > curl https://termbin.com/7ezm | git am > ``` > > When I did bug, I saw that there was a bug. One of the tasks ends with the following error. > > ``` > logs/previous_runs/2020-06-09_19_00_50/example_gcp_cloud_build_trigger/create_build_trigger/2020-06-08T00:00:00+00:00/1.log > ``` > > ``` > [2020-06-09 19:00:33,927] {taskinstance.py:719} INFO - Dependencies all met for <TaskInstance: example_gcp_cloud_build_trigger.create_build_trigger 2020-06-08T00:00:00+00:00 [queued]> > [2020-06-09 19:00:33,944] {taskinstance.py:719} INFO - Dependencies all met for <TaskInstance: example_gcp_cloud_build_trigger.create_build_trigger 2020-06-08T00:00:00+00:00 [queued]> > [2020-06-09 19:00:33,945] {taskinstance.py:908} INFO - > -------------------------------------------------------------------------------- > [2020-06-09 19:00:33,945] {taskinstance.py:909} INFO - Starting attempt 1 of 1 > [2020-06-09 19:00:33,946] {taskinstance.py:910} INFO - > -------------------------------------------------------------------------------- > [2020-06-09 19:00:33,953] {taskinstance.py:929} INFO - Executing <Task(CloudBuildCreateBuildTriggerOperator): create_build_trigger> on 2020-06-08T00:00:00+00:00 > [2020-06-09 19:00:33,957] {standard_task_runner.py:53} INFO - Started process 9042 to run task > [2020-06-09 19:00:34,039] {logging_mixin.py:91} INFO - Running <TaskInstance: example_gcp_cloud_build_trigger.create_build_trigger 2020-06-08T00:00:00+00:00 [None]> on host 70cf9669db62 > [2020-06-09 19:00:34,067] {taskinstance.py:1001} INFO - Exporting the following env vars: > AIRFLOW_CTX_DAG_OWNER=airflow > AIRFLOW_CTX_DAG_ID=example_gcp_cloud_build_trigger > AIRFLOW_CTX_TASK_ID=create_build_trigger > AIRFLOW_CTX_EXECUTION_DATE=2020-06-08T00:00:00+00:00 > AIRFLOW_CTX_DAG_RUN_ID=backfill__2020-06-08T00:00:00+00:00 > [2020-06-09 19:00:35,144] {taskinstance.py:1194} ERROR - 409 trigger (198907790164, test-cloud-build-trigger) already exists > Traceback (most recent call last): > File "/usr/local/lib/python3.8/site-packages/google/api_core/grpc_helpers.py", line 57, in error_remapped_callable > return callable_(*args, **kwargs) > File "/usr/local/lib/python3.8/site-packages/grpc/_channel.py", line 826, in __call__ > return _end_unary_response_blocking(state, call, False, None) > File "/usr/local/lib/python3.8/site-packages/grpc/_channel.py", line 729, in _end_unary_response_blocking > raise _InactiveRpcError(state) > grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with: > status = StatusCode.ALREADY_EXISTS > details = "trigger (198907790164, test-cloud-build-trigger) already exists" > debug_error_string = "{"created":"@1591729235.142798800","description":"Error received from peer ipv4:216.58.215.74:443","file":"src/core/lib/surface/call.cc","file_line":1056,"grpc_message":"trigger (198907790164, test-cloud-build-trigger) already exists","grpc_status":6}" > > > > The above exception was the direct cause of the following exception: > > Traceback (most recent call last): > File "/opt/airflow/airflow/models/taskinstance.py", line 1026, in _run_raw_task > result = task_copy.execute(context=context) > File "/opt/airflow/airflow/providers/google/cloud/operators/cloud_build.py", line 239, in execute > result = hook.create_build_trigger( > File "/opt/airflow/airflow/providers/google/common/hooks/base_google.py", line 356, in inner_wrapper > return func(self, *args, **kwargs) > File "/opt/airflow/airflow/providers/google/cloud/hooks/cloud_build.py", line 188, in create_build_trigger > return client.create_build_trigger( > File "/usr/local/lib/python3.8/site-packages/google/cloud/devtools/cloudbuild_v1/gapic/cloud_build_client.py", line 595, in create_build_trigger > return self._inner_api_calls["create_build_trigger"]( > File "/usr/local/lib/python3.8/site-packages/google/api_core/gapic_v1/method.py", line 143, in __call__ > return wrapped_func(*args, **kwargs) > File "/usr/local/lib/python3.8/site-packages/google/api_core/grpc_helpers.py", line 59, in error_remapped_callable > six.raise_from(exceptions.from_grpc_error(exc), exc) > File "<string>", line 3, in raise_from > google.api_core.exceptions.AlreadyExists: 409 trigger (198907790164, test-cloud-build-trigger) already exists > [2020-06-09 19:00:35,158] {taskinstance.py:1231} INFO - Marking task as FAILED. dag_id=example_gcp_cloud_build_trigger, task_id=create_build_trigger, execution_date=20200608T000000, start_date=20200609T190033, end_date=20200609T190035 > [2020-06-09 19:00:35,917] {logging_mixin.py:91} INFO - [2020-06-09 19:00:35,917] {local_task_job.py:103} INFO - Task exited with return code 1 > ``` > > Do you have an idea how to solve it? @mik-laj Do you still have this issue when you run the test? ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
