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
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-04T19:00:00+00:00 EmrCreateJobFlowOperator 2023-11-04T20:00:28.740748+00:00 2023-11-04T20:00:29.752075+00:00 0:00:01.011327 442726 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-04T20:00:26.743167+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-04T19:00:00+00:00 PythonOperator 2023-11-04T20:00:06.879253+00:00 2023-11-04T20:00:08.997341+00:00 0:00:02.118088 442724 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-04T20:00:04.729379+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-04T18:00:00+00:00 EmrJobFlowSensor 2023-11-04T19:00:56.150402+00:00 2023-11-04T19:22:59.704718+00:00 0:22:03.554316 442708 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-04T19:00:54.194038+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-04T18:00:00+00:00 EmrCreateJobFlowOperator 2023-11-04T19:00:34.258413+00:00 2023-11-04T19:00:35.266804+00:00 0:00:01.008391 442707 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-04T19:00:32.233486+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-04T18:00:00+00:00 PythonOperator 2023-11-04T19:00:14.239248+00:00 2023-11-04T19:00:17.371607+00:00 0:00:03.132359 442705 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-04T19:00:12.115070+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-04T17:00:00+00:00 EmrJobFlowSensor 2023-11-04T18:01:30.256466+00:00 2023-11-04T18:22:33.392494+00:00 0:21:03.136028 442692 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-04T18:01:28.227669+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-04T17:00:00+00:00 EmrCreateJobFlowOperator 2023-11-04T18:01:08.340378+00:00 2023-11-04T18:01:09.332394+00:00 0:00:00.992016 442691 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-04T18:01:06.205394+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-04T17:00:00+00:00 PythonOperator 2023-11-04T18:00:21.191045+00:00 2023-11-04T18:00:23.308143+00:00 0:00:02.117098 442689 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-04T18:00:19.239631+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-04T16:00:00+00:00 EmrJobFlowSensor 2023-11-04T17:12:43.884578+00:00 2023-11-04T17:33:47.755767+00:00 0:21:03.871189 442678 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-04T17:12:41.936607+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-04T16:00:00+00:00 EmrCreateJobFlowOperator 2023-11-04T17:12:21.853857+00:00 2023-11-04T17:12:22.911933+00:00 0:00:01.058076 442676 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-04T17:12:19.918624+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-04T16:00:00+00:00 PythonOperator 2023-11-04T17:12:02.319972+00:00 2023-11-04T17:12:04.612906+00:00 0:00:02.292934 442673 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-04T17:11:59.898002+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-04T15:00:00+00:00 EmrJobFlowSensor 2023-11-04T16:01:00.770633+00:00 2023-11-04T16:25:04.600582+00:00 0:24:03.829949 442659 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-04T16:00:58.741911+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-04T15:00:00+00:00 EmrCreateJobFlowOperator 2023-11-04T16:00:40.643754+00:00 2023-11-04T16:00:41.544635+00:00 0:00:00.900881 442658 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-04T16:00:38.723795+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-04T15:00:00+00:00 PythonOperator 2023-11-04T16:00:18.887628+00:00 2023-11-04T16:00:21.022533+00:00 0:00:02.134905 442657 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-04T16:00:16.758160+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-04T14:00:00+00:00 EmrJobFlowSensor 2023-11-04T15:01:03.386982+00:00 2023-11-04T15:24:06.963910+00:00 0:23:03.576928 442641 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-04T15:01:01.425758+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-04T14:00:00+00:00 EmrCreateJobFlowOperator 2023-11-04T15:00:41.549877+00:00 2023-11-04T15:00:42.652989+00:00 0:00:01.103112 442640 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-04T15:00:39.461257+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-04T14:00:00+00:00 PythonOperator 2023-11-04T15:00:21.397522+00:00 2023-11-04T15:00:23.527267+00:00 0:00:02.129745 442639 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-04T15:00:19.390232+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-04T13:00:00+00:00 EmrJobFlowSensor 2023-11-04T14:00:57.643982+00:00 2023-11-04T14:25:01.157879+00:00 0:24:03.513897 442624 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-04T14:00:55.533768+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-04T13:00:00+00:00 EmrCreateJobFlowOperator 2023-11-04T14:00:35.538813+00:00 2023-11-04T14:00:36.513235+00:00 0:00:00.974422 442623 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-04T14:00:33.453792+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-04T13:00:00+00:00 PythonOperator 2023-11-04T14:00:17.404183+00:00 2023-11-04T14:00:19.642430+00:00 0:00:02.238247 442622 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-04T14:00:13.437326+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-04T12:00:00+00:00 EmrJobFlowSensor 2023-11-04T13:00:48.876990+00:00 2023-11-04T13:24:52.377342+00:00 0:24:03.500352 442607 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-04T13:00:46.883416+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-04T12:00:00+00:00 EmrCreateJobFlowOperator 2023-11-04T13:00:26.869591+00:00 2023-11-04T13:00:28.112095+00:00 0:00:01.242504 442606 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-04T13:00:24.865927+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-04T12:00:00+00:00 PythonOperator 2023-11-04T13:00:06.990449+00:00 2023-11-04T13:00:09.101431+00:00 0:00:02.110982 442604 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-04T13:00:04.853079+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-04T11:00:00+00:00 EmrJobFlowSensor 2023-11-04T12:00:55.929002+00:00 2023-11-04T12:24:59.849891+00:00 0:24:03.920889 442589 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-04T12:00:53.911790+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-04T11:00:00+00:00 EmrCreateJobFlowOperator 2023-11-04T12:00:35.845744+00:00 2023-11-04T12:00:37.224348+00:00 0:00:01.378604 442588 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-04T12:00:33.895288+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-04T11:00:00+00:00 PythonOperator 2023-11-04T12:00:14.208005+00:00 2023-11-04T12:00:16.322768+00:00 0:00:02.114763 442586 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-04T12:00:11.875931+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-04T10:00:00+00:00 EmrJobFlowSensor 2023-11-04T11:01:02.344361+00:00 2023-11-04T11:25:06.224773+00:00 0:24:03.880412 442570 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-04T11:01:00.362501+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-04T10:00:00+00:00 EmrCreateJobFlowOperator 2023-11-04T11:00:42.388126+00:00 2023-11-04T11:00:43.370240+00:00 0:00:00.982114 442569 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-04T11:00:40.345270+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-04T10:00:00+00:00 PythonOperator 2023-11-04T11:00:20.584889+00:00 2023-11-04T11:00:22.709383+00:00 0:00:02.124494 442568 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-04T11:00:18.344093+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-04T09:00:00+00:00 EmrJobFlowSensor 2023-11-04T10:00:50.846430+00:00 2023-11-04T10:24:54.415020+00:00 0:24:03.568590 442552 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-04T10:00:48.863040+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-04T09:00:00+00:00 EmrCreateJobFlowOperator 2023-11-04T10:00:28.758436+00:00 2023-11-04T10:00:29.802893+00:00 0:00:01.044457 442551 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-04T10:00:26.831471+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-04T09:00:00+00:00 PythonOperator 2023-11-04T10:00:09.100336+00:00 2023-11-04T10:00:12.109836+00:00 0:00:03.009500 442549 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-04T10:00:06.815105+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-04T08:00:00+00:00 EmrJobFlowSensor 2023-11-04T09:04:12.480045+00:00 2023-11-04T09:28:16.089469+00:00 0:24:03.609424 442535 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-04T09:04:10.544273+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-04T08:00:00+00:00 EmrCreateJobFlowOperator 2023-11-04T09:03:50.464378+00:00 2023-11-04T09:03:51.482722+00:00 0:00:01.018344 442534 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-04T09:03:48.498571+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-04T08:00:00+00:00 PythonOperator 2023-11-04T09:03:30.746020+00:00 2023-11-04T09:03:32.833023+00:00 0:00:02.087003 442533 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-04T09:03:28.484214+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-04T07:00:00+00:00 EmrJobFlowSensor 2023-11-04T08:00:51.426860+00:00 2023-11-04T08:19:54.478846+00:00 0:19:03.051986 442516 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-04T08:00:49.277587+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-04T07:00:00+00:00 EmrCreateJobFlowOperator 2023-11-04T08:00:31.346299+00:00 2023-11-04T08:00:32.395481+00:00 0:00:01.049182 442515 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-04T08:00:29.331169+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-04T07:00:00+00:00 PythonOperator 2023-11-04T08:00:09.290866+00:00 2023-11-04T08:00:11.369389+00:00 0:00:02.078523 442513 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-04T08:00:07.241046+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-04T06:00:00+00:00 EmrJobFlowSensor 2023-11-04T07:07:30.492628+00:00 2023-11-04T07:24:33.486523+00:00 0:17:02.993895 442501 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-04T07:07:27.931359+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-04T06:00:00+00:00 EmrCreateJobFlowOperator 2023-11-04T07:00:32.890399+00:00 2023-11-04T07:00:34.010205+00:00 0:00:01.119806 442497 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-04T07:00:30.948382+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-04T06:00:00+00:00 PythonOperator 2023-11-04T07:00:11.207189+00:00 2023-11-04T07:00:13.279086+00:00 0:00:02.071897 442495 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-04T07:00:08.928028+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-04T05:00:00+00:00 EmrJobFlowSensor 2023-11-04T06:00:56.588890+00:00 2023-11-04T06:26:00.403496+00:00 0:25:03.814606 442480 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-04T06:00:54.540827+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-04T05:00:00+00:00 EmrCreateJobFlowOperator 2023-11-04T06:00:36.349301+00:00 2023-11-04T06:00:37.306560+00:00 0:00:00.957259 442479 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-04T06:00:34.455211+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-04T05:00:00+00:00 PythonOperator 2023-11-04T06:00:14.569765+00:00 2023-11-04T06:00:16.677818+00:00 0:00:02.108053 442477 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-04T06:00:12.427727+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-04T04:00:00+00:00 EmrJobFlowSensor 2023-11-04T05:00:46.249904+00:00 2023-11-04T05:24:49.672206+00:00 0:24:03.422302 442463 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-04T05:00:44.259060+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-04T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-04T05:00:26.185465+00:00 2023-11-04T05:00:27.321922+00:00 0:00:01.136457 442462 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-04T05:00:24.240067+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-04T04:00:00+00:00 PythonOperator 2023-11-04T05:00:04.787167+00:00 2023-11-04T05:00:06.939172+00:00 0:00:02.152005 442460 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-04T05:00:02.433580+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-04T03:00:00+00:00 EmrJobFlowSensor 2023-11-04T04:04:42.174255+00:00 2023-11-04T04:27:45.671224+00:00 0:23:03.496969 442442 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-04T04:04:40.091821+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-04T03:00:00+00:00 EmrCreateJobFlowOperator 2023-11-04T04:04:20.187373+00:00 2023-11-04T04:04:21.204663+00:00 0:00:01.017290 442440 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-04T04:04:18.049434+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-04T03:00:00+00:00 PythonOperator 2023-11-04T04:04:00.744202+00:00 2023-11-04T04:04:02.850770+00:00 0:00:02.106568 442437 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-04T04:03:58.031124+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-04T02:00:00+00:00 EmrJobFlowSensor 2023-11-04T03:01:06.478703+00:00 2023-11-04T03:25:10.076691+00:00 0:24:03.597988 442421 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-04T03:01:04.455019+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-04T02:00:00+00:00 EmrCreateJobFlowOperator 2023-11-04T03:00:44.354681+00:00 2023-11-04T03:00:45.333721+00:00 0:00:00.979040 442420 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-04T03:00:42.427221+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-04T02:00:00+00:00 PythonOperator 2023-11-04T03:00:24.614131+00:00 2023-11-04T03:00:27.700992+00:00 0:00:03.086861 442418 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-04T03:00:22.410653+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-04T01:00:00+00:00 EmrJobFlowSensor 2023-11-04T02:00:48.578962+00:00 2023-11-04T02:19:51.679178+00:00 0:19:03.100216 442403 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-04T02:00:46.564271+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-04T01:00:00+00:00 EmrCreateJobFlowOperator 2023-11-04T02:00:26.599104+00:00 2023-11-04T02:00:27.559728+00:00 0:00:00.960624 442402 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-04T02:00:24.551947+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-04T01:00:00+00:00 PythonOperator 2023-11-04T02:00:08.682163+00:00 2023-11-04T02:00:10.806606+00:00 0:00:02.124443 442401 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-04T02:00:04.528611+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-04T00:00:00+00:00 EmrJobFlowSensor 2023-11-04T01:00:58.681528+00:00 2023-11-04T01:20:01.644268+00:00 0:19:02.962740 442379 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-04T01:00:56.552272+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-04T00:00:00+00:00 EmrCreateJobFlowOperator 2023-11-04T01:00:38.568957+00:00 2023-11-04T01:00:39.683995+00:00 0:00:01.115038 442378 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-04T01:00:36.538447+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-04T00:00:00+00:00 PythonOperator 2023-11-04T01:00:16.621036+00:00 2023-11-04T01:00:18.752756+00:00 0:00:02.131720 442376 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-04T01:00:14.467707+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-03T23:00:00+00:00 EmrJobFlowSensor 2023-11-04T00:00:49.276068+00:00 2023-11-04T00:19:52.425262+00:00 0:19:03.149194 442362 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-04T00:00:47.169059+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-03T23:00:00+00:00 EmrCreateJobFlowOperator 2023-11-04T00:00:27.244960+00:00 2023-11-04T00:00:28.264987+00:00 0:00:01.020027 442361 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-04T00:00:25.155835+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-03T23:00:00+00:00 PythonOperator 2023-11-04T00:00:07.380455+00:00 2023-11-04T00:00:09.558457+00:00 0:00:02.178002 442359 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-04T00:00:05.133833+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-03T22:00:00+00:00 EmrJobFlowSensor 2023-11-03T23:00:54.440524+00:00 2023-11-03T23:20:57.467139+00:00 0:20:03.026615 442343 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-03T23:00:52.439175+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-03T22:00:00+00:00 EmrCreateJobFlowOperator 2023-11-03T23:00:32.297047+00:00 2023-11-03T23:00:33.445174+00:00 0:00:01.148127 442341 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-03T23:00:30.333624+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-03T22:00:00+00:00 PythonOperator 2023-11-03T23:00:12.403080+00:00 2023-11-03T23:00:14.574657+00:00 0:00:02.171577 442338 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-03T23:00:10.312408+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-03T21:00:00+00:00 EmrJobFlowSensor 2023-11-03T22:01:22.995325+00:00 2023-11-03T22:21:25.945190+00:00 0:20:02.949865 442323 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-03T22:01:20.996956+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-03T21:00:00+00:00 EmrCreateJobFlowOperator 2023-11-03T22:01:01.268405+00:00 2023-11-03T22:01:02.755597+00:00 0:00:01.487192 442322 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-03T22:00:59.023816+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-03T21:00:00+00:00 PythonOperator 2023-11-03T22:00:22.860503+00:00 2023-11-03T22:00:24.922079+00:00 0:00:02.061576 442320 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-03T22:00:20.638508+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-03T20:00:00+00:00 EmrJobFlowSensor 2023-11-03T21:01:43.457998+00:00 2023-11-03T21:22:46.675780+00:00 0:21:03.217782 442307 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-03T21:01:41.272309+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-03T20:00:00+00:00 EmrCreateJobFlowOperator 2023-11-03T21:00:39.048457+00:00 2023-11-03T21:00:40.000079+00:00 0:00:00.951622 442304 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-03T21:00:36.441242+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-03T20:00:00+00:00 PythonOperator 2023-11-03T21:00:16.554361+00:00 2023-11-03T21:00:18.678510+00:00 0:00:02.124149 442302 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-03T21:00:14.334514+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-03T19:00:00+00:00 EmrJobFlowSensor 2023-11-03T20:01:42.053950+00:00 2023-11-03T20:24:45.659415+00:00 0:23:03.605465 442289 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-03T20:01:40.108344+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-03T19:00:00+00:00 EmrCreateJobFlowOperator 2023-11-03T20:01:22.061084+00:00 2023-11-03T20:01:23.176520+00:00 0:00:01.115436 442287 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-03T20:01:20.092814+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-03T19:00:00+00:00 PythonOperator 2023-11-03T20:00:18.643169+00:00 2023-11-03T20:00:21.886284+00:00 0:00:03.243115 442283 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-03T20:00:16.514360+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-03T18:00:00+00:00 EmrJobFlowSensor 2023-11-03T19:03:43.213507+00:00 2023-11-03T19:26:46.589916+00:00 0:23:03.376409 442269 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-03T19:03:41.165624+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-03T18:00:00+00:00 EmrCreateJobFlowOperator 2023-11-03T19:03:23.092122+00:00 2023-11-03T19:03:24.111715+00:00 0:00:01.019593 442268 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-03T19:03:21.148566+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-03T18:00:00+00:00 PythonOperator 2023-11-03T19:03:01.661191+00:00 2023-11-03T19:03:03.794370+00:00 0:00:02.133179 442266 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-03T19:02:59.130449+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-03T17:00:00+00:00 EmrJobFlowSensor 2023-11-03T18:00:54.986679+00:00 2023-11-03T18:23:58.353505+00:00 0:23:03.366826 442252 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-03T18:00:52.997122+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-03T17:00:00+00:00 EmrCreateJobFlowOperator 2023-11-03T18:00:33.006913+00:00 2023-11-03T18:00:34.124033+00:00 0:00:01.117120 442251 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-03T18:00:30.980083+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-03T17:00:00+00:00 PythonOperator 2023-11-03T18:00:12.893572+00:00 2023-11-03T18:00:15.258273+00:00 0:00:02.364701 442250 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-03T18:00:10.962965+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-03T16:00:00+00:00 EmrJobFlowSensor 2023-11-03T17:02:41.248002+00:00 2023-11-03T17:24:44.934198+00:00 0:22:03.686196 442236 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-03T17:02:39.278047+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-03T16:00:00+00:00 EmrCreateJobFlowOperator 2023-11-03T17:02:19.249776+00:00 2023-11-03T17:02:20.217855+00:00 0:00:00.968079 442235 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-03T17:02:17.257876+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-03T16:00:00+00:00 PythonOperator 2023-11-03T17:01:59.471572+00:00 2023-11-03T17:02:01.588272+00:00 0:00:02.116700 442234 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-03T17:01:57.242062+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-03T15:00:00+00:00 EmrJobFlowSensor 2023-11-03T16:00:59.396009+00:00 2023-11-03T16:25:02.977736+00:00 0:24:03.581727 442217 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-03T16:00:57.266825+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-03T15:00:00+00:00 EmrCreateJobFlowOperator 2023-11-03T16:00:37.360037+00:00 2023-11-03T16:00:38.533267+00:00 0:00:01.173230 442216 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-03T16:00:35.253043+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-03T15:00:00+00:00 PythonOperator 2023-11-03T16:00:17.377749+00:00 2023-11-03T16:00:19.495528+00:00 0:00:02.117779 442215 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-03T16:00:15.191846+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-03T14:00:00+00:00 EmrJobFlowSensor 2023-11-03T15:00:54.325341+00:00 2023-11-03T15:24:57.681536+00:00 0:24:03.356195 442198 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-03T15:00:52.253661+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-03T14:00:00+00:00 EmrCreateJobFlowOperator 2023-11-03T15:00:34.288181+00:00 2023-11-03T15:00:35.347975+00:00 0:00:01.059794 442197 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-03T15:00:32.230481+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-03T14:00:00+00:00 PythonOperator 2023-11-03T15:00:12.065543+00:00 2023-11-03T15:00:14.177955+00:00 0:00:02.112412 442196 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-03T15:00:10.140394+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-03T13:00:00+00:00 EmrJobFlowSensor 2023-11-03T14:08:42.356792+00:00 2023-11-03T14:32:45.881479+00:00 0:24:03.524687 442183 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-03T14:08:38.795486+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-03T13:00:00+00:00 EmrCreateJobFlowOperator 2023-11-03T14:08:18.801199+00:00 2023-11-03T14:08:20.289945+00:00 0:00:01.488746 442180 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-03T14:08:16.776699+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-03T13:00:00+00:00 PythonOperator 2023-11-03T14:08:01.889426+00:00 2023-11-03T14:08:05.011007+00:00 0:00:03.121581 442178 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-03T14:07:56.824592+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-03T12:00:00+00:00 EmrJobFlowSensor 2023-11-03T13:05:14.729660+00:00 2023-11-03T13:29:18.432117+00:00 0:24:03.702457 442157 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-03T13:05:12.413638+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-03T12:00:00+00:00 EmrCreateJobFlowOperator 2023-11-03T13:04:52.345533+00:00 2023-11-03T13:04:53.408805+00:00 0:00:01.063272 442155 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-03T13:04:50.393582+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-03T12:00:00+00:00 PythonOperator 2023-11-03T13:04:32.361114+00:00 2023-11-03T13:04:34.603514+00:00 0:00:02.242400 442154 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-03T13:04:30.375075+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-03T11:00:00+00:00 EmrJobFlowSensor 2023-11-03T12:09:46.458552+00:00 2023-11-03T12:33:50.033065+00:00 0:24:03.574513 442136 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-03T12:09:44.487735+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-03T11:00:00+00:00 EmrCreateJobFlowOperator 2023-11-03T12:09:24.441575+00:00 2023-11-03T12:09:25.501580+00:00 0:00:01.060005 442134 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-03T12:09:22.471313+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-03T11:00:00+00:00 PythonOperator 2023-11-03T12:09:04.880583+00:00 2023-11-03T12:09:06.987177+00:00 0:00:02.106594 442131 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-03T12:09:02.454278+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-03T10:00:00+00:00 EmrJobFlowSensor 2023-11-03T11:01:06.469948+00:00 2023-11-03T11:25:09.949447+00:00 0:24:03.479499 442107 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-03T11:01:04.487881+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-03T10:00:00+00:00 EmrCreateJobFlowOperator 2023-11-03T11:00:44.445930+00:00 2023-11-03T11:00:45.402942+00:00 0:00:00.957012 442106 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-03T11:00:42.467340+00:00 2 default_pool