State | Dag Id | Task Id | Execution Date | Operator | Start Date | End Date | Duration | Job Id | Hostname | Unixname | Priority Weight | Queue | Queued Dttm | Try Number | Pool | Log Url | ||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
success | campaign-history-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:09:02.694503 | 4555 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.762064 | 4554 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.701426 | 4553 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.717677 | 4552 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.732359 | 4551 |
|
airflow | 2 | default |
|
2 | default_pool | |||
failed | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.548078 | 4549 |
|
airflow | 1 | default |
|
3 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.652978 | 4548 |
|
airflow | 2 | default |
|
3 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.508401 | 4547 |
|
airflow | 3 | default |
|
3 | default_pool | |||
success | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:04:01.927878 | 4536 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.683406 | 4535 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.570057 | 4534 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.619081 | 4531 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.669744 | 4530 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.514866 | 4529 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.708439 | 4527 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.714357 | 4526 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.518031 | 4525 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.708132 | 4450 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.764545 | 4448 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:09:02.588295 | 4447 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.706856 | 4446 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-history-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.727055 | 4445 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.781374 | 4443 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.671732 | 4442 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.496109 | 4441 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.679574 | 4429 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.679288 | 4428 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.658327 | 4427 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:09:02.495560 | 4426 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.762214 | 4425 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.561996 | 4424 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:03.013091 | 4421 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.689752 | 4420 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.578249 | 4419 |
|
airflow | 3 | default |
|
2 | default_pool | |||
failed | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:09:02.750276 | 4417 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.721088 | 4416 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.610870 | 4415 |
|
airflow | 3 | default |
|
2 | default_pool | |||
failed | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:17:03.464855 | 4414 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.665954 | 4413 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.495116 | 4412 |
|
airflow | 3 | default |
|
2 | default_pool | |||
failed | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:18:03.828339 | 4410 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.651322 | 4409 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.496672 | 4408 |
|
airflow | 3 | default |
|
2 | default_pool | |||
failed | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.603523 | 4407 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.631753 | 4406 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.521479 | 4405 |
|
airflow | 3 | default |
|
2 | default_pool | |||
failed | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:09:02.529209 | 4403 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.685595 | 4402 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.525719 | 4401 |
|
airflow | 3 | default |
|
2 | default_pool | |||
failed | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:09:02.541345 | 4400 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.661398 | 4399 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.538718 | 4398 |
|
airflow | 3 | default |
|
2 | default_pool | |||
failed | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.678217 | 4397 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.679937 | 4396 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.647750 | 4395 |
|
airflow | 3 | default |
|
2 | default_pool | |||
failed | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:09:02.531765 | 4393 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.676688 | 4392 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.631768 | 4391 |
|
airflow | 3 | default |
|
2 | default_pool | |||
failed | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.755711 | 4389 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.690809 | 4388 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.821222 | 4387 |
|
airflow | 3 | default |
|
2 | default_pool | |||
failed | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.460203 | 4363 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.513817 | 4362 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.497270 | 4361 |
|
airflow | 3 | default |
|
2 | default_pool | |||
failed | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.460383 | 4360 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.618356 | 4359 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.635399 | 4358 |
|
airflow | 3 | default |
|
2 | default_pool | |||
failed | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.612733 | 4356 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.547031 | 4355 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.575994 | 4354 |
|
airflow | 3 | default |
|
2 | default_pool | |||
failed | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:09:02.532670 | 4348 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.602977 | 4347 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.501705 | 4346 |
|
airflow | 3 | default |
|
2 | default_pool | |||
failed | campaign-versioning-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:09:02.323413 | 4345 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.556259 | 4344 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.498527 | 4343 |
|
airflow | 3 | default |
|
2 | default_pool | |||
failed | campaign-versioning-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.454006 | 4341 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-versioning-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.693905 | 4340 |
|
airflow | 3 | default |
|
2 | default_pool | |||
failed | 24hrPOP-processing-flow_v001 | create_cluster_n_add_steps |
|
PythonOperator |
|
|
0:00:02.446513 | 1558 |
|
airflow | 1 | default |
|
2 | default_pool | |||
failed | 24hrPOP-processing-flow_v001 | create_cluster_n_add_steps |
|
PythonOperator |
|
|
0:00:02.490013 | 1557 |
|
airflow | 1 | default |
|
5 | default_pool | |||
failed | 24hrPOP-processing-flow_v001 | create_cluster_n_add_steps |
|
PythonOperator |
|
|
0:00:02.369803 | 1553 |
|
airflow | 1 | default |
|
5 | default_pool | |||
success | Helloworld | task_4 |
|
BashOperator |
|
|
0:00:00.183689 | 165 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | Helloworld | task_2 |
|
BashOperator |
|
|
0:00:00.223836 | 164 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | Helloworld | task_3 |
|
BashOperator |
|
|
0:00:00.252151 | 163 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | Helloworld | task_1 |
|
BashOperator |
|
|
0:00:00.176840 | 162 |
|
airflow | 4 | default |
|
2 | default_pool | |||
success | Helloworld | task_4 |
|
BashOperator |
|
|
0:00:00.185273 | 139 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | Helloworld | task_3 |
|
BashOperator |
|
|
0:00:00.239284 | 138 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | Helloworld | task_2 |
|
BashOperator |
|
|
0:00:00.237697 | 137 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | Helloworld | task_1 |
|
BashOperator |
|
|
0:00:00.183089 | 136 |
|
airflow | 4 | default |
|
2 | default_pool | |||
success | Helloworld | task_4 |
|
BashOperator |
|
|
0:00:00.177546 | 106 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | Helloworld | task_2 |
|
BashOperator |
|
|
0:00:00.244127 | 105 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | Helloworld | task_3 |
|
BashOperator |
|
|
0:00:00.248065 | 104 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | Helloworld | task_1 |
|
BashOperator |
|
|
0:00:00.172465 | 103 |
|
airflow | 4 | default |
|
2 | default_pool |