| Id | Dttm | Dag Id | Task Id | Event | Execution Date | Owner | Extra |
|---|---|---|---|---|---|---|---|
| 41634 |
|
dc202106_cleaning | graph |
|
anonymous | [('dag_id', 'dc202106_cleaning'), ('root', 'create_table_task'), ('execution_date', '2026-03-26T15:00:00+00:00')] | |
| 41633 |
|
nd201905_kpi | graph |
|
anonymous | [('dag_id', 'nd201905_kpi'), ('root', 'writeKpiToPostgres'), ('execution_date', '2026-02-12T15:00:00+00:00')] | |
| 41632 |
|
dc202106_cleaning | graph |
|
anonymous | [('dag_id', 'dc202106_cleaning'), ('root', 'create_table_task'), ('execution_date', '2026-03-26T15:00:00+00:00')] | |
| 41631 |
|
nd201907_safety_walk | graph |
|
anonymous | [('dag_id', 'nd201907_safety_walk'), ('root', 'getMongoDB'), ('execution_date', '2026-03-27T04:00:00+00:00')] | |
| 41630 |
|
1wsd19_icwp_safety_data | getDrowToken | task |
|
anonymous | [('dag_id', '1wsd19_icwp_safety_data'), ('task_id', 'getDrowToken'), ('execution_date', '2025-12-08T15:00:00+00:00')] |
| 41629 |
|
sd201903_cleaning | graph |
|
anonymous | [('dag_id', 'sd201903_cleaning'), ('execution_date', '2026-02-07 15:00:00+00:00')] | |
| 41628 |
|
1wsd19_icwp_site_diary_general | graph |
|
anonymous | [('dag_id', '1wsd19_icwp_site_diary_general'), ('root', 'getDrowToken'), ('execution_date', '2026-03-03T15:20:00+00:00')] | |
| 41627 |
|
nec_section_of_work | graph |
|
anonymous | [('dag_id', 'nec_section_of_work'), ('execution_date', '2025-12-16 08:00:00+00:00')] | |
| 41626 |
|
5wsd21_icwp_site_diary_general | getMongoDB | task |
|
anonymous | [('dag_id', '5wsd21_icwp_site_diary_general'), ('task_id', 'getMongoDB'), ('execution_date', '2026-03-02T07:15:00+00:00')] |
| 41625 |
|
cv202303_nec | graph |
|
anonymous | [('dag_id', 'cv202303_nec'), ('execution_date', '2026-02-17 04:00:00+00:00')] | |
| 41624 |
|
1nec_6wsd21_icwps | getDataAndSendToPSQL | log |
|
anonymous | [('dag_id', '1nec_6wsd21_icwps'), ('task_id', 'getDataAndSendToPSQL'), ('execution_date', '2026-03-02T09:00:00+00:00')] |
| 41623 |
|
c4_nec_risk_reg | graph |
|
anonymous | [('dag_id', 'c4_nec_risk_reg'), ('execution_date', '2026-02-05 16:00:00+00:00')] | |
| 41622 |
|
c3_nec | graph |
|
anonymous | [('dag_id', 'c3_nec'), ('execution_date', '2025-12-18 16:00:00+00:00')] | |
| 41621 |
|
c1_nec | graph |
|
anonymous | [('dag_id', 'c1_nec'), ('execution_date', '2026-01-01 04:00:00+00:00')] | |
| 41620 |
|
1nec_1wsd19_icwps | getDrowToken | log |
|
anonymous | [('dag_id', '1nec_1wsd19_icwps'), ('task_id', 'getDrowToken'), ('execution_date', '2026-03-02T09:00:00+00:00')] |
| 41619 |
|
5wsd21_safety_walk | graph |
|
anonymous | [('dag_id', '5wsd21_safety_walk'), ('execution_date', '2026-01-27 15:00:00+00:00')] | |
| 41618 |
|
hy202308_icwp_cleansing | graph |
|
anonymous | [('dag_id', 'hy202308_icwp_cleansing'), ('root', 'getDailyCleansing'), ('execution_date', '2026-03-03T15:00:00+00:00')] | |
| 41617 |
|
dc202312_icwp_site_diary_general | graph |
|
anonymous | [('dag_id', 'dc202312_icwp_site_diary_general'), ('execution_date', '2026-03-26 15:20:00+00:00')] | |
| 41616 |
|
nd201905_kpi | graph |
|
anonymous | [('dag_id', 'nd201905_kpi'), ('root', 'getContractData'), ('execution_date', '2026-03-24T15:00:00+00:00')] | |
| 41615 |
|
6wsd21_risc_icwp_inspection | getDrowToken | task |
|
anonymous | [('dag_id', '6wsd21_risc_icwp_inspection'), ('task_id', 'getDrowToken'), ('execution_date', '2026-03-02T07:00:00+00:00')] |
| 41614 |
|
1test__nec_c4_icwp_june | getDataAndSendToPSQL | log |
|
anonymous | [('dag_id', '1test__nec_c4_icwp_june'), ('task_id', 'getDataAndSendToPSQL'), ('execution_date', '2026-03-05T11:00:00+00:00')] |
| 41613 |
|
5WSD_TOMS__financial_data | getDrowToken | log |
|
anonymous | [('dag_id', '5WSD_TOMS__financial_data'), ('task_id', 'getDrowToken'), ('execution_date', '2026-03-02T09:00:00+00:00')] |
| 41612 |
|
nd201907_site_diary_general | getDrowToken | task |
|
anonymous | [('dag_id', 'nd201907_site_diary_general'), ('task_id', 'getDrowToken'), ('execution_date', '2026-03-02T10:00:00+00:00')] |
| 41611 |
|
cv202303_cleaning | getDrowToken | task |
|
anonymous | [('dag_id', 'cv202303_cleaning'), ('task_id', 'getDrowToken'), ('execution_date', '2025-09-13T15:00:00+00:00')] |
| 41610 |
|
c2_nec | pipelineProcess | log |
|
anonymous | [('dag_id', 'c2_nec'), ('execution_date', '2026-03-26T11:00:00+00:00'), ('task_id', 'pipelineProcess')] |
| 41609 |
|
c6_nec | pipelineProcess | log |
|
anonymous | [('dag_id', 'c6_nec'), ('execution_date', '2026-03-26T08:00:00+00:00'), ('task_id', 'pipelineProcess')] |
| 41608 |
|
cv202308_labour_return | graph |
|
anonymous | [('dag_id', 'cv202308_labour_return'), ('root', 'getMongoDB'), ('execution_date', '2026-03-03T15:00:00+00:00')] | |
| 41607 |
|
c3_nec | pipelineProcess | log |
|
anonymous | [('dag_id', 'c3_nec'), ('execution_date', '2026-03-26T04:00:00+00:00'), ('task_id', 'pipelineProcess')] |
| 41606 |
|
5wsd21_site_diary_activity | getDrowToken | task |
|
anonymous | [('dag_id', '5wsd21_site_diary_activity'), ('task_id', 'getDrowToken'), ('execution_date', '2026-03-02T07:00:00+00:00')] |
| 41605 |
|
5wsd21_safety_walk | graph |
|
anonymous | [('dag_id', '5wsd21_safety_walk'), ('root', ''), ('execution_date', '2025-09-08T07:00:00+00:00')] | |
| 41604 |
|
nd201905_kpi | graph |
|
anonymous | [('dag_id', 'nd201905_kpi'), ('execution_date', '2026-03-02 07:00:00+00:00')] | |
| 41603 |
|
yl_c2_nec | getDrowToken | task |
|
anonymous | [('dag_id', 'yl_c2_nec'), ('task_id', 'getDrowToken'), ('execution_date', '2026-03-04T16:15:00+00:00')] |
| 41602 |
|
c5_nec | graph |
|
anonymous | [('dag_id', 'c5_nec'), ('execution_date', '2026-03-24T08:00:00+00:00'), ('root', 'pipelineProcess')] | |
| 41601 |
|
c6_nec | pipelineProcess | log |
|
anonymous | [('dag_id', 'c6_nec'), ('execution_date', '2026-03-24T08:00:00+00:00'), ('task_id', 'pipelineProcess')] |
| 41600 |
|
5WSD_TOMS__financial_data | getMongoDB | log |
|
anonymous | [('dag_id', '5WSD_TOMS__financial_data'), ('task_id', 'getMongoDB'), ('execution_date', '2026-03-02T09:00:00+00:00')] |
| 41599 |
|
6wsd21_icwp_site_diary_general | getMongoDB | log |
|
anonymous | [('dag_id', '6wsd21_icwp_site_diary_general'), ('task_id', 'getMongoDB'), ('execution_date', '2026-03-02T07:15:00+00:00')] |
| 41598 |
|
_1wsd19_edms_nec1 | graph |
|
anonymous | [('dag_id', '_1wsd19_edms_nec1'), ('execution_date', '2026-03-25T11:00:00+00:00'), ('root', 'pipelineProcess')] | |
| 41597 |
|
1wsd19_labour_return | getDrowToken | task |
|
anonymous | [('dag_id', '1wsd19_labour_return'), ('task_id', 'getDrowToken'), ('execution_date', '2026-03-03T15:00:00+00:00')] |
| 41596 |
|
6wsd21_risc_icwp_inspection | graph |
|
anonymous | [('dag_id', '6wsd21_risc_icwp_inspection'), ('root', 'getDrowToken'), ('execution_date', '2026-03-02T07:00:00+00:00')] | |
| 41595 |
|
1nec_1wsd19_icwps | graph |
|
anonymous | [('dag_id', '1nec_1wsd19_icwps'), ('execution_date', '2026-03-24 09:00:00+00:00')] | |
| 41594 |
|
c6_nec | graph |
|
anonymous | [('dag_id', 'c6_nec'), ('execution_date', '2026-03-24T16:00:00+00:00'), ('root', 'pipelineProcess')] | |
| 41593 |
|
nd201905_kpi | writeKpiToPostgres | task |
|
anonymous | [('dag_id', 'nd201905_kpi'), ('task_id', 'writeKpiToPostgres'), ('execution_date', '2026-03-24T15:00:00+00:00')] |
| 41592 |
|
nd201907_labour_return | getDrowToken | task |
|
anonymous | [('dag_id', 'nd201907_labour_return'), ('task_id', 'getDrowToken'), ('execution_date', '2026-03-27T04:00:00+00:00')] |
| 41591 |
|
nd201905_kpi | getProgrammeData | task |
|
anonymous | [('dag_id', 'nd201905_kpi'), ('task_id', 'getProgrammeData'), ('execution_date', '2026-03-02T07:00:00+00:00')] |
| 41590 |
|
dc202106_risc_icwp_inspection | delete_table_task | log |
|
anonymous | [('dag_id', 'dc202106_risc_icwp_inspection'), ('task_id', 'delete_table_task'), ('execution_date', '2026-03-03T15:00:00+00:00')] |
| 41589 |
|
yl_c2_nec | graph |
|
anonymous | [('dag_id', 'yl_c2_nec'), ('execution_date', '2026-03-25T03:15:00+00:00'), ('root', 'pipelineProcess')] | |
| 41588 |
|
1nec_6wsd21_icwps | graph |
|
anonymous | [('dag_id', '1nec_6wsd21_icwps'), ('root', 'getDrowToken'), ('execution_date', '2026-03-02T09:00:00+00:00')] | |
| 41587 |
|
cv202211_schedule_of_cost | graph |
|
anonymous | [('dag_id', 'cv202211_schedule_of_cost'), ('execution_date', '2026-02-13 04:00:00+00:00')] | |
| 41586 |
|
dc202312_nec | pipelineProcess | task |
|
anonymous | [('dag_id', 'dc202312_nec'), ('execution_date', '2026-03-24T11:00:00+00:00'), ('task_id', 'pipelineProcess')] |
| 41585 |
|
1nec_1wsd19_icwps | getDataAndSendToPSQL | log |
|
anonymous | [('dag_id', '1nec_1wsd19_icwps'), ('task_id', 'getDataAndSendToPSQL'), ('execution_date', '2026-03-02T09:00:00+00:00')] |
| 41584 |
|
dc202106_nec | graph |
|
anonymous | [('dag_id', 'dc202106_nec'), ('execution_date', '2026-03-24T08:00:00+00:00'), ('root', 'pipelineProcess')] | |
| 41583 |
|
dc202312_nec | pipelineProcess | task |
|
anonymous | [('dag_id', 'dc202312_nec'), ('task_id', 'pipelineProcess'), ('execution_date', '2026-03-04T08:00:00+00:00')] |
| 41582 |
|
5wsd21_safety_walk_old_record | graph |
|
anonymous | [('dag_id', '5wsd21_safety_walk_old_record'), ('root', ''), ('execution_date', '2026-03-24T15:00:00+00:00')] | |
| 41581 |
|
6wsd21_risc_icwp_inspection | getMongoDBSurveyCheck | task |
|
anonymous | [('dag_id', '6wsd21_risc_icwp_inspection'), ('task_id', 'getMongoDBSurveyCheck'), ('execution_date', '2026-03-02T07:00:00+00:00')] |
| 41580 |
|
nd201905_kpi | graph |
|
anonymous | [('dag_id', 'nd201905_kpi'), ('root', 'writeKpiToPostgres'), ('execution_date', '2026-03-02T07:00:00+00:00')] | |
| 41579 |
|
hy202308_icwp_cleansing | graph |
|
anonymous | [('dag_id', 'hy202308_icwp_cleansing'), ('execution_date', '2026-03-03 15:00:00+00:00')] | |
| 41578 |
|
6wsd21_site_diary_activity | graph |
|
anonymous | [('dag_id', '6wsd21_site_diary_activity'), ('execution_date', '2026-03-02 07:00:00+00:00')] | |
| 41577 |
|
dc202312_nec | graph |
|
anonymous | [('dag_id', 'dc202312_nec'), ('execution_date', '2026-03-25T04:00:00+00:00'), ('root', 'pipelineProcess')] | |
| 41576 |
|
1wsd19_icwp_site_diary_general | getMongoDB2 | log |
|
anonymous | [('dag_id', '1wsd19_icwp_site_diary_general'), ('task_id', 'getMongoDB2'), ('execution_date', '2026-03-03T15:20:00+00:00')] |
| 41575 |
|
nd201905_kpi | getCNCEData | task |
|
anonymous | [('dag_id', 'nd201905_kpi'), ('task_id', 'getCNCEData'), ('execution_date', '2026-03-02T07:00:00+00:00')] |
| 41574 |
|
cv202309_nec | graph |
|
anonymous | [('dag_id', 'cv202309_nec'), ('execution_date', '2026-01-10 11:00:00+00:00')] | |
| 41573 |
|
cv202309_nec | graph |
|
anonymous | [('dag_id', 'cv202309_nec'), ('execution_date', '2026-01-01 08:00:00+00:00')] | |
| 41572 |
|
6wsd21_site_diary_activity | graph |
|
anonymous | [('dag_id', '6wsd21_site_diary_activity'), ('root', 'getFirstAction'), ('execution_date', '2026-03-02T07:00:00+00:00')] | |
| 41571 |
|
cv202302_nec | graph |
|
anonymous | [('dag_id', 'cv202302_nec'), ('execution_date', '2026-02-17 04:00:00+00:00')] | |
| 41570 |
|
c5_nec | graph |
|
anonymous | [('dag_id', 'c5_nec'), ('execution_date', '2026-01-25 11:00:00+00:00')] | |
| 41569 |
|
5WSD_TOMS__financial_data | graph |
|
anonymous | [('dag_id', '5WSD_TOMS__financial_data'), ('root', 'getMongoDB'), ('execution_date', '2026-03-02T09:00:00+00:00')] | |
| 41568 |
|
cv202302_site_diary_activity | graph |
|
anonymous | [('dag_id', 'cv202302_site_diary_activity'), ('root', 'getThirdAction'), ('execution_date', '2026-03-03T15:00:00+00:00')] | |
| 41567 |
|
c2_nec | graph |
|
anonymous | [('dag_id', 'c2_nec'), ('execution_date', '2025-03-02 04:00:00+00:00')] | |
| 41566 |
|
nd201907_labour_return | getDrowToken | task |
|
anonymous | [('dag_id', 'nd201907_labour_return'), ('task_id', 'getDrowToken'), ('execution_date', '2026-03-02T10:00:00+00:00')] |
| 41565 |
|
yl_c2_nec | getDrowToken | task |
|
anonymous | [('dag_id', 'yl_c2_nec'), ('task_id', 'getDrowToken'), ('execution_date', '2026-03-05T01:15:00+00:00')] |
| 41564 |
|
nd201905_kpi | graph |
|
anonymous | [('dag_id', 'nd201905_kpi'), ('root', 'getProgrammeData'), ('execution_date', '2026-03-02T07:00:00+00:00')] | |
| 41563 |
|
nd201907_inspection | getMongoDB | task |
|
anonymous | [('dag_id', 'nd201907_inspection'), ('task_id', 'getMongoDB'), ('execution_date', '2026-03-27T04:35:00+00:00')] |
| 41562 |
|
nd201907_site_diary_general | graph |
|
anonymous | [('dag_id', 'nd201907_site_diary_general'), ('root', 'getDrowToken'), ('execution_date', '2026-03-02T10:00:00+00:00')] | |
| 41561 |
|
nd201905_kpi | getCEImplementationData | task |
|
anonymous | [('dag_id', 'nd201905_kpi'), ('task_id', 'getCEImplementationData'), ('execution_date', '2026-03-24T15:00:00+00:00')] |
| 41560 |
|
cv202302_site_diary_activity | graph |
|
anonymous | [('dag_id', 'cv202302_site_diary_activity'), ('execution_date', '2026-03-03 15:00:00+00:00')] | |
| 41559 |
|
_1wsd19_edms_nec1 | graph |
|
anonymous | [('dag_id', '_1wsd19_edms_nec1'), ('execution_date', '2026-03-24T08:00:00+00:00'), ('root', 'getDrowToken')] | |
| 41558 |
|
ssm519-scc | getPaymentStatistics | task |
|
anonymous | [('dag_id', 'ssm519-scc'), ('task_id', 'getPaymentStatistics'), ('execution_date', '2026-03-02T07:00:00+00:00')] |
| 41557 |
|
5wsd21_icwp_safety_data | graph |
|
anonymous | [('dag_id', '5wsd21_icwp_safety_data'), ('root', 'getMongoDB'), ('execution_date', '2026-03-02T07:00:00+00:00')] | |
| 41556 |
|
sd201903_risc_icwp_inspection | getDrowToken | xcom |
|
anonymous | [('dag_id', 'sd201903_risc_icwp_inspection'), ('execution_date', '2026-03-20T15:00:00+00:00'), ('task_id', 'getDrowToken')] |
| 41555 |
|
5wsd21_risc_icwp_inspection | getMongoDB2 | task |
|
anonymous | [('dag_id', '5wsd21_risc_icwp_inspection'), ('task_id', 'getMongoDB2'), ('execution_date', '2026-03-04T07:00:00+00:00')] |
| 41554 |
|
cv202302_icwp_site_diary_general | graph |
|
anonymous | [('dag_id', 'cv202302_icwp_site_diary_general'), ('execution_date', '2026-03-25T15:20:00+00:00'), ('root', 'getDrowToken')] | |
| 41553 |
|
cv202211_schedule_of_cost | graph |
|
anonymous | [('dag_id', 'cv202211_schedule_of_cost'), ('root', 'getDrowToken'), ('execution_date', '2026-03-24T16:00:00+00:00')] | |
| 41552 |
|
5wsd21_cleaning | getMongoDB | log |
|
anonymous | [('dag_id', '5wsd21_cleaning'), ('task_id', 'getMongoDB'), ('execution_date', '2026-03-02T07:00:00+00:00')] |
| 41551 |
|
yl_c2_nec | graph |
|
anonymous | [('dag_id', 'yl_c2_nec'), ('execution_date', '2026-03-25T03:15:00+00:00'), ('root', 'getDrowToken')] | |
| 41550 |
|
1nec_1wsd19_icwps | graph |
|
anonymous | [('dag_id', '1nec_1wsd19_icwps'), ('execution_date', '2026-03-05 12:00:00+00:00')] | |
| 41549 |
|
nd201907_site_diary_activity_general_count | getMongoDB | xcom |
|
anonymous | [('dag_id', 'nd201907_site_diary_activity_general_count'), ('task_id', 'getMongoDB'), ('execution_date', '2026-02-18T04:00:00+00:00')] |
| 41548 |
|
6wsd21_site_diary_activity | graph |
|
anonymous | [('dag_id', '6wsd21_site_diary_activity'), ('root', 'getDrowToken'), ('execution_date', '2026-03-02T07:00:00+00:00')] | |
| 41547 |
|
6wsd21_safety_walk | getMongoDB | task |
|
anonymous | [('dag_id', '6wsd21_safety_walk'), ('task_id', 'getMongoDB'), ('execution_date', '2026-03-02T07:00:00+00:00')] |
| 41546 |
|
c4_nec_risk_reg | getDrowToken | log |
|
anonymous | [('dag_id', 'c4_nec_risk_reg'), ('task_id', 'getDrowToken'), ('execution_date', '2026-03-04T16:00:00+00:00')] |
| 41545 |
|
c6_nec | pipelineProcess | get_logs_with_metadata |
|
anonymous | [('dag_id', 'c6_nec'), ('task_id', 'pipelineProcess'), ('execution_date', '2026-03-24T16:00:00+00:00'), ('try_number', '1'), ('metadata', 'null')] |
| 41544 |
|
cv202302_risc_icwp_inspection | graph |
|
anonymous | [('dag_id', 'cv202302_risc_icwp_inspection'), ('execution_date', '2026-03-24T15:00:00+00:00'), ('root', 'getDrowToken')] | |
| 41543 |
|
c6_nec | pipelineProcess | log |
|
anonymous | [('dag_id', 'c6_nec'), ('task_id', 'pipelineProcess'), ('execution_date', '2026-03-24T16:00:00+00:00')] |
| 41542 |
|
cv202308_cleaning | getMongoDB | task |
|
anonymous | [('dag_id', 'cv202308_cleaning'), ('task_id', 'getMongoDB'), ('execution_date', '2026-03-14T15:00:00+00:00')] |
| 41541 |
|
nd201905_kpi | writeKpiToPostgres | log |
|
anonymous | [('dag_id', 'nd201905_kpi'), ('task_id', 'writeKpiToPostgres'), ('execution_date', '2026-03-02T07:00:00+00:00')] |
| 41540 |
|
c5_nec | pipelineProcess | log |
|
anonymous | [('dag_id', 'c5_nec'), ('task_id', 'pipelineProcess'), ('execution_date', '2026-02-08T16:00:00+00:00')] |
| 41539 |
|
5wsd21_safety_walk | getMongoDB | task |
|
anonymous | [('dag_id', '5wsd21_safety_walk'), ('task_id', 'getMongoDB'), ('execution_date', '2026-03-02T07:00:00+00:00')] |
| 41538 |
|
1test__nec_c4_icwp_june | getDataAndSendToPSQL | task |
|
anonymous | [('dag_id', '1test__nec_c4_icwp_june'), ('task_id', 'getDataAndSendToPSQL'), ('execution_date', '2026-03-05T11:00:00+00:00')] |
| 41537 |
|
6wsd21_icwp_safety_data | getDrowToken | task |
|
anonymous | [('dag_id', '6wsd21_icwp_safety_data'), ('execution_date', '2026-03-25T07:00:00+00:00'), ('task_id', 'getDrowToken')] |
| 41536 |
|
cv202302_risc_icwp_inspection | graph |
|
anonymous | [('dag_id', 'cv202302_risc_icwp_inspection'), ('execution_date', '2026-03-23T15:00:00+00:00'), ('root', 'getDrowToken')] | |
| 41535 |
|
nd201905_kpi | graph |
|
anonymous | [('dag_id', 'nd201905_kpi'), ('root', 'getRiskRegisterData'), ('execution_date', '2026-03-02T07:00:00+00:00')] |