Id | Dttm | Dag Id | Task Id | Event | Execution Date | Owner | Extra |
---|---|---|---|---|---|---|---|
9430 |
|
booking-processing-job_v002 | check_cluster_status | running |
|
data.engineers@viooh.com | |
9429 |
|
booking-processing-job_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'check_cluster_status', '2020-11-03T14:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9428 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | success |
|
data.engineers@viooh.com | |
9427 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_cluster_and_add_emr_steps', '2020-11-03T14:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9426 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | running |
|
data.engineers@viooh.com | |
9425 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_cluster_and_add_emr_steps', '2020-11-03T14:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9424 |
|
booking-processing-job_v002 | create_emr_steps | success |
|
data.engineers@viooh.com | |
9423 |
|
booking-processing-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_emr_steps', '2020-11-03T14:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9422 |
|
booking-processing-job_v002 | create_emr_steps | running |
|
data.engineers@viooh.com | |
9421 |
|
booking-processing-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_emr_steps', '2020-11-03T14:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9420 |
|
booking-processing-job_v002 | create_emr_steps | get_logs_with_metadata |
|
anonymous | [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2020-11-03T14:45:04.640146+00:00'), ('try_number', '1'), ('metadata', 'null')] |
9419 |
|
booking-processing-job_v002 | create_emr_steps | get_logs_with_metadata |
|
anonymous | [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2020-11-03T14:45:04.640146+00:00'), ('try_number', '2'), ('metadata', 'null')] |
9418 |
|
booking-processing-job_v002 | create_emr_steps | log |
|
anonymous | [('task_id', 'create_emr_steps'), ('dag_id', 'booking-processing-job_v002'), ('execution_date', '2020-11-03T14:45:04.640146+00:00'), ('format', 'json')] |
9417 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9416 |
|
booking-processing-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_emr_steps', '2020-11-03T14:45:04.640146+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9415 |
|
booking-processing-job_v002 | create_emr_steps | running |
|
data.engineers@viooh.com | |
9414 |
|
booking-processing-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_emr_steps', '2020-11-03T14:45:04.640146+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9413 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9412 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9411 |
|
booking-processing-job_v002 | dagrun_clear |
|
anonymous | [('csrf_token', 'ImM3MjcwN2QzNGJhOWYxYWNmNTc4ZWJjMmUzNmYwYTM1MjY2OWU4N2Ii.X6Ftvg.yo0SSiG8ZbOFygipsCw16KrWoks'), ('confirmed', 'true'), ('dag_id', 'booking-processing-job_v002'), ('execution_date', '2020-11-03T14:45:04.640146+00:00'), ('origin', 'https://airflow.mgmt.viooh.net.cn/admin/airflow/tree?dag_id=booking-processing-job_v002')] | |
9410 |
|
booking-processing-job_v002 | dagrun_clear |
|
anonymous | [('csrf_token', 'ImM3MjcwN2QzNGJhOWYxYWNmNTc4ZWJjMmUzNmYwYTM1MjY2OWU4N2Ii.X6FtuA.O2h88HEd71jrWfKyadCVUkeLMUY'), ('dag_id', 'booking-processing-job_v002'), ('execution_date', '2020-11-03T14:45:04.640146+00:00'), ('origin', 'https://airflow.mgmt.viooh.net.cn/admin/airflow/tree?dag_id=booking-processing-job_v002')] | |
9409 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9408 |
|
booking-processing-job_v002 | create_emr_steps | get_logs_with_metadata |
|
anonymous | [('dag_id', 'booking-processing-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2020-11-03T14:45:04.640146+00:00'), ('try_number', '1'), ('metadata', 'null')] |
9407 |
|
booking-processing-job_v002 | create_emr_steps | log |
|
anonymous | [('task_id', 'create_emr_steps'), ('dag_id', 'booking-processing-job_v002'), ('execution_date', '2020-11-03T14:45:04.640146+00:00'), ('format', 'json')] |
9406 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9405 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9404 |
|
booking-processing-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_emr_steps', '2020-11-03T14:45:04.640146+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9403 |
|
booking-processing-job_v002 | create_emr_steps | running |
|
data.engineers@viooh.com | |
9402 |
|
booking-processing-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_emr_steps', '2020-11-03T14:45:04.640146+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9401 |
|
booking-processing-job_v002 | trigger |
|
anonymous | [('dag_id', 'booking-processing-job_v002'), ('origin', '/admin/airflow/tree?dag_id=booking-processing-job_v002'), ('csrf_token', 'ImM3MjcwN2QzNGJhOWYxYWNmNTc4ZWJjMmUzNmYwYTM1MjY2OWU4N2Ii.X6Fs6A.b9hDU_Q520QDrAbUOkp_XGtMX0k')] | |
9400 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9399 |
|
booking-processing-job_v002 | dagrun_success |
|
anonymous | [('csrf_token', 'ImM3MjcwN2QzNGJhOWYxYWNmNTc4ZWJjMmUzNmYwYTM1MjY2OWU4N2Ii.X6Fs5Q.eiwpCGhW_g61LHebzDu9r1GQRqA'), ('confirmed', 'true'), ('dag_id', 'booking-processing-job_v002'), ('execution_date', '2020-11-03T13:00:00+00:00'), ('origin', 'https://airflow.mgmt.viooh.net.cn/admin/airflow/tree?dag_id=booking-processing-job_v002')] | |
9398 |
|
booking-processing-job_v002 | dagrun_success |
|
anonymous | [('csrf_token', 'ImM3MjcwN2QzNGJhOWYxYWNmNTc4ZWJjMmUzNmYwYTM1MjY2OWU4N2Ii.X6Fs1g.s2lISUjo1FlBzlTHCrYiFRM_Vhs'), ('dag_id', 'booking-processing-job_v002'), ('execution_date', '2020-11-03T13:00:00+00:00'), ('origin', 'https://airflow.mgmt.viooh.net.cn/admin/airflow/tree?dag_id=booking-processing-job_v002')] | |
9397 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9396 |
|
booking-processing-job_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'check_cluster_status', '2020-11-03T13:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9395 |
|
booking-processing-job_v002 | check_cluster_status | running |
|
data.engineers@viooh.com | |
9394 |
|
booking-processing-job_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'check_cluster_status', '2020-11-03T13:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9393 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | success |
|
data.engineers@viooh.com | |
9392 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_cluster_and_add_emr_steps', '2020-11-03T13:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9391 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | running |
|
data.engineers@viooh.com | |
9390 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_cluster_and_add_emr_steps', '2020-11-03T13:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9389 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9388 |
|
booking-processing-job_v002 | dagrun_success |
|
anonymous | [('csrf_token', 'ImM3MjcwN2QzNGJhOWYxYWNmNTc4ZWJjMmUzNmYwYTM1MjY2OWU4N2Ii.X6FsuA.JOG8A8qyWqNhaUhQEu4qx5B5Hqo'), ('confirmed', 'true'), ('dag_id', 'booking-processing-job_v002'), ('execution_date', '2020-11-03T12:05:42.619828+00:00'), ('origin', 'https://airflow.mgmt.viooh.net.cn/admin/airflow/tree?dag_id=booking-processing-job_v002')] | |
9387 |
|
booking-processing-job_v002 | dagrun_success |
|
anonymous | [('csrf_token', 'ImM3MjcwN2QzNGJhOWYxYWNmNTc4ZWJjMmUzNmYwYTM1MjY2OWU4N2Ii.X6FssA.CxKwTQDm9exHp0QBLEKaq6_B4qA'), ('dag_id', 'booking-processing-job_v002'), ('execution_date', '2020-11-03T12:05:42.619828+00:00'), ('origin', 'https://airflow.mgmt.viooh.net.cn/admin/airflow/tree?dag_id=booking-processing-job_v002')] | |
9386 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9384 |
|
booking-processing-job_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'check_cluster_status', '2020-11-03T12:05:42.619828+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9383 |
|
booking-processing-job_v002 | check_cluster_status | running |
|
data.engineers@viooh.com | |
9382 |
|
booking-processing-job_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'check_cluster_status', '2020-11-03T12:05:42.619828+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9381 |
|
booking-processing-job_v002 | check_cluster_status | success |
|
data.engineers@viooh.com | |
9379 |
|
booking-processing-job_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'check_cluster_status', '2020-11-03T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9378 |
|
booking-processing-job_v002 | check_cluster_status | running |
|
data.engineers@viooh.com | |
9377 |
|
booking-processing-job_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'check_cluster_status', '2020-11-03T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9376 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | success |
|
data.engineers@viooh.com | |
9375 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_cluster_and_add_emr_steps', '2020-11-03T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9374 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | running |
|
data.engineers@viooh.com | |
9373 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_cluster_and_add_emr_steps', '2020-11-03T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9372 |
|
booking-processing-job_v002 | create_emr_steps | success |
|
data.engineers@viooh.com | |
9371 |
|
booking-processing-job_v002 | create_emr_steps | success |
|
data.engineers@viooh.com | |
9370 |
|
booking-processing-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_emr_steps', '2020-11-03T13:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9369 |
|
booking-processing-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_emr_steps', '2020-11-03T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9368 |
|
booking-processing-job_v002 | create_emr_steps | running |
|
data.engineers@viooh.com | |
9367 |
|
booking-processing-job_v002 | create_emr_steps | running |
|
data.engineers@viooh.com | |
9366 |
|
booking-processing-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_emr_steps', '2020-11-03T13:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9365 |
|
booking-processing-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_emr_steps', '2020-11-03T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9364 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9363 |
|
booking-processing-job_v002 | dagrun_clear |
|
anonymous | [('csrf_token', 'ImM3MjcwN2QzNGJhOWYxYWNmNTc4ZWJjMmUzNmYwYTM1MjY2OWU4N2Ii.X6Fq_w.P4hQYHaLC5xYkQEKWp6X-XWY8YQ'), ('confirmed', 'true'), ('dag_id', 'booking-processing-job_v002'), ('execution_date', '2020-11-03T11:00:00+00:00'), ('origin', 'https://airflow.mgmt.viooh.net.cn/admin/airflow/tree?dag_id=booking-processing-job_v002')] | |
9362 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | success |
|
data.engineers@viooh.com | |
9361 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_cluster_and_add_emr_steps', '2020-11-03T12:05:42.619828+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9360 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | running |
|
data.engineers@viooh.com | |
9359 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_cluster_and_add_emr_steps', '2020-11-03T12:05:42.619828+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9358 |
|
booking-processing-job_v002 | dagrun_clear |
|
anonymous | [('csrf_token', 'ImM3MjcwN2QzNGJhOWYxYWNmNTc4ZWJjMmUzNmYwYTM1MjY2OWU4N2Ii.X6Fq-Q.eHf0rrttgxHBqdokZ6E6_7G1Tzk'), ('dag_id', 'booking-processing-job_v002'), ('execution_date', '2020-11-03T11:00:00+00:00'), ('origin', 'https://airflow.mgmt.viooh.net.cn/admin/airflow/tree?dag_id=booking-processing-job_v002')] | |
9357 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9356 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9355 |
|
booking-processing-job_v002 | paused |
|
anonymous | [('is_paused', 'true'), ('dag_id', 'booking-processing-job_v002')] | |
9354 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9342 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9341 |
|
booking-processing-job_v002 | check_cluster_status | success |
|
data.engineers@viooh.com | |
9340 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9339 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9338 |
|
booking-processing-job_v002 | paused |
|
anonymous | [('is_paused', 'false'), ('dag_id', 'booking-processing-job_v002')] | |
9337 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9336 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9335 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9334 |
|
booking-processing-job_v002 | create_emr_steps | success |
|
data.engineers@viooh.com | |
9333 |
|
booking-processing-job_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'check_cluster_status', '2020-11-03T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9332 |
|
booking-processing-job_v002 | check_cluster_status | running |
|
data.engineers@viooh.com | |
9331 |
|
booking-processing-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_emr_steps', '2020-11-03T12:05:42.619828+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9330 |
|
booking-processing-job_v002 | create_emr_steps | running |
|
data.engineers@viooh.com | |
9329 |
|
booking-processing-job_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'check_cluster_status', '2020-11-03T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9328 |
|
booking-processing-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_emr_steps', '2020-11-03T12:05:42.619828+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9327 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | success |
|
data.engineers@viooh.com | |
9326 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_cluster_and_add_emr_steps', '2020-11-03T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9325 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | running |
|
data.engineers@viooh.com | |
9324 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_cluster_and_add_emr_steps', '2020-11-03T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9323 |
|
booking-processing-job_v002 | create_emr_steps | success |
|
data.engineers@viooh.com | |
9322 |
|
booking-processing-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_emr_steps', '2020-11-03T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9321 |
|
booking-processing-job_v002 | create_emr_steps | running |
|
data.engineers@viooh.com | |
9320 |
|
booking-processing-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_emr_steps', '2020-11-03T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9319 |
|
booking-processing-job_v002 | trigger |
|
anonymous | [('dag_id', 'booking-processing-job_v002'), ('origin', '/admin/airflow/tree?dag_id=booking-processing-job_v002'), ('csrf_token', 'ImM3MjcwN2QzNGJhOWYxYWNmNTc4ZWJjMmUzNmYwYTM1MjY2OWU4N2Ii.X6FHkA.E3gmi29gYGoXXdv7ZMNCS-aDlZ4')] | |
9318 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] |