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 | ||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
upstream_failed | backfill_snowflake-reporting-hourly-import_v001 | end |
|
DummyOperator |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps |
|
EmrCreateJobFlowOperator |
|
|
|
airflow | 2 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps |
|
PythonOperator |
|
|
|
airflow | 3 | default |
|
1 | default_pool | |||||
success | backfill_snowflake-reporting-hourly-import_v001 | start |
|
DummyOperator |
|
|
|
airflow | 9 | default |
|
1 | default_pool | |||||
upstream_failed | livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status |
|
EmrJobFlowSensor |
|
|
|
airflow | 1 | default |
|
1 | default_pool |