Недавно я обновил Apache Beam до 2.20.0, а затем мои задачи Airflow задания Dataflow перестали работать, хотя само задание потока данных выполнено успешно.
Я заметил, что после обновления GET API для потока данных использует местоположение вместо идентификатора задания в URL
GET https://dataflow.googleapis.com/v1b3/projects/umg-de/locations/us-central1/jobs/us-central1?alt=json
В идеале URL должен быть таким:
GET https://dataflow.googleapis.com/v1b3/projects/umg-de/locations/us-central1/jobs/{job_id}?alt=json
Может кто-нибудь объяснить, почему это происходит?