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 check_cluster_status 2023-12-07T10:00:00+00:00 EmrJobFlowSensor 2023-12-07T15:04:12.300532+00:00 2023-12-07T15:30:16.233290+00:00 0:26:03.932758 453538 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-07T15:04:10.584344+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-07T10:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T15:03:50.636628+00:00 2023-12-07T15:03:51.722111+00:00 0:00:01.085483 453537 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T15:03:48.563963+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-07T09:00:00+00:00 EmrJobFlowSensor 2023-12-07T14:37:01.988648+00:00 2023-12-07T15:03:05.950286+00:00 0:26:03.961638 453527 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-07T14:36:59.938305+00:00 3 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-07T09:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T14:36:39.911701+00:00 2023-12-07T14:36:41.015663+00:00 0:00:01.103962 453524 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T14:36:37.917938+00:00 3 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-07T09:00:00+00:00 PythonOperator 2023-12-07T14:36:20.193300+00:00 2023-12-07T14:36:22.150082+00:00 0:00:01.956782 453521 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T14:36:17.903581+00:00 3 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-07T08:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T14:22:50.591166+00:00 2023-12-07T14:22:52.058802+00:00 0:00:01.467636 453519 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T14:22:48.568258+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-07T08:00:00+00:00 PythonOperator 2023-12-07T14:22:28.581886+00:00 2023-12-07T14:22:30.567332+00:00 0:00:01.985446 453518 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T14:22:26.510673+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-07T07:00:00+00:00 EmrJobFlowSensor 2023-12-07T14:22:28.245175+00:00 453517 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-07T14:22:26.510641+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-07T07:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T14:22:06.587833+00:00 2023-12-07T14:22:07.589527+00:00 0:00:01.001694 453516 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T14:22:04.483903+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-07T07:00:00+00:00 PythonOperator 2023-12-07T14:21:46.165619+00:00 2023-12-07T14:21:47.904721+00:00 0:00:01.739102 453515 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T14:21:44.482480+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-06T15:00:00+00:00 EmrJobFlowSensor 2023-12-07T14:18:55.850761+00:00 453513 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-07T14:18:54.243935+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-06T15:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T14:18:36.211444+00:00 2023-12-07T14:18:37.251884+00:00 0:00:01.040440 453512 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T14:18:34.223477+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-06T15:00:00+00:00 PythonOperator 2023-12-07T14:18:14.201558+00:00 2023-12-07T14:18:16.126018+00:00 0:00:01.924460 453511 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T14:18:12.206054+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-06T14:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T14:17:52.301113+00:00 2023-12-07T14:17:53.311581+00:00 0:00:01.010468 453509 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T14:17:50.256840+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-06T13:00:00+00:00 EmrJobFlowSensor 2023-12-07T14:16:28.101699+00:00 453507 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-07T14:16:26.076074+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-06T14:00:00+00:00 PythonOperator 2023-12-07T14:16:27.755117+00:00 2023-12-07T14:16:29.465021+00:00 0:00:01.709904 453506 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T14:16:26.076103+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-06T13:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T14:16:08.382405+00:00 2023-12-07T14:16:09.647931+00:00 0:00:01.265526 453505 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T14:16:06.064417+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-06T13:00:00+00:00 PythonOperator 2023-12-07T14:15:20.448395+00:00 2023-12-07T14:15:22.091363+00:00 0:00:01.642968 453502 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T14:15:18.775037+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-06T12:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T14:14:58.690744+00:00 2023-12-07T14:14:59.755776+00:00 0:00:01.065032 453501 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T14:14:56.700830+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-06T08:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T14:14:58.437610+00:00 2023-12-07T14:14:59.447443+00:00 0:00:01.009833 453500 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T14:14:56.700802+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-06T08:00:00+00:00 PythonOperator 2023-12-07T14:14:36.673762+00:00 2023-12-07T14:14:38.556184+00:00 0:00:01.882422 453499 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T14:14:34.683198+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-06T07:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T14:14:16.397704+00:00 2023-12-07T14:14:17.413216+00:00 0:00:01.015512 453498 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T14:14:14.662672+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-06T07:00:00+00:00 PythonOperator 2023-12-07T14:13:54.700691+00:00 2023-12-07T14:13:56.649522+00:00 0:00:01.948831 453497 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T14:13:52.646453+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-06T06:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T14:13:30.461050+00:00 2023-12-07T14:13:31.472774+00:00 0:00:01.011724 453496 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T14:13:28.678002+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-06T11:00:00+00:00 EmrJobFlowSensor 2023-12-07T14:11:18.728613+00:00 453495 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-07T14:11:16.556630+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-06T12:00:00+00:00 PythonOperator 2023-12-07T14:11:18.362972+00:00 2023-12-07T14:11:19.977203+00:00 0:00:01.614231 453494 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T14:11:16.556659+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-06T11:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T14:10:56.245460+00:00 2023-12-07T14:10:57.179383+00:00 0:00:00.933923 453493 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T14:10:54.484095+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-06T11:00:00+00:00 PythonOperator 2023-12-07T14:10:34.228284+00:00 2023-12-07T14:10:35.892272+00:00 0:00:01.663988 453492 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T14:10:32.489794+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-06T06:00:00+00:00 PythonOperator 2023-12-07T14:09:30.705070+00:00 2023-12-07T14:09:32.628378+00:00 0:00:01.923308 453491 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T14:09:28.390586+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-06T05:00:00+00:00 EmrJobFlowSensor 2023-12-07T14:07:14.473659+00:00 453489 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-07T14:07:12.528762+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-06T05:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T14:06:52.690827+00:00 2023-12-07T14:06:53.912358+00:00 0:00:01.221531 453488 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T14:06:50.557690+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-06T05:00:00+00:00 PythonOperator 2023-12-07T14:06:32.546113+00:00 2023-12-07T14:06:34.480016+00:00 0:00:01.933903 453487 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T14:06:30.489235+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-07T10:00:00+00:00 PythonOperator 2023-12-07T13:45:19.935670+00:00 2023-12-07T13:45:21.642853+00:00 0:00:01.707183 453475 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T13:45:18.278166+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-06T18:00:00+00:00 PythonOperator 2023-12-07T13:38:49.980224+00:00 2023-12-07T13:38:51.974273+00:00 0:00:01.994049 453472 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T13:38:47.763798+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-06T10:00:00+00:00 PythonOperator 2023-12-07T13:35:42.108995+00:00 2023-12-07T13:35:44.014332+00:00 0:00:01.905337 453470 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T13:35:39.955438+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-05T18:00:00+00:00 PythonOperator 2023-12-07T13:28:41.150214+00:00 2023-12-07T13:28:42.879165+00:00 0:00:01.728951 453468 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T13:28:39.348212+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-05T02:00:00+00:00 PythonOperator 2023-12-07T13:07:31.596485+00:00 2023-12-07T13:07:33.514030+00:00 0:00:01.917545 453461 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T13:07:29.565273+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-04T10:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T13:05:19.073146+00:00 2023-12-07T13:05:20.051021+00:00 0:00:00.977875 453458 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T13:05:17.440527+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-04T09:00:00+00:00 EmrJobFlowSensor 2023-12-07T09:41:42.409435+00:00 2023-12-07T09:47:43.758152+00:00 0:06:01.348717 453384 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-07T09:41:40.258117+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-04T10:00:00+00:00 PythonOperator 2023-12-07T09:41:41.944412+00:00 2023-12-07T09:41:43.582265+00:00 0:00:01.637853 453383 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T09:41:40.258147+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-04T09:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T09:41:19.946774+00:00 2023-12-07T09:41:20.948506+00:00 0:00:01.001732 453382 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T09:41:18.190598+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-04T08:00:00+00:00 EmrJobFlowSensor 2023-12-07T09:16:58.799209+00:00 2023-12-07T09:41:02.536331+00:00 0:24:03.737122 453377 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-07T09:16:56.804517+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-04T09:00:00+00:00 PythonOperator 2023-12-07T09:16:58.455681+00:00 2023-12-07T09:17:00.178034+00:00 0:00:01.722353 453376 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T09:16:56.804544+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-04T08:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T09:16:36.668350+00:00 2023-12-07T09:16:37.653121+00:00 0:00:00.984771 453375 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T09:16:34.738018+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-04T08:00:00+00:00 PythonOperator 2023-12-07T09:16:14.744328+00:00 2023-12-07T09:16:16.710450+00:00 0:00:01.966122 453373 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T09:16:12.721918+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-03T22:00:00+00:00 PythonOperator 2023-12-07T09:07:39.194186+00:00 2023-12-07T09:07:41.102655+00:00 0:00:01.908469 453369 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T09:07:37.061657+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-03T06:00:00+00:00 PythonOperator 2023-12-07T08:56:57.591656+00:00 2023-12-07T08:56:59.278562+00:00 0:00:01.686906 453359 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T08:56:55.590768+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-02T14:00:00+00:00 PythonOperator 2023-12-07T08:48:36.195190+00:00 2023-12-07T08:48:37.806370+00:00 0:00:01.611180 453357 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T08:48:34.309159+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-01T22:00:00+00:00 PythonOperator 2023-12-07T08:36:51.555489+00:00 2023-12-07T08:36:53.422635+00:00 0:00:01.867146 453354 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T08:36:49.593338+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-01T21:00:00+00:00 PythonOperator 2023-12-07T08:36:29.649773+00:00 2023-12-07T08:36:31.658737+00:00 0:00:02.008964 453353 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T08:36:27.585116+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-01T06:00:00+00:00 PythonOperator 2023-12-07T08:31:03.175136+00:00 2023-12-07T08:31:05.092147+00:00 0:00:01.917011 453352 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T08:31:01.215066+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-12-01T05:00:00+00:00 EmrJobFlowSensor 2023-12-07T08:31:02.838414+00:00 453351 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-07T08:31:01.215039+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-12-01T05:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T08:30:41.240556+00:00 2023-12-07T08:30:42.250541+00:00 0:00:01.009985 453350 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T08:30:39.193597+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-12-01T05:00:00+00:00 PythonOperator 2023-12-07T08:30:20.970285+00:00 2023-12-07T08:30:22.650654+00:00 0:00:01.680369 453349 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T08:30:19.176165+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-30T13:00:00+00:00 PythonOperator 2023-12-07T08:15:43.385972+00:00 2023-12-07T08:15:45.264045+00:00 0:00:01.878073 453344 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T08:15:41.181564+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-29T21:00:00+00:00 PythonOperator 2023-12-07T07:56:34.657301+00:00 2023-12-07T07:56:36.376025+00:00 0:00:01.718724 453332 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T07:56:32.774448+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-29T05:00:00+00:00 PythonOperator 2023-12-07T07:47:28.624271+00:00 2023-12-07T07:47:30.579684+00:00 0:00:01.955413 453330 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T07:47:26.472589+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-28T13:00:00+00:00 PythonOperator 2023-12-07T07:31:55.985137+00:00 2023-12-07T07:31:57.910227+00:00 0:00:01.925090 453327 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T07:31:53.920978+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-27T21:00:00+00:00 PythonOperator 2023-12-07T07:19:55.784804+00:00 2023-12-07T07:19:57.529488+00:00 0:00:01.744684 453325 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T07:19:54.067692+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-27T05:00:00+00:00 PythonOperator 2023-12-07T07:13:47.831844+00:00 2023-12-07T07:13:49.802043+00:00 0:00:01.970199 453320 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T07:13:45.691246+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-27T01:00:00+00:00 EmrJobFlowSensor 2023-12-07T07:07:16.667473+00:00 453318 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-07T07:07:14.744288+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-27T02:00:00+00:00 PythonOperator 2023-12-07T07:07:16.440333+00:00 2023-12-07T07:07:18.071913+00:00 0:00:01.631580 453317 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T07:07:14.744317+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-27T01:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T07:06:54.817178+00:00 2023-12-07T07:06:55.860630+00:00 0:00:01.043452 453316 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T07:06:52.756362+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-27T01:00:00+00:00 PythonOperator 2023-12-07T07:06:34.448677+00:00 2023-12-07T07:06:36.101161+00:00 0:00:01.652484 453315 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T07:06:32.757973+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-26T09:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T06:59:51.200235+00:00 2023-12-07T06:59:52.452548+00:00 0:00:01.252313 453306 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T06:59:49.207417+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-26T09:00:00+00:00 PythonOperator 2023-12-07T06:59:29.147595+00:00 2023-12-07T06:59:30.781248+00:00 0:00:01.633653 453305 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T06:59:27.190424+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-25T17:00:00+00:00 PythonOperator 2023-12-07T06:48:51.943769+00:00 2023-12-07T06:48:53.679245+00:00 0:00:01.735476 453303 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T06:48:50.187888+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-25T01:00:00+00:00 PythonOperator 2023-12-07T06:40:22.261389+00:00 2023-12-07T06:40:23.970289+00:00 0:00:01.708900 453301 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T06:40:20.187326+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-24T09:00:00+00:00 PythonOperator 2023-12-07T06:33:57.566672+00:00 2023-12-07T06:33:59.217216+00:00 0:00:01.650544 453299 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T06:33:55.762317+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-23T17:00:00+00:00 PythonOperator 2023-12-07T06:26:02.332549+00:00 2023-12-07T06:26:03.994460+00:00 0:00:01.661911 453297 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T06:26:00.536605+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-23T02:00:00+00:00 PythonOperator 2023-12-07T06:09:15.172089+00:00 2023-12-07T06:09:16.809005+00:00 0:00:01.636916 453290 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T06:09:13.464195+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-23T01:00:00+00:00 EmrCreateJobFlowOperator 2023-12-07T06:08:53.379975+00:00 2023-12-07T06:08:54.396945+00:00 0:00:01.016970 453289 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-07T06:08:51.389016+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-23T01:00:00+00:00 PythonOperator 2023-12-07T06:08:33.161138+00:00 2023-12-07T06:08:34.801328+00:00 0:00:01.640190 453288 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-07T06:08:31.380014+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-22T10:00:00+00:00 EmrJobFlowSensor 2023-12-06T14:53:32.553795+00:00 2023-12-06T15:58:42.259452+00:00 1:05:09.705657 452977 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-06T14:53:30.495514+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-22T11:00:00+00:00 PythonOperator 2023-12-06T14:53:32.296518+00:00 2023-12-06T14:53:34.010263+00:00 0:00:01.713745 452976 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-06T14:53:30.495541+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-22T10:00:00+00:00 EmrCreateJobFlowOperator 2023-12-06T14:53:10.565071+00:00 2023-12-06T14:53:11.620844+00:00 0:00:01.055773 452975 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-06T14:53:08.486045+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-22T10:00:00+00:00 PythonOperator 2023-12-06T14:31:54.965648+00:00 2023-12-06T14:31:57.031890+00:00 0:00:02.066242 452971 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-06T14:31:52.982342+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-22T09:00:00+00:00 EmrJobFlowSensor 2023-12-06T14:31:54.681411+00:00 452970 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-06T14:31:52.982313+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-22T09:00:00+00:00 EmrCreateJobFlowOperator 2023-12-06T14:31:33.306889+00:00 2023-12-06T14:31:34.379139+00:00 0:00:01.072250 452969 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-06T14:31:30.961018+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-22T08:00:00+00:00 EmrJobFlowSensor 2023-12-06T07:55:29.760998+00:00 2023-12-06T08:21:33.738637+00:00 0:26:03.977639 452831 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-06T07:55:27.774636+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-22T09:00:00+00:00 PythonOperator 2023-12-06T07:55:29.540918+00:00 2023-12-06T07:55:31.500171+00:00 0:00:01.959253 452830 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-06T07:55:27.774665+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-22T08:00:00+00:00 EmrCreateJobFlowOperator 2023-12-06T07:55:08.072044+00:00 2023-12-06T07:55:09.095174+00:00 0:00:01.023130 452829 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-06T07:55:05.764844+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-22T07:00:00+00:00 EmrJobFlowSensor 2023-12-06T07:28:37.463434+00:00 2023-12-06T07:54:41.302400+00:00 0:26:03.838966 452826 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-12-06T07:28:35.475550+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-22T08:00:00+00:00 PythonOperator 2023-12-06T07:28:37.168031+00:00 2023-12-06T07:28:39.132955+00:00 0:00:01.964924 452825 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-12-06T07:28:35.475577+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-22T07:00:00+00:00 EmrCreateJobFlowOperator 2023-12-06T07:28:15.677809+00:00 2023-12-06T07:28:16.783343+00:00 0:00:01.105534 452824 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-12-06T07:28:13.502013+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-22T07:00:00+00:00 PythonOperator 2023-11-22T08:00:16.228945+00:00 2023-11-22T08:00:18.377527+00:00 0:00:02.148582 449033 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-22T08:00:14.062323+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-22T06:00:00+00:00 EmrJobFlowSensor 2023-11-22T07:27:28.759963+00:00 2023-11-22T07:27:29.257797+00:00 0:00:00.497834 449028 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-22T07:27:26.673579+00:00 6 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-22T06:00:00+00:00 EmrCreateJobFlowOperator 2023-11-22T07:01:06.460106+00:00 2023-11-22T07:01:07.399934+00:00 0:00:00.939828 449017 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-22T07:01:04.375999+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-22T06:00:00+00:00 PythonOperator 2023-11-22T07:00:23.425921+00:00 2023-11-22T07:00:25.625623+00:00 0:00:02.199702 449015 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-22T07:00:21.170427+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-22T05:00:00+00:00 EmrJobFlowSensor 2023-11-22T06:01:40.567868+00:00 2023-11-22T06:26:44.406926+00:00 0:25:03.839058 449004 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-22T06:01:38.479052+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-22T05:00:00+00:00 EmrCreateJobFlowOperator 2023-11-22T06:01:18.269255+00:00 2023-11-22T06:01:19.327961+00:00 0:00:01.058706 449003 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-22T06:01:16.459273+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-22T05:00:00+00:00 PythonOperator 2023-11-22T06:00:20.288496+00:00 2023-11-22T06:00:22.285179+00:00 0:00:01.996683 449001 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-22T06:00:18.488160+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-22T04:00:00+00:00 EmrJobFlowSensor 2023-11-22T05:02:27.250580+00:00 2023-11-22T05:27:31.165558+00:00 0:25:03.914978 448990 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-22T05:02:25.590517+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-22T04:00:00+00:00 EmrCreateJobFlowOperator 2023-11-22T05:02:05.499207+00:00 2023-11-22T05:02:06.551331+00:00 0:00:01.052124 448989 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-22T05:02:03.568987+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-22T04:00:00+00:00 PythonOperator 2023-11-22T05:00:24.988527+00:00 2023-11-22T05:00:27.214354+00:00 0:00:02.225827 448987 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-22T05:00:22.677129+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-22T03:00:00+00:00 EmrJobFlowSensor 2023-11-22T04:01:31.135376+00:00 2023-11-22T04:26:34.986104+00:00 0:25:03.850728 448975 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-22T04:01:29.083681+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-22T03:00:00+00:00 EmrCreateJobFlowOperator 2023-11-22T04:01:09.206004+00:00 2023-11-22T04:01:10.662423+00:00 0:00:01.456419 448973 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-22T04:01:07.059742+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_emr_steps 2023-11-22T03:00:00+00:00 PythonOperator 2023-11-22T04:00:20.129775+00:00 2023-11-22T04:00:22.381360+00:00 0:00:02.251585 448971 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-11-22T04:00:18.115270+00:00 2 default_pool
success exchange-trade-summary_v1_v002 check_cluster_status 2023-11-22T02:00:00+00:00 EmrJobFlowSensor 2023-11-22T03:00:46.648417+00:00 2023-11-22T03:25:50.548320+00:00 0:25:03.899903 448959 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-11-22T03:00:44.666054+00:00 2 default_pool
success exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps 2023-11-22T02:00:00+00:00 EmrCreateJobFlowOperator 2023-11-22T03:00:26.618970+00:00 2023-11-22T03:00:27.682339+00:00 0:00:01.063369 448958 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 2023-11-22T03:00:24.593345+00:00 2 default_pool