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 campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-08T02:00:00+00:00 EmrCreateJobFlowOperator 2023-06-08T03:01:48.763851+00:00 2023-06-08T03:01:49.590295+00:00 0:00:00.826444 392862 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-08T03:01:46.546005+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-08T02:00:00+00:00 PythonOperator 2023-06-08T03:01:27.418413+00:00 2023-06-08T03:01:28.282664+00:00 0:00:00.864251 392860 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-08T03:01:24.526384+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-08T01:00:00+00:00 TriggerDagRunOperator 2023-06-08T02:11:13.446600+00:00 2023-06-08T02:11:13.771726+00:00 0:00:00.325126 392849 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T02:11:11.237842+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-08T01:00:00+00:00 TriggerDagRunOperator 2023-06-08T02:11:13.273477+00:00 2023-06-08T02:11:13.728036+00:00 0:00:00.454559 392848 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T02:11:11.237808+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-08T01:00:00+00:00 EmrJobFlowSensor 2023-06-08T02:00:47.138616+00:00 2023-06-08T02:10:48.990568+00:00 0:10:01.851952 392841 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-08T02:00:44.993920+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-08T01:00:00+00:00 EmrCreateJobFlowOperator 2023-06-08T02:00:26.975514+00:00 2023-06-08T02:00:27.915088+00:00 0:00:00.939574 392839 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-08T02:00:24.924693+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-08T01:00:00+00:00 PythonOperator 2023-06-08T02:00:05.287520+00:00 2023-06-08T02:00:06.131711+00:00 0:00:00.844191 392837 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-08T02:00:02.895253+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-08T00:00:00+00:00 TriggerDagRunOperator 2023-06-08T01:11:12.622739+00:00 2023-06-08T01:11:13.031695+00:00 0:00:00.408956 392816 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T01:11:10.235902+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-08T00:00:00+00:00 TriggerDagRunOperator 2023-06-08T01:11:12.276282+00:00 2023-06-08T01:11:12.888935+00:00 0:00:00.612653 392815 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T01:11:10.235875+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-08T00:00:00+00:00 EmrJobFlowSensor 2023-06-08T01:00:57.792709+00:00 2023-06-08T01:10:59.610120+00:00 0:10:01.817411 392808 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-08T01:00:55.765253+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-08T00:00:00+00:00 EmrCreateJobFlowOperator 2023-06-08T01:00:37.990745+00:00 2023-06-08T01:00:38.866653+00:00 0:00:00.875908 392806 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-08T01:00:35.748796+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-08T00:00:00+00:00 PythonOperator 2023-06-08T01:00:16.095701+00:00 2023-06-08T01:00:16.938704+00:00 0:00:00.843003 392804 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-08T01:00:13.728071+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-07T23:00:00+00:00 TriggerDagRunOperator 2023-06-08T00:11:17.184494+00:00 2023-06-08T00:11:17.520281+00:00 0:00:00.335787 392793 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T00:11:14.948562+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-07T23:00:00+00:00 TriggerDagRunOperator 2023-06-08T00:11:17.138102+00:00 2023-06-08T00:11:17.586697+00:00 0:00:00.448595 392792 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-08T00:11:14.948529+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-07T23:00:00+00:00 EmrJobFlowSensor 2023-06-08T00:00:55.854866+00:00 2023-06-08T00:10:57.727155+00:00 0:10:01.872289 392785 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-08T00:00:53.793929+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-07T23:00:00+00:00 EmrCreateJobFlowOperator 2023-06-08T00:00:36.047397+00:00 2023-06-08T00:00:36.833259+00:00 0:00:00.785862 392783 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-08T00:00:33.757851+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-07T23:00:00+00:00 PythonOperator 2023-06-08T00:00:13.990685+00:00 2023-06-08T00:00:14.953924+00:00 0:00:00.963239 392781 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-08T00:00:11.737121+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-07T22:00:00+00:00 TriggerDagRunOperator 2023-06-07T23:11:27.574837+00:00 2023-06-07T23:11:27.922589+00:00 0:00:00.347752 392770 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T23:11:25.293124+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-07T22:00:00+00:00 TriggerDagRunOperator 2023-06-07T23:11:27.416140+00:00 2023-06-07T23:11:27.866879+00:00 0:00:00.450739 392769 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T23:11:25.293078+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-07T22:00:00+00:00 EmrJobFlowSensor 2023-06-07T23:01:05.442609+00:00 2023-06-07T23:11:07.340528+00:00 0:10:01.897919 392763 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-07T23:01:02.690259+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-07T22:00:00+00:00 EmrCreateJobFlowOperator 2023-06-07T23:00:45.385838+00:00 2023-06-07T23:00:46.183349+00:00 0:00:00.797511 392760 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-07T23:00:42.630837+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-07T22:00:00+00:00 PythonOperator 2023-06-07T23:00:23.456160+00:00 2023-06-07T23:00:24.331117+00:00 0:00:00.874957 392757 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-07T23:00:20.598354+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-07T21:00:00+00:00 TriggerDagRunOperator 2023-06-07T22:11:11.607574+00:00 2023-06-07T22:11:11.959736+00:00 0:00:00.352162 392744 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T22:11:09.335458+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-07T21:00:00+00:00 TriggerDagRunOperator 2023-06-07T22:11:11.571095+00:00 2023-06-07T22:11:12.039053+00:00 0:00:00.467958 392743 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T22:11:09.335428+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-07T21:00:00+00:00 EmrJobFlowSensor 2023-06-07T22:00:57.896043+00:00 2023-06-07T22:10:59.642576+00:00 0:10:01.746533 392737 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-07T22:00:55.689086+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-07T21:00:00+00:00 EmrCreateJobFlowOperator 2023-06-07T22:00:37.816676+00:00 2023-06-07T22:00:38.644479+00:00 0:00:00.827803 392735 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-07T22:00:35.602434+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-07T21:00:00+00:00 PythonOperator 2023-06-07T22:00:15.584485+00:00 2023-06-07T22:00:16.635114+00:00 0:00:01.050629 392733 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-07T22:00:13.579015+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-07T20:00:00+00:00 TriggerDagRunOperator 2023-06-07T21:11:14.441699+00:00 2023-06-07T21:11:14.782316+00:00 0:00:00.340617 392721 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T21:11:12.184496+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-07T20:00:00+00:00 TriggerDagRunOperator 2023-06-07T21:11:14.238978+00:00 2023-06-07T21:11:14.688397+00:00 0:00:00.449419 392720 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T21:11:12.184469+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-07T20:00:00+00:00 EmrJobFlowSensor 2023-06-07T21:01:03.085011+00:00 2023-06-07T21:11:04.837626+00:00 0:10:01.752615 392714 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-07T21:01:00.820990+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-07T20:00:00+00:00 EmrCreateJobFlowOperator 2023-06-07T21:00:42.895348+00:00 2023-06-07T21:00:43.801789+00:00 0:00:00.906441 392712 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-07T21:00:40.803230+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-07T20:00:00+00:00 PythonOperator 2023-06-07T21:00:20.819337+00:00 2023-06-07T21:00:21.884125+00:00 0:00:01.064788 392710 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-07T21:00:18.781715+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-07T19:00:00+00:00 TriggerDagRunOperator 2023-06-07T20:11:16.585517+00:00 2023-06-07T20:11:16.950210+00:00 0:00:00.364693 392698 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T20:11:14.114722+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-07T19:00:00+00:00 TriggerDagRunOperator 2023-06-07T20:11:16.346912+00:00 2023-06-07T20:11:16.772092+00:00 0:00:00.425180 392697 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T20:11:14.114749+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-07T19:00:00+00:00 EmrJobFlowSensor 2023-06-07T20:00:54.152088+00:00 2023-06-07T20:10:55.995318+00:00 0:10:01.843230 392691 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-07T20:00:51.950326+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-07T19:00:00+00:00 EmrCreateJobFlowOperator 2023-06-07T20:00:32.146930+00:00 2023-06-07T20:00:32.996377+00:00 0:00:00.849447 392689 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-07T20:00:29.924439+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-07T19:00:00+00:00 PythonOperator 2023-06-07T20:00:09.972678+00:00 2023-06-07T20:00:10.974369+00:00 0:00:01.001691 392687 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-07T20:00:07.907223+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-07T18:00:00+00:00 TriggerDagRunOperator 2023-06-07T19:11:12.635589+00:00 2023-06-07T19:11:13.059927+00:00 0:00:00.424338 392673 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T19:11:10.287366+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-07T18:00:00+00:00 TriggerDagRunOperator 2023-06-07T19:11:12.374002+00:00 2023-06-07T19:11:12.977514+00:00 0:00:00.603512 392672 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T19:11:10.287400+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-07T18:00:00+00:00 EmrJobFlowSensor 2023-06-07T19:01:01.059305+00:00 2023-06-07T19:11:02.926227+00:00 0:10:01.866922 392665 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-07T19:00:58.605930+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-07T18:00:00+00:00 EmrCreateJobFlowOperator 2023-06-07T19:00:40.913004+00:00 2023-06-07T19:00:41.744574+00:00 0:00:00.831570 392664 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-07T19:00:38.519008+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-07T18:00:00+00:00 PythonOperator 2023-06-07T19:00:18.698656+00:00 2023-06-07T19:00:19.555904+00:00 0:00:00.857248 392663 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-07T19:00:16.499793+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-07T17:00:00+00:00 TriggerDagRunOperator 2023-06-07T18:11:11.506589+00:00 2023-06-07T18:11:11.858378+00:00 0:00:00.351789 392649 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T18:11:09.219132+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-07T17:00:00+00:00 TriggerDagRunOperator 2023-06-07T18:11:11.249998+00:00 2023-06-07T18:11:11.677234+00:00 0:00:00.427236 392648 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T18:11:09.219100+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-07T17:00:00+00:00 EmrJobFlowSensor 2023-06-07T18:00:57.448567+00:00 2023-06-07T18:10:59.271631+00:00 0:10:01.823064 392641 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-07T18:00:55.234365+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-07T17:00:00+00:00 EmrCreateJobFlowOperator 2023-06-07T18:00:37.455477+00:00 2023-06-07T18:00:38.263083+00:00 0:00:00.807606 392640 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-07T18:00:35.217279+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-07T17:00:00+00:00 PythonOperator 2023-06-07T18:00:16.032276+00:00 2023-06-07T18:00:16.844477+00:00 0:00:00.812201 392639 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-07T18:00:13.200203+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-07T16:00:00+00:00 TriggerDagRunOperator 2023-06-07T17:11:20.364717+00:00 2023-06-07T17:11:20.713797+00:00 0:00:00.349080 392627 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T17:11:18.199352+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-07T16:00:00+00:00 TriggerDagRunOperator 2023-06-07T17:11:20.319082+00:00 2023-06-07T17:11:20.781984+00:00 0:00:00.462902 392626 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T17:11:18.199383+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-07T16:00:00+00:00 EmrJobFlowSensor 2023-06-07T17:01:05.831323+00:00 2023-06-07T17:11:07.693874+00:00 0:10:01.862551 392617 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-07T17:01:03.518738+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-07T16:00:00+00:00 EmrCreateJobFlowOperator 2023-06-07T17:00:43.796121+00:00 2023-06-07T17:00:44.573240+00:00 0:00:00.777119 392616 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-07T17:00:41.501699+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-07T16:00:00+00:00 PythonOperator 2023-06-07T17:00:23.485939+00:00 2023-06-07T17:00:24.437062+00:00 0:00:00.951123 392615 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-07T17:00:21.476279+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-07T15:00:00+00:00 TriggerDagRunOperator 2023-06-07T16:11:13.541178+00:00 2023-06-07T16:11:13.876757+00:00 0:00:00.335579 392604 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T16:11:10.990193+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-07T15:00:00+00:00 TriggerDagRunOperator 2023-06-07T16:11:13.401506+00:00 2023-06-07T16:11:13.849881+00:00 0:00:00.448375 392603 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T16:11:10.990163+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-07T15:00:00+00:00 EmrJobFlowSensor 2023-06-07T16:01:07.068409+00:00 2023-06-07T16:11:08.806420+00:00 0:10:01.738011 392598 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-07T16:01:04.606319+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-07T15:00:00+00:00 EmrCreateJobFlowOperator 2023-06-07T16:00:44.907682+00:00 2023-06-07T16:00:45.869316+00:00 0:00:00.961634 392595 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-07T16:00:42.606812+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-07T15:00:00+00:00 PythonOperator 2023-06-07T16:00:24.527422+00:00 2023-06-07T16:00:25.490536+00:00 0:00:00.963114 392593 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-07T16:00:22.535607+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-07T14:00:00+00:00 TriggerDagRunOperator 2023-06-07T15:30:36.766209+00:00 2023-06-07T15:30:37.132932+00:00 0:00:00.366723 392585 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T15:30:34.139771+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-07T14:00:00+00:00 TriggerDagRunOperator 2023-06-07T15:30:36.568565+00:00 2023-06-07T15:30:37.057279+00:00 0:00:00.488714 392584 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T15:30:34.139734+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-07T14:00:00+00:00 EmrJobFlowSensor 2023-06-07T15:12:31.455476+00:00 2023-06-07T15:22:33.262568+00:00 0:10:01.807092 392579 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-07T15:12:29.266297+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-07T14:00:00+00:00 EmrCreateJobFlowOperator 2023-06-07T15:12:09.507915+00:00 2023-06-07T15:12:10.424216+00:00 0:00:00.916301 392576 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-07T15:12:07.245135+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-07T14:00:00+00:00 PythonOperator 2023-06-07T15:11:50.094563+00:00 2023-06-07T15:11:51.319905+00:00 0:00:01.225342 392573 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-07T15:11:47.122003+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-07T13:00:00+00:00 TriggerDagRunOperator 2023-06-07T14:24:19.541904+00:00 2023-06-07T14:24:19.881776+00:00 0:00:00.339872 392563 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T14:24:16.810982+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-07T13:00:00+00:00 TriggerDagRunOperator 2023-06-07T14:24:19.361754+00:00 2023-06-07T14:24:19.798776+00:00 0:00:00.437022 392562 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T14:24:16.810947+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-07T13:00:00+00:00 EmrJobFlowSensor 2023-06-07T14:00:46.675892+00:00 2023-06-07T14:10:48.598059+00:00 0:10:01.922167 392558 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-07T14:00:44.294274+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-07T13:00:00+00:00 EmrCreateJobFlowOperator 2023-06-07T14:00:26.572333+00:00 2023-06-07T14:00:27.454149+00:00 0:00:00.881816 392556 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-07T14:00:24.205442+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-07T13:00:00+00:00 PythonOperator 2023-06-07T14:00:04.382923+00:00 2023-06-07T14:00:05.406774+00:00 0:00:01.023851 392553 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-07T14:00:02.143594+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-07T12:00:00+00:00 TriggerDagRunOperator 2023-06-07T13:11:19.691810+00:00 2023-06-07T13:11:20.037432+00:00 0:00:00.345622 392543 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T13:11:17.489349+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-07T12:00:00+00:00 TriggerDagRunOperator 2023-06-07T13:11:19.545680+00:00 2023-06-07T13:11:19.978899+00:00 0:00:00.433219 392542 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T13:11:17.489322+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-07T12:00:00+00:00 EmrJobFlowSensor 2023-06-07T13:01:03.950295+00:00 2023-06-07T13:11:05.919171+00:00 0:10:01.968876 392538 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-07T13:01:01.714034+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-07T12:00:00+00:00 EmrCreateJobFlowOperator 2023-06-07T13:00:42.071010+00:00 2023-06-07T13:00:43.050727+00:00 0:00:00.979717 392536 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-07T13:00:39.694288+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-07T12:00:00+00:00 PythonOperator 2023-06-07T13:00:17.838960+00:00 2023-06-07T13:00:18.815166+00:00 0:00:00.976206 392534 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-07T13:00:15.674152+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-07T11:00:00+00:00 TriggerDagRunOperator 2023-06-07T12:11:57.700979+00:00 2023-06-07T12:11:58.046316+00:00 0:00:00.345337 392524 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T12:11:55.373849+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-07T11:00:00+00:00 TriggerDagRunOperator 2023-06-07T12:11:57.609320+00:00 2023-06-07T12:11:58.065775+00:00 0:00:00.456455 392523 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T12:11:55.373819+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-07T11:00:00+00:00 EmrJobFlowSensor 2023-06-07T12:01:33.405559+00:00 2023-06-07T12:11:35.273984+00:00 0:10:01.868425 392517 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-07T12:01:31.182988+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-07T11:00:00+00:00 EmrCreateJobFlowOperator 2023-06-07T12:01:11.753621+00:00 2023-06-07T12:01:12.658914+00:00 0:00:00.905293 392515 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-07T12:01:09.160213+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-07T11:00:00+00:00 PythonOperator 2023-06-07T12:00:51.370482+00:00 2023-06-07T12:00:52.199493+00:00 0:00:00.829011 392513 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-07T12:00:49.144853+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-07T10:00:00+00:00 TriggerDagRunOperator 2023-06-07T11:10:59.772833+00:00 2023-06-07T11:11:00.165605+00:00 0:00:00.392772 392502 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T11:10:57.224244+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-07T10:00:00+00:00 TriggerDagRunOperator 2023-06-07T11:10:59.528601+00:00 2023-06-07T11:10:59.970783+00:00 0:00:00.442182 392501 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T11:10:57.224272+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-07T10:00:00+00:00 EmrJobFlowSensor 2023-06-07T11:00:51.158319+00:00 2023-06-07T11:10:52.897855+00:00 0:10:01.739536 392494 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-07T11:00:48.433908+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-07T10:00:00+00:00 EmrCreateJobFlowOperator 2023-06-07T11:00:26.808749+00:00 2023-06-07T11:00:27.780391+00:00 0:00:00.971642 392491 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-07T11:00:24.412196+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-07T10:00:00+00:00 PythonOperator 2023-06-07T11:00:04.878694+00:00 2023-06-07T11:00:05.742510+00:00 0:00:00.863816 392489 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-07T11:00:02.404581+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-07T09:00:00+00:00 TriggerDagRunOperator 2023-06-07T10:10:57.264311+00:00 2023-06-07T10:10:57.601863+00:00 0:00:00.337552 392479 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T10:10:55.004769+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-07T09:00:00+00:00 TriggerDagRunOperator 2023-06-07T10:10:57.104512+00:00 2023-06-07T10:10:57.544638+00:00 0:00:00.440126 392478 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T10:10:55.004739+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-07T09:00:00+00:00 EmrJobFlowSensor 2023-06-07T10:00:46.174396+00:00 2023-06-07T10:10:48.082825+00:00 0:10:01.908429 392471 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-07T10:00:44.023655+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-07T09:00:00+00:00 EmrCreateJobFlowOperator 2023-06-07T10:00:26.172845+00:00 2023-06-07T10:00:27.067807+00:00 0:00:00.894962 392469 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-07T10:00:24.005861+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-07T09:00:00+00:00 PythonOperator 2023-06-07T10:00:04.480856+00:00 2023-06-07T10:00:05.304918+00:00 0:00:00.824062 392467 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-07T10:00:01.983159+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-07T08:00:00+00:00 TriggerDagRunOperator 2023-06-07T09:11:26.817885+00:00 2023-06-07T09:11:27.156842+00:00 0:00:00.338957 392457 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T09:11:24.522053+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-07T08:00:00+00:00 TriggerDagRunOperator 2023-06-07T09:11:26.475043+00:00 2023-06-07T09:11:26.943893+00:00 0:00:00.468850 392456 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T09:11:24.522084+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-07T08:00:00+00:00 EmrJobFlowSensor 2023-06-07T09:01:06.486264+00:00 2023-06-07T09:11:08.297594+00:00 0:10:01.811330 392450 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-07T09:01:04.271849+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-07T08:00:00+00:00 EmrCreateJobFlowOperator 2023-06-07T09:00:46.477576+00:00 2023-06-07T09:00:47.320258+00:00 0:00:00.842682 392448 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-07T09:00:44.250237+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-07T08:00:00+00:00 PythonOperator 2023-06-07T09:00:24.424592+00:00 2023-06-07T09:00:25.399675+00:00 0:00:00.975083 392446 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-07T09:00:22.296865+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-07T07:00:00+00:00 TriggerDagRunOperator 2023-06-07T08:11:03.629401+00:00 2023-06-07T08:11:03.972377+00:00 0:00:00.342976 392434 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T08:11:01.351814+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-07T07:00:00+00:00 TriggerDagRunOperator 2023-06-07T08:11:03.454209+00:00 2023-06-07T08:11:03.909376+00:00 0:00:00.455167 392433 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T08:11:01.351784+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-07T07:00:00+00:00 EmrJobFlowSensor 2023-06-07T08:00:55.863656+00:00 2023-06-07T08:10:57.681218+00:00 0:10:01.817562 392426 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-07T08:00:53.779141+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-07T07:00:00+00:00 EmrCreateJobFlowOperator 2023-06-07T08:00:33.859835+00:00 2023-06-07T08:00:34.837076+00:00 0:00:00.977241 392424 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-07T08:00:31.758005+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-07T07:00:00+00:00 PythonOperator 2023-06-07T08:00:13.195656+00:00 2023-06-07T08:00:14.716248+00:00 0:00:01.520592 392422 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-07T08:00:09.784322+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-07T06:00:00+00:00 TriggerDagRunOperator 2023-06-07T07:16:47.544946+00:00 2023-06-07T07:16:47.879243+00:00 0:00:00.334297 392414 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T07:16:45.136353+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-07T06:00:00+00:00 TriggerDagRunOperator 2023-06-07T07:16:47.340467+00:00 2023-06-07T07:16:47.783333+00:00 0:00:00.442866 392413 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-07T07:16:45.136318+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-07T06:00:00+00:00 EmrJobFlowSensor 2023-06-07T07:01:01.666831+00:00 2023-06-07T07:11:03.596533+00:00 0:10:01.929702 392406 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-07T07:00:59.474293+00:00 2 default_pool