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 | exchange-daily-revenue-report_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:00.939160 | 553652 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:07:01.374828 | 553168 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:00.670418 | 553166 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:00.679293 | 553164 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:07:02.399844 | 552634 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:07.461660 | 552600 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:14.229394 | 552534 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:06:01.173740 | 552242 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:00.863173 | 552240 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:00.668039 | 552237 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:08:01.622024 | 551758 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:00.688041 | 551755 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:00.889453 | 551752 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:06:01.394559 | 551258 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:00.850795 | 551256 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:00.949368 | 551254 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:06:01.398164 | 550779 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:00.891544 | 550776 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:01.081105 | 550773 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:06:01.598488 | 550287 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:00.874080 | 550284 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:00.968139 | 550281 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:08:01.669192 | 549788 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:00.975492 | 549785 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:02.112298 | 549781 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:07:01.613052 | 549305 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:00.867189 | 549302 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:01.169546 | 549299 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:08:01.700964 | 548814 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.187498 | 548811 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:01.117033 | 548807 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:08:01.846525 | 548322 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:00.814526 | 548319 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:00.960689 | 548316 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:08:02.381482 | 547824 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.229537 | 547821 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:00.939870 | 547818 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:07:01.554972 | 547314 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:00.797328 | 547309 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:01.262019 | 547307 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:08:01.717727 | 546827 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:00.937744 | 546824 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:01.009666 | 546820 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:08:01.767464 | 546332 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:00.979873 | 546330 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:00.942640 | 546326 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:08:01.768646 | 545825 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:01.019248 | 545823 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:01.328666 | 545819 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:07:01.511823 | 545323 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:00.905733 | 545320 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:01.187379 | 545317 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:08:01.769556 | 545310 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:00.856049 | 545309 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:01.240200 | 545308 |
|
airflow | 3 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:07:01.442229 | 545291 |
|
airflow | 1 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:00.866149 | 545290 |
|
airflow | 2 | default |
|
5 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:01.063857 | 545289 |
|
airflow | 3 | default |
|
5 | default_pool | |||
success | exchange-daily-revenue-report_v002 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
0:02:00.904243 | 544869 |
|
airflow | 1 | default |
|
17 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:00.866330 | 544868 |
|
airflow | 2 | default |
|
10 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:00.940738 | 544867 |
|
airflow | 3 | default |
|
6 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
0:00:02.117380 | 544804 |
|
airflow | 2 | default |
|
2 | default_pool | |||
success | exchange-daily-revenue-report_v002 | create_emr_steps |
|
PythonOperator |
|
|
0:00:01.711706 | 544800 |
|
airflow | 3 | default |
|
2 | default_pool |