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_emr_steps 2023-12-25T20:00:00+00:00 PythonOperator 2023-12-25T21:00:23.322426+00:00 2023-12-25T21:00:24.953846+00:00 0:00:01.631420 462033 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-25T21:00:21.226489+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-25T19:00:00+00:00 EmrJobFlowSensor 2023-12-25T20:00:57.163082+00:00 2023-12-25T20:28:01.100193+00:00 0:27:03.937111 462019 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-25T20:00:54.994750+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-25T19:00:00+00:00 EmrCreateJobFlowOperator 2023-12-25T20:00:35.058227+00:00 2023-12-25T20:00:35.995448+00:00 0:00:00.937221 462017 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-25T20:00:32.974373+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-25T19:00:00+00:00 PythonOperator 2023-12-25T20:00:14.662354+00:00 2023-12-25T20:00:16.256412+00:00 0:00:01.594058 462015 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-25T20:00:12.958260+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-25T18:00:00+00:00 EmrJobFlowSensor 2023-12-25T19:01:04.754797+00:00 2023-12-25T19:28:08.537738+00:00 0:27:03.782941 462001 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-25T19:01:03.058151+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-25T18:00:00+00:00 EmrCreateJobFlowOperator 2023-12-25T19:00:43.137305+00:00 2023-12-25T19:00:44.110472+00:00 0:00:00.973167 461999 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-25T19:00:41.055327+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-25T18:00:00+00:00 PythonOperator 2023-12-25T19:00:22.960632+00:00 2023-12-25T19:00:24.554619+00:00 0:00:01.593987 461997 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-25T19:00:21.025224+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-25T17:00:00+00:00 EmrJobFlowSensor 2023-12-25T18:01:06.502881+00:00 2023-12-25T18:27:10.567731+00:00 0:26:04.064850 461983 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-25T18:01:04.386099+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-25T17:00:00+00:00 EmrCreateJobFlowOperator 2023-12-25T18:00:44.069925+00:00 2023-12-25T18:00:45.035936+00:00 0:00:00.966011 461981 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-25T18:00:42.365773+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-25T17:00:00+00:00 PythonOperator 2023-12-25T18:00:24.686886+00:00 2023-12-25T18:00:26.244391+00:00 0:00:01.557505 461979 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-25T18:00:22.351769+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-25T16:00:00+00:00 EmrJobFlowSensor 2023-12-25T17:01:01.086811+00:00 2023-12-25T17:26:04.861797+00:00 0:25:03.774986 461965 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-25T17:00:59.394608+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-25T16:00:00+00:00 EmrCreateJobFlowOperator 2023-12-25T17:00:39.337801+00:00 2023-12-25T17:00:40.376716+00:00 0:00:01.038915 461963 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-25T17:00:37.384970+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-25T16:00:00+00:00 PythonOperator 2023-12-25T17:00:19.176954+00:00 2023-12-25T17:00:20.761126+00:00 0:00:01.584172 461961 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-25T17:00:17.373375+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-25T15:00:00+00:00 EmrJobFlowSensor 2023-12-25T16:00:54.569506+00:00 2023-12-25T16:26:58.439450+00:00 0:26:03.869944 461946 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-25T16:00:52.460678+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-25T15:00:00+00:00 EmrCreateJobFlowOperator 2023-12-25T16:00:32.167246+00:00 2023-12-25T16:00:33.149375+00:00 0:00:00.982129 461944 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-25T16:00:30.442841+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-25T15:00:00+00:00 PythonOperator 2023-12-25T16:00:10.678091+00:00 2023-12-25T16:00:12.560339+00:00 0:00:01.882248 461942 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-25T16:00:08.476357+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-25T14:00:00+00:00 EmrJobFlowSensor 2023-12-25T15:00:52.717494+00:00 2023-12-25T15:25:56.713449+00:00 0:25:03.995955 461929 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-25T15:00:50.644795+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-25T14:00:00+00:00 EmrCreateJobFlowOperator 2023-12-25T15:00:32.657104+00:00 2023-12-25T15:00:33.584660+00:00 0:00:00.927556 461927 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-25T15:00:30.624533+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-25T14:00:00+00:00 PythonOperator 2023-12-25T15:00:11.259732+00:00 2023-12-25T15:00:12.859874+00:00 0:00:01.600142 461925 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-25T15:00:08.666200+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-25T13:00:00+00:00 EmrJobFlowSensor 2023-12-25T14:01:06.958498+00:00 2023-12-25T14:26:10.770664+00:00 0:25:03.812166 461913 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-25T14:01:05.259526+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-25T13:00:00+00:00 EmrCreateJobFlowOperator 2023-12-25T14:00:44.861585+00:00 2023-12-25T14:00:45.944065+00:00 0:00:01.082480 461911 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-25T14:00:43.157595+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-25T13:00:00+00:00 PythonOperator 2023-12-25T14:00:25.303093+00:00 2023-12-25T14:00:26.849485+00:00 0:00:01.546392 461909 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-25T14:00:23.139504+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-25T12:00:00+00:00 EmrJobFlowSensor 2023-12-25T13:08:13.349307+00:00 2023-12-25T13:26:16.305908+00:00 0:18:02.956601 461897 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-25T13:08:10.979756+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-25T12:00:00+00:00 EmrCreateJobFlowOperator 2023-12-25T13:00:42.068908+00:00 2023-12-25T13:00:42.990540+00:00 0:00:00.921632 461893 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-25T13:00:39.526162+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-25T12:00:00+00:00 PythonOperator 2023-12-25T13:00:19.165578+00:00 2023-12-25T13:00:20.788608+00:00 0:00:01.623030 461891 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-25T13:00:17.504265+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-25T11:00:00+00:00 EmrJobFlowSensor 2023-12-25T12:07:08.987897+00:00 2023-12-25T12:32:12.641232+00:00 0:25:03.653335 461883 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-25T12:07:06.903489+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-25T11:00:00+00:00 EmrCreateJobFlowOperator 2023-12-25T12:06:46.956001+00:00 2023-12-25T12:06:47.774839+00:00 0:00:00.818838 461879 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-25T12:06:44.887219+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-25T11:00:00+00:00 PythonOperator 2023-12-25T12:06:26.983627+00:00 2023-12-25T12:06:28.506274+00:00 0:00:01.522647 461877 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-25T12:06:24.867493+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-25T10:00:00+00:00 EmrJobFlowSensor 2023-12-25T11:01:03.728635+00:00 2023-12-25T11:26:07.348299+00:00 0:25:03.619664 461862 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-25T11:01:01.483476+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-25T10:00:00+00:00 EmrCreateJobFlowOperator 2023-12-25T11:00:41.482838+00:00 2023-12-25T11:00:42.403035+00:00 0:00:00.920197 461860 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-25T11:00:39.426383+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-25T10:00:00+00:00 PythonOperator 2023-12-25T11:00:21.063676+00:00 2023-12-25T11:00:22.595501+00:00 0:00:01.531825 461858 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-25T11:00:19.409858+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-25T09:00:00+00:00 EmrJobFlowSensor 2023-12-25T10:00:59.658358+00:00 2023-12-25T10:26:03.494102+00:00 0:25:03.835744 461844 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-25T10:00:57.478857+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-25T09:00:00+00:00 EmrCreateJobFlowOperator 2023-12-25T10:00:38.285042+00:00 2023-12-25T10:00:39.235370+00:00 0:00:00.950328 461842 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-25T10:00:35.460915+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-25T09:00:00+00:00 PythonOperator 2023-12-25T10:00:17.164860+00:00 2023-12-25T10:00:18.746807+00:00 0:00:01.581947 461840 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-25T10:00:15.449682+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-25T08:00:00+00:00 EmrJobFlowSensor 2023-12-25T09:00:55.348649+00:00 2023-12-25T09:25:59.157574+00:00 0:25:03.808925 461825 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-25T09:00:53.582513+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-25T08:00:00+00:00 EmrCreateJobFlowOperator 2023-12-25T09:00:33.592966+00:00 2023-12-25T09:00:34.598951+00:00 0:00:01.005985 461823 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-25T09:00:31.518205+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-25T08:00:00+00:00 PythonOperator 2023-12-25T09:00:13.258519+00:00 2023-12-25T09:00:14.875902+00:00 0:00:01.617383 461821 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-25T09:00:11.501848+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-25T07:00:00+00:00 EmrJobFlowSensor 2023-12-25T08:01:32.936658+00:00 2023-12-25T08:26:37.154654+00:00 0:25:04.217996 461807 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-25T08:01:30.817274+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-25T07:00:00+00:00 EmrCreateJobFlowOperator 2023-12-25T08:01:10.876673+00:00 2023-12-25T08:01:12.183988+00:00 0:00:01.307315 461805 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-25T08:01:08.800863+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-25T07:00:00+00:00 PythonOperator 2023-12-25T08:00:10.800166+00:00 2023-12-25T08:00:12.445678+00:00 0:00:01.645512 461803 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-25T08:00:08.775334+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-25T06:00:00+00:00 EmrJobFlowSensor 2023-12-25T07:00:52.010927+00:00 2023-12-25T07:26:56.145006+00:00 0:26:04.134079 461792 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-25T07:00:49.769433+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-25T06:00:00+00:00 EmrCreateJobFlowOperator 2023-12-25T07:00:29.453062+00:00 2023-12-25T07:00:30.407200+00:00 0:00:00.954138 461790 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-25T07:00:27.755181+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-25T06:00:00+00:00 PythonOperator 2023-12-25T07:00:10.170590+00:00 2023-12-25T07:00:11.723783+00:00 0:00:01.553193 461788 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-25T07:00:07.686749+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-25T05:00:00+00:00 EmrJobFlowSensor 2023-12-25T06:00:50.270302+00:00 2023-12-25T06:25:54.107910+00:00 0:25:03.837608 461775 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-25T06:00:48.151499+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-25T05:00:00+00:00 EmrCreateJobFlowOperator 2023-12-25T06:00:27.832612+00:00 2023-12-25T06:00:28.811368+00:00 0:00:00.978756 461773 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-25T06:00:26.132039+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-25T05:00:00+00:00 PythonOperator 2023-12-25T06:00:07.904218+00:00 2023-12-25T06:00:09.477618+00:00 0:00:01.573400 461771 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-25T06:00:06.113349+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-25T04:00:00+00:00 EmrJobFlowSensor 2023-12-25T05:00:49.753583+00:00 2023-12-25T05:26:53.756827+00:00 0:26:04.003244 461759 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-25T05:00:47.717877+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-25T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-25T05:00:29.382252+00:00 2023-12-25T05:00:30.351695+00:00 0:00:00.969443 461757 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-25T05:00:27.700984+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-25T04:00:00+00:00 PythonOperator 2023-12-25T05:00:07.556875+00:00 2023-12-25T05:00:09.142480+00:00 0:00:01.585605 461755 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-25T05:00:05.660721+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-25T03:00:00+00:00 EmrJobFlowSensor 2023-12-25T04:06:12.666185+00:00 2023-12-25T04:32:16.989321+00:00 0:26:04.323136 461744 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-25T04:06:10.287477+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-25T03:00:00+00:00 EmrCreateJobFlowOperator 2023-12-25T04:05:49.905595+00:00 2023-12-25T04:05:50.953317+00:00 0:00:01.047722 461739 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-25T04:05:48.232387+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-25T03:00:00+00:00 PythonOperator 2023-12-25T04:05:30.183445+00:00 2023-12-25T04:05:31.770794+00:00 0:00:01.587349 461736 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-25T04:05:28.222025+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-25T02:00:00+00:00 EmrJobFlowSensor 2023-12-25T03:01:40.337885+00:00 2023-12-25T03:28:44.572206+00:00 0:27:04.234321 461722 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-25T03:01:38.252315+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-25T02:00:00+00:00 EmrCreateJobFlowOperator 2023-12-25T03:01:18.310736+00:00 2023-12-25T03:01:19.224089+00:00 0:00:00.913353 461720 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-25T03:01:16.231113+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-25T02:00:00+00:00 PythonOperator 2023-12-25T03:00:14.724783+00:00 2023-12-25T03:00:16.475084+00:00 0:00:01.750301 461717 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-25T03:00:12.649740+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-25T01:00:00+00:00 EmrJobFlowSensor 2023-12-25T02:01:29.064565+00:00 2023-12-25T02:26:32.835083+00:00 0:25:03.770518 461705 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-25T02:01:26.981558+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-25T01:00:00+00:00 EmrCreateJobFlowOperator 2023-12-25T02:01:08.644126+00:00 2023-12-25T02:01:09.656213+00:00 0:00:01.012087 461703 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-25T02:01:06.966142+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-25T01:00:00+00:00 PythonOperator 2023-12-25T02:00:15.495446+00:00 2023-12-25T02:00:17.098299+00:00 0:00:01.602853 461699 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-25T02:00:13.354887+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-25T00:00:00+00:00 EmrJobFlowSensor 2023-12-25T01:00:57.111854+00:00 2023-12-25T01:27:01.098006+00:00 0:26:03.986152 461682 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-25T01:00:54.941360+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-25T00:00:00+00:00 EmrCreateJobFlowOperator 2023-12-25T01:00:34.752054+00:00 2023-12-25T01:00:35.846300+00:00 0:00:01.094246 461680 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-25T01:00:32.970866+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-25T00:00:00+00:00 PythonOperator 2023-12-25T01:00:15.223135+00:00 2023-12-25T01:00:16.840861+00:00 0:00:01.617726 461678 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-25T01:00:12.977104+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-24T23:00:00+00:00 EmrJobFlowSensor 2023-12-25T00:01:06.742311+00:00 2023-12-25T00:26:11.392458+00:00 0:25:04.650147 461664 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-25T00:01:04.215112+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-24T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-25T00:00:44.379820+00:00 2023-12-25T00:00:45.413194+00:00 0:00:01.033374 461662 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-25T00:00:42.260675+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-24T23:00:00+00:00 PythonOperator 2023-12-25T00:00:24.360122+00:00 2023-12-25T00:00:25.922999+00:00 0:00:01.562877 461660 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-25T00:00:22.185528+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-24T22:00:00+00:00 EmrJobFlowSensor 2023-12-24T23:00:52.344686+00:00 2023-12-24T23:25:56.154826+00:00 0:25:03.810140 461644 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-24T23:00:50.713213+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-24T22:00:00+00:00 EmrCreateJobFlowOperator 2023-12-24T23:00:30.449465+00:00 2023-12-24T23:00:31.491297+00:00 0:00:01.041832 461641 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-24T23:00:28.692255+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-24T22:00:00+00:00 PythonOperator 2023-12-24T23:00:08.554427+00:00 2023-12-24T23:00:10.176268+00:00 0:00:01.621841 461638 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-24T23:00:06.624303+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-24T21:00:00+00:00 EmrJobFlowSensor 2023-12-24T22:01:23.437955+00:00 2023-12-24T22:24:26.934300+00:00 0:23:03.496345 461625 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-24T22:01:21.303354+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-24T21:00:00+00:00 EmrCreateJobFlowOperator 2023-12-24T22:01:01.417499+00:00 2023-12-24T22:01:02.554408+00:00 0:00:01.136909 461623 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-24T22:00:59.284708+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-24T21:00:00+00:00 PythonOperator 2023-12-24T22:00:41.767206+00:00 2023-12-24T22:00:43.382905+00:00 0:00:01.615699 461621 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-24T22:00:39.268653+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-24T20:00:00+00:00 EmrJobFlowSensor 2023-12-24T21:01:45.693728+00:00 2023-12-24T21:27:49.874007+00:00 0:26:04.180279 461608 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-24T21:01:43.489393+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-24T20:00:00+00:00 EmrCreateJobFlowOperator 2023-12-24T21:01:25.577994+00:00 2023-12-24T21:01:26.467212+00:00 0:00:00.889218 461606 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-24T21:01:23.466594+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-24T20:00:00+00:00 PythonOperator 2023-12-24T21:01:03.588520+00:00 2023-12-24T21:01:05.161749+00:00 0:00:01.573229 461604 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-24T21:01:01.509542+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-24T19:00:00+00:00 EmrJobFlowSensor 2023-12-24T20:01:16.738696+00:00 2023-12-24T20:28:20.762404+00:00 0:27:04.023708 461589 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-24T20:01:14.863933+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-24T19:00:00+00:00 EmrCreateJobFlowOperator 2023-12-24T20:00:57.056238+00:00 2023-12-24T20:00:57.973562+00:00 0:00:00.917324 461587 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-24T20:00:54.844827+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-24T19:00:00+00:00 PythonOperator 2023-12-24T20:00:07.889474+00:00 2023-12-24T20:00:09.470256+00:00 0:00:01.580782 461584 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-24T20:00:05.693558+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-24T18:00:00+00:00 EmrJobFlowSensor 2023-12-24T19:01:55.232800+00:00 2023-12-24T19:28:59.434878+00:00 0:27:04.202078 461573 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-24T19:01:53.094637+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-24T18:00:00+00:00 EmrCreateJobFlowOperator 2023-12-24T19:01:34.741073+00:00 2023-12-24T19:01:35.732341+00:00 0:00:00.991268 461571 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-24T19:01:33.077944+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-24T18:00:00+00:00 PythonOperator 2023-12-24T19:01:13.055951+00:00 2023-12-24T19:01:14.597323+00:00 0:00:01.541372 461569 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-24T19:01:11.087570+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-24T17:00:00+00:00 EmrJobFlowSensor 2023-12-24T18:01:47.671170+00:00 2023-12-24T18:28:51.732259+00:00 0:27:04.061089 461554 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-24T18:01:45.590758+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-24T17:00:00+00:00 EmrCreateJobFlowOperator 2023-12-24T18:01:27.284275+00:00 2023-12-24T18:01:28.259348+00:00 0:00:00.975073 461552 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-24T18:01:25.537815+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-24T17:00:00+00:00 PythonOperator 2023-12-24T18:01:06.081013+00:00 2023-12-24T18:01:07.662244+00:00 0:00:01.581231 461550 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-24T18:01:03.523324+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-24T16:00:00+00:00 EmrJobFlowSensor 2023-12-24T17:01:52.347065+00:00 2023-12-24T17:25:55.838995+00:00 0:24:03.491930 461536 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-24T17:01:50.713124+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-24T16:00:00+00:00 EmrCreateJobFlowOperator 2023-12-24T17:01:30.400088+00:00 2023-12-24T17:01:31.307621+00:00 0:00:00.907533 461534 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-24T17:01:28.695741+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-24T16:00:00+00:00 PythonOperator 2023-12-24T17:01:10.885940+00:00 2023-12-24T17:01:12.497296+00:00 0:00:01.611356 461532 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-24T17:01:08.679344+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-24T15:00:00+00:00 EmrJobFlowSensor 2023-12-24T16:01:06.609635+00:00 2023-12-24T16:27:10.428041+00:00 0:26:03.818406 461518 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-24T16:01:04.525318+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-24T15:00:00+00:00 EmrCreateJobFlowOperator 2023-12-24T16:00:44.170583+00:00 2023-12-24T16:00:45.237242+00:00 0:00:01.066659 461516 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-24T16:00:42.511795+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-24T15:00:00+00:00 PythonOperator 2023-12-24T16:00:24.596094+00:00 2023-12-24T16:00:26.132309+00:00 0:00:01.536215 461514 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-24T16:00:22.492793+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-24T14:00:00+00:00 EmrJobFlowSensor 2023-12-24T15:00:57.550051+00:00 2023-12-24T15:26:01.553775+00:00 0:25:04.003724 461501 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-24T15:00:55.364121+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-24T14:00:00+00:00 EmrCreateJobFlowOperator 2023-12-24T15:00:37.373787+00:00 2023-12-24T15:00:38.311916+00:00 0:00:00.938129 461499 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-24T15:00:35.282583+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-24T14:00:00+00:00 PythonOperator 2023-12-24T15:00:15.583189+00:00 2023-12-24T15:00:17.256420+00:00 0:00:01.673231 461497 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-24T15:00:13.264278+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-24T13:00:00+00:00 EmrJobFlowSensor 2023-12-24T14:02:28.547538+00:00 2023-12-24T14:27:32.430662+00:00 0:25:03.883124 461485 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-24T14:02:26.515537+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-24T13:00:00+00:00 EmrCreateJobFlowOperator 2023-12-24T14:02:08.151811+00:00 2023-12-24T14:02:09.174456+00:00 0:00:01.022645 461483 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-24T14:02:06.484390+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-24T13:00:00+00:00 PythonOperator 2023-12-24T14:01:46.363336+00:00 2023-12-24T14:01:48.005980+00:00 0:00:01.642644 461481 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-24T14:01:44.472123+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-24T12:00:00+00:00 EmrJobFlowSensor 2023-12-24T13:00:56.276780+00:00 2023-12-24T13:26:00.289769+00:00 0:25:04.012989 461468 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-24T13:00:54.063056+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-24T12:00:00+00:00 EmrCreateJobFlowOperator 2023-12-24T13:00:34.163103+00:00 2023-12-24T13:00:35.101014+00:00 0:00:00.937911 461466 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-24T13:00:32.055304+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-24T12:00:00+00:00 PythonOperator 2023-12-24T13:00:13.678101+00:00 2023-12-24T13:00:15.305082+00:00 0:00:01.626981 461464 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-24T13:00:11.959350+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-24T11:00:00+00:00 EmrJobFlowSensor 2023-12-24T12:00:53.563551+00:00 2023-12-24T12:25:57.383217+00:00 0:25:03.819666 461449 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-24T12:00:51.512942+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-24T11:00:00+00:00 EmrCreateJobFlowOperator 2023-12-24T12:00:31.261455+00:00 2023-12-24T12:00:32.241156+00:00 0:00:00.979701 461447 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-24T12:00:29.552657+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-24T11:00:00+00:00 PythonOperator 2023-12-24T12:00:11.926060+00:00 2023-12-24T12:00:13.501046+00:00 0:00:01.574986 461445 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-24T12:00:09.475369+00:00 2 default_pool