| 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 | ||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
| 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_cleansing | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | cv202309_nec | pipelineProcess |
|
|
|
|
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_cleansing | getMonthCleansing |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | hy202308_risc_icwp_inspection | getSurveyCheck |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | dc201911_site_diary_activity | getSecondAction |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | 1wsd19_site_diary_activity | getSecondAction |
|
|
|
|
airflow | 3 | default |
|
1 | default_pool | ||||||
| upstream_failed | 1wsd19_site_diary_activity | getThirdAction |
|
|
|
|
airflow | 2 | default |
|
1 | default_pool | ||||||
| upstream_failed | 1wsd19_site_diary_activity | getForthAction |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| upstream_failed | dc201911_risc_icwp_inspection | getMongoDB2 |
|
|
|
|
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 | ||||||
| None | 5wsd21_site_diary_activity | getSecondAction |
|
|
|
|
airflow | 2 | default |
|
1 | default_pool | ||||||
| None | 5wsd21_site_diary_activity | getThirdAction |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| None | dc202106_site_diary_activity | getSecondAction |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| None | dc201911_site_diary_activity | getSecondAction |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| None | dc202312_site_diary_activity | getForthAction |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| None | 1wsd19_risc_icwp_inspection | getMongoDB3 |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| None | sd201903_site_diary_activity | getSecondAction |
|
|
|
|
airflow | 1 | default |
|
1 | default_pool | ||||||
| None | 1wsd19_site_diary_activity | getSecondAction |
|
|
|
|
airflow | 3 | default |
|
1 | default_pool | ||||||
| None | 1wsd19_site_diary_activity | getThirdAction |
|
|
|
|
airflow | 2 | default |
|
1 | default_pool | ||||||
| None | 1wsd19_site_diary_activity | getForthAction |
|
|
|
|
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 | ||||||
| success | yl_c2_nec | pipelineProcess |
|
PythonOperator |
|
|
0:02:28.792491 | 27785 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| running | nec_c4 | getDataAndSendToPSQL |
|
PythonOperator |
|
|
27784 |
|
airflow | 1 | default |
|
2 | default_pool | ||||
| success | yl_c2_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:00.662278 | 27783 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| running | nd201907_site_diary_activity | getMongoDB |
|
PythonOperator |
|
|
27782 |
|
airflow | 1 | default |
|
1 | default_pool | ||||
| success | nd201907_site_diary_activity | getDrowToken |
|
PythonOperator |
|
|
0:00:00.909765 | 27781 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | nd201907_cleaning | getMongoDB |
|
PythonOperator |
|
|
0:04:33.073423 | 27780 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | cv202302_nec | pipelineProcess |
|
PythonOperator |
|
|
0:06:39.978156 | 27779 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| running | c1_nec | pipelineProcess |
|
PythonOperator |
|
|
27778 |
|
airflow | 1 | default |
|
1 | default_pool | ||||
| success | _1wsd19_edms_nec1 | pipelineProcess |
|
PythonOperator |
|
|
0:06:19.321809 | 27777 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| running | nd201907_safety_walk | getMongoDB |
|
PythonOperator |
|
|
27776 |
|
airflow | 1 | default |
|
1 | default_pool | ||||
| running | c5_nec | pipelineProcess |
|
PythonOperator |
|
|
27775 |
|
airflow | 1 | default |
|
1 | default_pool | ||||
| success | cv202309_nec | pipelineProcess |
|
PythonOperator |
|
|
0:09:01.968502 | 27774 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | cv202211_payment_excel | getDataAndSendToPSQL |
|
PythonOperator |
|
|
0:01:52.661320 | 27773 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | nd201907_labour_return | getMongoDB |
|
PythonOperator |
|
|
0:00:22.341214 | 27772 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | c5_nec_report_copy | pipelineProcess |
|
PythonOperator |
|
|
0:00:10.403569 | 27771 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | c3_nec | pipelineProcess |
|
PythonOperator |
|
|
0:05:58.650226 | 27770 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | nd201907_icwp_safety_data | getMongoDB |
|
PythonOperator |
|
|
0:00:10.301489 | 27769 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | 1test__nec_c4_icwp_july | getDataAndSendToPSQL |
|
PythonOperator |
|
|
0:01:08.564323 | 27768 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | nd201907_cleaning | getDrowToken |
|
PythonOperator |
|
|
0:00:00.672679 | 27767 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | c4_financial_data | getMongoDB |
|
PythonOperator |
|
|
0:01:16.841951 | 27766 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | c2_nec | pipelineProcess |
|
PythonOperator |
|
|
0:05:25.531552 | 27765 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | c6_nec | pipelineProcess |
|
PythonOperator |
|
|
0:02:28.258624 | 27764 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | 1test__nec_c4_icwp_june | getDataAndSendToPSQL |
|
PythonOperator |
|
|
0:00:31.020406 | 27763 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | cv202302_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:01.748869 | 27762 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | cv202211_schedule_of_cost | getDataAndSendToPSQL |
|
PythonOperator |
|
|
0:03:13.669916 | 27761 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | c7_nec | pipelineProcess |
|
PythonOperator |
|
|
0:08:09.949636 | 27760 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | nd201907_safety_walk | getDrowToken |
|
PythonOperator |
|
|
0:00:09.337162 | 27759 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | cv202303_nec | pipelineProcess |
|
PythonOperator |
|
|
0:04:44.606651 | 27758 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| running | nd201907_site_diary_general | getMongoDB |
|
PythonOperator |
|
|
27757 |
|
airflow | 1 | default |
|
1 | default_pool | ||||
| success | _1wsd19_edms_nec1 | getDrowToken |
|
PythonOperator |
|
|
0:00:04.134888 | 27756 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | dc202312_nec | pipelineProcess |
|
PythonOperator |
|
|
0:05:41.269105 | 27755 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | c3_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:02.369034 | 27754 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | 1test__nec_c4_icwp_july | getDrowToken |
|
PythonOperator |
|
|
0:00:05.824514 | 27753 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | c1_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:01.286757 | 27752 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | nec_section_of_work | getDataAndSendToPSQL |
|
PythonOperator |
|
|
0:00:13.250932 | 27751 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | dc202106_nec | pipelineProcess |
|
PythonOperator |
|
|
0:00:06.245583 | 27749 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| running | nd201907_site_diary_activity_general_count | getMongoDB |
|
PythonOperator |
|
|
27748 |
|
airflow | 1 | default |
|
1 | default_pool | ||||
| success | nec_section_of_work | getDrowToken |
|
PythonOperator |
|
|
0:00:01.137794 | 27747 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | nd201907_site_diary_general | getDrowToken |
|
PythonOperator |
|
|
0:00:00.689047 | 27746 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | cv202303_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:01.121864 | 27745 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | cv202211_schedule_of_cost | getDrowToken |
|
PythonOperator |
|
|
0:00:01.193969 | 27744 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | c4_nec_risk_reg | pipelineProcess |
|
PythonOperator |
|
|
0:00:14.554541 | 27743 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | dc202106_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:01.315089 | 27742 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | cv202309_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:00.611000 | 27741 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | c5_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:01.290639 | 27740 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | c4_financial_data | getDrowToken |
|
PythonOperator |
|
|
0:00:00.670535 | 27739 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | cv202211_payment_excel | getDrowToken |
|
PythonOperator |
|
|
0:00:00.740971 | 27738 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | c5_nec_report_copy | getDrowToken |
|
PythonOperator |
|
|
0:00:01.201339 | 27737 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | nd201907_labour_return | getDrowToken |
|
PythonOperator |
|
|
0:00:00.574790 | 27736 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | nd201907_icwp_safety_data | getDrowToken |
|
PythonOperator |
|
|
0:00:00.813582 | 27735 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | nd201907_cleaning | create_table_task |
|
PostgresOperator |
|
|
0:00:00.722490 | 27734 |
|
airflow | 3 | default |
|
2 | default_pool | |||
| success | c7_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:00.718116 | 27733 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | c4_nec_risk_reg | getDrowToken |
|
PythonOperator |
|
|
0:00:01.235278 | 27732 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | 1test__nec_c4_icwp_june | getDrowToken |
|
PythonOperator |
|
|
0:00:00.878195 | 27731 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | c2_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:00.583704 | 27730 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | c6_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:00.694261 | 27729 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | nec_c4 | getDrowToken |
|
PythonOperator |
|
|
0:00:00.817796 | 27728 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | dc202312_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:00.775843 | 27727 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | nd201907_site_diary_activity_general_count | getDrowToken |
|
PythonOperator |
|
|
0:00:00.786595 | 27726 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | 1wsd19_icwp_site_diary_general | getMongoDB3 |
|
PythonOperator |
|
|
0:12:07.428581 | 27725 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| running | 1wsd19_risc_icwp_inspection | getMongoDB2 |
|
PythonOperator |
|
|
27724 |
|
airflow | 2 | default |
|
1 | default_pool | ||||
| success | 1wsd19_icwp_site_diary_general | getMongoDB2 |
|
PythonOperator |
|
|
0:01:17.267208 | 27723 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | 5wsd21_risc_icwp_inspection | getMongoDB2 |
|
PythonOperator |
|
|
0:11:19.747174 | 27722 |
|
airflow | 1 | default |
|
2 | default_pool |