| 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 | ||||||
| success | nd201907_survey | getMongoDB |
|
PythonOperator |
|
|
0:03:21.055027 | 26015 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | nd201907_survey | getDrowToken |
|
PythonOperator |
|
|
0:00:00.482878 | 26014 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | nd201907_survey | create_table_task |
|
PostgresOperator |
|
|
0:00:00.468202 | 26013 |
|
airflow | 3 | default |
|
2 | default_pool | |||
| success | nd201907_inspection | getMongoDB |
|
PythonOperator |
|
|
0:11:21.148434 | 26012 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | nd201907_inspection | getDrowToken |
|
PythonOperator |
|
|
0:00:00.482867 | 26011 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | nd201907_inspection | create_table_task |
|
PostgresOperator |
|
|
0:00:00.514831 | 26010 |
|
airflow | 3 | default |
|
2 | default_pool | |||
| success | nd201907_inspection | delete_table_task |
|
PostgresOperator |
|
|
0:00:00.532817 | 26009 |
|
airflow | 4 | default |
|
2 | default_pool | |||
| success | nd201907_labour_return | getMongoDB |
|
PythonOperator |
|
|
0:00:19.107235 | 26008 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | nd201907_icwp_safety_data | getMongoDB |
|
PythonOperator |
|
|
0:00:06.734657 | 26007 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | nd201907_labour_return | getDrowToken |
|
PythonOperator |
|
|
0:00:00.706779 | 26006 |
|
airflow | 2 | default |
|
3 | default_pool | |||
| success | nd201907_icwp_safety_data | getDrowToken |
|
PythonOperator |
|
|
0:00:05.024683 | 26005 |
|
airflow | 2 | default |
|
3 | default_pool | |||
| running | nd201907_site_diary_activity | getMongoDB |
|
PythonOperator |
|
|
26004 |
|
airflow | 1 | default |
|
1 | default_pool | ||||
| success | nd201907_site_diary_activity | getDrowToken |
|
PythonOperator |
|
|
0:00:00.569341 | 26003 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | nd201907_cleaning | getMongoDB |
|
PythonOperator |
|
|
0:03:28.854305 | 26002 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | nd201907_cleaning | getDrowToken |
|
PythonOperator |
|
|
0:00:03.548973 | 26001 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | nd201907_site_diary_general | getMongoDB |
|
PythonOperator |
|
|
0:18:19.070246 | 26000 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | nd201907_cleaning | create_table_task |
|
PostgresOperator |
|
|
0:00:00.535064 | 25997 |
|
airflow | 3 | default |
|
2 | default_pool | |||
| success | nd201907_site_diary_activity_general_count | getMongoDB |
|
PythonOperator |
|
|
0:09:58.603810 | 25996 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | nd201907_site_diary_general | getDrowToken |
|
PythonOperator |
|
|
0:00:00.520780 | 25995 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | nd201907_site_diary_activity_general_count | getDrowToken |
|
PythonOperator |
|
|
0:00:00.552418 | 25994 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | 5wsd21_site_diary_activity | getThirdAction |
|
PythonOperator |
|
|
0:04:24.433728 | 25993 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | 1nec_1wsd19_icwps | getDataAndSendToPSQL |
|
PythonOperator |
|
|
0:00:12.826414 | 25992 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | 1nec_6wsd21_icwps | getDataAndSendToPSQL |
|
PythonOperator |
|
|
0:00:06.893236 | 25991 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | 1nec_1wsd19_icwps | getDrowToken |
|
PythonOperator |
|
|
0:00:00.994032 | 25990 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | dc202106_site_diary_activity | getSecondAction |
|
PythonOperator |
|
|
1:07:18.585838 | 25989 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | 1nec_6wsd21_icwps | getDrowToken |
|
PythonOperator |
|
|
0:00:00.507946 | 25988 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | nd201907_survey | getMongoDB |
|
PythonOperator |
|
|
0:03:30.519125 | 25987 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | nd201907_survey | getDrowToken |
|
PythonOperator |
|
|
0:00:00.527855 | 25986 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | nd201907_survey | create_table_task |
|
PostgresOperator |
|
|
0:00:00.494002 | 25985 |
|
airflow | 3 | default |
|
2 | default_pool | |||
| success | 5wsd21_site_diary_activity | getSecondAction |
|
PythonOperator |
|
|
0:35:52.368660 | 25984 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | nd201907_inspection | getMongoDB |
|
PythonOperator |
|
|
0:16:31.207894 | 25983 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | nd201907_inspection | getDrowToken |
|
PythonOperator |
|
|
0:00:00.669926 | 25982 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | nd201907_inspection | create_table_task |
|
PostgresOperator |
|
|
0:00:00.689658 | 25981 |
|
airflow | 3 | default |
|
2 | default_pool | |||
| success | nd201907_inspection | delete_table_task |
|
PostgresOperator |
|
|
0:00:00.672654 | 25980 |
|
airflow | 4 | default |
|
2 | default_pool | |||
| success | sd201903_site_diary_activity | getSecondAction |
|
PythonOperator |
|
|
1:00:56.099231 | 25979 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | nec_c4 | getDataAndSendToPSQL |
|
PythonOperator |
|
|
0:28:08.095335 | 25978 |
|
airflow | 1 | default |
|
3 | default_pool | |||
| success | yl_c2_nec | pipelineProcess |
|
PythonOperator |
|
|
0:02:12.731540 | 25977 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | yl_c2_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:00.742403 | 25976 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | dc202312_site_diary_activity | getForthAction |
|
PythonOperator |
|
|
0:02:29.300475 | 25975 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| failed | 1test__nec_c4_icwp_june | getDataAndSendToPSQL |
|
PythonOperator |
|
|
0:00:25.222781 | 25974 |
|
airflow | 1 | default |
|
3 | default_pool | |||
| failed | 1test__nec_c4_icwp_july | getDataAndSendToPSQL |
|
PythonOperator |
|
|
0:00:35.692627 | 25973 |
|
airflow | 1 | default |
|
3 | default_pool | |||
| success | nd201907_site_diary_activity | getMongoDB |
|
PythonOperator |
|
|
1:44:24.762112 | 25972 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | nd201907_site_diary_activity | getDrowToken |
|
PythonOperator |
|
|
0:00:01.174572 | 25971 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | 1wsd19_risc_icwp_inspection | getMongoDB3 |
|
PythonOperator |
|
|
0:09:30.537063 | 25970 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | nec_section_of_work | getDataAndSendToPSQL |
|
PythonOperator |
|
|
0:00:20.483804 | 25969 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | dc202106_nec | pipelineProcess |
|
PythonOperator |
|
|
0:00:29.451196 | 25968 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | c5_nec | pipelineProcess |
|
PythonOperator |
|
|
0:34:35.361620 | 25967 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | nd201907_cleaning | getMongoDB |
|
PythonOperator |
|
|
0:05:58.557014 | 25966 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | c6_nec | pipelineProcess |
|
PythonOperator |
|
|
0:03:50.127811 | 25965 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | nd201907_safety_walk | getMongoDB |
|
PythonOperator |
|
|
0:09:20.042531 | 25964 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | c3_nec | pipelineProcess |
|
PythonOperator |
|
|
0:04:26.466543 | 25963 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | nd201907_site_diary_general | getMongoDB |
|
PythonOperator |
|
|
0:23:56.457936 | 25962 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | dc202312_nec | pipelineProcess |
|
PythonOperator |
|
|
0:06:28.588809 | 25961 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | nd201907_site_diary_activity_general_count | getMongoDB |
|
PythonOperator |
|
|
0:17:59.862657 | 25958 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | cv202303_nec | pipelineProcess |
|
PythonOperator |
|
|
0:05:21.865592 | 25957 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | nec_section_of_work | getDrowToken |
|
PythonOperator |
|
|
0:00:04.454970 | 25956 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | cv202211_schedule_of_cost | getDataAndSendToPSQL |
|
PythonOperator |
|
|
0:06:18.614134 | 25955 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | dc202106_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:05.723421 | 25954 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | nd201907_site_diary_general | getDrowToken |
|
PythonOperator |
|
|
0:00:00.647455 | 25953 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | c4_nec_risk_reg | pipelineProcess |
|
PythonOperator |
|
|
0:00:30.191149 | 25952 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | c5_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:01.701678 | 25951 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | cv202309_nec | pipelineProcess |
|
PythonOperator |
|
|
0:08:12.442026 | 25950 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | c5_nec_report_copy | pipelineProcess |
|
PythonOperator |
|
|
0:00:08.872241 | 25949 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | nd201907_cleaning | getDrowToken |
|
PythonOperator |
|
|
0:00:00.964916 | 25948 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | cv202211_payment_excel | getDataAndSendToPSQL |
|
PythonOperator |
|
|
0:00:25.468340 | 25947 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | c4_financial_data | getMongoDB |
|
PythonOperator |
|
|
0:01:23.987244 | 25946 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | c4_nec_risk_reg | getDrowToken |
|
PythonOperator |
|
|
0:00:02.428010 | 25945 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | nd201907_labour_return | getMongoDB |
|
PythonOperator |
|
|
0:00:22.370203 | 25943 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | c5_nec_report_copy | getDrowToken |
|
PythonOperator |
|
|
0:00:00.676138 | 25942 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | cv202211_payment_excel | getDrowToken |
|
PythonOperator |
|
|
0:00:00.731630 | 25941 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | nd201907_icwp_safety_data | getMongoDB |
|
PythonOperator |
|
|
0:00:08.007677 | 25940 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | c2_nec | pipelineProcess |
|
PythonOperator |
|
|
0:07:34.697944 | 25939 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | nd201907_cleaning | create_table_task |
|
PostgresOperator |
|
|
0:00:00.795756 | 25938 |
|
airflow | 3 | default |
|
2 | default_pool | |||
| success | nd201907_labour_return | getDrowToken |
|
PythonOperator |
|
|
0:00:00.801204 | 25937 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | c7_nec | pipelineProcess |
|
PythonOperator |
|
|
0:05:58.724785 | 25936 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | nd201907_icwp_safety_data | getDrowToken |
|
PythonOperator |
|
|
0:00:00.843648 | 25935 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | c2_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:00.590690 | 25934 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | 1test__nec_c4_icwp_june | getDrowToken |
|
PythonOperator |
|
|
0:00:00.669634 | 25933 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | c6_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:00.699421 | 25932 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | nec_c4 | getDrowToken |
|
PythonOperator |
|
|
0:00:00.750595 | 25931 |
|
airflow | 2 | default |
|
2 | default_pool |