Logs

Id Dttm Dag Id Task Id Event Execution Date Owner Extra
312847 04-22T07:08:41.601894+00:00 c5_nec pipelineProcess log 04-05T00:00:00+00:00 anonymous [('dag_id', 'c5_nec'), ('task_id', 'pipelineProcess'), ('execution_date', '2026-04-05T00:00:00+00:00')]
312846 04-22T07:08:36.273760+00:00 5wsd21_safety_walk_old_record graph 04-06T07:00:00+00:00 anonymous [('dag_id', '5wsd21_safety_walk_old_record'), ('execution_date', '2026-04-06 07:00:00+00:00')]
312845 04-22T07:08:31.001093+00:00 1test__nec_c4_icwp_july getDataAndSendToPSQL rendered 04-11T00:00:00+00:00 anonymous [('dag_id', '1test__nec_c4_icwp_july'), ('execution_date', '2026-04-11T00:00:00+00:00'), ('task_id', 'getDataAndSendToPSQL')]
312844 04-22T07:08:30.501840+00:00 nd201905_kpi writeKpiToPostgres success 04-21T15:00:00+00:00 airflow
312843 04-22T07:08:30.493449+00:00 6wsd21_site_diary_activity landing_times anonymous [('dag_id', '6wsd21_site_diary_activity'), ('days', '30'), ('root', '')]
312842 04-22T07:08:28.914842+00:00 nd201905_kpi writeKpiToPostgres cli_run 04-21T15:00:00+00:00 airflow {"host_name": "7cdf3beeecfc", "full_command": "['/usr/local/bin/airflow', 'run', 'nd201905_kpi', 'writeKpiToPostgres', '2026-04-21T15:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/nd201905_kpi.py']"}
312841 04-22T07:08:28.842460+00:00 nd201905_kpi writeKpiToPostgres running 04-21T15:00:00+00:00 airflow
312840 04-22T07:08:27.808958+00:00 nd201905_kpi writeKpiToPostgres cli_run 04-21T15:00:00+00:00 airflow {"host_name": "7cdf3beeecfc", "full_command": "['/usr/local/bin/airflow', 'run', 'nd201905_kpi', 'writeKpiToPostgres', '2026-04-21T15:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/nd201905_kpi.py']"}
312839 04-22T07:08:15.148559+00:00 dc202312_nec pipelineProcess xcom 04-19T16:00:00+00:00 anonymous [('dag_id', 'dc202312_nec'), ('execution_date', '2026-04-19T16:00:00+00:00'), ('task_id', 'pipelineProcess')]
312838 04-22T07:08:12.296826+00:00 c5_nec pipelineProcess get_logs_with_metadata 04-04T11:00:00+00:00 anonymous [('dag_id', 'c5_nec'), ('task_id', 'pipelineProcess'), ('execution_date', '2026-04-04T11:00:00+00:00'), ('try_number', '1'), ('metadata', 'null')]
312837 04-22T07:08:09.880456+00:00 c5_nec pipelineProcess get_logs_with_metadata 04-04T11:00:00+00:00 anonymous [('dag_id', 'c5_nec'), ('task_id', 'pipelineProcess'), ('execution_date', '2026-04-04T11:00:00+00:00'), ('try_number', '2'), ('metadata', 'null')]
312836 04-22T07:08:05.820822+00:00 c5_nec pipelineProcess log 04-04T11:00:00+00:00 anonymous [('dag_id', 'c5_nec'), ('task_id', 'pipelineProcess'), ('execution_date', '2026-04-04T11:00:00+00:00')]
312835 04-22T07:08:00.739881+00:00 nd201907_site_diary_activity graph 04-06T16:05:00+00:00 anonymous [('dag_id', 'nd201907_site_diary_activity'), ('execution_date', '2026-04-06 16:05:00+00:00')]
312834 04-22T07:07:57.805071+00:00 ssm519-scc getPaymentStatistics task 04-12T07:00:00+00:00 anonymous [('dag_id', 'ssm519-scc'), ('execution_date', '2026-04-12T07:00:00+00:00'), ('task_id', 'getPaymentStatistics')]
312833 04-22T07:07:49.906780+00:00 dc202106_nec pipelineProcess rendered 04-11T11:00:00+00:00 anonymous [('dag_id', 'dc202106_nec'), ('execution_date', '2026-04-11T11:00:00+00:00'), ('task_id', 'pipelineProcess')]
312832 04-22T07:07:48.837718+00:00 cv202302_nec graph 04-04T11:00:00+00:00 anonymous [('dag_id', 'cv202302_nec'), ('root', 'pipelineProcess'), ('execution_date', '2026-04-04T11:00:00+00:00')]
312831 04-22T07:07:44.128668+00:00 nd201905_kpi getCNCEData success 04-21T15:00:00+00:00 airflow
312830 04-22T07:07:42.809209+00:00 yl_c2_nec graph 04-06T05:15:00+00:00 anonymous [('dag_id', 'yl_c2_nec'), ('execution_date', '2026-04-06 05:15:00+00:00')]
312829 04-22T07:07:41.181230+00:00 dc202106_cleaning landing_times anonymous [('dag_id', 'dc202106_cleaning'), ('days', '30'), ('root', '')]
312828 04-22T07:07:14.297572+00:00 1test__nec_c4_icwp_july getDataAndSendToPSQL task 04-05T00:00:00+00:00 anonymous [('dag_id', '1test__nec_c4_icwp_july'), ('task_id', 'getDataAndSendToPSQL'), ('execution_date', '2026-04-05T00:00:00+00:00')]
312827 04-22T07:07:07.171705+00:00 1nec_6wsd21_icwps graph 04-06T09:00:00+00:00 anonymous [('dag_id', '1nec_6wsd21_icwps'), ('execution_date', '2026-04-06 09:00:00+00:00')]
312826 04-22T07:06:58.327537+00:00 cv202303_nec getDrowToken task 04-09T08:00:00+00:00 anonymous [('dag_id', 'cv202303_nec'), ('execution_date', '2026-04-09T08:00:00+00:00'), ('task_id', 'getDrowToken')]
312825 04-22T07:06:57.174762+00:00 cv202211_payment_excel getDataAndSendToPSQL task 04-05T00:00:00+00:00 anonymous [('dag_id', 'cv202211_payment_excel'), ('task_id', 'getDataAndSendToPSQL'), ('execution_date', '2026-04-05T00:00:00+00:00')]
312824 04-22T07:06:54.129447+00:00 nd201907_icwp_safety_data getMongoDB task 04-09T10:00:00+00:00 anonymous [('dag_id', 'nd201907_icwp_safety_data'), ('execution_date', '2026-04-09T10:00:00+00:00'), ('task_id', 'getMongoDB')]
312823 04-22T07:06:49.795040+00:00 ssh505-scc landing_times anonymous [('dag_id', 'ssh505-scc'), ('days', '30'), ('root', 'getDisallowedCostSummary')]
312822 04-22T07:06:49.353393+00:00 5WSD_TOMS__financial_data graph 04-06T06:00:00+00:00 anonymous [('dag_id', '5WSD_TOMS__financial_data'), ('run_id', 'scheduled__2026-04-06T06:00:00+00:00'), ('execution_date', '2026-04-06 06:00:00+00:00')]
312821 04-22T07:06:45.961295+00:00 ssh505-scc tries anonymous [('dag_id', 'ssh505-scc'), ('days', '30'), ('root', 'getDisallowedCostSummary')]
312820 04-22T07:06:33.922650+00:00 dc202312_nec pipelineProcess rendered 04-10T04:00:00+00:00 anonymous [('dag_id', 'dc202312_nec'), ('execution_date', '2026-04-10T04:00:00+00:00'), ('task_id', 'pipelineProcess')]
312819 04-22T07:06:26.369066+00:00 c5_nec pipelineProcess log 04-13T16:00:00+00:00 anonymous [('dag_id', 'c5_nec'), ('execution_date', '2026-04-13T16:00:00+00:00'), ('task_id', 'pipelineProcess')]
312818 04-22T07:06:22.957577+00:00 nec_c4 getDataAndSendToPSQL task 04-05T00:00:00+00:00 anonymous [('dag_id', 'nec_c4'), ('task_id', 'getDataAndSendToPSQL'), ('execution_date', '2026-04-05T00:00:00+00:00')]
312816 04-22T07:06:15.644363+00:00 dc202312_nec pipelineProcess get_logs_with_metadata 04-05T00:00:00+00:00 anonymous [('dag_id', 'dc202312_nec'), ('task_id', 'pipelineProcess'), ('execution_date', '2026-04-05T00:00:00+00:00'), ('try_number', '1'), ('metadata', 'null')]
312817 04-22T07:06:15.642943+00:00 5wsd21_labour_return getMongoDB success 04-21T15:00:00+00:00 airflow
312815 04-22T07:06:13.725581+00:00 c6_nec pipelineProcess log 04-12T00:00:00+00:00 anonymous [('dag_id', 'c6_nec'), ('execution_date', '2026-04-12T00:00:00+00:00'), ('task_id', 'pipelineProcess')]
312814 04-22T07:06:13.717504+00:00 c2_nec graph 04-06T08:00:00+00:00 anonymous [('dag_id', 'c2_nec'), ('execution_date', '2026-04-06 08:00:00+00:00')]
312813 04-22T07:06:10.200650+00:00 ssh505-scc gantt anonymous [('dag_id', 'ssh505-scc'), ('root', 'getDisallowedCostSummary')]
312812 04-22T07:06:06.135804+00:00 cv202308_site_diary_activity graph 03-25T15:00:00+00:00 anonymous [('dag_id', 'cv202308_site_diary_activity'), ('execution_date', '2026-03-25 15:00:00+00:00')]
312811 04-22T07:06:05.857142+00:00 dc202312_nec pipelineProcess log 04-05T00:00:00+00:00 anonymous [('dag_id', 'dc202312_nec'), ('task_id', 'pipelineProcess'), ('execution_date', '2026-04-05T00:00:00+00:00')]
312810 04-22T07:06:00.059709+00:00 1test__nec_c4_icwp_july graph 04-06T08:00:00+00:00 anonymous [('dag_id', '1test__nec_c4_icwp_july'), ('run_id', 'scheduled__2026-04-06T08:00:00+00:00'), ('execution_date', '2026-04-06 08:00:00+00:00')]
312809 04-22T07:05:57.740987+00:00 5wsd21_site_diary_activity graph 04-11T15:00:00+00:00 anonymous [('dag_id', '5wsd21_site_diary_activity'), ('execution_date', '2026-04-11T15:00:00+00:00'), ('root', 'getSecondAction')]
312808 04-22T07:05:53.977557+00:00 c4_financial_data getDrowToken task 04-12T00:00:00+00:00 anonymous [('dag_id', 'c4_financial_data'), ('execution_date', '2026-04-12T00:00:00+00:00'), ('task_id', 'getDrowToken')]
312807 04-22T07:05:50.102747+00:00 c2_nec graph 04-09T04:00:00+00:00 anonymous [('dag_id', 'c2_nec'), ('execution_date', '2026-04-09 04:00:00+00:00'), ('run_id', 'scheduled__2026-04-09T04:00:00+00:00')]
312806 04-22T07:05:46.496971+00:00 dc202106_cleaning graph 04-08T15:00:00+00:00 anonymous [('dag_id', 'dc202106_cleaning'), ('execution_date', '2026-04-08 15:00:00+00:00')]
312805 04-22T07:05:43.709531+00:00 c4_nec_risk_reg graph 04-05T00:00:00+00:00 anonymous [('dag_id', 'c4_nec_risk_reg'), ('root', 'pipelineProcess'), ('execution_date', '2026-04-05T00:00:00+00:00')]
312804 04-22T07:05:37.960635+00:00 c1_nec graph 04-12T00:00:00+00:00 anonymous [('dag_id', 'c1_nec'), ('execution_date', '2026-04-12 00:00:00+00:00')]
312803 04-22T07:05:34.866869+00:00 6wsd21_safety_walk getMongoDB success 04-21T07:00:00+00:00 airflow
312802 04-22T07:05:34.479353+00:00 5wsd21_site_diary_activity graph 04-09T15:00:00+00:00 anonymous [('dag_id', '5wsd21_site_diary_activity'), ('execution_date', '2026-04-09T15:00:00+00:00'), ('root', 'getDrowToken')]
312801 04-22T07:05:27.282333+00:00 _6wsd21_edms_nec graph 04-05T04:00:00+00:00 anonymous [('dag_id', '_6wsd21_edms_nec'), ('execution_date', '2026-04-05 04:00:00+00:00')]
312800 04-22T07:05:21.988073+00:00 c3_nec graph 04-09T11:00:00+00:00 anonymous [('dag_id', 'c3_nec'), ('execution_date', '2026-04-09 11:00:00+00:00')]
312799 04-22T07:05:20.257495+00:00 _6wsd21_edms_nec graph 04-06T08:00:00+00:00 anonymous [('dag_id', '_6wsd21_edms_nec'), ('run_id', 'scheduled__2026-04-06T08:00:00+00:00'), ('execution_date', '2026-04-06 08:00:00+00:00')]
312798 04-22T07:05:18.467065+00:00 cv202303_icwp_safety_data graph 04-11T15:00:00+00:00 anonymous [('dag_id', 'cv202303_icwp_safety_data'), ('execution_date', '2026-04-11 15:00:00+00:00')]
312797 04-22T07:05:17.348601+00:00 nd201907_inspection getMongoDB get_logs_with_metadata 04-04T16:35:00+00:00 anonymous [('dag_id', 'nd201907_inspection'), ('task_id', 'getMongoDB'), ('execution_date', '2026-04-04T16:35:00+00:00'), ('try_number', '1'), ('metadata', 'null')]
312796 04-22T07:05:14.530347+00:00 nd201907_inspection getMongoDB log 04-04T16:35:00+00:00 anonymous [('dag_id', 'nd201907_inspection'), ('task_id', 'getMongoDB'), ('execution_date', '2026-04-04T16:35:00+00:00')]
312795 04-22T07:05:14.178879+00:00 hy202308_site_diary_activity graph 04-11T15:00:00+00:00 anonymous [('dag_id', 'hy202308_site_diary_activity'), ('execution_date', '2026-04-11 15:00:00+00:00')]
312794 04-22T07:05:10.157281+00:00 nec_section_of_work graph 04-03T04:00:00+00:00 anonymous [('dag_id', 'nec_section_of_work'), ('execution_date', '2026-04-03 04:00:00+00:00')]
312793 04-22T07:05:07.261295+00:00 5wsd21_icwp_safety_data graph 04-08T15:00:00+00:00 anonymous [('dag_id', '5wsd21_icwp_safety_data'), ('execution_date', '2026-04-08 15:00:00+00:00')]
312792 04-22T07:05:03.092338+00:00 nd201907_cleaning graph 04-06T04:00:00+00:00 anonymous [('dag_id', 'nd201907_cleaning'), ('execution_date', '2026-04-06 04:00:00+00:00')]
312791 04-22T07:05:01.770423+00:00 5WSD_TOMS__financial_data graph 04-09T06:00:00+00:00 anonymous [('dag_id', '5WSD_TOMS__financial_data'), ('execution_date', '2026-04-09 06:00:00+00:00')]
312790 04-22T07:04:57.702727+00:00 5wsd21_site_diary_activity graph 04-09T07:00:00+00:00 anonymous [('dag_id', '5wsd21_site_diary_activity'), ('execution_date', '2026-04-09 07:00:00+00:00')]
312789 04-22T07:04:57.422038+00:00 c5_nec_report_copy graph 04-21T04:00:00+00:00 anonymous [('dag_id', 'c5_nec_report_copy'), ('root', 'getDrowToken'), ('execution_date', '2026-04-21T04:00:00+00:00')]
312788 04-22T07:04:56.432277+00:00 nd201905_kpi getCNCEData cli_run 04-21T15:00:00+00:00 airflow {"host_name": "7cdf3beeecfc", "full_command": "['/usr/local/bin/airflow', 'run', 'nd201905_kpi', 'getCNCEData', '2026-04-21T15:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/nd201905_kpi.py']"}
312787 04-22T07:04:56.338548+00:00 nd201905_kpi getCNCEData running 04-21T15:00:00+00:00 airflow
312786 04-22T07:04:55.138833+00:00 nd201905_kpi getCNCEData cli_run 04-21T15:00:00+00:00 airflow {"host_name": "7cdf3beeecfc", "full_command": "['/usr/local/bin/airflow', 'run', 'nd201905_kpi', 'getCNCEData', '2026-04-21T15:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/nd201905_kpi.py']"}
312785 04-22T07:04:53.813227+00:00 c2_nec graph 03-25T16:00:00+00:00 anonymous [('dag_id', 'c2_nec'), ('execution_date', '2026-03-25 16:00:00+00:00'), ('run_id', 'scheduled__2026-03-25T16:00:00+00:00')]
312784 04-22T07:04:50.158238+00:00 1test__nec_c4_icwp_june graph 04-08T00:00:00+00:00 anonymous [('dag_id', '1test__nec_c4_icwp_june'), ('execution_date', '2026-04-08 00:00:00+00:00')]
312783 04-22T07:04:45.904148+00:00 1nec_6wsd21_icwps graph 04-06T01:00:00+00:00 anonymous [('dag_id', '1nec_6wsd21_icwps'), ('execution_date', '2026-04-06 01:00:00+00:00')]
312782 04-22T07:04:42.533394+00:00 cv202302_cleaning graph 03-25T15:00:00+00:00 anonymous [('dag_id', 'cv202302_cleaning'), ('execution_date', '2026-03-25 15:00:00+00:00'), ('run_id', 'scheduled__2026-03-25T15:00:00+00:00')]
312781 04-22T07:04:40.321390+00:00 cv202309_nec graph 04-05T00:00:00+00:00 anonymous [('dag_id', 'cv202309_nec'), ('execution_date', '2026-04-05 00:00:00+00:00')]
312780 04-22T07:04:38.517292+00:00 1nec_1wsd19_icwps graph 04-11T01:00:00+00:00 anonymous [('dag_id', '1nec_1wsd19_icwps'), ('execution_date', '2026-04-11 01:00:00+00:00')]
312779 04-22T07:04:33.817699+00:00 yl_c2_nec graph 04-05T03:15:00+00:00 anonymous [('dag_id', 'yl_c2_nec'), ('execution_date', '2026-04-05 03:15:00+00:00')]
312778 04-22T07:04:30.171160+00:00 c1_nec graph 04-06T08:00:00+00:00 anonymous [('dag_id', 'c1_nec'), ('run_id', 'scheduled__2026-04-06T08:00:00+00:00'), ('execution_date', '2026-04-06 08:00:00+00:00')]
312777 04-22T07:04:29.991410+00:00 dc202312_nec graph 04-11T16:00:00+00:00 anonymous [('dag_id', 'dc202312_nec'), ('execution_date', '2026-04-11 16:00:00+00:00')]
312776 04-22T07:04:26.744764+00:00 c7_nec getDrowToken task 04-19T11:00:00+00:00 anonymous [('dag_id', 'c7_nec'), ('task_id', 'getDrowToken'), ('execution_date', '2026-04-19T11:00:00+00:00')]
312775 04-22T07:04:25.697655+00:00 c5_nec graph 04-12T11:00:00+00:00 anonymous [('dag_id', 'c5_nec'), ('execution_date', '2026-04-12 11:00:00+00:00'), ('run_id', 'scheduled__2026-04-12T11:00:00+00:00')]
312774 04-22T07:04:21.999958+00:00 5wsd21_risc_icwp_inspection graph 04-11T15:00:00+00:00 anonymous [('dag_id', '5wsd21_risc_icwp_inspection'), ('execution_date', '2026-04-11 15:00:00+00:00')]
312773 04-22T07:04:18.749276+00:00 c2_nec graph 04-12T00:00:00+00:00 anonymous [('dag_id', 'c2_nec'), ('execution_date', '2026-04-12 00:00:00+00:00')]
312772 04-22T07:04:13.721265+00:00 cv202303_nec graph 04-09T00:00:00+00:00 anonymous [('dag_id', 'cv202303_nec'), ('execution_date', '2026-04-09 00:00:00+00:00')]
312771 04-22T07:04:12.555589+00:00 ssh505-scc graph 04-06T07:00:00+00:00 anonymous [('dag_id', 'ssh505-scc'), ('run_id', 'scheduled__2026-04-06T07:00:00+00:00'), ('execution_date', '2026-04-06 07:00:00+00:00')]
312770 04-22T07:04:10.091568+00:00 1wsd19_safety_walk graph 04-08T15:00:00+00:00 anonymous [('dag_id', '1wsd19_safety_walk'), ('execution_date', '2026-04-08 15:00:00+00:00')]
312769 04-22T07:04:09.217178+00:00 5wsd21_cleaning getMongoDB success 04-21T15:00:00+00:00 airflow
312768 04-22T07:04:05.869348+00:00 hy202308_icwp_safety_data graph 04-11T15:00:00+00:00 anonymous [('dag_id', 'hy202308_icwp_safety_data'), ('execution_date', '2026-04-11 15:00:00+00:00'), ('run_id', 'scheduled__2026-04-11T15:00:00+00:00')]
312767 04-22T07:04:05.756324+00:00 nd201905_kpi getCEImplementationData success 04-21T15:00:00+00:00 airflow
312766 04-22T07:04:04.624216+00:00 nd201905_kpi getCEImplementationData cli_run 04-21T15:00:00+00:00 airflow {"host_name": "c8820bd82d81", "full_command": "['/usr/local/bin/airflow', 'run', 'nd201905_kpi', 'getCEImplementationData', '2026-04-21T15:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/nd201905_kpi.py']"}
312765 04-22T07:04:04.429102+00:00 nd201905_kpi getCEImplementationData running 04-21T15:00:00+00:00 airflow
312764 04-22T07:04:03.165212+00:00 sd201903_cleaning graph 04-03T15:00:00+00:00 anonymous [('dag_id', 'sd201903_cleaning'), ('execution_date', '2026-04-03 15:00:00+00:00')]
312763 04-22T07:04:02.942251+00:00 nd201905_kpi getCEImplementationData cli_run 04-21T15:00:00+00:00 airflow {"host_name": "c8820bd82d81", "full_command": "['/usr/local/bin/airflow', 'run', 'nd201905_kpi', 'getCEImplementationData', '2026-04-21T15:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/nd201905_kpi.py']"}
312762 04-22T07:03:57.844320+00:00 5wsd21_risc_icwp_inspection graph 04-08T15:00:00+00:00 anonymous [('dag_id', '5wsd21_risc_icwp_inspection'), ('execution_date', '2026-04-08 15:00:00+00:00')]
312761 04-22T07:03:54.223022+00:00 6wsd21_cleaning getMongoDB success 04-21T07:00:00+00:00 airflow
312760 04-22T07:03:54.177662+00:00 5wsd21_safety_walk_old_record getMongoDB success 04-21T15:00:00+00:00 airflow
312759 04-22T07:03:48.983006+00:00 yl_c2_nec pipelineProcess task 04-05T03:15:00+00:00 anonymous [('dag_id', 'yl_c2_nec'), ('task_id', 'pipelineProcess'), ('execution_date', '2026-04-05T03:15:00+00:00')]
312758 04-22T07:03:44.683667+00:00 hy202308_itp_dashboard getInspectionData success 04-21T15:00:00+00:00 airflow
312757 04-22T07:03:42.073981+00:00 nd201907_icwp_safety_data getMongoDB get_logs_with_metadata 04-04T16:00:00+00:00 anonymous [('dag_id', 'nd201907_icwp_safety_data'), ('task_id', 'getMongoDB'), ('execution_date', '2026-04-04T16:00:00+00:00'), ('try_number', '1'), ('metadata', 'null')]
312756 04-22T07:03:37.404379+00:00 c6_nec graph 04-06T08:00:00+00:00 anonymous [('dag_id', 'c6_nec'), ('execution_date', '2026-04-06 08:00:00+00:00')]
312755 04-22T07:03:31.873407+00:00 nd201907_icwp_safety_data getMongoDB log 04-04T16:00:00+00:00 anonymous [('dag_id', 'nd201907_icwp_safety_data'), ('task_id', 'getMongoDB'), ('execution_date', '2026-04-04T16:00:00+00:00')]
312754 04-22T07:03:30.183389+00:00 c4_nec_risk_reg pipelineProcess task 04-09T16:00:00+00:00 anonymous [('dag_id', 'c4_nec_risk_reg'), ('execution_date', '2026-04-09T16:00:00+00:00'), ('task_id', 'pipelineProcess')]
312753 04-22T07:03:20.860635+00:00 5wsd21_cleaning graph 04-06T07:00:00+00:00 anonymous [('dag_id', '5wsd21_cleaning'), ('run_id', 'scheduled__2026-04-06T07:00:00+00:00'), ('execution_date', '2026-04-06 07:00:00+00:00')]
312752 04-22T07:03:14.699446+00:00 5wsd21_safety_walk getMongoDB success 04-21T15:00:00+00:00 airflow
312751 04-22T07:03:05.765473+00:00 1wsd19_risc_icwp_inspection getMongoDB task 04-06T15:00:00+00:00 anonymous [('dag_id', '1wsd19_risc_icwp_inspection'), ('execution_date', '2026-04-06T15:00:00+00:00'), ('task_id', 'getMongoDB')]
312750 04-22T07:03:04.004371+00:00 nd201905_kpi getRiskRegisterData success 04-21T15:00:00+00:00 airflow
312749 04-22T07:03:02.633776+00:00 nd201907_cleaning getMongoDB get_logs_with_metadata 04-04T16:00:00+00:00 anonymous [('dag_id', 'nd201907_cleaning'), ('task_id', 'getMongoDB'), ('execution_date', '2026-04-04T16:00:00+00:00'), ('try_number', '1'), ('metadata', 'null')]
312748 04-22T07:03:01.683120+00:00 nd201905_kpi getRiskRegisterData cli_run 04-21T15:00:00+00:00 airflow {"host_name": "7cdf3beeecfc", "full_command": "['/usr/local/bin/airflow', 'run', 'nd201905_kpi', 'getRiskRegisterData', '2026-04-21T15:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/nd201905_kpi.py']"}