Task Instances

Reset Filters
  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-12-18T17:00:00+00:00 EmrCreateJobFlowOperator 2023-12-18T18:00:36.519855+00:00 2023-12-18T18:00:37.504247+00:00 0:00:00.984392 458969 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-18T18:00:34.381176+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-18T17:00:00+00:00 PythonOperator 2023-12-18T18:00:14.070019+00:00 2023-12-18T18:00:15.645030+00:00 0:00:01.575011 458967 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-18T18:00:12.362413+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-18T16:00:00+00:00 EmrJobFlowSensor 2023-12-18T17:02:21.195651+00:00 2023-12-18T17:24:24.630176+00:00 0:22:03.434525 458953 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-18T17:02:19.137853+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-18T16:00:00+00:00 EmrCreateJobFlowOperator 2023-12-18T17:00:32.481914+00:00 2023-12-18T17:00:33.590246+00:00 0:00:01.108332 458951 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-18T17:00:30.816158+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-18T16:00:00+00:00 PythonOperator 2023-12-18T17:00:10.569739+00:00 2023-12-18T17:00:12.214810+00:00 0:00:01.645071 458949 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-18T17:00:08.859802+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-18T15:00:00+00:00 EmrJobFlowSensor 2023-12-18T16:00:49.962995+00:00 2023-12-18T16:26:53.835095+00:00 0:26:03.872100 458936 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-18T16:00:48.166903+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-18T15:00:00+00:00 EmrCreateJobFlowOperator 2023-12-18T16:00:29.845158+00:00 2023-12-18T16:00:30.913985+00:00 0:00:01.068827 458934 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-18T16:00:28.080700+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-18T15:00:00+00:00 PythonOperator 2023-12-18T16:00:07.868366+00:00 2023-12-18T16:00:09.425753+00:00 0:00:01.557387 458932 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-18T16:00:06.060776+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-18T14:00:00+00:00 EmrJobFlowSensor 2023-12-18T15:00:48.289957+00:00 2023-12-18T15:26:52.206003+00:00 0:26:03.916046 458918 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-18T15:00:45.759370+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-18T14:00:00+00:00 EmrCreateJobFlowOperator 2023-12-18T15:00:27.809000+00:00 2023-12-18T15:00:28.737122+00:00 0:00:00.928122 458916 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-18T15:00:25.670170+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-18T14:00:00+00:00 PythonOperator 2023-12-18T15:00:05.466471+00:00 2023-12-18T15:00:07.042431+00:00 0:00:01.575960 458914 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-18T15:00:03.648015+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-18T13:00:00+00:00 EmrJobFlowSensor 2023-12-18T14:02:06.487215+00:00 2023-12-18T14:26:10.063696+00:00 0:24:03.576481 458904 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-18T14:02:04.754727+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-18T13:00:00+00:00 EmrCreateJobFlowOperator 2023-12-18T14:00:40.353777+00:00 2023-12-18T14:00:41.752418+00:00 0:00:01.398641 458901 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-18T14:00:37.714216+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-18T13:00:00+00:00 PythonOperator 2023-12-18T14:00:17.862900+00:00 2023-12-18T14:00:19.417422+00:00 0:00:01.554522 458899 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-18T14:00:15.695830+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-18T12:00:00+00:00 EmrJobFlowSensor 2023-12-18T13:00:52.067947+00:00 2023-12-18T13:25:55.806631+00:00 0:25:03.738684 458884 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-18T13:00:49.583886+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-18T12:00:00+00:00 EmrCreateJobFlowOperator 2023-12-18T13:00:30.198064+00:00 2023-12-18T13:00:31.116701+00:00 0:00:00.918637 458882 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-18T13:00:27.560528+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-18T12:00:00+00:00 PythonOperator 2023-12-18T13:00:09.202373+00:00 2023-12-18T13:00:10.819587+00:00 0:00:01.617214 458880 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-18T13:00:07.531326+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-18T11:00:00+00:00 EmrJobFlowSensor 2023-12-18T12:00:48.003390+00:00 2023-12-18T12:25:51.715080+00:00 0:25:03.711690 458866 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-18T12:00:45.908749+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-18T11:00:00+00:00 EmrCreateJobFlowOperator 2023-12-18T12:00:25.577211+00:00 2023-12-18T12:00:26.509543+00:00 0:00:00.932332 458864 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-18T12:00:23.882236+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-18T11:00:00+00:00 PythonOperator 2023-12-18T12:00:06.076768+00:00 2023-12-18T12:00:07.707244+00:00 0:00:01.630476 458862 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-18T12:00:03.866129+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-18T10:00:00+00:00 EmrJobFlowSensor 2023-12-18T11:00:54.133926+00:00 2023-12-18T11:25:58.182636+00:00 0:25:04.048710 458849 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-18T11:00:52.081235+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-18T10:00:00+00:00 EmrCreateJobFlowOperator 2023-12-18T11:00:32.266285+00:00 2023-12-18T11:00:33.323887+00:00 0:00:01.057602 458847 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-18T11:00:30.070807+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-18T10:00:00+00:00 PythonOperator 2023-12-18T11:00:11.758911+00:00 2023-12-18T11:00:13.357174+00:00 0:00:01.598263 458845 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-18T11:00:10.055140+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-18T09:00:00+00:00 EmrJobFlowSensor 2023-12-18T10:00:50.242971+00:00 2023-12-18T10:25:53.988471+00:00 0:25:03.745500 458830 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-18T10:00:48.175691+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-18T09:00:00+00:00 EmrCreateJobFlowOperator 2023-12-18T10:00:29.956720+00:00 2023-12-18T10:00:30.861656+00:00 0:00:00.904936 458828 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-18T10:00:28.163949+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-18T09:00:00+00:00 PythonOperator 2023-12-18T10:00:08.076828+00:00 2023-12-18T10:00:09.666536+00:00 0:00:01.589708 458826 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-18T10:00:06.086890+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-18T08:00:00+00:00 EmrJobFlowSensor 2023-12-18T09:00:55.749963+00:00 2023-12-18T09:25:59.642915+00:00 0:25:03.892952 458813 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-18T09:00:53.561403+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-18T08:00:00+00:00 EmrCreateJobFlowOperator 2023-12-18T09:00:34.158378+00:00 2023-12-18T09:00:35.113981+00:00 0:00:00.955603 458811 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-18T09:00:31.487176+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-18T08:00:00+00:00 PythonOperator 2023-12-18T09:00:13.304193+00:00 2023-12-18T09:00:14.901015+00:00 0:00:01.596822 458809 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-18T09:00:11.552096+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-18T07:00:00+00:00 EmrJobFlowSensor 2023-12-18T08:01:03.871300+00:00 2023-12-18T08:26:07.797892+00:00 0:25:03.926592 458795 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-18T08:01:01.812698+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-18T07:00:00+00:00 EmrCreateJobFlowOperator 2023-12-18T08:00:43.971619+00:00 2023-12-18T08:00:44.905265+00:00 0:00:00.933646 458793 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-18T08:00:41.851967+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-18T07:00:00+00:00 PythonOperator 2023-12-18T08:00:21.839594+00:00 2023-12-18T08:00:23.434387+00:00 0:00:01.594793 458791 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-18T08:00:19.739686+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-18T06:00:00+00:00 EmrJobFlowSensor 2023-12-18T07:01:00.548455+00:00 2023-12-18T07:27:04.531595+00:00 0:26:03.983140 458776 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-18T07:00:58.773900+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-18T06:00:00+00:00 EmrCreateJobFlowOperator 2023-12-18T07:00:38.973927+00:00 2023-12-18T07:00:39.859215+00:00 0:00:00.885288 458774 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-18T07:00:36.773883+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-18T06:00:00+00:00 PythonOperator 2023-12-18T07:00:18.788412+00:00 2023-12-18T07:00:20.357746+00:00 0:00:01.569334 458772 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-18T07:00:16.765499+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-18T05:00:00+00:00 EmrJobFlowSensor 2023-12-18T06:02:31.569458+00:00 2023-12-18T06:26:35.108524+00:00 0:24:03.539066 458760 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-18T06:02:29.898913+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-18T05:00:00+00:00 EmrCreateJobFlowOperator 2023-12-18T06:02:09.968603+00:00 2023-12-18T06:02:10.943087+00:00 0:00:00.974484 458758 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-18T06:02:07.876532+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-18T05:00:00+00:00 PythonOperator 2023-12-18T06:01:50.549287+00:00 2023-12-18T06:01:52.091248+00:00 0:00:01.541961 458756 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-18T06:01:47.868447+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-18T04:00:00+00:00 EmrJobFlowSensor 2023-12-18T05:01:30.636507+00:00 2023-12-18T05:26:34.726145+00:00 0:25:04.089638 458742 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-18T05:01:28.987780+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-18T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-18T05:01:11.019284+00:00 2023-12-18T05:01:12.026353+00:00 0:00:01.007069 458740 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-18T05:01:08.964557+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-18T04:00:00+00:00 PythonOperator 2023-12-18T05:00:48.982088+00:00 2023-12-18T05:00:50.543431+00:00 0:00:01.561343 458738 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-18T05:00:46.946628+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-18T03:00:00+00:00 EmrJobFlowSensor 2023-12-18T04:01:24.033943+00:00 2023-12-18T04:25:28.205073+00:00 0:24:04.171130 458721 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-18T04:01:21.706187+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-18T03:00:00+00:00 EmrCreateJobFlowOperator 2023-12-18T04:01:01.361878+00:00 2023-12-18T04:01:02.790287+00:00 0:00:01.428409 458718 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-18T04:00:59.687164+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-18T03:00:00+00:00 PythonOperator 2023-12-18T04:00:41.905612+00:00 2023-12-18T04:00:43.464585+00:00 0:00:01.558973 458715 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-18T04:00:39.669774+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-18T02:00:00+00:00 EmrJobFlowSensor 2023-12-18T03:01:56.672110+00:00 2023-12-18T03:26:00.363305+00:00 0:24:03.691195 458702 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-18T03:01:54.765010+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-18T02:00:00+00:00 EmrCreateJobFlowOperator 2023-12-18T03:00:36.176674+00:00 2023-12-18T03:00:37.085531+00:00 0:00:00.908857 458700 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-18T03:00:33.664247+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-18T02:00:00+00:00 PythonOperator 2023-12-18T03:00:15.419184+00:00 2023-12-18T03:00:17.051413+00:00 0:00:01.632229 458698 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-18T03:00:13.647953+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-18T01:00:00+00:00 EmrJobFlowSensor 2023-12-18T02:00:47.699364+00:00 2023-12-18T02:25:51.519575+00:00 0:25:03.820211 458684 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-18T02:00:45.485818+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-18T01:00:00+00:00 EmrCreateJobFlowOperator 2023-12-18T02:00:25.096419+00:00 2023-12-18T02:00:26.303510+00:00 0:00:01.207091 458682 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-18T02:00:23.422103+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-18T01:00:00+00:00 PythonOperator 2023-12-18T02:00:05.616754+00:00 2023-12-18T02:00:07.192349+00:00 0:00:01.575595 458680 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-18T02:00:03.404145+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-18T00:00:00+00:00 EmrJobFlowSensor 2023-12-18T01:00:49.690310+00:00 2023-12-18T01:25:54.222672+00:00 0:25:04.532362 458661 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-18T01:00:47.554327+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-18T00:00:00+00:00 EmrCreateJobFlowOperator 2023-12-18T01:00:29.569185+00:00 2023-12-18T01:00:30.535417+00:00 0:00:00.966232 458660 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-18T01:00:27.452363+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-18T00:00:00+00:00 PythonOperator 2023-12-18T01:00:07.261961+00:00 2023-12-18T01:00:09.511161+00:00 0:00:02.249200 458657 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-18T01:00:05.442550+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-17T23:00:00+00:00 EmrJobFlowSensor 2023-12-18T00:00:45.778389+00:00 2023-12-18T00:25:49.504216+00:00 0:25:03.725827 458642 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-18T00:00:43.964294+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-17T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-18T00:00:26.019448+00:00 2023-12-18T00:00:26.966737+00:00 0:00:00.947289 458640 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-18T00:00:23.885222+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-17T23:00:00+00:00 PythonOperator 2023-12-18T00:00:04.057993+00:00 2023-12-18T00:00:05.550537+00:00 0:00:01.492544 458638 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-18T00:00:01.864942+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-17T22:00:00+00:00 EmrJobFlowSensor 2023-12-17T23:00:58.831917+00:00 2023-12-17T23:27:02.960618+00:00 0:26:04.128701 458624 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-17T23:00:56.652140+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-17T22:00:00+00:00 EmrCreateJobFlowOperator 2023-12-17T23:00:36.397472+00:00 2023-12-17T23:00:37.358201+00:00 0:00:00.960729 458621 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-17T23:00:34.652229+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-17T22:00:00+00:00 PythonOperator 2023-12-17T23:00:16.757473+00:00 2023-12-17T23:00:18.268527+00:00 0:00:01.511054 458618 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-17T23:00:14.582090+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-17T21:00:00+00:00 EmrJobFlowSensor 2023-12-17T22:00:59.482107+00:00 2023-12-17T22:24:03.210672+00:00 0:23:03.728565 458604 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-17T22:00:57.269243+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-17T21:00:00+00:00 EmrCreateJobFlowOperator 2023-12-17T22:00:37.364525+00:00 2023-12-17T22:00:38.277718+00:00 0:00:00.913193 458602 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-17T22:00:35.258730+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-17T21:00:00+00:00 PythonOperator 2023-12-17T22:00:17.356659+00:00 2023-12-17T22:00:18.918556+00:00 0:00:01.561897 458600 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-17T22:00:15.184165+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-17T20:00:00+00:00 EmrJobFlowSensor 2023-12-17T21:01:03.451370+00:00 2023-12-17T21:26:07.239132+00:00 0:25:03.787762 458586 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-17T21:01:01.682884+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-17T20:00:00+00:00 EmrCreateJobFlowOperator 2023-12-17T21:00:41.355347+00:00 2023-12-17T21:00:42.359608+00:00 0:00:01.004261 458584 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-17T21:00:39.671454+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-17T20:00:00+00:00 PythonOperator 2023-12-17T21:00:21.910726+00:00 2023-12-17T21:00:23.465267+00:00 0:00:01.554541 458582 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-17T21:00:19.665312+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-17T19:00:00+00:00 EmrJobFlowSensor 2023-12-17T20:00:52.164492+00:00 2023-12-17T20:27:56.420885+00:00 0:27:04.256393 458567 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-17T20:00:50.116513+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-17T19:00:00+00:00 EmrCreateJobFlowOperator 2023-12-17T20:00:29.961344+00:00 2023-12-17T20:00:31.074263+00:00 0:00:01.112919 458565 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-17T20:00:28.161400+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-17T19:00:00+00:00 PythonOperator 2023-12-17T20:00:10.257109+00:00 2023-12-17T20:00:11.807187+00:00 0:00:01.550078 458563 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-17T20:00:08.080948+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-17T18:00:00+00:00 EmrJobFlowSensor 2023-12-17T19:00:49.458101+00:00 2023-12-17T19:26:53.261952+00:00 0:26:03.803851 458549 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-17T19:00:47.684827+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-17T18:00:00+00:00 EmrCreateJobFlowOperator 2023-12-17T19:00:29.423376+00:00 2023-12-17T19:00:30.303073+00:00 0:00:00.879697 458547 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-17T19:00:27.667365+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-17T18:00:00+00:00 PythonOperator 2023-12-17T19:00:07.845047+00:00 2023-12-17T19:00:09.383748+00:00 0:00:01.538701 458545 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-17T19:00:05.647272+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-17T17:00:00+00:00 EmrJobFlowSensor 2023-12-17T18:01:05.333156+00:00 2023-12-17T18:27:09.252954+00:00 0:26:03.919798 458532 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-17T18:01:03.710961+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-17T17:00:00+00:00 EmrCreateJobFlowOperator 2023-12-17T18:00:43.358632+00:00 2023-12-17T18:00:44.280093+00:00 0:00:00.921461 458530 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-17T18:00:41.693662+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-17T17:00:00+00:00 PythonOperator 2023-12-17T18:00:23.820336+00:00 2023-12-17T18:00:25.314146+00:00 0:00:01.493810 458528 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-17T18:00:21.672397+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-17T16:00:00+00:00 EmrJobFlowSensor 2023-12-17T17:02:22.547219+00:00 2023-12-17T17:25:26.013935+00:00 0:23:03.466716 458515 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-17T17:02:20.884874+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-17T16:00:00+00:00 EmrCreateJobFlowOperator 2023-12-17T17:02:01.002817+00:00 2023-12-17T17:02:02.019769+00:00 0:00:01.016952 458513 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-17T17:01:58.855619+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-17T16:00:00+00:00 PythonOperator 2023-12-17T17:01:40.506019+00:00 2023-12-17T17:01:42.059563+00:00 0:00:01.553544 458511 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-17T17:01:38.837076+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-17T15:00:00+00:00 EmrJobFlowSensor 2023-12-17T16:00:46.255316+00:00 2023-12-17T16:26:50.027841+00:00 0:26:03.772525 458496 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-17T16:00:44.452678+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-17T15:00:00+00:00 EmrCreateJobFlowOperator 2023-12-17T16:00:24.470445+00:00 2023-12-17T16:00:25.340874+00:00 0:00:00.870429 458494 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-17T16:00:22.293686+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-17T15:00:00+00:00 PythonOperator 2023-12-17T16:00:04.118520+00:00 2023-12-17T16:00:05.712345+00:00 0:00:01.593825 458492 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-17T16:00:02.272140+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-17T14:00:00+00:00 EmrJobFlowSensor 2023-12-17T15:00:51.489774+00:00 2023-12-17T15:25:55.270717+00:00 0:25:03.780943 458480 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-17T15:00:49.682288+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-17T14:00:00+00:00 EmrCreateJobFlowOperator 2023-12-17T15:00:31.352755+00:00 2023-12-17T15:00:32.449978+00:00 0:00:01.097223 458478 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-17T15:00:29.649129+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-17T14:00:00+00:00 PythonOperator 2023-12-17T15:00:09.488069+00:00 2023-12-17T15:00:11.098695+00:00 0:00:01.610626 458476 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-17T15:00:07.635105+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-17T13:00:00+00:00 EmrJobFlowSensor 2023-12-17T14:01:12.463835+00:00 2023-12-17T14:26:16.307156+00:00 0:25:03.843321 458464 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-17T14:01:10.805861+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-17T13:00:00+00:00 EmrCreateJobFlowOperator 2023-12-17T14:00:52.539563+00:00 2023-12-17T14:00:53.618536+00:00 0:00:01.078973 458462 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-17T14:00:50.784929+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-17T13:00:00+00:00 PythonOperator 2023-12-17T14:00:31.013057+00:00 2023-12-17T14:00:32.621147+00:00 0:00:01.608090 458460 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-17T14:00:28.774044+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-17T12:00:00+00:00 EmrJobFlowSensor 2023-12-17T13:08:51.275857+00:00 2023-12-17T13:33:55.097055+00:00 0:25:03.821198 458450 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-17T13:08:49.261830+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-17T12:00:00+00:00 EmrCreateJobFlowOperator 2023-12-17T13:08:30.849477+00:00 2023-12-17T13:08:31.839438+00:00 0:00:00.989961 458447 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-17T13:08:29.225502+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-17T12:00:00+00:00 PythonOperator 2023-12-17T13:08:09.269567+00:00 2023-12-17T13:08:10.799172+00:00 0:00:01.529605 458444 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-17T13:08:07.208359+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-17T11:00:00+00:00 EmrJobFlowSensor 2023-12-17T12:00:56.655123+00:00 2023-12-17T12:26:00.542844+00:00 0:25:03.887721 458432 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-17T12:00:54.469345+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-17T11:00:00+00:00 EmrCreateJobFlowOperator 2023-12-17T12:00:34.593660+00:00 2023-12-17T12:00:35.687677+00:00 0:00:01.094017 458430 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-17T12:00:32.454529+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-17T11:00:00+00:00 PythonOperator 2023-12-17T12:00:14.146677+00:00 2023-12-17T12:00:15.720980+00:00 0:00:01.574303 458428 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-17T12:00:12.382918+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-17T10:00:00+00:00 EmrJobFlowSensor 2023-12-17T11:01:04.950413+00:00 2023-12-17T11:27:09.119979+00:00 0:26:04.169566 458414 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-17T11:01:03.258533+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-17T10:00:00+00:00 EmrCreateJobFlowOperator 2023-12-17T11:00:45.024571+00:00 2023-12-17T11:00:46.031653+00:00 0:00:01.007082 458412 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-17T11:00:43.187553+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-17T10:00:00+00:00 PythonOperator 2023-12-17T11:00:23.351875+00:00 2023-12-17T11:00:24.859248+00:00 0:00:01.507373 458410 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-17T11:00:21.149026+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-17T09:00:00+00:00 EmrJobFlowSensor 2023-12-17T10:01:00.952571+00:00 2023-12-17T10:25:04.984185+00:00 0:24:04.031614 458397 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-17T10:00:59.320638+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-17T09:00:00+00:00 EmrCreateJobFlowOperator 2023-12-17T10:00:41.253108+00:00 2023-12-17T10:00:42.236399+00:00 0:00:00.983291 458395 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-17T10:00:39.254797+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-17T09:00:00+00:00 PythonOperator 2023-12-17T10:00:19.443589+00:00 2023-12-17T10:00:20.972600+00:00 0:00:01.529011 458393 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-17T10:00:17.285693+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-17T08:00:00+00:00 EmrJobFlowSensor 2023-12-17T09:07:56.483966+00:00 2023-12-17T09:33:00.233060+00:00 0:25:03.749094 458383 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-17T09:07:54.754864+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-17T08:00:00+00:00 EmrCreateJobFlowOperator 2023-12-17T09:07:37.475330+00:00 2023-12-17T09:07:38.323187+00:00 0:00:00.847857 458381 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-17T09:07:34.696032+00:00 2 default_pool