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-22T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-23T00:00:27.257179+00:00 2023-12-23T00:00:28.493697+00:00 0:00:01.236518 460809 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-23T00:00:25.243666+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-22T23:00:00+00:00 PythonOperator 2023-12-23T00:00:07.080113+00:00 2023-12-23T00:00:09.267919+00:00 0:00:02.187806 460807 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-23T00:00:05.227954+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-22T22:00:00+00:00 EmrJobFlowSensor 2023-12-22T23:01:05.183559+00:00 2023-12-22T23:27:08.985645+00:00 0:26:03.802086 460793 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-22T23:01:03.473215+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-22T22:00:00+00:00 EmrCreateJobFlowOperator 2023-12-22T23:00:43.600234+00:00 2023-12-22T23:00:44.569593+00:00 0:00:00.969359 460790 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-22T23:00:41.451892+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-22T22:00:00+00:00 PythonOperator 2023-12-22T23:00:23.079874+00:00 2023-12-22T23:00:24.621099+00:00 0:00:01.541225 460787 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-22T23:00:21.433003+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-22T21:00:00+00:00 EmrJobFlowSensor 2023-12-22T22:00:56.955478+00:00 2023-12-22T22:24:00.466539+00:00 0:23:03.511061 460772 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-22T22:00:54.820490+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-22T21:00:00+00:00 EmrCreateJobFlowOperator 2023-12-22T22:00:36.846879+00:00 2023-12-22T22:00:37.791891+00:00 0:00:00.945012 460770 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-22T22:00:34.800107+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-22T21:00:00+00:00 PythonOperator 2023-12-22T22:00:15.121593+00:00 2023-12-22T22:00:16.734652+00:00 0:00:01.613059 460768 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-22T22:00:12.782464+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-22T20:00:00+00:00 EmrJobFlowSensor 2023-12-22T21:00:52.328175+00:00 2023-12-22T21:27:56.399095+00:00 0:27:04.070920 460754 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-22T21:00:50.248235+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-22T20:00:00+00:00 EmrCreateJobFlowOperator 2023-12-22T21:00:32.279945+00:00 2023-12-22T21:00:33.209042+00:00 0:00:00.929097 460752 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-22T21:00:30.231234+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-22T20:00:00+00:00 PythonOperator 2023-12-22T21:00:10.688123+00:00 2023-12-22T21:00:12.311156+00:00 0:00:01.623033 460750 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-22T21:00:08.157787+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-22T19:00:00+00:00 EmrJobFlowSensor 2023-12-22T20:00:51.667970+00:00 2023-12-22T20:27:55.719918+00:00 0:27:04.051948 460736 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-22T20:00:49.560570+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-22T19:00:00+00:00 EmrCreateJobFlowOperator 2023-12-22T20:00:31.245294+00:00 2023-12-22T20:00:32.269168+00:00 0:00:01.023874 460734 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-22T20:00:29.532920+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-22T19:00:00+00:00 PythonOperator 2023-12-22T20:00:09.268768+00:00 2023-12-22T20:00:10.830470+00:00 0:00:01.561702 460732 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-22T20:00:07.565593+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-22T18:00:00+00:00 EmrJobFlowSensor 2023-12-22T19:01:39.755925+00:00 2023-12-22T19:29:44.163767+00:00 0:28:04.407842 460717 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-22T19:01:38.135623+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-22T18:00:00+00:00 EmrCreateJobFlowOperator 2023-12-22T19:01:18.052723+00:00 2023-12-22T19:01:19.059493+00:00 0:00:01.006770 460715 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-22T19:01:16.119597+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-22T18:00:00+00:00 PythonOperator 2023-12-22T19:00:58.552290+00:00 2023-12-22T19:01:00.222562+00:00 0:00:01.670272 460713 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-22T19:00:56.113373+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-22T17:00:00+00:00 EmrJobFlowSensor 2023-12-22T18:01:29.779993+00:00 2023-12-22T18:27:34.090571+00:00 0:26:04.310578 460700 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-22T18:01:27.914465+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-22T17:00:00+00:00 EmrCreateJobFlowOperator 2023-12-22T18:00:36.035950+00:00 2023-12-22T18:00:36.890516+00:00 0:00:00.854566 460698 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-22T18:00:33.918684+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-22T17:00:00+00:00 PythonOperator 2023-12-22T18:00:13.950916+00:00 2023-12-22T18:00:15.577100+00:00 0:00:01.626184 460696 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-22T18:00:11.900470+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-22T16:00:00+00:00 EmrJobFlowSensor 2023-12-22T17:00:48.478703+00:00 2023-12-22T17:23:52.226730+00:00 0:23:03.748027 460686 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-22T17:00:45.970212+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-22T16:00:00+00:00 EmrCreateJobFlowOperator 2023-12-22T17:00:25.672078+00:00 2023-12-22T17:00:26.722814+00:00 0:00:01.050736 460683 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-22T17:00:23.891402+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-22T16:00:00+00:00 PythonOperator 2023-12-22T17:00:06.464878+00:00 2023-12-22T17:00:07.972663+00:00 0:00:01.507785 460682 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-22T17:00:03.863305+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-22T15:00:00+00:00 EmrJobFlowSensor 2023-12-22T16:00:45.895884+00:00 2023-12-22T16:26:50.004617+00:00 0:26:04.108733 460670 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-22T16:00:43.786975+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-22T15:00:00+00:00 EmrCreateJobFlowOperator 2023-12-22T16:00:25.455676+00:00 2023-12-22T16:00:26.374588+00:00 0:00:00.918912 460668 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-22T16:00:23.769383+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-22T15:00:00+00:00 PythonOperator 2023-12-22T16:00:03.995317+00:00 2023-12-22T16:00:05.555848+00:00 0:00:01.560531 460666 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-22T16:00:01.783850+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-22T14:00:00+00:00 EmrJobFlowSensor 2023-12-22T15:02:33.155552+00:00 2023-12-22T15:27:37.002615+00:00 0:25:03.847063 460653 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-22T15:02:31.519424+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-22T14:00:00+00:00 EmrCreateJobFlowOperator 2023-12-22T15:02:12.284622+00:00 2023-12-22T15:02:13.196463+00:00 0:00:00.911841 460651 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-22T15:02:09.560390+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-22T14:00:00+00:00 PythonOperator 2023-12-22T15:00:07.862011+00:00 2023-12-22T15:00:09.455426+00:00 0:00:01.593415 460649 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-22T15:00:05.961507+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-22T13:00:00+00:00 EmrJobFlowSensor 2023-12-22T14:01:05.978607+00:00 2023-12-22T14:25:09.730993+00:00 0:24:03.752386 460639 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-22T14:01:03.766349+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-22T13:00:00+00:00 EmrCreateJobFlowOperator 2023-12-22T14:00:44.778672+00:00 2023-12-22T14:00:45.789541+00:00 0:00:01.010869 460637 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-22T14:00:41.778727+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-22T13:00:00+00:00 PythonOperator 2023-12-22T14:00:23.556048+00:00 2023-12-22T14:00:25.129859+00:00 0:00:01.573811 460635 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-22T14:00:21.766038+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-22T12:00:00+00:00 EmrJobFlowSensor 2023-12-22T13:00:54.158075+00:00 2023-12-22T13:25:58.081624+00:00 0:25:03.923549 460620 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-22T13:00:52.064903+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-22T12:00:00+00:00 EmrCreateJobFlowOperator 2023-12-22T13:00:33.862002+00:00 2023-12-22T13:00:34.853409+00:00 0:00:00.991407 460618 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-22T13:00:32.051568+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-22T12:00:00+00:00 PythonOperator 2023-12-22T13:00:12.066536+00:00 2023-12-22T13:00:13.607452+00:00 0:00:01.540916 460616 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-22T13:00:10.061851+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-22T11:00:00+00:00 EmrJobFlowSensor 2023-12-22T12:00:53.077186+00:00 2023-12-22T12:25:57.014250+00:00 0:25:03.937064 460603 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-22T12:00:50.576050+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-22T11:00:00+00:00 EmrCreateJobFlowOperator 2023-12-22T12:00:30.609175+00:00 2023-12-22T12:00:31.522490+00:00 0:00:00.913315 460601 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-22T12:00:28.552407+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-22T11:00:00+00:00 PythonOperator 2023-12-22T12:00:10.352565+00:00 2023-12-22T12:00:11.975609+00:00 0:00:01.623044 460599 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-22T12:00:08.484432+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-22T10:00:00+00:00 EmrJobFlowSensor 2023-12-22T11:00:45.971847+00:00 2023-12-22T11:24:49.496062+00:00 0:24:03.524215 460585 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-22T11:00:44.322369+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-22T10:00:00+00:00 EmrCreateJobFlowOperator 2023-12-22T11:00:24.474156+00:00 2023-12-22T11:00:25.458647+00:00 0:00:00.984491 460583 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-22T11:00:22.301888+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-22T10:00:00+00:00 PythonOperator 2023-12-22T11:00:04.584453+00:00 2023-12-22T11:00:06.142523+00:00 0:00:01.558070 460581 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-22T11:00:02.286810+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-22T09:00:00+00:00 EmrJobFlowSensor 2023-12-22T10:01:01.833135+00:00 2023-12-22T10:25:05.739262+00:00 0:24:03.906127 460570 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-22T10:00:59.668627+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-22T09:00:00+00:00 EmrCreateJobFlowOperator 2023-12-22T10:00:41.723337+00:00 2023-12-22T10:00:42.689641+00:00 0:00:00.966304 460568 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-22T10:00:39.591479+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-22T09:00:00+00:00 PythonOperator 2023-12-22T10:00:19.610343+00:00 2023-12-22T10:00:21.156325+00:00 0:00:01.545982 460566 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-22T10:00:17.572632+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-22T08:00:00+00:00 EmrJobFlowSensor 2023-12-22T09:09:29.207956+00:00 2023-12-22T09:35:33.066972+00:00 0:26:03.859016 460558 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-22T09:09:27.485144+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-22T08:00:00+00:00 EmrCreateJobFlowOperator 2023-12-22T09:09:09.533789+00:00 2023-12-22T09:09:10.455428+00:00 0:00:00.921639 460555 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-22T09:09:07.467616+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-22T08:00:00+00:00 PythonOperator 2023-12-22T09:08:47.548541+00:00 2023-12-22T09:08:49.088678+00:00 0:00:01.540137 460552 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-22T09:08:45.451031+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-22T07:00:00+00:00 EmrJobFlowSensor 2023-12-22T08:10:40.968772+00:00 2023-12-22T08:36:45.085607+00:00 0:26:04.116835 460544 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-22T08:10:39.289702+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-22T07:00:00+00:00 EmrCreateJobFlowOperator 2023-12-22T08:10:19.368414+00:00 2023-12-22T08:10:20.359028+00:00 0:00:00.990614 460541 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-22T08:10:17.264269+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-22T07:00:00+00:00 PythonOperator 2023-12-22T08:09:59.135961+00:00 2023-12-22T08:10:00.763073+00:00 0:00:01.627112 460538 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-22T08:09:57.246833+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-22T06:00:00+00:00 EmrJobFlowSensor 2023-12-22T07:00:57.665363+00:00 2023-12-22T07:26:01.445154+00:00 0:25:03.779791 460524 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-22T07:00:55.954373+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-22T06:00:00+00:00 EmrCreateJobFlowOperator 2023-12-22T07:00:36.231157+00:00 2023-12-22T07:00:37.284843+00:00 0:00:01.053686 460522 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-22T07:00:33.979680+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-22T06:00:00+00:00 PythonOperator 2023-12-22T07:00:14.162319+00:00 2023-12-22T07:00:15.754829+00:00 0:00:01.592510 460519 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-22T07:00:11.969618+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-22T05:00:00+00:00 EmrJobFlowSensor 2023-12-22T06:00:47.400496+00:00 2023-12-22T06:26:51.357721+00:00 0:26:03.957225 460505 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-22T06:00:45.278164+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-22T05:00:00+00:00 EmrCreateJobFlowOperator 2023-12-22T06:00:25.122756+00:00 2023-12-22T06:00:26.138613+00:00 0:00:01.015857 460503 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-22T06:00:23.272497+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-22T05:00:00+00:00 PythonOperator 2023-12-22T06:00:03.372935+00:00 2023-12-22T06:00:04.968763+00:00 0:00:01.595828 460501 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-22T06:00:01.188670+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-22T04:00:00+00:00 EmrJobFlowSensor 2023-12-22T05:01:31.390804+00:00 2023-12-22T05:26:35.162138+00:00 0:25:03.771334 460488 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-22T05:01:29.287750+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-22T04:00:00+00:00 EmrCreateJobFlowOperator 2023-12-22T05:01:11.360809+00:00 2023-12-22T05:01:12.486356+00:00 0:00:01.125547 460486 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-22T05:01:09.256398+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-22T04:00:00+00:00 PythonOperator 2023-12-22T05:00:49.854588+00:00 2023-12-22T05:00:51.448634+00:00 0:00:01.594046 460484 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-22T05:00:47.238179+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-22T03:00:00+00:00 EmrJobFlowSensor 2023-12-22T04:01:20.502745+00:00 2023-12-22T04:26:24.361481+00:00 0:25:03.858736 460470 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-22T04:01:18.365032+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-22T03:00:00+00:00 EmrCreateJobFlowOperator 2023-12-22T04:00:58.708911+00:00 2023-12-22T04:00:59.704950+00:00 0:00:00.996039 460467 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-22T04:00:56.346332+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-22T03:00:00+00:00 PythonOperator 2023-12-22T04:00:38.369814+00:00 2023-12-22T04:00:39.919559+00:00 0:00:01.549745 460464 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-22T04:00:36.327381+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-22T02:00:00+00:00 EmrJobFlowSensor 2023-12-22T03:01:28.915542+00:00 2023-12-22T03:26:32.716836+00:00 0:25:03.801294 460449 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-22T03:01:26.387763+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-22T02:00:00+00:00 EmrCreateJobFlowOperator 2023-12-22T03:01:06.459777+00:00 2023-12-22T03:01:07.408014+00:00 0:00:00.948237 460447 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-22T03:01:04.360163+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-22T02:00:00+00:00 PythonOperator 2023-12-22T03:00:46.333758+00:00 2023-12-22T03:00:47.947935+00:00 0:00:01.614177 460445 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-22T03:00:44.343837+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-22T01:00:00+00:00 EmrJobFlowSensor 2023-12-22T02:00:46.512486+00:00 2023-12-22T02:25:50.302348+00:00 0:25:03.789862 460430 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-22T02:00:43.980213+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-22T01:00:00+00:00 EmrCreateJobFlowOperator 2023-12-22T02:00:23.776580+00:00 2023-12-22T02:00:24.731859+00:00 0:00:00.955279 460428 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-22T02:00:21.981350+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-22T01:00:00+00:00 PythonOperator 2023-12-22T02:00:04.219829+00:00 2023-12-22T02:00:05.805616+00:00 0:00:01.585787 460426 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-22T02:00:01.966600+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-22T00:00:00+00:00 EmrJobFlowSensor 2023-12-22T01:00:49.599694+00:00 2023-12-22T01:25:53.427302+00:00 0:25:03.827608 460405 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-22T01:00:47.549695+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-22T00:00:00+00:00 EmrCreateJobFlowOperator 2023-12-22T01:00:29.462755+00:00 2023-12-22T01:00:30.520030+00:00 0:00:01.057275 460403 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-22T01:00:27.459268+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-22T00:00:00+00:00 PythonOperator 2023-12-22T01:00:07.765914+00:00 2023-12-22T01:00:09.358575+00:00 0:00:01.592661 460401 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-22T01:00:05.453248+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-21T23:00:00+00:00 EmrJobFlowSensor 2023-12-22T00:00:47.144195+00:00 2023-12-22T00:25:50.936466+00:00 0:25:03.792271 460387 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-22T00:00:44.807876+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-21T23:00:00+00:00 EmrCreateJobFlowOperator 2023-12-22T00:00:25.044238+00:00 2023-12-22T00:00:26.062858+00:00 0:00:01.018620 460385 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-22T00:00:22.852666+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-21T23:00:00+00:00 PythonOperator 2023-12-22T00:00:04.855076+00:00 2023-12-22T00:00:06.522679+00:00 0:00:01.667603 460383 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-22T00:00:02.760530+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-21T22:00:00+00:00 EmrJobFlowSensor 2023-12-21T23:01:06.668846+00:00 2023-12-21T23:27:10.778732+00:00 0:26:04.109886 460369 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-21T23:01:04.623826+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-21T22:00:00+00:00 EmrCreateJobFlowOperator 2023-12-21T23:00:44.771052+00:00 2023-12-21T23:00:45.783964+00:00 0:00:01.012912 460366 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-21T23:00:42.664451+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-21T22:00:00+00:00 PythonOperator 2023-12-21T23:00:24.259451+00:00 2023-12-21T23:00:25.977550+00:00 0:00:01.718099 460363 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-21T23:00:22.590017+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-21T21:00:00+00:00 EmrJobFlowSensor 2023-12-21T22:00:53.215216+00:00 2023-12-21T22:23:56.671605+00:00 0:23:03.456389 460347 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-21T22:00:51.058129+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-21T21:00:00+00:00 EmrCreateJobFlowOperator 2023-12-21T22:00:31.180691+00:00 2023-12-21T22:00:32.097949+00:00 0:00:00.917258 460345 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-21T22:00:29.034672+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-21T21:00:00+00:00 PythonOperator 2023-12-21T22:00:09.170174+00:00 2023-12-21T22:00:10.734147+00:00 0:00:01.563973 460343 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-21T22:00:07.018184+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-21T20:00:00+00:00 EmrJobFlowSensor 2023-12-21T21:00:48.253695+00:00 2023-12-21T21:26:52.180584+00:00 0:26:03.926889 460328 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-21T21:00:45.720500+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-21T20:00:00+00:00 EmrCreateJobFlowOperator 2023-12-21T21:00:26.354677+00:00 2023-12-21T21:00:27.300708+00:00 0:00:00.946031 460326 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-21T21:00:23.752355+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-21T20:00:00+00:00 PythonOperator 2023-12-21T21:00:05.762519+00:00 2023-12-21T21:00:07.299653+00:00 0:00:01.537134 460324 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-21T21:00:03.688506+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-21T19:00:00+00:00 EmrJobFlowSensor 2023-12-21T20:01:02.689938+00:00 2023-12-21T20:28:06.790964+00:00 0:27:04.101026 460311 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-21T20:01:00.557087+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-21T19:00:00+00:00 EmrCreateJobFlowOperator 2023-12-21T20:00:40.610341+00:00 2023-12-21T20:00:41.527938+00:00 0:00:00.917597 460309 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-21T20:00:38.537184+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-21T19:00:00+00:00 PythonOperator 2023-12-21T20:00:18.747457+00:00 2023-12-21T20:00:20.236912+00:00 0:00:01.489455 460307 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-21T20:00:16.574483+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-21T18:00:00+00:00 EmrJobFlowSensor 2023-12-21T19:00:56.249983+00:00 2023-12-21T19:28:00.404250+00:00 0:27:04.154267 460293 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-21T19:00:54.089508+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-21T18:00:00+00:00 EmrCreateJobFlowOperator 2023-12-21T19:00:34.383813+00:00 2023-12-21T19:00:35.273755+00:00 0:00:00.889942 460291 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-21T19:00:32.078129+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-21T18:00:00+00:00 PythonOperator 2023-12-21T19:00:14.109744+00:00 2023-12-21T19:00:15.683035+00:00 0:00:01.573291 460289 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-21T19:00:12.014599+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-21T17:00:00+00:00 EmrJobFlowSensor 2023-12-21T18:00:51.550033+00:00 2023-12-21T18:25:55.463774+00:00 0:25:03.913741 460274 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-21T18:00:49.385646+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-21T17:00:00+00:00 EmrCreateJobFlowOperator 2023-12-21T18:00:29.979048+00:00 2023-12-21T18:00:30.903523+00:00 0:00:00.924475 460272 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-21T18:00:27.366806+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-21T17:00:00+00:00 PythonOperator 2023-12-21T18:00:09.593168+00:00 2023-12-21T18:00:11.185644+00:00 0:00:01.592476 460270 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-21T18:00:07.300162+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-21T16:00:00+00:00 EmrJobFlowSensor 2023-12-21T17:01:01.699364+00:00 2023-12-21T17:24:05.708764+00:00 0:23:04.009400 460257 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-21T17:01:00.026694+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-21T16:00:00+00:00 EmrCreateJobFlowOperator 2023-12-21T17:00:40.094819+00:00 2023-12-21T17:00:41.089000+00:00 0:00:00.994181 460255 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-21T17:00:38.007663+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-21T16:00:00+00:00 PythonOperator 2023-12-21T17:00:17.777137+00:00 2023-12-21T17:00:19.387832+00:00 0:00:01.610695 460253 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-21T17:00:15.986461+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-21T15:00:00+00:00 EmrJobFlowSensor 2023-12-21T16:00:46.450393+00:00 2023-12-21T16:24:50.439229+00:00 0:24:03.988836 460239 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-21T16:00:44.664584+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-21T15:00:00+00:00 EmrCreateJobFlowOperator 2023-12-21T16:00:24.989938+00:00 2023-12-21T16:00:25.889229+00:00 0:00:00.899291 460237 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-21T16:00:22.686095+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-21T15:00:00+00:00 PythonOperator 2023-12-21T16:00:04.790514+00:00 2023-12-21T16:00:06.331774+00:00 0:00:01.541260 460235 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-21T16:00:02.662984+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-21T14:00:00+00:00 EmrJobFlowSensor 2023-12-21T15:00:49.152892+00:00 2023-12-21T15:25:53.017263+00:00 0:25:03.864371 460223 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-21T15:00:47.404513+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-21T14:00:00+00:00 EmrCreateJobFlowOperator 2023-12-21T15:00:29.058863+00:00 2023-12-21T15:00:29.960787+00:00 0:00:00.901924 460221 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-21T15:00:27.389089+00:00 2 default_pool