StoryCode

Airflow.초기화.강제 매뉴얼

Apache AirFlow
반응형

> docker exec -it airflow bash
    
>> airflow list_dags
>> airflow trigger_dag gatherdag1
# 실행중인 dag 가 없어야 함.
    
>>   접속: mysql -uroot -p

MariaDB [(none)]> set names utf8;
MariaDB [(none)]> use airflow;
MariaDB [airflow]> SELECT * FROM dag_run;
MariaDB [airflow]> UPDATE  dag SET  is_paused ='0' WHERE dag_id IN('gatherdag1','inferencedag1') AND is_paused ='1';
MariaDB [airflow]> SELECT * FROM job where  state NOT IN('failed','success');
MariaDB [airflow]> SELECT * FROM dag_run where  state NOT IN('failed','success');

MariaDB [airflow]> UPDATE job SET state = 'failed' where  state NOT IN('failed','success') ;
MariaDB [airflow]> UPDATE dag_run SET state = 'failed' where  state NOT IN('failed','success');

MariaDB [airflow]> commit;

 

# 이후 airflow web 화면에서 시작버튼 클릭

반응형

'Apache AirFlow' 카테고리의 다른 글

VMWare.Docker.Centos.Airflow 직접 설치  (0) 2020.10.28
설치.maria db for airflow  (0) 2020.10.19
VMWare.Docker.Airflow Official Image 에 설치  (0) 2020.10.11