Id | Dttm | Dag Id | Task Id | Event | Execution Date | Owner | Extra |
---|---|---|---|---|---|---|---|
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')] | |
9317 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9316 |
|
booking-processing-job_v002 | tree |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
9315 |
|
booking-processing-job_v002 | paused |
|
anonymous | [('is_paused', 'true'), ('dag_id', 'booking-processing-job_v002')] | |
9203 |
|
booking-processing-job_v002 | paused |
|
anonymous | [('is_paused', 'false'), ('dag_id', 'booking-processing-job_v002')] | |
9201 |
|
booking-processing-job_v002 | check_cluster_status | success |
|
data.engineers@viooh.com | |
9200 |
|
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-02T04:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9199 |
|
booking-processing-job_v002 | check_cluster_status | running |
|
data.engineers@viooh.com | |
9198 |
|
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-02T04:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9197 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | success |
|
data.engineers@viooh.com | |
9196 |
|
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-02T04:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9195 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | running |
|
data.engineers@viooh.com | |
9194 |
|
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-02T04:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9193 |
|
booking-processing-job_v002 | create_emr_steps | success |
|
data.engineers@viooh.com | |
9192 |
|
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-02T04:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9191 |
|
booking-processing-job_v002 | create_emr_steps | running |
|
data.engineers@viooh.com | |
9190 |
|
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-02T04:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9188 |
|
booking-processing-job_v002 | check_cluster_status | success |
|
data.engineers@viooh.com | |
9187 |
|
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-02T03:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9186 |
|
booking-processing-job_v002 | check_cluster_status | running |
|
data.engineers@viooh.com | |
9185 |
|
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-02T03:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9184 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | success |
|
data.engineers@viooh.com | |
9183 |
|
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-02T03:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9182 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | running |
|
data.engineers@viooh.com | |
9181 |
|
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-02T03:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9180 |
|
booking-processing-job_v002 | create_emr_steps | success |
|
data.engineers@viooh.com | |
9179 |
|
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-02T03:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9178 |
|
booking-processing-job_v002 | create_emr_steps | running |
|
data.engineers@viooh.com | |
9177 |
|
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-02T03:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9175 |
|
booking-processing-job_v002 | check_cluster_status | success |
|
data.engineers@viooh.com | |
9174 |
|
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-02T02:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9173 |
|
booking-processing-job_v002 | check_cluster_status | running |
|
data.engineers@viooh.com | |
9172 |
|
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-02T02:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9171 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | success |
|
data.engineers@viooh.com | |
9170 |
|
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-02T02:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9169 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | running |
|
data.engineers@viooh.com | |
9168 |
|
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-02T02:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9167 |
|
booking-processing-job_v002 | create_emr_steps | success |
|
data.engineers@viooh.com | |
9166 |
|
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-02T02:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9165 |
|
booking-processing-job_v002 | create_emr_steps | running |
|
data.engineers@viooh.com | |
9164 |
|
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-02T02:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9162 |
|
booking-processing-job_v002 | check_cluster_status | success |
|
data.engineers@viooh.com | |
9161 |
|
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-02T01:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9160 |
|
booking-processing-job_v002 | check_cluster_status | running |
|
data.engineers@viooh.com | |
9159 |
|
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-02T01:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9158 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | success |
|
data.engineers@viooh.com | |
9157 |
|
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-02T01:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9156 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | running |
|
data.engineers@viooh.com | |
9155 |
|
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-02T01:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9154 |
|
booking-processing-job_v002 | create_emr_steps | success |
|
data.engineers@viooh.com | |
9153 |
|
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-02T01:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9152 |
|
booking-processing-job_v002 | create_emr_steps | running |
|
data.engineers@viooh.com | |
9151 |
|
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-02T01:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9149 |
|
booking-processing-job_v002 | check_cluster_status | success |
|
data.engineers@viooh.com | |
9148 |
|
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-02T00:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9147 |
|
booking-processing-job_v002 | check_cluster_status | running |
|
data.engineers@viooh.com | |
9146 |
|
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-02T00:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9145 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | success |
|
data.engineers@viooh.com | |
9144 |
|
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-02T00:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9143 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | running |
|
data.engineers@viooh.com | |
9142 |
|
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-02T00:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9141 |
|
booking-processing-job_v002 | create_emr_steps | success |
|
data.engineers@viooh.com | |
9140 |
|
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-02T00:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9139 |
|
booking-processing-job_v002 | create_emr_steps | running |
|
data.engineers@viooh.com | |
9138 |
|
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-02T00:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9136 |
|
booking-processing-job_v002 | check_cluster_status | success |
|
data.engineers@viooh.com | |
9135 |
|
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-01T23:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9134 |
|
booking-processing-job_v002 | check_cluster_status | running |
|
data.engineers@viooh.com | |
9133 |
|
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-01T23:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
9132 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | success |
|
data.engineers@viooh.com |