背景

原因

UPDATE task_fail SET duration=0 WHERE duration IS NULL をしてあげればいい
今回はCloud Composerを使っているので、手順としては、worker container とかに入って、mysqlに繋いでコマンドを実行する
- Airflowを独自で立てている場合は、直接DBにコマンド叩けばok

GKEクラスタに接続

gcloud container clusters get-credentials ${GKE_CLUSTER} --zone ${GKE_LOCATION}

podsを表示する

kubectl get pods --all-namespaces

workerにログイン

kubectl -n ${NAME_SPACE} exec -it ${CONTAINER_NAME} -c airflow-worker -- /bin/bash

mysql -h airflow-sqlproxy-service.default -u root

use some_db
UPDATE task_fail SET duration=0 WHERE duration IS NULL

参考: https://cloud.google.com/composer/docs/how-to/using/testing-dags#checking_for_pypi_package_errors