Id | Dttm | Dag Id | Task Id | Event | Execution Date | Owner | Extra |
---|---|---|---|---|---|---|---|
7370 |
|
campaign-delta-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-10-28T04:42:29.678537+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7369 |
|
campaign-delta-job_v002 | trigger |
|
anonymous | [('dag_id', 'campaign-delta-job_v002'), ('origin', '/admin/airflow/tree?dag_id=campaign-delta-job_v002'), ('csrf_token', 'ImFlMGJkZGUzMmNjZTg1ODE2NzY3NTczYjk0YjU3MDE4OGRiYjE2NWYi.X5j2dA.bJG1q7VnxKJKfk_YArlcJ7bSL3M')] | |
7368 |
|
campaign-delta-job_v002 | tree |
|
anonymous | [('dag_id', 'campaign-delta-job_v002')] | |
7366 |
|
campaign-delta-job_v002 | check_cluster_status | success |
|
data.engineers@viooh.com | |
7365 |
|
campaign-delta-job_v002 | tree |
|
anonymous | [('dag_id', 'campaign-delta-job_v002')] | |
7364 |
|
campaign-delta-job_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'check_cluster_status', '2020-10-28T04:12:39.241180+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7363 |
|
campaign-delta-job_v002 | check_cluster_status | running |
|
data.engineers@viooh.com | |
7362 |
|
campaign-delta-job_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'check_cluster_status', '2020-10-28T04:12:39.241180+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7361 |
|
campaign-delta-job_v002 | create_cluster_and_add_emr_steps | success |
|
data.engineers@viooh.com | |
7360 |
|
campaign-delta-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_cluster_and_add_emr_steps', '2020-10-28T04:12:39.241180+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7359 |
|
campaign-delta-job_v002 | create_cluster_and_add_emr_steps | running |
|
data.engineers@viooh.com | |
7358 |
|
campaign-delta-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_cluster_and_add_emr_steps', '2020-10-28T04:12:39.241180+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7357 |
|
campaign-delta-job_v002 | create_emr_steps | success |
|
data.engineers@viooh.com | |
7356 |
|
campaign-delta-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-10-28T04:12:39.241180+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7355 |
|
campaign-delta-job_v002 | create_emr_steps | running |
|
data.engineers@viooh.com | |
7354 |
|
campaign-delta-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-10-28T04:12:39.241180+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7353 |
|
campaign-delta-job_v002 | trigger |
|
anonymous | [('dag_id', 'campaign-delta-job_v002'), ('origin', '/admin/airflow/tree?dag_id=campaign-delta-job_v002'), ('csrf_token', 'ImFlMGJkZGUzMmNjZTg1ODE2NzY3NTczYjk0YjU3MDE4OGRiYjE2NWYi.X5jvrQ.lfYcbK5ZkdxjAGa7o0JdcGBDf1U')] | |
7352 |
|
campaign-delta-job_v002 | tree |
|
anonymous | [('dag_id', 'campaign-delta-job_v002')] | |
7282 |
|
campaign-delta-job_v002 | check_cluster_status | success |
|
data.engineers@viooh.com | |
7281 |
|
campaign-delta-job_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'check_cluster_status', '2020-10-27T08:51:16.826478+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7280 |
|
campaign-delta-job_v002 | check_cluster_status | running |
|
data.engineers@viooh.com | |
7279 |
|
campaign-delta-job_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'check_cluster_status', '2020-10-27T08:51:16.826478+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7278 |
|
campaign-delta-job_v002 | create_cluster_and_add_emr_steps | success |
|
data.engineers@viooh.com | |
7277 |
|
campaign-delta-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_cluster_and_add_emr_steps', '2020-10-27T08:51:16.826478+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7276 |
|
campaign-delta-job_v002 | create_cluster_and_add_emr_steps | running |
|
data.engineers@viooh.com | |
7275 |
|
campaign-delta-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_cluster_and_add_emr_steps', '2020-10-27T08:51:16.826478+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7274 |
|
campaign-delta-job_v002 | create_emr_steps | success |
|
data.engineers@viooh.com | |
7273 |
|
campaign-delta-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-10-27T08:51:16.826478+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7272 |
|
campaign-delta-job_v002 | create_emr_steps | running |
|
data.engineers@viooh.com | |
7271 |
|
campaign-delta-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-10-27T08:51:16.826478+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7270 |
|
campaign-delta-job_v002 | trigger |
|
anonymous | [('dag_id', 'campaign-delta-job_v002'), ('origin', '/admin/airflow/tree?dag_id=campaign-delta-job_v002'), ('csrf_token', 'ImM5MDI0N2Q3OWIzNGZiYjhjMDZmZDJjZTFhNGVjZTk1NGY5ZDJmYjEi.X5fffw.rn0-YzveRgwPHJso0nApGBsxNdo')] | |
7269 |
|
campaign-delta-job_v002 | tree |
|
anonymous | [('dag_id', 'campaign-delta-job_v002')] | |
7268 |
|
campaign-delta-job_v002 | tree |
|
anonymous | [('dag_id', 'campaign-delta-job_v002')] | |
7266 |
|
campaign-delta-job_v002 | check_cluster_status | success |
|
data.engineers@viooh.com | |
7265 |
|
campaign-delta-job_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'check_cluster_status', '2020-10-27T08:21:37.361079+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7264 |
|
campaign-delta-job_v002 | check_cluster_status | running |
|
data.engineers@viooh.com | |
7263 |
|
campaign-delta-job_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'check_cluster_status', '2020-10-27T08:21:37.361079+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7262 |
|
campaign-delta-job_v002 | create_cluster_and_add_emr_steps | success |
|
data.engineers@viooh.com | |
7261 |
|
campaign-delta-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_cluster_and_add_emr_steps', '2020-10-27T08:21:37.361079+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7260 |
|
campaign-delta-job_v002 | create_cluster_and_add_emr_steps | running |
|
data.engineers@viooh.com | |
7259 |
|
campaign-delta-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_cluster_and_add_emr_steps', '2020-10-27T08:21:37.361079+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7258 |
|
campaign-delta-job_v002 | create_emr_steps | success |
|
data.engineers@viooh.com | |
7257 |
|
campaign-delta-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-10-27T08:21:37.361079+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7256 |
|
campaign-delta-job_v002 | create_emr_steps | running |
|
data.engineers@viooh.com | |
7255 |
|
campaign-delta-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-10-27T08:21:37.361079+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7254 |
|
campaign-delta-job_v002 | trigger |
|
anonymous | [('dag_id', 'campaign-delta-job_v002'), ('origin', '/admin/airflow/tree?dag_id=campaign-delta-job_v002'), ('csrf_token', 'ImM5MDI0N2Q3OWIzNGZiYjhjMDZmZDJjZTFhNGVjZTk1NGY5ZDJmYjEi.X5fYiw.ESA1-gW7TPdJ-dQLiRZZPCnjcB0')] | |
7253 |
|
campaign-delta-job_v002 | tree |
|
anonymous | [('dag_id', 'campaign-delta-job_v002')] | |
7252 |
|
campaign-delta-job_v002 | check_cluster_status | success |
|
data.engineers@viooh.com | |
7251 |
|
campaign-delta-job_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'check_cluster_status', '2020-10-27T08:09:18.813936+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7250 |
|
campaign-delta-job_v002 | check_cluster_status | running |
|
data.engineers@viooh.com | |
7249 |
|
campaign-delta-job_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'check_cluster_status', '2020-10-27T08:09:18.813936+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7248 |
|
campaign-delta-job_v002 | create_cluster_and_add_emr_steps | success |
|
data.engineers@viooh.com | |
7247 |
|
campaign-delta-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_cluster_and_add_emr_steps', '2020-10-27T08:09:18.813936+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7246 |
|
campaign-delta-job_v002 | create_cluster_and_add_emr_steps | running |
|
data.engineers@viooh.com | |
7245 |
|
campaign-delta-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_cluster_and_add_emr_steps', '2020-10-27T08:09:18.813936+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7244 |
|
campaign-delta-job_v002 | create_emr_steps | success |
|
data.engineers@viooh.com | |
7243 |
|
campaign-delta-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-10-27T08:09:18.813936+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7242 |
|
campaign-delta-job_v002 | create_emr_steps | running |
|
data.engineers@viooh.com | |
7241 |
|
campaign-delta-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-10-27T08:09:18.813936+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7240 |
|
campaign-delta-job_v002 | trigger |
|
anonymous | [('dag_id', 'campaign-delta-job_v002'), ('origin', '/admin/airflow/tree?dag_id=campaign-delta-job_v002'), ('csrf_token', 'ImM5MDI0N2Q3OWIzNGZiYjhjMDZmZDJjZTFhNGVjZTk1NGY5ZDJmYjEi.X5fVpQ.bl7tAOuVnBrXqmi1fRHgPoOfKgY')] | |
7239 |
|
campaign-delta-job_v002 | tree |
|
anonymous | [('dag_id', 'campaign-delta-job_v002')] | |
7238 |
|
campaign-delta-job_v002 | tree |
|
anonymous | [('dag_id', 'campaign-delta-job_v002'), ('num_runs', '')] | |
7224 |
|
campaign-delta-job_v002 | tree |
|
anonymous | [('dag_id', 'campaign-delta-job_v002')] | |
7223 |
|
campaign-delta-job_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'check_cluster_status', '2020-10-27T07:14:42.288860+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7222 |
|
campaign-delta-job_v002 | check_cluster_status | running |
|
data.engineers@viooh.com | |
7221 |
|
campaign-delta-job_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'check_cluster_status', '2020-10-27T07:14:42.288860+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7220 |
|
campaign-delta-job_v002 | create_cluster_and_add_emr_steps | success |
|
data.engineers@viooh.com | |
7219 |
|
campaign-delta-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_cluster_and_add_emr_steps', '2020-10-27T07:14:42.288860+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7218 |
|
campaign-delta-job_v002 | create_cluster_and_add_emr_steps | running |
|
data.engineers@viooh.com | |
7217 |
|
campaign-delta-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_cluster_and_add_emr_steps', '2020-10-27T07:14:42.288860+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7216 |
|
campaign-delta-job_v002 | create_emr_steps | success |
|
data.engineers@viooh.com | |
7215 |
|
campaign-delta-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-10-27T07:14:42.288860+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7214 |
|
campaign-delta-job_v002 | create_emr_steps | running |
|
data.engineers@viooh.com | |
7213 |
|
campaign-delta-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-10-27T07:14:42.288860+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7212 |
|
campaign-delta-job_v002 | trigger |
|
anonymous | [('dag_id', 'campaign-delta-job_v002'), ('origin', '/admin/airflow/tree?dag_id=campaign-delta-job_v002'), ('csrf_token', 'ImM5MDI0N2Q3OWIzNGZiYjhjMDZmZDJjZTFhNGVjZTk1NGY5ZDJmYjEi.X5fI3A.RQBHpJQEWQ9IhfKu2Kav_UcK8uk')] | |
7211 |
|
campaign-delta-job_v002 | tree |
|
anonymous | [('dag_id', 'campaign-delta-job_v002')] | |
7209 |
|
campaign-delta-job_v002 | create_emr_steps | get_logs_with_metadata |
|
anonymous | [('dag_id', 'campaign-delta-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2020-10-27T05:28:31.182130+00:00'), ('try_number', '1'), ('metadata', 'null')] |
7208 |
|
campaign-delta-job_v002 | create_emr_steps | log |
|
anonymous | [('task_id', 'create_emr_steps'), ('dag_id', 'campaign-delta-job_v002'), ('execution_date', '2020-10-27T05:28:31.182130+00:00'), ('format', 'json')] |
7207 |
|
campaign-delta-job_v002 | tree |
|
anonymous | [('dag_id', 'campaign-delta-job_v002'), ('num_runs', ''), ('root', '')] | |
7206 |
|
campaign-delta-job_v002 | tree |
|
anonymous | [('dag_id', 'campaign-delta-job_v002')] | |
7180 |
|
campaign-delta-job_v002 | create_emr_steps | get_logs_with_metadata |
|
anonymous | [('dag_id', 'campaign-delta-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2020-10-27T05:28:31.182130+00:00'), ('try_number', '1'), ('metadata', 'null')] |
7177 |
|
campaign-delta-job_v002 | create_emr_steps | log |
|
anonymous | [('task_id', 'create_emr_steps'), ('dag_id', 'campaign-delta-job_v002'), ('execution_date', '2020-10-27T05:28:31.182130+00:00'), ('format', 'json')] |
7174 |
|
campaign-delta-job_v002 | tree |
|
anonymous | [('dag_id', 'campaign-delta-job_v002')] | |
7173 |
|
campaign-delta-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-delta-job_v002'), ('execution_date', '')] | |
7172 |
|
campaign-delta-job_v002 | tree |
|
anonymous | [('dag_id', 'campaign-delta-job_v002')] | |
7171 |
|
campaign-delta-job_v002 | create_emr_steps | get_logs_with_metadata |
|
anonymous | [('dag_id', 'campaign-delta-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2020-10-27T05:28:31.182130+00:00'), ('try_number', '1'), ('metadata', 'null')] |
7170 |
|
campaign-delta-job_v002 | create_emr_steps | log |
|
anonymous | [('dag_id', 'campaign-delta-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2020-10-27T05:28:31.182130+00:00')] |
7169 |
|
campaign-delta-job_v002 | create_emr_steps | get_logs_with_metadata |
|
anonymous | [('dag_id', 'campaign-delta-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2020-10-27T05:28:31.182130+00:00'), ('try_number', '1'), ('metadata', 'null')] |
7168 |
|
campaign-delta-job_v002 | create_emr_steps | log |
|
anonymous | [('dag_id', 'campaign-delta-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2020-10-27T05:28:31.182130+00:00')] |
7167 |
|
campaign-delta-job_v002 | tree |
|
anonymous | [('dag_id', 'campaign-delta-job_v002')] | |
7166 |
|
campaign-delta-job_v002 | tree |
|
anonymous | [('dag_id', 'campaign-delta-job_v002'), ('num_runs', ''), ('root', '')] | |
7164 |
|
campaign-delta-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-10-27T05:28:31.182130+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7163 |
|
campaign-delta-job_v002 | create_emr_steps | running |
|
data.engineers@viooh.com | |
7162 |
|
campaign-delta-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-10-27T05:28:31.182130+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"} |
7161 |
|
campaign-delta-job_v002 | trigger |
|
anonymous | [('dag_id', 'campaign-delta-job_v002'), ('origin', '/admin/airflow/tree?dag_id=campaign-delta-job_v002'), ('csrf_token', 'ImM5MDI0N2Q3OWIzNGZiYjhjMDZmZDJjZTFhNGVjZTk1NGY5ZDJmYjEi.X5ev-g.cnJ8BJecQfBi3PxB1yn7x-KWJ28')] | |
7160 |
|
campaign-delta-job_v002 | tree |
|
anonymous | [('dag_id', 'campaign-delta-job_v002'), ('num_runs', ''), ('root', '')] | |
7159 |
|
campaign-delta-job_v002 | create_emr_steps | get_logs_with_metadata |
|
anonymous | [('dag_id', 'campaign-delta-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2020-10-27T05:12:16.511905+00:00'), ('try_number', '1'), ('metadata', 'null')] |
7158 |
|
campaign-delta-job_v002 | create_emr_steps | log |
|
anonymous | [('dag_id', 'campaign-delta-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2020-10-27T05:12:16.511905+00:00')] |
7157 |
|
campaign-delta-job_v002 | tree |
|
anonymous | [('dag_id', 'campaign-delta-job_v002')] | |
7156 |
|
campaign-delta-job_v002 | create_cluster_and_add_emr_steps | log |
|
anonymous | [('dag_id', 'campaign-delta-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2020-10-27T05:08:42.421887+00:00')] |