Id | Dttm | Dag Id | Task Id | Event | Execution Date | Owner | Extra |
---|---|---|---|---|---|---|---|
9771 |
|
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-06T12:00:54.278096+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9770 |
|
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-10T04:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9769 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9768 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | success |
|
data.engineers@viooh.com | |
9767 |
|
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-06T12:00:54.278096+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9766 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | running |
|
data.engineers@viooh.com | |
9765 |
|
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-06T12:00:54.278096+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9764 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9763 |
|
booking-processing-job_v002 | paused |
|
anonymous | [('is_paused', 'true'), ('dag_id', 'booking-processing-job_v002')] | |
9762 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9613 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9611 |
|
booking-processing-job_v002 | check_cluster_status | success |
|
data.engineers@viooh.com | |
9610 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9609 |
|
booking-processing-job_v002 | paused |
|
anonymous | [('is_paused', 'false'), ('dag_id', 'booking-processing-job_v002')] | |
9608 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9607 |
|
booking-processing-job_v002 | create_emr_steps | success |
|
data.engineers@viooh.com | |
9606 |
|
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-06T12:00:54.278096+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9605 |
|
booking-processing-job_v002 | create_emr_steps | running |
|
data.engineers@viooh.com | |
9604 |
|
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-06T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9603 |
|
booking-processing-job_v002 | check_cluster_status | running |
|
data.engineers@viooh.com | |
9602 |
|
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-06T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9601 |
|
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-06T12:00:54.278096+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9600 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | success |
|
data.engineers@viooh.com | |
9599 |
|
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-06T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9598 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | running |
|
data.engineers@viooh.com | |
9597 |
|
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-06T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9596 |
|
booking-processing-job_v002 | create_emr_steps | success |
|
data.engineers@viooh.com | |
9595 |
|
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-06T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9594 |
|
booking-processing-job_v002 | create_emr_steps | running |
|
data.engineers@viooh.com | |
9593 |
|
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-06T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9592 |
|
booking-processing-job_v002 | trigger |
|
anonymous | [('dag_id', 'booking-processing-job_v002'), ('origin', '/admin/airflow/tree?dag_id=booking-processing-job_v002'), ('csrf_token', 'IjUwZDI3MmNkM2U2ZGMzZTUyOTAyOWM4NDUxNTVlZDhhYjlhYzQ1ZTUi.X6U68Q.ht8zoXuF5M9-_CCQo9Ww9Bi4UY0')] | |
9591 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9590 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9589 |
|
booking-processing-job_v002 | paused |
|
anonymous | [('is_paused', 'true'), ('dag_id', 'booking-processing-job_v002')] | |
9538 |
|
booking-processing-job_v002 | paused |
|
anonymous | [('is_paused', 'false'), ('dag_id', 'booking-processing-job_v002')] | |
9537 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9535 |
|
booking-processing-job_v002 | check_cluster_status | success |
|
data.engineers@viooh.com | |
9534 |
|
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']"} |
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 |