Logs

Reset Filters
Id Dttm Dag Id Task Id Event Execution Date Owner Extra
282607 2021-08-30T10:06:43.516938+00:00 campaign-delta-job_v002 create_cluster_and_add_emr_steps running 2021-08-30T10:04:43.798949+00:00 data.engineers@viooh.com
282605 2021-08-30T10:06:42.965960+00:00 campaign-delta-job_v002 create_cluster_and_add_emr_steps cli_run 2021-08-30T10:04:43.798949+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_cluster_and_add_emr_steps', '2021-08-30T10:04:43.798949+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
282594 2021-08-30T10:06:28.542926+00:00 campaign-delta-job_v002 create_emr_steps success 2021-08-30T10:04:43.798949+00:00 data.engineers@viooh.com
282593 2021-08-30T10:06:23.417994+00:00 campaign-delta-job_v002 create_emr_steps cli_run 2021-08-30T10:04:43.798949+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2021-08-30T10:04:43.798949+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
282592 2021-08-30T10:06:23.386991+00:00 campaign-delta-job_v002 create_emr_steps running 2021-08-30T10:04:43.798949+00:00 data.engineers@viooh.com
282590 2021-08-30T10:06:22.878972+00:00 campaign-delta-job_v002 create_emr_steps cli_run 2021-08-30T10:04:43.798949+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2021-08-30T10:04:43.798949+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
282586 2021-08-30T10:06:13.802025+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
282583 2021-08-30T10:06:09.669248+00:00 campaign-delta-job_v002 trigger anonymous [('dag_id', 'campaign-delta-job_v002'), ('origin', '/admin/airflow/tree?dag_id=campaign-delta-job_v002')]
282572 2021-08-30T10:04:43.791342+00:00 campaign-delta-job_v002 trigger anonymous [('dag_id', 'campaign-delta-job_v002'), ('origin', '/admin/airflow/tree?dag_id=campaign-delta-job_v002'), ('csrf_token', 'ImI0MDAwOTUzYTg1MzZhYzQzYmY4ZjYxNGUyZWQ5MjM2MGI1Y2MyZjYi.YSytOQ.BGCZhin6M8VwqKt8wbejgeqI0X4'), ('conf', '')]
282571 2021-08-30T10:04:41.812345+00:00 campaign-delta-job_v002 trigger anonymous [('dag_id', 'campaign-delta-job_v002'), ('origin', '/admin/airflow/tree?dag_id=campaign-delta-job_v002')]
282570 2021-08-30T10:04:37.589635+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
277853 2021-08-27T06:47:12.781948+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
88758 2021-05-11T10:27:56.684141+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
88757 2021-05-11T10:21:33.839917+00:00 campaign-delta-job_v002 trigger anonymous [('dag_id', 'campaign-delta-job_v002'), ('origin', '/admin/airflow/tree?dag_id=campaign-delta-job_v002')]
88756 2021-05-11T10:21:29.562860+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
18561 2021-03-17T11:04:59.126333+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
18552 2021-03-17T11:01:14.732495+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
18550 2021-03-17T10:59:03.426870+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
9293 2020-11-03T05:37:03.086507+00:00 campaign-delta-job_v002 check_cluster_status success 2020-11-03T05:27:35.075929+00:00 data.engineers@viooh.com
9292 2020-11-03T05:31:56.548981+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
9291 2020-11-03T05:28:00.576270+00:00 campaign-delta-job_v002 check_cluster_status cli_run 2020-11-03T05:27:35.075929+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'check_cluster_status', '2020-11-03T05:27:35.075929+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
9290 2020-11-03T05:28:00.529269+00:00 campaign-delta-job_v002 check_cluster_status running 2020-11-03T05:27:35.075929+00:00 data.engineers@viooh.com
9289 2020-11-03T05:28:00.053083+00:00 campaign-delta-job_v002 check_cluster_status cli_run 2020-11-03T05:27:35.075929+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'check_cluster_status', '2020-11-03T05:27:35.075929+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
9288 2020-11-03T05:27:54.412690+00:00 campaign-delta-job_v002 create_cluster_and_add_emr_steps success 2020-11-03T05:27:35.075929+00:00 data.engineers@viooh.com
9287 2020-11-03T05:27:52.842840+00:00 campaign-delta-job_v002 create_cluster_and_add_emr_steps cli_run 2020-11-03T05:27:35.075929+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_cluster_and_add_emr_steps', '2020-11-03T05:27:35.075929+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
9286 2020-11-03T05:27:52.782356+00:00 campaign-delta-job_v002 create_cluster_and_add_emr_steps running 2020-11-03T05:27:35.075929+00:00 data.engineers@viooh.com
9285 2020-11-03T05:27:52.110191+00:00 campaign-delta-job_v002 create_cluster_and_add_emr_steps cli_run 2020-11-03T05:27:35.075929+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_cluster_and_add_emr_steps', '2020-11-03T05:27:35.075929+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
9284 2020-11-03T05:27:45.395139+00:00 campaign-delta-job_v002 create_emr_steps success 2020-11-03T05:27:35.075929+00:00 data.engineers@viooh.com
9283 2020-11-03T05:27:42.683468+00:00 campaign-delta-job_v002 create_emr_steps cli_run 2020-11-03T05:27:35.075929+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-11-03T05:27:35.075929+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
9282 2020-11-03T05:27:42.633864+00:00 campaign-delta-job_v002 create_emr_steps running 2020-11-03T05:27:35.075929+00:00 data.engineers@viooh.com
9281 2020-11-03T05:27:42.108005+00:00 campaign-delta-job_v002 create_emr_steps cli_run 2020-11-03T05:27:35.075929+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-11-03T05:27:35.075929+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
9280 2020-11-03T05:27:35.061872+00:00 campaign-delta-job_v002 trigger anonymous [('dag_id', 'campaign-delta-job_v002'), ('origin', '/admin/airflow/tree?dag_id=campaign-delta-job_v002'), ('csrf_token', 'ImM3MjcwN2QzNGJhOWYxYWNmNTc4ZWJjMmUzNmYwYTM1MjY2OWU4N2Ii.X6DqQA.qnM1X9QFiGB5fA0Pm3xTgU-ELOQ')]
9279 2020-11-03T05:27:28.581657+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
9249 2020-11-02T14:17:17.847626+00:00 campaign-delta-job_v002 create_emr_steps get_logs_with_metadata 2020-11-02T05:50:47.457694+00:00 anonymous [('dag_id', 'campaign-delta-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2020-11-02T05:50:47.457694+00:00'), ('try_number', '2'), ('metadata', 'null')]
9248 2020-11-02T14:17:16.705817+00:00 campaign-delta-job_v002 create_emr_steps get_logs_with_metadata 2020-11-02T05:50:47.457694+00:00 anonymous [('dag_id', 'campaign-delta-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2020-11-02T05:50:47.457694+00:00'), ('try_number', '1'), ('metadata', 'null')]
9247 2020-11-02T14:17:13.957161+00:00 campaign-delta-job_v002 create_emr_steps log 2020-11-02T05:50:47.457694+00:00 anonymous [('execution_date', '2020-11-02T05:50:47.457694+00:00'), ('task_id', 'create_emr_steps'), ('dag_id', 'campaign-delta-job_v002')]
9242 2020-11-02T10:03:05.733258+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
9240 2020-11-02T08:58:08.148859+00:00 campaign-delta-job_v002 create_cluster_and_add_emr_steps get_logs_with_metadata 2020-11-02T05:50:47.457694+00:00 anonymous [('dag_id', 'campaign-delta-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2020-11-02T05:50:47.457694+00:00'), ('try_number', '1'), ('metadata', 'null')]
9239 2020-11-02T08:58:07.079155+00:00 campaign-delta-job_v002 create_cluster_and_add_emr_steps log 2020-11-02T05:50:47.457694+00:00 anonymous [('task_id', 'create_cluster_and_add_emr_steps'), ('dag_id', 'campaign-delta-job_v002'), ('execution_date', '2020-11-02T05:50:47.457694+00:00'), ('format', 'json')]
9238 2020-11-02T08:57:53.645744+00:00 campaign-delta-job_v002 graph anonymous [('dag_id', 'campaign-delta-job_v002')]
9237 2020-11-02T08:57:37.314801+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
9234 2020-11-02T06:50:17.858391+00:00 campaign-delta-job_v002 check_cluster_status success 2020-11-02T05:50:47.457694+00:00 data.engineers@viooh.com
9233 2020-11-02T06:40:15.233776+00:00 campaign-delta-job_v002 check_cluster_status cli_run 2020-11-02T05:50:47.457694+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'check_cluster_status', '2020-11-02T05:50:47.457694+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
9232 2020-11-02T06:40:15.202485+00:00 campaign-delta-job_v002 check_cluster_status running 2020-11-02T05:50:47.457694+00:00 data.engineers@viooh.com
9231 2020-11-02T06:40:14.692805+00:00 campaign-delta-job_v002 check_cluster_status cli_run 2020-11-02T05:50:47.457694+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'check_cluster_status', '2020-11-02T05:50:47.457694+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
9230 2020-11-02T06:40:10.868134+00:00 campaign-delta-job_v002 create_cluster_and_add_emr_steps success 2020-11-02T05:50:47.457694+00:00 data.engineers@viooh.com
9229 2020-11-02T06:40:09.281355+00:00 campaign-delta-job_v002 create_cluster_and_add_emr_steps cli_run 2020-11-02T05:50:47.457694+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_cluster_and_add_emr_steps', '2020-11-02T05:50:47.457694+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
9228 2020-11-02T06:40:09.250779+00:00 campaign-delta-job_v002 create_cluster_and_add_emr_steps running 2020-11-02T05:50:47.457694+00:00 data.engineers@viooh.com
9227 2020-11-02T06:40:08.761206+00:00 campaign-delta-job_v002 create_cluster_and_add_emr_steps cli_run 2020-11-02T05:50:47.457694+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_cluster_and_add_emr_steps', '2020-11-02T05:50:47.457694+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
9226 2020-11-02T06:39:59.787674+00:00 campaign-delta-job_v002 create_emr_steps success 2020-11-02T05:50:47.457694+00:00 data.engineers@viooh.com
9225 2020-11-02T06:39:57.084588+00:00 campaign-delta-job_v002 create_emr_steps cli_run 2020-11-02T05:50:47.457694+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-11-02T05:50:47.457694+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
9224 2020-11-02T06:39:57.041081+00:00 campaign-delta-job_v002 create_emr_steps running 2020-11-02T05:50:47.457694+00:00 data.engineers@viooh.com
9223 2020-11-02T06:39:56.555522+00:00 campaign-delta-job_v002 create_emr_steps cli_run 2020-11-02T05:50:47.457694+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-11-02T05:50:47.457694+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
9222 2020-11-02T06:39:52.584158+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
9221 2020-11-02T06:39:48.587733+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
9220 2020-11-02T06:39:43.650088+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
9219 2020-11-02T06:39:43.185673+00:00 campaign-delta-job_v002 dagrun_clear 2020-11-02T05:50:47.457694+00:00 anonymous [('csrf_token', 'ImNiZDQwMTI3NDRiZTJhNzE0YTA0OGI4OTkwNzI4MWQ5M2RkMDJlNTUi.X5-prA.Hw8no0GSIwaeCfpgn4hrI6LMlno'), ('confirmed', 'true'), ('dag_id', 'campaign-delta-job_v002'), ('execution_date', '2020-11-02T05:50:47.457694+00:00'), ('origin', 'https://airflow.mgmt.viooh.net.cn/admin/airflow/tree?dag_id=campaign-delta-job_v002')]
9218 2020-11-02T06:39:40.670949+00:00 campaign-delta-job_v002 dagrun_clear 2020-11-02T05:50:47.457694+00:00 anonymous [('csrf_token', 'ImNiZDQwMTI3NDRiZTJhNzE0YTA0OGI4OTkwNzI4MWQ5M2RkMDJlNTUi.X5-ppQ.FlHCcVbDMwwj3u4n5UAxUUPGsVc'), ('dag_id', 'campaign-delta-job_v002'), ('execution_date', '2020-11-02T05:50:47.457694+00:00'), ('origin', 'https://airflow.mgmt.viooh.net.cn/admin/airflow/tree?dag_id=campaign-delta-job_v002')]
9217 2020-11-02T06:39:33.719434+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
9215 2020-11-02T05:55:00.340000+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
9214 2020-11-02T05:53:00.903676+00:00 campaign-delta-job_v002 create_emr_steps get_logs_with_metadata 2020-11-02T05:50:47.457694+00:00 anonymous [('dag_id', 'campaign-delta-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2020-11-02T05:50:47.457694+00:00'), ('try_number', '1'), ('metadata', 'null')]
9213 2020-11-02T05:52:45.316543+00:00 campaign-delta-job_v002 create_emr_steps log 2020-11-02T05:50:47.457694+00:00 anonymous [('task_id', 'create_emr_steps'), ('dag_id', 'campaign-delta-job_v002'), ('execution_date', '2020-11-02T05:50:47.457694+00:00'), ('format', 'json')]
9212 2020-11-02T05:52:40.568554+00:00 campaign-delta-job_v002 create_emr_steps get_logs_with_metadata 2020-11-02T05:50:47.457694+00:00 anonymous [('dag_id', 'campaign-delta-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2020-11-02T05:50:47.457694+00:00'), ('metadata', 'null'), ('format', 'file'), ('try_number', '1')]
9211 2020-11-02T05:52:32.290408+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
9210 2020-11-02T05:52:25.480671+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
9209 2020-11-02T05:50:56.142751+00:00 campaign-delta-job_v002 create_emr_steps cli_run 2020-11-02T05:50:47.457694+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-11-02T05:50:47.457694+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
9208 2020-11-02T05:50:56.097355+00:00 campaign-delta-job_v002 create_emr_steps running 2020-11-02T05:50:47.457694+00:00 data.engineers@viooh.com
9207 2020-11-02T05:50:55.568042+00:00 campaign-delta-job_v002 create_emr_steps cli_run 2020-11-02T05:50:47.457694+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-11-02T05:50:47.457694+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
9206 2020-11-02T05:50:47.445241+00:00 campaign-delta-job_v002 trigger anonymous [('dag_id', 'campaign-delta-job_v002'), ('origin', '/admin/airflow/tree?dag_id=campaign-delta-job_v002'), ('csrf_token', 'ImNiZDQwMTI3NDRiZTJhNzE0YTA0OGI4OTkwNzI4MWQ5M2RkMDJlNTUi.X5-eLQ.43svTLDYTqsNHLekfhrnIAKjCYw')]
9205 2020-11-02T05:50:37.566692+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
8245 2020-10-30T08:44:33.852183+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
7799 2020-10-29T08:26:56.971606+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
7735 2020-10-29T06:45:47.983313+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
7442 2020-10-28T05:34:11.200487+00:00 campaign-delta-job_v002 check_cluster_status success 2020-10-28T05:21:44.098825+00:00 data.engineers@viooh.com
7426 2020-10-28T05:23:19.856643+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
7425 2020-10-28T05:22:08.264987+00:00 campaign-delta-job_v002 check_cluster_status cli_run 2020-10-28T05:21:44.098825+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'check_cluster_status', '2020-10-28T05:21:44.098825+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
7424 2020-10-28T05:22:08.219454+00:00 campaign-delta-job_v002 check_cluster_status running 2020-10-28T05:21:44.098825+00:00 data.engineers@viooh.com
7423 2020-10-28T05:22:07.656813+00:00 campaign-delta-job_v002 check_cluster_status cli_run 2020-10-28T05:21:44.098825+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'check_cluster_status', '2020-10-28T05:21:44.098825+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
7422 2020-10-28T05:21:59.814817+00:00 campaign-delta-job_v002 create_cluster_and_add_emr_steps success 2020-10-28T05:21:44.098825+00:00 data.engineers@viooh.com
7421 2020-10-28T05:21:58.220422+00:00 campaign-delta-job_v002 create_cluster_and_add_emr_steps cli_run 2020-10-28T05:21:44.098825+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_cluster_and_add_emr_steps', '2020-10-28T05:21:44.098825+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
7420 2020-10-28T05:21:58.167628+00:00 campaign-delta-job_v002 create_cluster_and_add_emr_steps running 2020-10-28T05:21:44.098825+00:00 data.engineers@viooh.com
7419 2020-10-28T05:21:57.679581+00:00 campaign-delta-job_v002 create_cluster_and_add_emr_steps cli_run 2020-10-28T05:21:44.098825+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_cluster_and_add_emr_steps', '2020-10-28T05:21:44.098825+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
7418 2020-10-28T05:21:50.718030+00:00 campaign-delta-job_v002 create_emr_steps success 2020-10-28T05:21:44.098825+00:00 data.engineers@viooh.com
7417 2020-10-28T05:21:48.061787+00:00 campaign-delta-job_v002 create_emr_steps cli_run 2020-10-28T05:21:44.098825+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-10-28T05:21:44.098825+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
7416 2020-10-28T05:21:48.015187+00:00 campaign-delta-job_v002 create_emr_steps running 2020-10-28T05:21:44.098825+00:00 data.engineers@viooh.com
7415 2020-10-28T05:21:47.579420+00:00 campaign-delta-job_v002 create_emr_steps cli_run 2020-10-28T05:21:44.098825+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-10-28T05:21:44.098825+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
7414 2020-10-28T05:21:44.086264+00:00 campaign-delta-job_v002 trigger anonymous [('dag_id', 'campaign-delta-job_v002'), ('origin', '/admin/airflow/tree?dag_id=campaign-delta-job_v002'), ('csrf_token', 'ImFlMGJkZGUzMmNjZTg1ODE2NzY3NTczYjk0YjU3MDE4OGRiYjE2NWYi.X5j_1g.kyzXb_K8FyatN2M4xYxlsHL1KrI')]
7413 2020-10-28T05:21:26.863743+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
7412 2020-10-28T05:18:29.979729+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
7411 2020-10-28T05:18:14.453654+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
7410 2020-10-28T05:17:55.904008+00:00 campaign-delta-job_v002 check_cluster_status success 2020-10-28T05:07:27.403339+00:00 data.engineers@viooh.com
7409 2020-10-28T05:07:53.286477+00:00 campaign-delta-job_v002 check_cluster_status cli_run 2020-10-28T05:07:27.403339+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'check_cluster_status', '2020-10-28T05:07:27.403339+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
7408 2020-10-28T05:07:53.249077+00:00 campaign-delta-job_v002 check_cluster_status running 2020-10-28T05:07:27.403339+00:00 data.engineers@viooh.com
7407 2020-10-28T05:07:52.758265+00:00 campaign-delta-job_v002 check_cluster_status cli_run 2020-10-28T05:07:27.403339+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'check_cluster_status', '2020-10-28T05:07:27.403339+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
7406 2020-10-28T05:07:46.935046+00:00 campaign-delta-job_v002 create_cluster_and_add_emr_steps success 2020-10-28T05:07:27.403339+00:00 data.engineers@viooh.com
7405 2020-10-28T05:07:45.405800+00:00 campaign-delta-job_v002 create_cluster_and_add_emr_steps cli_run 2020-10-28T05:07:27.403339+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_cluster_and_add_emr_steps', '2020-10-28T05:07:27.403339+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
7404 2020-10-28T05:07:45.372774+00:00 campaign-delta-job_v002 create_cluster_and_add_emr_steps running 2020-10-28T05:07:27.403339+00:00 data.engineers@viooh.com
7403 2020-10-28T05:07:44.877240+00:00 campaign-delta-job_v002 create_cluster_and_add_emr_steps cli_run 2020-10-28T05:07:27.403339+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_cluster_and_add_emr_steps', '2020-10-28T05:07:27.403339+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
7402 2020-10-28T05:07:37.944816+00:00 campaign-delta-job_v002 create_emr_steps success 2020-10-28T05:07:27.403339+00:00 data.engineers@viooh.com
7401 2020-10-28T05:07:35.297491+00:00 campaign-delta-job_v002 create_emr_steps cli_run 2020-10-28T05:07:27.403339+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-10-28T05:07:27.403339+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}