Logs


Id Dttm Dag Id Task Id Event Execution Date Owner Extra
2241099 2024-07-02T12:08:37.789664+00:00 exchange-trade-summary_v1_v002 graph 2024-06-06T02:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T02:00:00+00:00'), ('root', 'check_cluster_status')]
2241097 2024-07-02T12:08:36.596734+00:00 exchange-trade-summary_v1_v002 create_emr_steps log 2024-06-06T09:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T09:00:00+00:00'), ('task_id', 'create_emr_steps')]
2241082 2024-07-02T12:08:19.349210+00:00 exchange-trade-summary_v1_v002 create_emr_steps log 2024-06-06T05:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T05:00:00+00:00'), ('task_id', 'create_emr_steps')]
2241081 2024-07-02T12:08:18.660462+00:00 exchange-trade-summary_v1_v002 graph 2024-06-06T01:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06 01:00:00+00:00')]
2241071 2024-07-02T12:07:46.805681+00:00 exchange-trade-summary_v1_v002 graph 2024-06-06T03:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T03:00:00+00:00'), ('root', 'create_cluster_and_add_emr_steps')]
2241066 2024-07-02T12:07:17.110506+00:00 exchange-trade-summary_v1_v002 graph 2024-06-30T07:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-30 07:00:00+00:00')]
2241059 2024-07-02T12:06:57.516463+00:00 exchange-trade-summary_v1_v002 graph 2024-06-06T08:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T08:00:00+00:00'), ('root', 'create_emr_steps')]
2241056 2024-07-02T12:06:42.876635+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps log 2024-06-06T10:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T10:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2241049 2024-07-02T12:06:33.721135+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps log 2024-06-06T12:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T12:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2241045 2024-07-02T12:06:15.821144+00:00 exchange-trade-summary_v1_v002 graph 2024-06-29T18:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-29 18:00:00+00:00'), ('run_id', 'scheduled__2024-06-29T18:00:00+00:00')]
2241044 2024-07-02T12:06:15.131709+00:00 exchange-trade-summary_v1_v002 graph 2024-06-29T14:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-29 14:00:00+00:00')]
2241041 2024-07-02T12:06:09.420598+00:00 exchange-trade-summary_v1_v002 graph 2024-06-30T09:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-30 09:00:00+00:00')]
2241038 2024-07-02T12:05:59.488758+00:00 exchange-trade-summary_v1_v002 graph 2024-06-06T10:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06 10:00:00+00:00')]
2241037 2024-07-02T12:05:58.918827+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps log 2024-06-06T04:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T04:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2241036 2024-07-02T12:05:58.089682+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps log 2024-06-06T02:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T02:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2241035 2024-07-02T12:05:55.556130+00:00 exchange-trade-summary_v1_v002 create_emr_steps task 2024-06-06T01:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T01:00:00+00:00'), ('task_id', 'create_emr_steps')]
2241032 2024-07-02T12:05:51.707932+00:00 exchange-trade-summary_v1_v002 check_cluster_status log 2024-06-06T08:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T08:00:00+00:00'), ('task_id', 'check_cluster_status')]
2241023 2024-07-02T12:05:48.601160+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps task 2024-06-06T02:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T02:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2241022 2024-07-02T12:05:48.130060+00:00 exchange-trade-summary_v1_v002 graph 2024-06-06T13:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T13:00:00+00:00'), ('root', 'create_cluster_and_add_emr_steps')]
2241020 2024-07-02T12:05:47.237945+00:00 exchange-trade-summary_v1_v002 graph 2024-06-29T19:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-29 19:00:00+00:00'), ('run_id', 'scheduled__2024-06-29T19:00:00+00:00')]
2241009 2024-07-02T12:05:29.584341+00:00 exchange-trade-summary_v1_v002 graph 2024-06-06T01:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T01:00:00+00:00'), ('root', 'create_emr_steps')]
2241006 2024-07-02T12:05:28.498328+00:00 exchange-trade-summary_v1_v002 check_cluster_status log 2024-06-06T05:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T05:00:00+00:00'), ('task_id', 'check_cluster_status')]
2241004 2024-07-02T12:05:21.354510+00:00 exchange-trade-summary_v1_v002 graph 2024-06-29T17:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-29 17:00:00+00:00'), ('run_id', 'scheduled__2024-06-29T17:00:00+00:00')]
2241000 2024-07-02T12:05:01.802951+00:00 exchange-trade-summary_v1_v002 graph 2024-06-29T18:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-29 18:00:00+00:00')]
2240994 2024-07-02T12:04:36.350302+00:00 exchange-trade-summary_v1_v002 graph 2024-06-30T12:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-30 12:00:00+00:00'), ('run_id', 'scheduled__2024-06-30T12:00:00+00:00')]
2240993 2024-07-02T12:04:29.633261+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps task 2024-06-06T06:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T06:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2240988 2024-07-02T12:04:22.138194+00:00 exchange-trade-summary_v1_v002 graph 2024-06-06T04:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T04:00:00+00:00'), ('root', 'check_cluster_status')]
2240979 2024-07-02T12:03:42.352003+00:00 exchange-trade-summary_v1_v002 graph 2024-06-06T05:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T05:00:00+00:00'), ('root', 'create_emr_steps')]
2240978 2024-07-02T12:03:41.580703+00:00 exchange-trade-summary_v1_v002 graph 2024-06-06T07:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T07:00:00+00:00'), ('root', 'check_cluster_status')]
2240977 2024-07-02T12:03:40.571542+00:00 exchange-trade-summary_v1_v002 graph 2024-06-30T08:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-30 08:00:00+00:00'), ('run_id', 'scheduled__2024-06-30T08:00:00+00:00')]
2240976 2024-07-02T12:03:39.935734+00:00 exchange-trade-summary_v1_v002 graph 2024-06-29T13:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-29 13:00:00+00:00'), ('run_id', 'scheduled__2024-06-29T13:00:00+00:00')]
2240970 2024-07-02T12:03:20.706687+00:00 exchange-trade-summary_v1_v002 graph 2024-06-06T02:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06 02:00:00+00:00')]
2240969 2024-07-02T12:03:19.708980+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps task 2024-06-06T10:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T10:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2240962 2024-07-02T12:02:44.962267+00:00 exchange-trade-summary_v1_v002 graph 2024-06-30T11:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-30 11:00:00+00:00'), ('run_id', 'scheduled__2024-06-30T11:00:00+00:00')]
2240956 2024-07-02T12:02:26.593029+00:00 exchange-trade-summary_v1_v002 graph 2024-06-06T07:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T07:00:00+00:00'), ('root', 'create_cluster_and_add_emr_steps')]
2240954 2024-07-02T12:02:24.905019+00:00 exchange-trade-summary_v1_v002 duration anonymous [('dag_id', 'exchange-trade-summary_v1_v002')]
2240945 2024-07-02T12:01:56.119652+00:00 exchange-trade-summary_v1_v002 graph 2024-06-29T20:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-29 20:00:00+00:00')]
2240943 2024-07-02T12:01:52.133640+00:00 exchange-trade-summary_v1_v002 graph 2024-06-29T21:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-29 21:00:00+00:00'), ('run_id', 'scheduled__2024-06-29T21:00:00+00:00')]
2240924 2024-07-02T12:01:06.893825+00:00 exchange-trade-summary_v1_v002 check_cluster_status cli_run 2024-07-02T11: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', '2024-07-02T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240923 2024-07-02T12:01:06.842312+00:00 exchange-trade-summary_v1_v002 check_cluster_status running 2024-07-02T11:00:00+00:00 data.engineers@viooh.com
2240922 2024-07-02T12:01:05.982782+00:00 exchange-trade-summary_v1_v002 check_cluster_status cli_run 2024-07-02T11: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', '2024-07-02T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240919 2024-07-02T12:00:54.723506+00:00 exchange-trade-summary_v1_v002 graph 2024-06-06T13:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T13:00:00+00:00'), ('root', 'create_emr_steps')]
2240910 2024-07-02T12:00:44.875556+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps success 2024-07-02T11:00:00+00:00 data.engineers@viooh.com
2240908 2024-07-02T12:00:43.945785+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 2024-07-02T11:00:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_cluster_and_add_emr_steps', '2024-07-02T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240907 2024-07-02T12:00:43.900018+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps running 2024-07-02T11:00:00+00:00 data.engineers@viooh.com
2240905 2024-07-02T12:00:43.223194+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 2024-07-02T11:00:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_cluster_and_add_emr_steps', '2024-07-02T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240904 2024-07-02T12:00:26.593002+00:00 exchange-trade-summary_v1_v002 create_emr_steps success 2024-07-02T11:00:00+00:00 data.engineers@viooh.com
2240899 2024-07-02T12:00:24.497704+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 2024-07-02T11: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', '2024-07-02T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240898 2024-07-02T12:00:24.443351+00:00 exchange-trade-summary_v1_v002 create_emr_steps running 2024-07-02T11:00:00+00:00 data.engineers@viooh.com
2240897 2024-07-02T12:00:23.704761+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 2024-07-02T11: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', '2024-07-02T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240894 2024-07-02T12:00:13.748048+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps log 2024-06-06T06:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T06:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')]
2240893 2024-07-02T12:00:12.722766+00:00 exchange-trade-summary_v1_v002 create_emr_steps task 2024-06-06T06:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T06:00:00+00:00'), ('task_id', 'create_emr_steps')]
2240877 2024-07-02T11:43:27.607419+00:00 exchange-trade-summary_v1_v002 check_cluster_status task 2024-02-28T09:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-02-28T09:00:00+00:00')]
2240863 2024-07-02T11:23:06.368377+00:00 exchange-trade-summary_v1_v002 check_cluster_status success 2024-07-02T10:00:00+00:00 data.engineers@viooh.com
2240837 2024-07-02T11:01:09.906618+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps xcom 2024-03-25T15:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-03-25T15:00:00+00:00')]
2240832 2024-07-02T11:01:02.733319+00:00 exchange-trade-summary_v1_v002 check_cluster_status cli_run 2024-07-02T10: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', '2024-07-02T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240831 2024-07-02T11:01:02.677101+00:00 exchange-trade-summary_v1_v002 check_cluster_status running 2024-07-02T10:00:00+00:00 data.engineers@viooh.com
2240830 2024-07-02T11:01:01.991168+00:00 exchange-trade-summary_v1_v002 check_cluster_status cli_run 2024-07-02T10: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', '2024-07-02T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240822 2024-07-02T11:00:41.503963+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps success 2024-07-02T10:00:00+00:00 data.engineers@viooh.com
2240821 2024-07-02T11:00:40.652373+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 2024-07-02T10: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', '2024-07-02T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240820 2024-07-02T11:00:40.606586+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps running 2024-07-02T10:00:00+00:00 data.engineers@viooh.com
2240819 2024-07-02T11:00:39.854440+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 2024-07-02T10: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', '2024-07-02T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240815 2024-07-02T11:00:23.207615+00:00 exchange-trade-summary_v1_v002 create_emr_steps success 2024-07-02T10:00:00+00:00 data.engineers@viooh.com
2240810 2024-07-02T11:00:21.154853+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 2024-07-02T10: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', '2024-07-02T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240809 2024-07-02T11:00:21.110337+00:00 exchange-trade-summary_v1_v002 create_emr_steps running 2024-07-02T10:00:00+00:00 data.engineers@viooh.com
2240808 2024-07-02T11:00:20.295083+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 2024-07-02T10: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', '2024-07-02T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240781 2024-07-02T10:24:07.546782+00:00 exchange-trade-summary_v1_v002 check_cluster_status success 2024-07-02T09:00:00+00:00 data.engineers@viooh.com
2240748 2024-07-02T10:01:03.864368+00:00 exchange-trade-summary_v1_v002 check_cluster_status cli_run 2024-07-02T09: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', '2024-07-02T09:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240747 2024-07-02T10:01:03.828575+00:00 exchange-trade-summary_v1_v002 check_cluster_status running 2024-07-02T09:00:00+00:00 data.engineers@viooh.com
2240746 2024-07-02T10:01:03.083525+00:00 exchange-trade-summary_v1_v002 check_cluster_status cli_run 2024-07-02T09: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', '2024-07-02T09:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240740 2024-07-02T10:00:42.174359+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps success 2024-07-02T09:00:00+00:00 data.engineers@viooh.com
2240739 2024-07-02T10:00:41.146092+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 2024-07-02T09:00:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_cluster_and_add_emr_steps', '2024-07-02T09:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240738 2024-07-02T10:00:41.112542+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps running 2024-07-02T09:00:00+00:00 data.engineers@viooh.com
2240737 2024-07-02T10:00:40.414569+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 2024-07-02T09:00:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_cluster_and_add_emr_steps', '2024-07-02T09:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240732 2024-07-02T10:00:21.940473+00:00 exchange-trade-summary_v1_v002 create_emr_steps success 2024-07-02T09:00:00+00:00 data.engineers@viooh.com
2240731 2024-07-02T10:00:19.963070+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 2024-07-02T09:00:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_emr_steps', '2024-07-02T09:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240730 2024-07-02T10:00:19.918013+00:00 exchange-trade-summary_v1_v002 create_emr_steps running 2024-07-02T09:00:00+00:00 data.engineers@viooh.com
2240729 2024-07-02T10:00:19.202321+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 2024-07-02T09:00:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_emr_steps', '2024-07-02T09:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240699 2024-07-02T09:26:02.151306+00:00 exchange-trade-summary_v1_v002 check_cluster_status success 2024-07-02T08:00:00+00:00 data.engineers@viooh.com
2240648 2024-07-02T09:00:57.671100+00:00 exchange-trade-summary_v1_v002 check_cluster_status cli_run 2024-07-02T08: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', '2024-07-02T08:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240647 2024-07-02T09:00:57.625633+00:00 exchange-trade-summary_v1_v002 check_cluster_status running 2024-07-02T08:00:00+00:00 data.engineers@viooh.com
2240646 2024-07-02T09:00:56.968568+00:00 exchange-trade-summary_v1_v002 check_cluster_status cli_run 2024-07-02T08: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', '2024-07-02T08:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240637 2024-07-02T09:00:38.935307+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps success 2024-07-02T08:00:00+00:00 data.engineers@viooh.com
2240636 2024-07-02T09:00:38.041619+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 2024-07-02T08: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', '2024-07-02T08:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240635 2024-07-02T09:00:38.001400+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps running 2024-07-02T08:00:00+00:00 data.engineers@viooh.com
2240634 2024-07-02T09:00:37.179768+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 2024-07-02T08: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', '2024-07-02T08:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240623 2024-07-02T09:00:17.643083+00:00 exchange-trade-summary_v1_v002 create_emr_steps success 2024-07-02T08:00:00+00:00 data.engineers@viooh.com
2240622 2024-07-02T09:00:15.719324+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 2024-07-02T08:00:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_emr_steps', '2024-07-02T08:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240621 2024-07-02T09:00:15.687251+00:00 exchange-trade-summary_v1_v002 create_emr_steps running 2024-07-02T08:00:00+00:00 data.engineers@viooh.com
2240620 2024-07-02T09:00:14.552286+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 2024-07-02T08:00:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_emr_steps', '2024-07-02T08:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240610 2024-07-02T08:54:30.206267+00:00 exchange-trade-summary_v1_v002 create_emr_steps xcom 2024-03-25T05:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-03-25T05:00:00+00:00')]
2240591 2024-07-02T08:28:11.222644+00:00 exchange-trade-summary_v1_v002 check_cluster_status success 2024-07-02T07:00:00+00:00 data.engineers@viooh.com
2240532 2024-07-02T08:01:07.003276+00:00 exchange-trade-summary_v1_v002 check_cluster_status cli_run 2024-07-02T07: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', '2024-07-02T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240531 2024-07-02T08:01:06.965987+00:00 exchange-trade-summary_v1_v002 check_cluster_status running 2024-07-02T07:00:00+00:00 data.engineers@viooh.com
2240528 2024-07-02T08:01:06.280754+00:00 exchange-trade-summary_v1_v002 check_cluster_status cli_run 2024-07-02T07: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', '2024-07-02T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240524 2024-07-02T08:00:43.727545+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps success 2024-07-02T07:00:00+00:00 data.engineers@viooh.com
2240523 2024-07-02T08:00:42.845639+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 2024-07-02T07: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', '2024-07-02T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240522 2024-07-02T08:00:42.806097+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps running 2024-07-02T07:00:00+00:00 data.engineers@viooh.com
2240519 2024-07-02T08:00:42.082307+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 2024-07-02T07: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', '2024-07-02T07:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240516 2024-07-02T08:00:22.999345+00:00 exchange-trade-summary_v1_v002 create_emr_steps success 2024-07-02T07:00:00+00:00 data.engineers@viooh.com