Task Instances

  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_emr_steps 2023-10-30T16:00:00+00:00 PythonOperator 2023-10-30T17:24:34.853289+00:00 2023-10-30T17:24:34.853298+00:00 airflow 3 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status 2023-10-30T15:00:00+00:00 EmrJobFlowSensor 2023-10-30T16:32:50.666006+00:00 2023-10-30T16:32:50.666014+00:00 airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps 2023-10-30T15:00:00+00:00 EmrCreateJobFlowOperator 2023-10-30T16:32:50.650915+00:00 2023-10-30T16:32:50.650924+00:00 airflow 2 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps 2023-10-30T15:00:00+00:00 PythonOperator 2023-10-30T16:32:50.627838+00:00 2023-10-30T16:32:50.627847+00:00 airflow 3 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status 2023-10-30T14:00:00+00:00 EmrJobFlowSensor 2023-10-30T15:23:48.290951+00:00 2023-10-30T15:23:48.290961+00:00 airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps 2023-10-30T14:00:00+00:00 EmrCreateJobFlowOperator 2023-10-30T15:23:48.274000+00:00 2023-10-30T15:23:48.274009+00:00 airflow 2 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps 2023-10-30T14:00:00+00:00 PythonOperator 2023-10-30T15:23:48.248021+00:00 2023-10-30T15:23:48.248032+00:00 airflow 3 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status 2023-10-30T13:00:00+00:00 EmrJobFlowSensor 2023-10-30T14:29:52.036847+00:00 2023-10-30T14:29:52.036856+00:00 airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps 2023-10-30T13:00:00+00:00 EmrCreateJobFlowOperator 2023-10-30T14:29:52.019415+00:00 2023-10-30T14:29:52.019424+00:00 airflow 2 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps 2023-10-30T13:00:00+00:00 PythonOperator 2023-10-30T14:29:51.994185+00:00 2023-10-30T14:29:51.994194+00:00 airflow 3 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status 2023-10-30T12:00:00+00:00 EmrJobFlowSensor 2023-10-30T13:31:31.424351+00:00 2023-10-30T13:31:31.424360+00:00 airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps 2023-10-30T12:00:00+00:00 EmrCreateJobFlowOperator 2023-10-30T13:31:31.409085+00:00 2023-10-30T13:31:31.409095+00:00 airflow 2 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps 2023-10-30T12:00:00+00:00 PythonOperator 2023-10-30T13:31:31.384014+00:00 2023-10-30T13:31:31.384025+00:00 airflow 3 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status 2023-10-30T11:00:00+00:00 EmrJobFlowSensor 2023-10-30T12:32:28.992987+00:00 2023-10-30T12:32:28.992996+00:00 airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps 2023-10-30T11:00:00+00:00 EmrCreateJobFlowOperator 2023-10-30T12:32:28.977646+00:00 2023-10-30T12:32:28.977655+00:00 airflow 2 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps 2023-10-30T11:00:00+00:00 PythonOperator 2023-10-30T12:32:28.953599+00:00 2023-10-30T12:32:28.953610+00:00 airflow 3 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status 2023-10-30T10:00:00+00:00 EmrJobFlowSensor 2023-10-30T11:43:15.156859+00:00 2023-10-30T11:43:15.156870+00:00 airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps 2023-10-30T10:00:00+00:00 EmrCreateJobFlowOperator 2023-10-30T11:43:15.140797+00:00 2023-10-30T11:43:15.140807+00:00 airflow 2 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps 2023-10-30T10:00:00+00:00 PythonOperator 2023-10-30T11:43:15.116106+00:00 2023-10-30T11:43:15.116117+00:00 airflow 3 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status 2023-10-30T09:00:00+00:00 EmrJobFlowSensor 2023-10-30T10:21:23.661352+00:00 2023-10-30T10:21:23.661361+00:00 airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps 2023-10-30T09:00:00+00:00 EmrCreateJobFlowOperator 2023-10-30T10:21:23.646383+00:00 2023-10-30T10:21:23.646392+00:00 airflow 2 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps 2023-10-30T09:00:00+00:00 PythonOperator 2023-10-30T10:21:23.621987+00:00 2023-10-30T10:21:23.621997+00:00 airflow 3 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status 2023-10-30T08:00:00+00:00 EmrJobFlowSensor 2023-10-30T09:21:44.932361+00:00 2023-10-30T09:21:44.932370+00:00 airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps 2023-10-30T08:00:00+00:00 EmrCreateJobFlowOperator 2023-10-30T09:21:44.917147+00:00 2023-10-30T09:21:44.917156+00:00 airflow 2 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps 2023-10-30T08:00:00+00:00 PythonOperator 2023-10-30T09:21:44.892890+00:00 2023-10-30T09:21:44.892900+00:00 airflow 3 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status 2023-10-30T07:00:00+00:00 EmrJobFlowSensor 2023-10-30T08:23:02.751695+00:00 2023-10-30T08:23:02.751705+00:00 airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps 2023-10-30T07:00:00+00:00 EmrCreateJobFlowOperator 2023-10-30T08:23:02.735686+00:00 2023-10-30T08:23:02.735695+00:00 airflow 2 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps 2023-10-30T07:00:00+00:00 PythonOperator 2023-10-30T08:23:02.710837+00:00 2023-10-30T08:23:02.710848+00:00 airflow 3 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status 2023-10-30T06:00:00+00:00 EmrJobFlowSensor 2023-10-30T07:27:18.725239+00:00 2023-10-30T07:27:18.725249+00:00 airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps 2023-10-30T06:00:00+00:00 EmrCreateJobFlowOperator 2023-10-30T07:27:18.710423+00:00 2023-10-30T07:27:18.710432+00:00 airflow 2 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps 2023-10-30T06:00:00+00:00 PythonOperator 2023-10-30T07:27:18.686862+00:00 2023-10-30T07:27:18.686874+00:00 airflow 3 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status 2023-10-30T05:00:00+00:00 EmrJobFlowSensor 2023-10-30T06:26:10.991069+00:00 2023-10-30T06:26:10.991078+00:00 airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps 2023-10-30T05:00:00+00:00 EmrCreateJobFlowOperator 2023-10-30T06:26:10.976305+00:00 2023-10-30T06:26:10.976314+00:00 airflow 2 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps 2023-10-30T05:00:00+00:00 PythonOperator 2023-10-30T06:26:10.951603+00:00 2023-10-30T06:26:10.951613+00:00 airflow 3 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status 2023-10-30T04:00:00+00:00 EmrJobFlowSensor 2023-10-30T05:21:34.575176+00:00 2023-10-30T05:21:34.575186+00:00 airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps 2023-10-30T04:00:00+00:00 EmrCreateJobFlowOperator 2023-10-30T05:21:34.559291+00:00 2023-10-30T05:21:34.559329+00:00 airflow 2 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps 2023-10-30T04:00:00+00:00 PythonOperator 2023-10-30T05:21:34.531441+00:00 2023-10-30T05:21:34.531451+00:00 airflow 3 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status 2023-10-30T03:00:00+00:00 EmrJobFlowSensor 2023-10-30T04:29:13.944401+00:00 2023-10-30T04:29:13.944410+00:00 airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps 2023-10-30T03:00:00+00:00 EmrCreateJobFlowOperator 2023-10-30T04:29:13.929005+00:00 2023-10-30T04:29:13.929015+00:00 airflow 2 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps 2023-10-30T03:00:00+00:00 PythonOperator 2023-10-30T04:29:13.905010+00:00 2023-10-30T04:29:13.905020+00:00 airflow 3 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status 2023-10-30T02:00:00+00:00 EmrJobFlowSensor 2023-10-30T03:39:32.619545+00:00 2023-10-30T03:39:32.619555+00:00 airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps 2023-10-30T02:00:00+00:00 EmrCreateJobFlowOperator 2023-10-30T03:39:32.602591+00:00 2023-10-30T03:39:32.602600+00:00 airflow 2 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps 2023-10-30T02:00:00+00:00 PythonOperator 2023-10-30T03:39:32.578470+00:00 2023-10-30T03:39:32.578480+00:00 airflow 3 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status 2023-10-30T01:00:00+00:00 EmrJobFlowSensor 2023-10-30T02:21:34.205322+00:00 2023-10-30T02:21:34.205331+00:00 airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps 2023-10-30T01:00:00+00:00 EmrCreateJobFlowOperator 2023-10-30T02:21:34.190163+00:00 2023-10-30T02:21:34.190173+00:00 airflow 2 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps 2023-10-30T01:00:00+00:00 PythonOperator 2023-10-30T02:21:34.165838+00:00 2023-10-30T02:21:34.165849+00:00 airflow 3 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status 2023-10-30T00:00:00+00:00 EmrJobFlowSensor 2023-10-30T01:28:44.517075+00:00 2023-10-30T01:28:44.517090+00:00 airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps 2023-10-30T00:00:00+00:00 EmrCreateJobFlowOperator 2023-10-30T01:28:44.499526+00:00 2023-10-30T01:28:44.499536+00:00 airflow 2 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps 2023-10-30T00:00:00+00:00 PythonOperator 2023-10-30T01:28:44.473173+00:00 2023-10-30T01:28:44.473186+00:00 airflow 3 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status 2023-10-29T23:00:00+00:00 EmrJobFlowSensor 2023-10-30T00:39:23.384763+00:00 2023-10-30T00:39:23.384772+00:00 airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps 2023-10-29T23:00:00+00:00 EmrCreateJobFlowOperator 2023-10-30T00:39:23.368856+00:00 2023-10-30T00:39:23.368870+00:00 airflow 2 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps 2023-10-29T23:00:00+00:00 PythonOperator 2023-10-30T00:39:23.341677+00:00 2023-10-30T00:39:23.341688+00:00 airflow 3 default 1 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-10T11:00:00+00:00 EmrJobFlowSensor airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status 2023-10-29T22:00:00+00:00 EmrJobFlowSensor 2023-10-29T23:22:19.283025+00:00 2023-10-29T23:22:19.283034+00:00 airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps 2023-10-29T22:00:00+00:00 EmrCreateJobFlowOperator 2023-10-29T23:22:19.268359+00:00 2023-10-29T23:22:19.268368+00:00 airflow 2 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps 2023-10-29T22:00:00+00:00 PythonOperator 2023-10-29T23:22:19.244010+00:00 2023-10-29T23:22:19.244020+00:00 airflow 3 default 1 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-10T10:00:00+00:00 PythonOperator airflow 3 default 1 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-10T10:00:00+00:00 EmrCreateJobFlowOperator airflow 2 default 1 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-10T10:00:00+00:00 EmrJobFlowSensor airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status 2023-10-29T21:00:00+00:00 EmrJobFlowSensor 2023-10-29T22:22:05.474926+00:00 2023-10-29T22:22:05.474953+00:00 airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps 2023-10-29T21:00:00+00:00 EmrCreateJobFlowOperator 2023-10-29T22:22:05.460375+00:00 2023-10-29T22:22:05.460384+00:00 airflow 2 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps 2023-10-29T21:00:00+00:00 PythonOperator 2023-10-29T22:22:05.436890+00:00 2023-10-29T22:22:05.436901+00:00 airflow 3 default 1 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-10T09:00:00+00:00 PythonOperator airflow 3 default 1 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-10T09:00:00+00:00 EmrCreateJobFlowOperator airflow 2 default 1 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-10T09:00:00+00:00 EmrJobFlowSensor airflow 1 default 1 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-10T08:00:00+00:00 PythonOperator airflow 3 default 1 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-10T08:00:00+00:00 EmrCreateJobFlowOperator airflow 2 default 1 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-10T08:00:00+00:00 EmrJobFlowSensor airflow 1 default 1 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-10T07:00:00+00:00 PythonOperator airflow 3 default 1 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-10T07:00:00+00:00 EmrCreateJobFlowOperator airflow 2 default 1 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-10T07:00:00+00:00 EmrJobFlowSensor airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status 2023-10-29T18:00:00+00:00 EmrJobFlowSensor 2023-10-29T19:21:45.484288+00:00 2023-10-29T19:21:45.484297+00:00 airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps 2023-10-29T18:00:00+00:00 EmrCreateJobFlowOperator 2023-10-29T19:21:45.469392+00:00 2023-10-29T19:21:45.469400+00:00 airflow 2 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps 2023-10-29T18:00:00+00:00 PythonOperator 2023-10-29T19:21:45.445622+00:00 2023-10-29T19:21:45.445632+00:00 airflow 3 default 1 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-10T06:00:00+00:00 PythonOperator airflow 3 default 1 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-10T06:00:00+00:00 EmrCreateJobFlowOperator airflow 2 default 1 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-10T06:00:00+00:00 EmrJobFlowSensor airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status 2023-10-29T17:00:00+00:00 EmrJobFlowSensor 2023-10-29T18:25:17.911664+00:00 2023-10-29T18:25:17.911673+00:00 airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps 2023-10-29T17:00:00+00:00 EmrCreateJobFlowOperator 2023-10-29T18:25:17.896951+00:00 2023-10-29T18:25:17.896959+00:00 airflow 2 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps 2023-10-29T17:00:00+00:00 PythonOperator 2023-10-29T18:25:17.873691+00:00 2023-10-29T18:25:17.873701+00:00 airflow 3 default 1 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-10T05:00:00+00:00 PythonOperator airflow 3 default 1 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-10T05:00:00+00:00 EmrCreateJobFlowOperator airflow 2 default 1 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-10T05:00:00+00:00 EmrJobFlowSensor airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status 2023-10-29T16:00:00+00:00 EmrJobFlowSensor 2023-10-29T17:22:38.190306+00:00 2023-10-29T17:22:38.190314+00:00 airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps 2023-10-29T16:00:00+00:00 EmrCreateJobFlowOperator 2023-10-29T17:22:38.175242+00:00 2023-10-29T17:22:38.175250+00:00 airflow 2 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps 2023-10-29T16:00:00+00:00 PythonOperator 2023-10-29T17:22:38.151659+00:00 2023-10-29T17:22:38.151669+00:00 airflow 3 default 1 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-10T04:00:00+00:00 PythonOperator airflow 3 default 1 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-10T04:00:00+00:00 EmrCreateJobFlowOperator airflow 2 default 1 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-10T04:00:00+00:00 EmrJobFlowSensor airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status 2023-10-29T15:00:00+00:00 EmrJobFlowSensor 2023-10-29T16:23:16.085741+00:00 2023-10-29T16:23:16.085749+00:00 airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps 2023-10-29T15:00:00+00:00 EmrCreateJobFlowOperator 2023-10-29T16:23:16.070549+00:00 2023-10-29T16:23:16.070558+00:00 airflow 2 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps 2023-10-29T15:00:00+00:00 PythonOperator 2023-10-29T16:23:16.043807+00:00 2023-10-29T16:23:16.043818+00:00 airflow 3 default 1 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-10T03:00:00+00:00 PythonOperator airflow 3 default 1 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-10T03:00:00+00:00 EmrCreateJobFlowOperator airflow 2 default 1 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-10T03:00:00+00:00 EmrJobFlowSensor airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status 2023-10-29T14:00:00+00:00 EmrJobFlowSensor 2023-10-29T15:30:21.580630+00:00 2023-10-29T15:30:21.580642+00:00 airflow 1 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps 2023-10-29T14:00:00+00:00 EmrCreateJobFlowOperator 2023-10-29T15:30:21.563499+00:00 2023-10-29T15:30:21.563509+00:00 airflow 2 default 1 default_pool
upstream_failed livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps 2023-10-29T14:00:00+00:00 PythonOperator 2023-10-29T15:30:21.538341+00:00 2023-10-29T15:30:21.538351+00:00 airflow 3 default 1 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-10T02:00:00+00:00 PythonOperator airflow 3 default 1 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-10T02:00:00+00:00 EmrCreateJobFlowOperator airflow 2 default 1 default_pool