Apache AirFlow

Airflow.초기화.강제 매뉴얼

jake_kim 2021. 6. 24. 10:44
반응형

> 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 화면에서 시작버튼 클릭

반응형