The scheduler does not appear to be running. Last heartbeat was received .

The DAGs list may not update, and new tasks will not be scheduled.

Logs

Reset Filters
Id Dttm Dag Id Task Id Event Execution Date Owner Extra
1786466 2023-11-10T15:44:21.314538+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786465 2023-11-10T15:41:56.295651+00:00 exchange-trade-summary_v1_v002 create_emr_steps success 2023-11-10T14:00:00+00:00 data.engineers@viooh.com
1786464 2023-11-10T15:41:54.138168+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 2023-11-10T14:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_emr_steps', '2023-11-10T14:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786463 2023-11-10T15:41:54.135617+00:00 exchange-trade-summary_v1_v002 check_cluster_status cli_run 2023-11-10T13:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'check_cluster_status', '2023-11-10T13:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786461 2023-11-10T15:41:54.083005+00:00 exchange-trade-summary_v1_v002 check_cluster_status running 2023-11-10T13:00:00+00:00 data.engineers@viooh.com
1786462 2023-11-10T15:41:54.082748+00:00 exchange-trade-summary_v1_v002 create_emr_steps running 2023-11-10T14:00:00+00:00 data.engineers@viooh.com
1786460 2023-11-10T15:41:53.206411+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 2023-11-10T14:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_emr_steps', '2023-11-10T14:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786459 2023-11-10T15:41:53.174364+00:00 exchange-trade-summary_v1_v002 check_cluster_status cli_run 2023-11-10T13:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'check_cluster_status', '2023-11-10T13:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786458 2023-11-10T15:41:33.518760+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps success 2023-11-10T13:00:00+00:00 data.engineers@viooh.com
1786457 2023-11-10T15:41:32.536875+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 2023-11-10T13:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_cluster_and_add_emr_steps', '2023-11-10T13:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786456 2023-11-10T15:41:32.499484+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps running 2023-11-10T13:00:00+00:00 data.engineers@viooh.com
1786455 2023-11-10T15:41:31.926726+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 2023-11-10T13:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_cluster_and_add_emr_steps', '2023-11-10T13:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786454 2023-11-10T15:41:08.980296+00:00 exchange-trade-summary_v1_v002 check_cluster_status success 2023-11-10T12:00:00+00:00 data.engineers@viooh.com
1786445 2023-11-10T15:25:40.843691+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786444 2023-11-10T15:17:48.766733+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786443 2023-11-10T15:17:40.853353+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786442 2023-11-10T15:17:07.646563+00:00 exchange-trade-summary_v1_v002 create_emr_steps success 2023-11-10T13:00:00+00:00 data.engineers@viooh.com
1786441 2023-11-10T15:17:05.475183+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 2023-11-10T13:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_emr_steps', '2023-11-10T13:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786440 2023-11-10T15:17:05.474044+00:00 exchange-trade-summary_v1_v002 check_cluster_status cli_run 2023-11-10T12:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'check_cluster_status', '2023-11-10T12:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786439 2023-11-10T15:17:05.445346+00:00 exchange-trade-summary_v1_v002 create_emr_steps running 2023-11-10T13:00:00+00:00 data.engineers@viooh.com
1786438 2023-11-10T15:17:05.429665+00:00 exchange-trade-summary_v1_v002 check_cluster_status running 2023-11-10T12:00:00+00:00 data.engineers@viooh.com
1786437 2023-11-10T15:17:04.581221+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 2023-11-10T13:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_emr_steps', '2023-11-10T13:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786436 2023-11-10T15:17:04.559683+00:00 exchange-trade-summary_v1_v002 check_cluster_status cli_run 2023-11-10T12:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'check_cluster_status', '2023-11-10T12:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786434 2023-11-10T15:16:42.784881+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps success 2023-11-10T12:00:00+00:00 data.engineers@viooh.com
1786433 2023-11-10T15:16:41.849759+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 2023-11-10T12:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_cluster_and_add_emr_steps', '2023-11-10T12:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786432 2023-11-10T15:16:41.821705+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps running 2023-11-10T12:00:00+00:00 data.engineers@viooh.com
1786431 2023-11-10T15:16:41.243755+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 2023-11-10T12:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_cluster_and_add_emr_steps', '2023-11-10T12:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786426 2023-11-10T15:15:42.395692+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786425 2023-11-10T15:15:42.096660+00:00 exchange-trade-summary_v1_v002 dagrun_success 2023-11-10T11:00:00+00:00 anonymous [('csrf_token', 'ImE3MjhhYmI2NzAwMTZjZjUxZjM5ZjkxMzFjZjkzYWJlZTFmODFjODki.ZU5JHQ.dWAL5q3CArfl8hOJ0U3gpdbpaSk'), ('confirmed', 'true'), ('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2023-11-10T11:00:00+00:00'), ('origin', 'https://airflow.devel.viooh.net.cn/admin/airflow/tree?dag_id=exchange-trade-summary_v1_v002')]
1786424 2023-11-10T15:15:40.980059+00:00 exchange-trade-summary_v1_v002 dagrun_success 2023-11-10T11:00:00+00:00 anonymous [('csrf_token', 'ImE3MjhhYmI2NzAwMTZjZjUxZjM5ZjkxMzFjZjkzYWJlZTFmODFjODki.ZU5JGQ.XMSvXAWb951aIJsZ7prdgipjOX8'), ('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2023-11-10T11:00:00+00:00'), ('origin', 'https://airflow.devel.viooh.net.cn/admin/airflow/tree?dag_id=exchange-trade-summary_v1_v002')]
1786423 2023-11-10T15:15:36.955625+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786422 2023-11-10T15:15:36.599377+00:00 exchange-trade-summary_v1_v002 check_cluster_status success 2023-11-10T11:00:00+00:00 anonymous [('csrf_token', 'ImE3MjhhYmI2NzAwMTZjZjUxZjM5ZjkxMzFjZjkzYWJlZTFmODFjODki.ZU5JFw.ctm7_RzK8OD1x4jqyuhrEWN9W-c'), ('confirmed', 'true'), ('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-11-10T11:00:00+00:00'), ('origin', 'https://airflow.devel.viooh.net.cn/admin/airflow/tree?dag_id=exchange-trade-summary_v1_v002'), ('downstream', 'true'), ('recursive', 'true')]
1786421 2023-11-10T15:15:34.875454+00:00 exchange-trade-summary_v1_v002 check_cluster_status success 2023-11-10T11:00:00+00:00 anonymous [('csrf_token', 'ImE3MjhhYmI2NzAwMTZjZjUxZjM5ZjkxMzFjZjkzYWJlZTFmODFjODki.ZU5JDw.QIF5iJuyYKsTNjUfoCJJQQ95mXw'), ('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-11-10T11:00:00+00:00'), ('origin', 'https://airflow.devel.viooh.net.cn/admin/airflow/tree?dag_id=exchange-trade-summary_v1_v002'), ('downstream', 'true'), ('recursive', 'true')]
1786420 2023-11-10T15:15:27.724841+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786392 2023-11-10T14:44:20.719236+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786387 2023-11-10T14:26:08.812567+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786386 2023-11-10T14:26:06.931200+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786385 2023-11-10T14:26:05.105237+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786384 2023-11-10T14:26:04.052030+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786383 2023-11-10T14:26:01.987176+00:00 exchange-trade-summary_v1_v002 create_emr_steps success 2023-11-10T12:00:00+00:00 data.engineers@viooh.com
1786382 2023-11-10T14:25:59.926278+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786381 2023-11-10T14:25:59.907585+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 2023-11-10T12:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_emr_steps', '2023-11-10T12:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786380 2023-11-10T14:25:59.869617+00:00 exchange-trade-summary_v1_v002 create_emr_steps running 2023-11-10T12:00:00+00:00 data.engineers@viooh.com
1786379 2023-11-10T14:25:59.233642+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 2023-11-10T12:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_emr_steps', '2023-11-10T12:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786378 2023-11-10T14:25:57.619945+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786377 2023-11-10T14:25:40.835414+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps success 2023-11-10T11:00:00+00:00 data.engineers@viooh.com
1786376 2023-11-10T14:25:39.845275+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 2023-11-10T11:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_cluster_and_add_emr_steps', '2023-11-10T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786375 2023-11-10T14:25:39.808043+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps running 2023-11-10T11:00:00+00:00 data.engineers@viooh.com
1786374 2023-11-10T14:25:39.223879+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 2023-11-10T11:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_cluster_and_add_emr_steps', '2023-11-10T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786373 2023-11-10T14:25:20.375694+00:00 exchange-trade-summary_v1_v002 create_emr_steps success 2023-11-10T11:00:00+00:00 data.engineers@viooh.com
1786372 2023-11-10T14:25:19.453017+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786371 2023-11-10T14:25:18.263898+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 2023-11-10T11:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_emr_steps', '2023-11-10T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786370 2023-11-10T14:25:18.217333+00:00 exchange-trade-summary_v1_v002 create_emr_steps running 2023-11-10T11:00:00+00:00 data.engineers@viooh.com
1786369 2023-11-10T14:25:17.528829+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 2023-11-10T11:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_emr_steps', '2023-11-10T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786368 2023-11-10T14:25:15.054915+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786367 2023-11-10T14:25:13.357077+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786366 2023-11-10T14:25:11.438070+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786365 2023-11-10T14:25:07.788869+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786364 2023-11-10T14:25:07.457107+00:00 exchange-trade-summary_v1_v002 check_cluster_status failed 2023-11-10T11:00:00+00:00 anonymous [('csrf_token', 'ImE3MjhhYmI2NzAwMTZjZjUxZjM5ZjkxMzFjZjkzYWJlZTFmODFjODki.ZU49Qg.AOWzMM5jayNqimbbnOzp_qyVKTM'), ('confirmed', 'true'), ('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-11-10T11:00:00+00:00'), ('origin', 'https://airflow.devel.viooh.net.cn/admin/airflow/tree?dag_id=exchange-trade-summary_v1_v002'), ('downstream', 'true'), ('recursive', 'true')]
1786363 2023-11-10T14:25:06.454063+00:00 exchange-trade-summary_v1_v002 check_cluster_status failed 2023-11-10T11:00:00+00:00 anonymous [('csrf_token', 'ImE3MjhhYmI2NzAwMTZjZjUxZjM5ZjkxMzFjZjkzYWJlZTFmODFjODki.ZU49Pw.RNU-jM0HTBgXQG_oomLoH8Qe4ZM'), ('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-11-10T11:00:00+00:00'), ('origin', 'https://airflow.devel.viooh.net.cn/admin/airflow/tree?dag_id=exchange-trade-summary_v1_v002'), ('downstream', 'true'), ('recursive', 'true')]
1786362 2023-11-10T14:25:03.457060+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786361 2023-11-10T14:24:25.817360+00:00 exchange-trade-summary_v1_v002 check_cluster_status failed 2023-11-09T20:00:00+00:00 anonymous [('csrf_token', 'ImE3MjhhYmI2NzAwMTZjZjUxZjM5ZjkxMzFjZjkzYWJlZTFmODFjODki.ZU44bQ.cpdSrAekSl6YHpiq4AC7g-HZexA'), ('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-11-09T20:00:00+00:00'), ('origin', 'https://airflow.devel.viooh.net.cn/admin/airflow/tree?dag_id=exchange-trade-summary_v1_v002'), ('downstream', 'true'), ('recursive', 'true')]
1786360 2023-11-10T14:24:20.199421+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786359 2023-11-10T14:19:12.352135+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786342 2023-11-10T14:05:12.080019+00:00 exchange-trade-summary_v1_v002 create_emr_steps success 2023-11-09T21:00:00+00:00 data.engineers@viooh.com
1786341 2023-11-10T14:05:10.058623+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 2023-11-09T21:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_emr_steps', '2023-11-09T21:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786340 2023-11-10T14:05:10.027905+00:00 exchange-trade-summary_v1_v002 create_emr_steps running 2023-11-09T21:00:00+00:00 data.engineers@viooh.com
1786339 2023-11-10T14:05:09.442083+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 2023-11-09T21:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_emr_steps', '2023-11-09T21:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786334 2023-11-10T14:04:48.517418+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps success 2023-11-09T20:00:00+00:00 data.engineers@viooh.com
1786333 2023-11-10T14:04:47.595890+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 2023-11-09T20:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_cluster_and_add_emr_steps', '2023-11-09T20:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786332 2023-11-10T14:04:47.566493+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps running 2023-11-09T20:00:00+00:00 data.engineers@viooh.com
1786331 2023-11-10T14:04:46.931739+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 2023-11-09T20:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_cluster_and_add_emr_steps', '2023-11-09T20:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786330 2023-11-10T14:04:35.449339+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786329 2023-11-10T14:04:33.209401+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786328 2023-11-10T14:04:32.871398+00:00 exchange-trade-summary_v1_v002 check_cluster_status failed 2023-11-09T20:00:00+00:00 anonymous [('csrf_token', 'ImE3MjhhYmI2NzAwMTZjZjUxZjM5ZjkxMzFjZjkzYWJlZTFmODFjODki.ZU44bw.D4_q1SCloQF9597qQfQ5hvUokBs'), ('confirmed', 'true'), ('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-11-09T20:00:00+00:00'), ('origin', 'https://airflow.devel.viooh.net.cn/admin/airflow/tree?dag_id=exchange-trade-summary_v1_v002'), ('downstream', 'true'), ('recursive', 'true')]
1786327 2023-11-10T14:04:31.686873+00:00 exchange-trade-summary_v1_v002 check_cluster_status failed 2023-11-09T20:00:00+00:00 anonymous [('csrf_token', 'ImE3MjhhYmI2NzAwMTZjZjUxZjM5ZjkxMzFjZjkzYWJlZTFmODFjODki.ZU44bQ.cpdSrAekSl6YHpiq4AC7g-HZexA'), ('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-11-09T20:00:00+00:00'), ('origin', 'https://airflow.devel.viooh.net.cn/admin/airflow/tree?dag_id=exchange-trade-summary_v1_v002'), ('downstream', 'true'), ('recursive', 'true')]
1786326 2023-11-10T14:04:29.897615+00:00 exchange-trade-summary_v1_v002 create_emr_steps success 2023-11-09T20:00:00+00:00 data.engineers@viooh.com
1786325 2023-11-10T14:04:29.226761+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786324 2023-11-10T14:04:27.837657+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 2023-11-09T20:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_emr_steps', '2023-11-09T20:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786323 2023-11-10T14:04:27.798717+00:00 exchange-trade-summary_v1_v002 create_emr_steps running 2023-11-09T20:00:00+00:00 data.engineers@viooh.com
1786322 2023-11-10T14:04:27.231466+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 2023-11-09T20:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_emr_steps', '2023-11-09T20:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786321 2023-11-10T14:04:27.137633+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786320 2023-11-10T14:04:21.491412+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786315 2023-11-10T14:03:37.577884+00:00 exchange-trade-summary_v1_v002 check_cluster_status failed 2023-11-09T04:00:00+00:00 anonymous [('csrf_token', 'ImE3MjhhYmI2NzAwMTZjZjUxZjM5ZjkxMzFjZjkzYWJlZTFmODFjODki.ZU40jQ.00d8Mwjcdown8ne_D4YoTxyYInk'), ('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-11-09T04:00:00+00:00'), ('origin', 'https://airflow.devel.viooh.net.cn/admin/airflow/tree?dag_id=exchange-trade-summary_v1_v002'), ('downstream', 'true'), ('recursive', 'true')]
1786314 2023-11-10T14:03:25.424244+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786309 2023-11-10T13:48:41.059377+00:00 exchange-trade-summary_v1_v002 create_emr_steps success 2023-11-09T05:00:00+00:00 data.engineers@viooh.com
1786308 2023-11-10T13:48:38.986880+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 2023-11-09T05:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_emr_steps', '2023-11-09T05:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786307 2023-11-10T13:48:38.959241+00:00 exchange-trade-summary_v1_v002 create_emr_steps running 2023-11-09T05:00:00+00:00 data.engineers@viooh.com
1786306 2023-11-10T13:48:38.336979+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 2023-11-09T05:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_emr_steps', '2023-11-09T05:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786305 2023-11-10T13:48:20.016685+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps success 2023-11-09T04:00:00+00:00 data.engineers@viooh.com
1786304 2023-11-10T13:48:18.879831+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 2023-11-09T04:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_cluster_and_add_emr_steps', '2023-11-09T04:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786303 2023-11-10T13:48:18.852522+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps running 2023-11-09T04:00:00+00:00 data.engineers@viooh.com
1786302 2023-11-10T13:48:18.226893+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 2023-11-09T04:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_cluster_and_add_emr_steps', '2023-11-09T04:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
1786301 2023-11-10T13:48:13.179015+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786300 2023-11-10T13:48:09.658152+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786299 2023-11-10T13:48:07.093902+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786298 2023-11-10T13:48:04.323454+00:00 exchange-trade-summary_v1_v002 tree anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
1786297 2023-11-10T13:48:03.993631+00:00 exchange-trade-summary_v1_v002 check_cluster_status failed 2023-11-09T04:00:00+00:00 anonymous [('csrf_token', 'ImE3MjhhYmI2NzAwMTZjZjUxZjM5ZjkxMzFjZjkzYWJlZTFmODFjODki.ZU40kw.Fr_9SVxetlUCuO50wwBGTK1XQ88'), ('confirmed', 'true'), ('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-11-09T04:00:00+00:00'), ('origin', 'https://airflow.devel.viooh.net.cn/admin/airflow/tree?dag_id=exchange-trade-summary_v1_v002'), ('downstream', 'true'), ('recursive', 'true')]
1786296 2023-11-10T13:48:02.664638+00:00 exchange-trade-summary_v1_v002 check_cluster_status failed 2023-11-09T04:00:00+00:00 anonymous [('csrf_token', 'ImE3MjhhYmI2NzAwMTZjZjUxZjM5ZjkxMzFjZjkzYWJlZTFmODFjODki.ZU40jQ.00d8Mwjcdown8ne_D4YoTxyYInk'), ('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2023-11-09T04:00:00+00:00'), ('origin', 'https://airflow.devel.viooh.net.cn/admin/airflow/tree?dag_id=exchange-trade-summary_v1_v002'), ('downstream', 'true'), ('recursive', 'true')]
1786295 2023-11-10T13:47:58.986020+00:00 exchange-trade-summary_v1_v002 create_emr_steps success 2023-11-09T04:00:00+00:00 data.engineers@viooh.com