| 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 | ||||||
| running | nec_c4 | getDataAndSendToPSQL |
|
PythonOperator |
|
|
26065 |
|
airflow | 1 | default |
|
2 | default_pool | ||||
| running | c5_nec | pipelineProcess |
|
PythonOperator |
|
|
26064 |
|
airflow | 1 | default |
|
2 | default_pool | ||||
| failed | 1test__nec_c4_icwp_july | getDataAndSendToPSQL |
|
PythonOperator |
|
|
0:00:07.851949 | 26063 |
|
airflow | 1 | default |
|
3 | default_pool | |||
| failed | 1test__nec_c4_icwp_june | getDataAndSendToPSQL |
|
PythonOperator |
|
|
0:00:07.518352 | 26062 |
|
airflow | 1 | default |
|
3 | default_pool | |||
| success | dc202312_nec | pipelineProcess |
|
PythonOperator |
|
|
0:05:59.988015 | 26061 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | cv202303_nec | pipelineProcess |
|
PythonOperator |
|
|
0:03:11.885434 | 26060 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | c6_nec | pipelineProcess |
|
PythonOperator |
|
|
0:02:30.851431 | 26059 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | manage_connections_and_variables | validate_connections |
|
PythonOperator |
|
|
0:00:00.399699 | 26058 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | c7_nec | pipelineProcess |
|
PythonOperator |
|
|
0:03:54.493145 | 26057 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | c3_nec | pipelineProcess |
|
PythonOperator |
|
|
0:03:42.549679 | 26056 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | c2_nec | pipelineProcess |
|
PythonOperator |
|
|
0:04:00.541614 | 26054 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | c4_financial_data | getMongoDB |
|
PythonOperator |
|
|
0:01:05.655374 | 26053 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | c6_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:03.649401 | 26052 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | cv202302_nec | pipelineProcess |
|
PythonOperator |
|
|
0:03:30.994377 | 26050 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | c7_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:00.739890 | 26048 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | cv202211_schedule_of_cost | getDataAndSendToPSQL |
|
PythonOperator |
|
|
0:02:09.312687 | 26047 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | dc202312_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:00.874630 | 26046 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | cv202302_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:00.616117 | 26045 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | nec_c4 | getDrowToken |
|
PythonOperator |
|
|
0:00:00.682201 | 26044 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | manage_connections_and_variables | create_or_update_variables |
|
PythonOperator |
|
|
0:00:00.314640 | 26043 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | manage_connections_and_variables | create_or_update_connections |
|
PythonOperator |
|
|
0:00:00.281029 | 26042 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | cv202303_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:02.953868 | 26041 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | nec_section_of_work | getDataAndSendToPSQL |
|
PythonOperator |
|
|
0:00:03.675303 | 26040 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | cv202211_schedule_of_cost | getDrowToken |
|
PythonOperator |
|
|
0:00:00.917484 | 26039 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | dc202106_nec | pipelineProcess |
|
PythonOperator |
|
|
0:00:09.079092 | 26038 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | _1wsd19_edms_nec1 | pipelineProcess |
|
PythonOperator |
|
|
0:04:45.556799 | 26037 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | c3_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:01.207547 | 26036 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | 1test__nec_c4_icwp_july | getDrowToken |
|
PythonOperator |
|
|
0:00:01.695289 | 26034 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | c1_nec | pipelineProcess |
|
PythonOperator |
|
|
0:06:23.060764 | 26033 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | c5_nec_report_copy | pipelineProcess |
|
PythonOperator |
|
|
0:00:09.845555 | 26032 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | nec_section_of_work | getDrowToken |
|
PythonOperator |
|
|
0:00:00.740757 | 26031 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | dc202106_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:00.657371 | 26030 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | c4_nec_risk_reg | pipelineProcess |
|
PythonOperator |
|
|
0:00:21.889986 | 26029 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | 1test__nec_c4_icwp_june | getDrowToken |
|
PythonOperator |
|
|
0:00:00.805800 | 26028 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | cv202211_payment_excel | getDataAndSendToPSQL |
|
PythonOperator |
|
|
0:00:13.742002 | 26027 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | c4_nec_risk_reg | getDrowToken |
|
PythonOperator |
|
|
0:00:00.628541 | 26026 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | c2_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:00.683945 | 26025 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | c5_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:00.827459 | 26024 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | cv202309_nec | pipelineProcess |
|
PythonOperator |
|
|
0:04:20.060613 | 26023 |
|
airflow | 1 | default |
|
2 | default_pool | |||
| success | c4_financial_data | getDrowToken |
|
PythonOperator |
|
|
0:00:00.514492 | 26022 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | cv202211_payment_excel | getDrowToken |
|
PythonOperator |
|
|
0:00:00.732715 | 26021 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | c1_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:00.835249 | 26020 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | cv202309_nec | getDrowToken |
|
PythonOperator |
|
|
0:00:00.761508 | 26019 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | c5_nec_report_copy | getDrowToken |
|
PythonOperator |
|
|
0:00:01.650682 | 26018 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | _1wsd19_edms_nec1 | getDrowToken |
|
PythonOperator |
|
|
0:00:00.974263 | 26017 |
|
airflow | 2 | default |
|
2 | default_pool | |||
| success | manage_connections_and_variables | clear_error_connections |
|
PythonOperator |
|
|
0:00:00.294246 | 26016 |
|
airflow | 4 | default |
|
2 | 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 | |||
| success | nd201907_site_diary_activity | getMongoDB |
|
PythonOperator |
|
|
1:27:12.960550 | 26004 |
|
airflow | 1 | default |
|
2 | 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 |