Id | Dttm | Dag Id | Task Id | Event | Execution Date | Owner | Extra |
---|---|---|---|---|---|---|---|
7192 |
|
daily-import-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'daily-import-job_v002', 'create_cluster_and_add_emr_steps', '2020-10-27T04:30:04.247874+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/daily-import-job_v002.py']"} |
7191 |
|
daily-import-job_v002 | create_cluster_and_add_emr_steps | running |
|
data.engineers@viooh.com | |
7190 |
|
daily-import-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'daily-import-job_v002', 'create_cluster_and_add_emr_steps', '2020-10-27T04:30:04.247874+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/daily-import-job_v002.py']"} |
7189 |
|
daily-import-job_v002 | tree |
|
anonymous | [('dag_id', 'daily-import-job_v002'), ('num_runs', '25')] | |
7188 |
|
daily-import-job_v002 | tree |
|
anonymous | [('dag_id', 'daily-import-job_v002'), ('num_runs', '25')] | |
7187 |
|
daily-import-job_v002 | tree |
|
anonymous | [('dag_id', 'daily-import-job_v002'), ('num_runs', '25')] | |
7186 |
|
daily-import-job_v002 | create_emr_steps | success |
|
data.engineers@viooh.com | |
7185 |
|
daily-import-job_v002 | tree |
|
anonymous | [('dag_id', 'daily-import-job_v002'), ('num_runs', '25')] | |
7184 |
|
daily-import-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'daily-import-job_v002', 'create_emr_steps', '2020-10-27T04:30:04.247874+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/daily-import-job_v002.py']"} |
7183 |
|
daily-import-job_v002 | create_emr_steps | running |
|
data.engineers@viooh.com | |
7182 |
|
daily-import-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'daily-import-job_v002', 'create_emr_steps', '2020-10-27T04:30:04.247874+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/daily-import-job_v002.py']"} |
7181 |
|
daily-import-job_v002 | tree |
|
anonymous | [('dag_id', 'daily-import-job_v002'), ('num_runs', '25')] | |
7179 |
|
daily-import-job_v002 | tree |
|
anonymous | [('dag_id', 'daily-import-job_v002')] | |
7178 |
|
daily-import-job_v002 | create_emr_steps | clear |
|
anonymous | [('csrf_token', 'IjMxYmViMmIxOGUzNzlkOGU0OTEwZWFhMjEzNjlkMzcyZjYxNzE4ODIi.X5e5YQ.zzkquagPhPmzQ4dTBMjQM9rRxVo'), ('confirmed', 'true'), ('dag_id', 'daily-import-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2020-10-27T04:30:04.247874+00:00'), ('origin', 'https://airflow.mgmt.viooh.net.cn/admin/airflow/tree?dag_id=daily-import-job_v002'), ('downstream', 'true'), ('recursive', 'true')] |
7176 |
|
daily-import-job_v002 | create_emr_steps | clear |
|
anonymous | [('csrf_token', 'IjMxYmViMmIxOGUzNzlkOGU0OTEwZWFhMjEzNjlkMzcyZjYxNzE4ODIi.X5e5WA.2weG2rxXEjuNs1qRiPotkkbnQMI'), ('dag_id', 'daily-import-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2020-10-27T04:30:04.247874+00:00'), ('origin', 'https://airflow.mgmt.viooh.net.cn/admin/airflow/tree?dag_id=daily-import-job_v002'), ('downstream', 'true'), ('recursive', 'true')] |
7175 |
|
daily-import-job_v002 | tree |
|
anonymous | [('dag_id', 'daily-import-job_v002')] | |
7141 |
|
daily-import-job_v002 | tree |
|
anonymous | [('dag_id', 'daily-import-job_v002'), ('num_runs', '')] | |
7139 |
|
daily-import-job_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'daily-import-job_v002', 'check_cluster_status', '2020-10-27T04:30:04.247874+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/daily-import-job_v002.py']"} |
7138 |
|
daily-import-job_v002 | check_cluster_status | running |
|
data.engineers@viooh.com | |
7137 |
|
daily-import-job_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'daily-import-job_v002', 'check_cluster_status', '2020-10-27T04:30:04.247874+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/daily-import-job_v002.py']"} |
7136 |
|
daily-import-job_v002 | create_cluster_and_add_emr_steps | success |
|
data.engineers@viooh.com | |
7135 |
|
daily-import-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'daily-import-job_v002', 'create_cluster_and_add_emr_steps', '2020-10-27T04:30:04.247874+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/daily-import-job_v002.py']"} |
7134 |
|
daily-import-job_v002 | create_cluster_and_add_emr_steps | running |
|
data.engineers@viooh.com | |
7133 |
|
daily-import-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'daily-import-job_v002', 'create_cluster_and_add_emr_steps', '2020-10-27T04:30:04.247874+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/daily-import-job_v002.py']"} |
7132 |
|
daily-import-job_v002 | create_emr_steps | success |
|
data.engineers@viooh.com | |
7131 |
|
daily-import-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'daily-import-job_v002', 'create_emr_steps', '2020-10-27T04:30:04.247874+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/daily-import-job_v002.py']"} |
7130 |
|
daily-import-job_v002 | create_emr_steps | running |
|
data.engineers@viooh.com | |
7129 |
|
daily-import-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'daily-import-job_v002', 'create_emr_steps', '2020-10-27T04:30:04.247874+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/daily-import-job_v002.py']"} |
7128 |
|
daily-import-job_v002 | trigger |
|
anonymous | [('dag_id', 'daily-import-job_v002'), ('origin', '/admin/airflow/tree?dag_id=daily-import-job_v002'), ('csrf_token', 'ImM5MDI0N2Q3OWIzNGZiYjhjMDZmZDJjZTFhNGVjZTk1NGY5ZDJmYjEi.X5eiRQ.cbSPHQRwr6xvxn9BhUzGh-ujEUk')] | |
7127 |
|
daily-import-job_v002 | tree |
|
anonymous | [('dag_id', 'daily-import-job_v002'), ('num_runs', '')] | |
7126 |
|
daily-import-job_v002 | tree |
|
anonymous | [('dag_id', 'daily-import-job_v002')] | |
7123 |
|
daily-import-job_v002 | tree |
|
anonymous | [('dag_id', 'daily-import-job_v002')] | |
7122 |
|
daily-import-job_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'daily-import-job_v002', 'check_cluster_status', '2020-10-27T03:24:03.835170+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/daily-import-job_v002.py']"} |
7121 |
|
daily-import-job_v002 | check_cluster_status | running |
|
data.engineers@viooh.com | |
7120 |
|
daily-import-job_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'daily-import-job_v002', 'check_cluster_status', '2020-10-27T03:24:03.835170+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/daily-import-job_v002.py']"} |
7119 |
|
daily-import-job_v002 | create_cluster_and_add_emr_steps | success |
|
data.engineers@viooh.com | |
7118 |
|
daily-import-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'daily-import-job_v002', 'create_cluster_and_add_emr_steps', '2020-10-27T03:24:03.835170+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/daily-import-job_v002.py']"} |
7117 |
|
daily-import-job_v002 | create_cluster_and_add_emr_steps | running |
|
data.engineers@viooh.com | |
7116 |
|
daily-import-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'daily-import-job_v002', 'create_cluster_and_add_emr_steps', '2020-10-27T03:24:03.835170+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/daily-import-job_v002.py']"} |
7115 |
|
daily-import-job_v002 | create_emr_steps | success |
|
data.engineers@viooh.com | |
7114 |
|
daily-import-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'daily-import-job_v002', 'create_emr_steps', '2020-10-27T03:24:03.835170+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/daily-import-job_v002.py']"} |
7113 |
|
daily-import-job_v002 | create_emr_steps | running |
|
data.engineers@viooh.com | |
7112 |
|
daily-import-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'daily-import-job_v002', 'create_emr_steps', '2020-10-27T03:24:03.835170+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/daily-import-job_v002.py']"} |
7111 |
|
daily-import-job_v002 | trigger |
|
anonymous | [('dag_id', 'daily-import-job_v002'), ('origin', '/admin/airflow/tree?dag_id=daily-import-job_v002'), ('csrf_token', 'ImM5MDI0N2Q3OWIzNGZiYjhjMDZmZDJjZTFhNGVjZTk1NGY5ZDJmYjEi.X5eSzA.mEJYznnRgDjY5StkRe1TMK7IFcQ')] | |
7110 |
|
daily-import-job_v002 | paused |
|
anonymous | [('is_paused', 'true'), ('dag_id', 'daily-import-job_v002')] | |
7109 |
|
daily-import-job_v002 | tree |
|
anonymous | [('dag_id', 'daily-import-job_v002')] | |
7108 |
|
daily-import-job_v002 | tree |
|
anonymous | [('dag_id', 'daily-import-job_v002')] | |
7101 |
|
daily-import-job_v002 | tree |
|
anonymous | [('dag_id', 'daily-import-job_v002')] |