Logs


Id Dttm Dag Id Task Id Event Execution Date Owner Extra
2649145 06-12T08:29:52.665528+00:00 6wsd21_cleaning graph 2024-09-10T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-09-10T07:00:00+00:00')]
2649116 06-12T08:28:12.383810+00:00 6wsd21_cleaning graph 2024-09-13T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-09-13T07:00:00+00:00')]
2649093 06-12T08:27:20.782571+00:00 6wsd21_cleaning graph 2024-08-06T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-08-06 07:00:00+00:00')]
2649052 06-12T08:24:56.645946+00:00 6wsd21_cleaning graph 2024-09-18T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-09-18T07:00:00+00:00')]
2647819 06-12T07:32:50.182899+00:00 6wsd21_cleaning tree anonymous [('dag_id', '6wsd21_cleaning'), ('num_runs', ''), ('root', '')]
2647688 06-12T07:23:55.125989+00:00 6wsd21_cleaning graph 03-25T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2025-03-25 07:00:00+00:00')]
2647514 06-12T07:15:18.199596+00:00 6wsd21_cleaning graph 2024-11-25T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-11-25 07:00:00+00:00')]
2647376 06-12T07:08:49.934148+00:00 6wsd21_cleaning getMongoDB success 06-11T07:00:00+00:00 airflow
2647356 06-12T07:08:03.243917+00:00 6wsd21_cleaning getMongoDB cli_run 06-11T07:00:00+00:00 airflow {"host_name": "63fbafbc3109", "full_command": "['/usr/local/bin/airflow', 'run', '6wsd21_cleaning', 'getMongoDB', '2025-06-11T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/6wsd21_cleaning.py']"}
2647354 06-12T07:08:03.113977+00:00 6wsd21_cleaning getMongoDB running 06-11T07:00:00+00:00 airflow
2647346 06-12T07:08:02.477982+00:00 6wsd21_cleaning getMongoDB cli_run 06-11T07:00:00+00:00 airflow {"host_name": "63fbafbc3109", "full_command": "['/usr/local/bin/airflow', 'run', '6wsd21_cleaning', 'getMongoDB', '2025-06-11T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/6wsd21_cleaning.py']"}
2647323 06-12T07:07:05.064509+00:00 6wsd21_cleaning getDrowToken success 06-11T07:00:00+00:00 airflow
2647322 06-12T07:07:04.690632+00:00 6wsd21_cleaning getDrowToken cli_run 06-11T07:00:00+00:00 airflow {"host_name": "63fbafbc3109", "full_command": "['/usr/local/bin/airflow', 'run', '6wsd21_cleaning', 'getDrowToken', '2025-06-11T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/6wsd21_cleaning.py']"}
2647321 06-12T07:07:04.622461+00:00 6wsd21_cleaning getDrowToken running 06-11T07:00:00+00:00 airflow
2647320 06-12T07:07:04.275613+00:00 6wsd21_cleaning getDrowToken cli_run 06-11T07:00:00+00:00 airflow {"host_name": "63fbafbc3109", "full_command": "['/usr/local/bin/airflow', 'run', '6wsd21_cleaning', 'getDrowToken', '2025-06-11T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/6wsd21_cleaning.py']"}
2647302 06-12T07:06:09.768267+00:00 6wsd21_cleaning create_table_task success 06-11T07:00:00+00:00 airflow
2647301 06-12T07:06:09.356828+00:00 6wsd21_cleaning create_table_task cli_run 06-11T07:00:00+00:00 airflow {"host_name": "63fbafbc3109", "full_command": "['/usr/local/bin/airflow', 'run', '6wsd21_cleaning', 'create_table_task', '2025-06-11T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/6wsd21_cleaning.py']"}
2647300 06-12T07:06:09.305946+00:00 6wsd21_cleaning create_table_task running 06-11T07:00:00+00:00 airflow
2647299 06-12T07:06:08.738441+00:00 6wsd21_cleaning create_table_task cli_run 06-11T07:00:00+00:00 airflow {"host_name": "63fbafbc3109", "full_command": "['/usr/local/bin/airflow', 'run', '6wsd21_cleaning', 'create_table_task', '2025-06-11T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/6wsd21_cleaning.py']"}
2647108 06-12T07:00:28.699874+00:00 6wsd21_cleaning create_table_task failed 06-11T07:00:00+00:00 airflow
2647107 06-12T07:00:28.603755+00:00 6wsd21_cleaning create_table_task cli_run 06-11T07:00:00+00:00 airflow {"host_name": "63fbafbc3109", "full_command": "['/usr/local/bin/airflow', 'run', '6wsd21_cleaning', 'create_table_task', '2025-06-11T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/6wsd21_cleaning.py']"}
2647106 06-12T07:00:28.529656+00:00 6wsd21_cleaning create_table_task running 06-11T07:00:00+00:00 airflow
2647105 06-12T07:00:28.034656+00:00 6wsd21_cleaning create_table_task cli_run 06-11T07:00:00+00:00 airflow {"host_name": "63fbafbc3109", "full_command": "['/usr/local/bin/airflow', 'run', '6wsd21_cleaning', 'create_table_task', '2025-06-11T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/6wsd21_cleaning.py']"}
2645939 06-12T05:02:13.884954+00:00 6wsd21_cleaning graph 2024-11-23T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-11-23 07:00:00+00:00')]
2645931 06-12T05:01:44.176678+00:00 6wsd21_cleaning duration anonymous [('dag_id', '6wsd21_cleaning')]
2644611 06-12T03:05:12.445431+00:00 6wsd21_cleaning graph 2023-12-29T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2023-12-29 07:00:00+00:00')]
2644586 06-12T03:02:53.699729+00:00 6wsd21_cleaning graph 2024-10-29T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-10-29 07:00:00+00:00')]
2644513 06-12T02:54:25.113913+00:00 6wsd21_cleaning graph 2023-10-25T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2023-10-25 07:00:00+00:00')]
2644477 06-12T02:51:06.752643+00:00 6wsd21_cleaning graph 2024-01-24T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-01-24 07:00:00+00:00')]
2644451 06-12T02:47:56.968607+00:00 6wsd21_cleaning graph 2023-11-09T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2023-11-09 07:00:00+00:00')]
2644425 06-12T02:44:50.838792+00:00 6wsd21_cleaning graph 2023-11-01T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2023-11-01 07:00:00+00:00')]
2644386 06-12T02:40:54.400425+00:00 6wsd21_cleaning graph 2023-10-23T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2023-10-23 07:00:00+00:00')]
2644242 06-12T02:25:42.381123+00:00 6wsd21_cleaning graph 2024-10-29T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-10-29T07:00:00+00:00'), ('root', 'getDrowToken')]
2644173 06-12T02:17:59.937801+00:00 6wsd21_cleaning getDrowToken log 2024-10-29T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-10-29T07:00:00+00:00'), ('task_id', 'getDrowToken')]
2644035 06-12T02:03:48.725084+00:00 6wsd21_cleaning getDrowToken task 2024-10-29T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-10-29T07:00:00+00:00'), ('task_id', 'getDrowToken')]
2642127 06-12T00:29:57.493198+00:00 6wsd21_cleaning graph 01-21T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2025-01-21 07:00:00+00:00')]
2641636 06-12T00:23:04.152459+00:00 6wsd21_cleaning graph 04-20T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2025-04-20 07:00:00+00:00')]
2641446 06-12T00:19:16.410371+00:00 6wsd21_cleaning graph 2024-12-17T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-12-17 07:00:00+00:00')]
2641354 06-12T00:18:23.991810+00:00 6wsd21_cleaning graph 01-14T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2025-01-14T07:00:00+00:00')]
2641335 06-12T00:18:21.396008+00:00 6wsd21_cleaning graph 2024-11-21T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-11-21 07:00:00+00:00')]
2641317 06-12T00:17:27.871383+00:00 6wsd21_cleaning graph 01-22T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2025-01-22T07:00:00+00:00')]
2641234 06-12T00:16:37.023712+00:00 6wsd21_cleaning graph 01-23T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2025-01-23T07:00:00+00:00')]
2641164 06-12T00:15:45.430615+00:00 6wsd21_cleaning graph 2024-12-15T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-12-15 07:00:00+00:00')]
2641069 06-12T00:14:04.839880+00:00 6wsd21_cleaning graph 2024-11-12T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-11-12 07:00:00+00:00')]
2640970 06-12T00:13:13.117875+00:00 6wsd21_cleaning graph 2024-11-22T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-11-22 07:00:00+00:00')]
2640966 06-12T00:13:12.983819+00:00 6wsd21_cleaning graph 2023-12-19T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2023-12-19 07:00:00+00:00')]
2640951 06-12T00:12:24.888898+00:00 6wsd21_cleaning graph 2023-12-20T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2023-12-20 07:00:00+00:00')]
2640870 06-12T00:11:33.216555+00:00 6wsd21_cleaning graph 2023-11-14T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2023-11-14 07:00:00+00:00')]
2640815 06-12T00:10:41.279862+00:00 6wsd21_cleaning graph 2024-10-30T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-10-30 07:00:00+00:00')]
2640558 06-12T00:07:03.751352+00:00 6wsd21_cleaning graph 2024-08-15T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-08-15 07:00:00+00:00')]
2640525 06-12T00:06:16.342602+00:00 6wsd21_cleaning graph 2024-10-03T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-10-03 07:00:00+00:00')]
2640523 06-12T00:06:16.161238+00:00 6wsd21_cleaning graph 2024-11-04T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-11-04 07:00:00+00:00')]
2640485 06-12T00:06:12.984422+00:00 6wsd21_cleaning graph 2024-09-19T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-09-19 07:00:00+00:00')]
2640447 06-12T00:05:23.500637+00:00 6wsd21_cleaning graph 2024-01-14T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-01-14 07:00:00+00:00')]
2640405 06-12T00:04:36.876921+00:00 6wsd21_cleaning graph 2024-09-25T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-09-25 07:00:00+00:00')]
2640280 06-12T00:03:37.119761+00:00 6wsd21_cleaning graph 2024-02-22T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-02-22 07:00:00+00:00')]
2640233 06-12T00:02:50.251096+00:00 6wsd21_cleaning graph 2024-05-18T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-05-18 07:00:00+00:00')]
2640035 06-12T00:01:13.676972+00:00 6wsd21_cleaning graph 2023-10-09T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2023-10-09 07:00:00+00:00')]
2639443 06-11T23:54:42.333056+00:00 6wsd21_cleaning graph 2024-09-01T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-09-01 07:00:00+00:00')]
2639147 06-11T23:50:40.277099+00:00 6wsd21_cleaning graph 2024-04-23T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-04-23 07:00:00+00:00')]
2638608 06-11T23:09:33.604453+00:00 6wsd21_cleaning graph 2024-09-11T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-09-11T07:00:00+00:00'), ('root', 'getDrowToken')]
2638595 06-11T23:09:32.418095+00:00 6wsd21_cleaning graph 2024-09-10T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-09-10T07:00:00+00:00'), ('root', 'getDrowToken')]
2638074 06-11T23:00:22.976745+00:00 6wsd21_cleaning getDrowToken log 2024-09-11T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-09-11T07:00:00+00:00'), ('task_id', 'getDrowToken')]
2638052 06-11T23:00:20.972117+00:00 6wsd21_cleaning getDrowToken log 2024-09-10T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-09-10T07:00:00+00:00'), ('task_id', 'getDrowToken')]
2637479 06-11T22:49:27.156573+00:00 6wsd21_cleaning getDrowToken task 2024-09-11T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-09-11T07:00:00+00:00'), ('task_id', 'getDrowToken')]
2637476 06-11T22:49:26.882021+00:00 6wsd21_cleaning getDrowToken task 2024-09-10T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-09-10T07:00:00+00:00'), ('task_id', 'getDrowToken')]
2637444 06-11T22:49:23.955162+00:00 6wsd21_cleaning graph 2024-09-10T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-09-10T07:00:00+00:00'), ('root', 'getMongoDB')]
2637443 06-11T22:49:23.863175+00:00 6wsd21_cleaning graph 2024-09-11T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-09-11T07:00:00+00:00'), ('root', 'getMongoDB')]
2637390 06-11T22:48:36.175170+00:00 6wsd21_cleaning getMongoDB log 2024-09-11T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-09-11T07:00:00+00:00'), ('task_id', 'getMongoDB')]
2637388 06-11T22:48:35.994176+00:00 6wsd21_cleaning getMongoDB log 2024-09-10T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-09-10T07:00:00+00:00'), ('task_id', 'getMongoDB')]
2637187 06-11T22:45:37.896388+00:00 6wsd21_cleaning getMongoDB task 2024-09-11T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-09-11T07:00:00+00:00'), ('task_id', 'getMongoDB')]
2637184 06-11T22:45:37.759289+00:00 6wsd21_cleaning getMongoDB task 2024-09-10T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-09-10T07:00:00+00:00'), ('task_id', 'getMongoDB')]
2636144 06-11T16:51:30.302102+00:00 6wsd21_cleaning landing_times anonymous [('dag_id', '6wsd21_cleaning'), ('days', '30')]
2636062 06-11T16:24:24.627313+00:00 6wsd21_cleaning tries anonymous [('dag_id', '6wsd21_cleaning'), ('days', '30')]
2634892 06-11T14:20:44.498556+00:00 6wsd21_cleaning graph 2024-11-17T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-11-17 07:00:00+00:00')]
2634542 06-11T13:34:38.326767+00:00 6wsd21_cleaning graph 2024-10-31T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-10-31 07:00:00+00:00')]
2634435 06-11T13:18:11.975649+00:00 6wsd21_cleaning graph 2024-10-09T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-10-09 07:00:00+00:00')]
2633167 06-11T11:11:06.635210+00:00 6wsd21_cleaning landing_times anonymous [('dag_id', '6wsd21_cleaning'), ('days', '30'), ('root', 'getDrowToken')]
2633166 06-11T11:11:06.523684+00:00 6wsd21_cleaning duration anonymous [('dag_id', '6wsd21_cleaning'), ('days', '30'), ('root', 'getDrowToken')]
2633165 06-11T11:11:06.486870+00:00 6wsd21_cleaning tries anonymous [('dag_id', '6wsd21_cleaning'), ('days', '30'), ('root', 'getDrowToken')]
2633151 06-11T11:09:34.493198+00:00 6wsd21_cleaning duration anonymous [('dag_id', '6wsd21_cleaning'), ('days', '30'), ('root', 'getMongoDB')]
2633150 06-11T11:09:34.443197+00:00 6wsd21_cleaning tries anonymous [('dag_id', '6wsd21_cleaning'), ('days', '30'), ('root', 'getMongoDB')]
2633144 06-11T11:09:33.353530+00:00 6wsd21_cleaning landing_times anonymous [('dag_id', '6wsd21_cleaning'), ('days', '30'), ('root', 'getMongoDB')]
2633139 06-11T11:08:37.344664+00:00 6wsd21_cleaning gantt anonymous [('dag_id', '6wsd21_cleaning'), ('root', 'getDrowToken')]
2632978 06-11T11:01:33.963056+00:00 6wsd21_cleaning gantt anonymous [('dag_id', '6wsd21_cleaning'), ('root', 'getMongoDB')]
2632650 06-11T10:51:10.498696+00:00 6wsd21_cleaning graph 03-28T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2025-03-28 07:00:00+00:00')]
2632612 06-11T10:48:49.615190+00:00 6wsd21_cleaning graph 01-15T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2025-01-15 07:00:00+00:00')]
2632586 06-11T10:47:19.108596+00:00 6wsd21_cleaning graph 01-14T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2025-01-14 07:00:00+00:00')]
2632577 06-11T10:46:35.481747+00:00 6wsd21_cleaning graph 01-20T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2025-01-20 07:00:00+00:00')]
2632526 06-11T10:44:17.213120+00:00 6wsd21_cleaning graph 02-25T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2025-02-25 07:00:00+00:00')]
2632372 06-11T10:35:30.311454+00:00 6wsd21_cleaning graph 01-19T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2025-01-19T07:00:00+00:00')]
2632348 06-11T10:34:46.082932+00:00 6wsd21_cleaning graph 2023-11-29T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2023-11-29 07:00:00+00:00')]
2632331 06-11T10:33:54.786923+00:00 6wsd21_cleaning graph 04-09T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2025-04-09 07:00:00+00:00')]
2632197 06-11T10:25:21.597353+00:00 6wsd21_cleaning graph 2024-10-10T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-10-10 07:00:00+00:00')]
2631863 06-11T10:04:57.638953+00:00 6wsd21_cleaning tree anonymous [('dag_id', '6wsd21_cleaning'), ('root', 'getMongoDB')]
2631724 06-11T09:59:02.539627+00:00 6wsd21_cleaning graph 2024-05-23T07:00:00+00:00 anonymous [('dag_id', '6wsd21_cleaning'), ('execution_date', '2024-05-23 07:00:00+00:00')]
2631242 06-11T09:26:18.012361+00:00 6wsd21_cleaning landing_times anonymous [('dag_id', '6wsd21_cleaning')]
2631238 06-11T09:26:17.773932+00:00 6wsd21_cleaning tries anonymous [('dag_id', '6wsd21_cleaning')]
2631236 06-11T09:26:17.062718+00:00 6wsd21_cleaning duration anonymous [('dag_id', '6wsd21_cleaning')]
2631032 06-11T09:05:06.397125+00:00 6wsd21_cleaning graph anonymous [('dag_id', '6wsd21_cleaning')]