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-delta-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:12:02.017201 | 394974 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:00.976213 | 394973 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:01.232159 | 394972 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:08:02.787176 | 101894 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.767197 | 101893 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:03.519073 | 101892 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
86250 |
|
airflow | 1 | default |
|
2 | default_pool | ||||
success | campaign-delta-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.787055 | 86249 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:03.090862 | 86248 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
73846 |
|
airflow | 1 | default |
|
2 | default_pool | ||||
success | campaign-delta-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.697798 | 73843 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:05.182463 | 73839 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:09:02.587595 | 5265 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.677186 | 5264 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.791646 | 5263 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.698429 | 5236 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.661873 | 5235 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.774659 | 5234 |
|
airflow | 3 | default |
|
3 | default_pool | |||
success | campaign-delta-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:12:03.011745 | 4734 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.680117 | 4733 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.728805 | 4732 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.700208 | 4731 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.607651 | 4730 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.718033 | 4729 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:11:02.929876 | 4728 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.683268 | 4727 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.721503 | 4726 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:09:02.493017 | 4725 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.679357 | 4724 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.707766 | 4723 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:12:02.856480 | 4721 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.610643 | 4720 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.781873 | 4719 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.786883 | 4690 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.697316 | 4689 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.741666 | 4688 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:09:02.646712 | 4686 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.707498 | 4685 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.771592 | 4684 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:10:02.910831 | 4683 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.634565 | 4682 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.802372 | 4681 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.662177 | 4675 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | campaign-delta-job_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.808605 | 4674 |
|
airflow | 3 | default |
|
2 | default_pool |