| State | Dag Id | Task Id | Execution Date | Operator | Start Date | End Date | Duration | Job Id | Hostname | Unixname | Priority Weight | Queue | Queued Dttm | Try Number | Pool | Log Url | ||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
| removed | hy202308_risc_icwp_inspection | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| removed | hy202308_risc_icwp_inspection | getWeeklyCleansing |
|
|
|
|
airflow | 2 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| removed | hy202308_risc_icwp_inspection | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| removed | hy202308_risc_icwp_inspection | getWeeklyCleansing |
|
|
|
|
airflow | 2 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| removed | hy202308_risc_icwp_inspection | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| removed | hy202308_risc_icwp_inspection | getWeeklyCleansing |
|
|
|
|
airflow | 2 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| removed | hy202308_risc_icwp_inspection | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| removed | hy202308_risc_icwp_inspection | getWeeklyCleansing |
|
|
|
|
airflow | 2 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| removed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getWeeklyCleansing |
|
|
|
|
airflow | 2 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| removed | hy202308_risc_icwp_inspection | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| removed | hy202308_risc_icwp_inspection | getWeeklyCleansing |
|
|
|
|
airflow | 2 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | nd201905_kpi | writeKpiToPostgres |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | nd201905_kpi | writeKpiToPostgres |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | nd201905_kpi | writeKpiToPostgres |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| removed | hy202308_risc_icwp_inspection | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| removed | hy202308_risc_icwp_inspection | getWeeklyCleansing |
|
|
|
|
airflow | 2 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| removed | hy202308_risc_icwp_inspection | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| removed | hy202308_risc_icwp_inspection | getWeeklyCleansing |
|
|
|
|
airflow | 2 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| removed | hy202308_risc_icwp_inspection | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| removed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getWeeklyCleansing |
|
|
|
|
airflow | 2 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | dc202312_risc_icwp_inspection | getMongoDB2 |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| removed | hy202308_risc_icwp_inspection | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| removed | hy202308_risc_icwp_inspection | getWeeklyCleansing |
|
|
|
|
airflow | 2 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| removed | hy202308_risc_icwp_inspection | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| removed | hy202308_risc_icwp_inspection | getWeeklyCleansing |
|
|
|
|
airflow | 2 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_cleansing | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_cleansing | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | dc201911_site_diary_activity | getSecondAction |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_cleansing | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_cleansing | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_cleansing | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_cleansing | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_cleansing | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_cleansing | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_cleansing | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_cleansing | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | c5_nec_report_copy | pipelineProcess |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_cleansing | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_cleansing | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_cleansing | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_cleansing | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | 1wsd19_risc_icwp_inspection | getMongoDB2 |
|
|
|
|
airflow | 2 | default |
|
1 | default_pool | ||||||
| upstream_failed | 1wsd19_risc_icwp_inspection | getMongoDB3 |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_cleansing | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_cleansing | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | 1wsd19_risc_icwp_inspection | getMongoDB2 |
|
|
|
|
airflow | 2 | default |
|
1 | default_pool | ||||||
| upstream_failed | 1wsd19_risc_icwp_inspection | getMongoDB3 |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_cleansing | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_cleansing | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | c4_financial_data | getMongoDB |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_cleansing | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| None | nd201907_cleaning | getMongoDB |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| success | nd201907_labour_return | getMongoDB |
|
PythonOperator |
|
|
0:00:18.677358 | 17554 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| up_for_retry | nd201907_cleaning | getDrowToken |
|
PythonOperator |
|
|
0:00:24.661245 | 17553 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| running | nd201907_site_diary_general | getMongoDB |
|
PythonOperator |
|
|
17552 |
|
airflow | 1 | default |
|
1 | default_pool | ||||
| success | nd201907_site_diary_general | getDrowToken |
|
PythonOperator |
|
|
0:00:00.438685 | 17551 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| running | nd201907_site_diary_activity_general_count | getMongoDB |
|
PythonOperator |
|
|
17550 |
|
airflow | 1 | default |
|
1 | default_pool | ||||
| success | nd201907_labour_return | getDrowToken |
|
PythonOperator |
|
|
0:00:00.716949 | 17549 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | nd201907_icwp_safety_data | getMongoDB |
|
PythonOperator |
|
|
0:00:06.510457 | 17548 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | nd201907_cleaning | create_table_task |
|
PostgresOperator |
|
|
0:00:00.586509 | 17547 |
|
airflow | 3 | default |
|
2 | default_pool | |||
| success | nd201907_icwp_safety_data | getDrowToken |
|
PythonOperator |
|
|
0:00:00.524251 | 17546 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | nd201907_site_diary_activity_general_count | getDrowToken |
|
PythonOperator |
|
|
0:00:00.558509 | 17545 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | 1wsd19_site_diary_activity | getForthAction |
|
PythonOperator |
|
|
0:17:41.549806 | 17544 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | 1wsd19_site_diary_activity | getThirdAction |
|
PythonOperator |
|
|
0:15:33.054620 | 17543 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | 1wsd19_site_diary_activity | getSecondAction |
|
PythonOperator |
|
|
1:32:20.143797 | 17542 |
|
airflow | 3 | default |
|
2 | default_pool | |||
| success | dc201911_site_diary_activity | getSecondAction |
|
PythonOperator |
|
|
1:35:59.374951 | 17541 |
|
airflow | 1 | default |
|
3 | default_pool | |||
| success | 5wsd21_site_diary_activity | getThirdAction |
|
PythonOperator |
|
|
0:04:29.574453 | 17539 |
|
airflow | 1 | default |
|
2 | default_pool |