Id | Dttm | Dag Id | Task Id | Event | Execution Date | Owner | Extra |
---|---|---|---|---|---|---|---|
9533 |
|
booking-processing-job_v002 | check_cluster_status | running |
|
data.engineers@viooh.com | |
9532 |
|
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-05T04:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9531 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | success |
|
data.engineers@viooh.com | |
9530 |
|
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-05T04:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9529 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | running |
|
data.engineers@viooh.com | |
9528 |
|
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-05T04:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9527 |
|
booking-processing-job_v002 | create_emr_steps | success |
|
data.engineers@viooh.com | |
9526 |
|
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-05T04:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9525 |
|
booking-processing-job_v002 | create_emr_steps | running |
|
data.engineers@viooh.com | |
9524 |
|
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-05T04:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9522 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9521 |
|
booking-processing-job_v002 | check_cluster_status | success |
|
data.engineers@viooh.com | |
9520 |
|
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-05T03:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9519 |
|
booking-processing-job_v002 | check_cluster_status | running |
|
data.engineers@viooh.com | |
9518 |
|
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-05T03:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9517 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | success |
|
data.engineers@viooh.com | |
9516 |
|
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-05T03:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9515 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | running |
|
data.engineers@viooh.com | |
9514 |
|
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-05T03:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9513 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9512 |
|
booking-processing-job_v002 | create_emr_steps | success |
|
data.engineers@viooh.com | |
9511 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9510 |
|
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-05T03:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9509 |
|
booking-processing-job_v002 | create_emr_steps | running |
|
data.engineers@viooh.com | |
9508 |
|
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-05T03:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9507 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9506 |
|
booking-processing-job_v002 | paused |
|
anonymous | [('is_paused', 'true'), ('dag_id', 'booking-processing-job_v002')] | |
9505 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9504 |
|
booking-processing-job_v002 | dagrun_success |
|
anonymous | [('csrf_token', 'IjUwZDI3MmNkM2U2ZGMzZTUyOTAyOWM4NDUxNTVlZDhhYjlhYzQ1ZTUi.X6N6Yg.pGrNoPABaMTprQ8v08YZ9X6havM'), ('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')] | |
9503 |
|
booking-processing-job_v002 | dagrun_success |
|
anonymous | [('csrf_token', 'IjUwZDI3MmNkM2U2ZGMzZTUyOTAyOWM4NDUxNTVlZDhhYjlhYzQ1ZTUi.X6N6Ww.mNr41h_B84jpWNqWHFgG43VsOp0'), ('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')] | |
9502 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9464 |
|
booking-processing-job_v002 | paused |
|
anonymous | [('is_paused', 'false'), ('dag_id', 'booking-processing-job_v002')] | |
9463 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9431 |
|
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']"} |
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')] |