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_emr_steps 2023-03-27T08:00:00+00:00 PythonOperator 2023-03-27T09:26:57.225276+00:00 2023-03-27T09:27:03.663542+00:00 0:00:06.438266 359869 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-27T09:26:52.707094+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-27T07:00:00+00:00 EmrJobFlowSensor 2023-03-27T08:45:30.250020+00:00 2023-03-27T08:55:32.009113+00:00 0:10:01.759093 359864 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-27T08:45:27.730346+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-27T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-27T08:45:09.913822+00:00 2023-03-27T08:45:10.753369+00:00 0:00:00.839547 359861 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-27T08:45:07.707405+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-27T07:00:00+00:00 PythonOperator 2023-03-27T08:44:47.998530+00:00 2023-03-27T08:44:51.805817+00:00 0:00:03.807287 359858 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-27T08:44:45.670164+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-27T06:00:00+00:00 TriggerDagRunOperator 2023-03-27T07:23:28.650498+00:00 2023-03-27T07:23:29.129913+00:00 0:00:00.479415 359847 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T07:23:26.188342+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-27T06:00:00+00:00 TriggerDagRunOperator 2023-03-27T07:23:28.540394+00:00 2023-03-27T07:23:29.012149+00:00 0:00:00.471755 359846 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T07:23:26.188370+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-27T06:00:00+00:00 EmrJobFlowSensor 2023-03-27T07:13:10.184879+00:00 2023-03-27T07:23:12.018415+00:00 0:10:01.833536 359841 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-27T07:13:07.928928+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-27T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-27T07:12:48.251494+00:00 2023-03-27T07:12:49.375935+00:00 0:00:01.124441 359838 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-27T07:12:45.897153+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-27T06:00:00+00:00 PythonOperator 2023-03-27T07:12:28.513544+00:00 2023-03-27T07:12:32.572405+00:00 0:00:04.058861 359835 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-27T07:12:25.950672+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-27T05:00:00+00:00 TriggerDagRunOperator 2023-03-27T06:23:45.440842+00:00 2023-03-27T06:23:45.922980+00:00 0:00:00.482138 359824 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T06:23:42.787488+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-27T05:00:00+00:00 TriggerDagRunOperator 2023-03-27T06:23:44.981541+00:00 2023-03-27T06:23:45.542140+00:00 0:00:00.560599 359823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T06:23:42.787516+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-27T05:00:00+00:00 EmrJobFlowSensor 2023-03-27T06:00:54.340724+00:00 2023-03-27T06:10:56.038988+00:00 0:10:01.698264 359818 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-27T06:00:52.202631+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-27T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-27T06:00:34.829159+00:00 2023-03-27T06:00:36.116447+00:00 0:00:01.287288 359816 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-27T06:00:32.187271+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-27T05:00:00+00:00 PythonOperator 2023-03-27T06:00:13.330069+00:00 2023-03-27T06:00:18.707425+00:00 0:00:05.377356 359814 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-27T06:00:10.149031+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-27T04:00:00+00:00 TriggerDagRunOperator 2023-03-27T05:17:59.534515+00:00 2023-03-27T05:18:00.165479+00:00 0:00:00.630964 359808 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T05:17:57.081078+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-27T04:00:00+00:00 TriggerDagRunOperator 2023-03-27T05:17:59.488913+00:00 2023-03-27T05:17:59.985946+00:00 0:00:00.497033 359807 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T05:17:57.081106+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-27T04:00:00+00:00 EmrJobFlowSensor 2023-03-27T05:07:51.103138+00:00 2023-03-27T05:17:53.052864+00:00 0:10:01.949726 359803 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-27T05:07:48.727137+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-27T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-27T05:07:30.868856+00:00 2023-03-27T05:07:31.814513+00:00 0:00:00.945657 359800 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-27T05:07:28.661743+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-27T04:00:00+00:00 PythonOperator 2023-03-27T05:07:08.860831+00:00 2023-03-27T05:07:13.039506+00:00 0:00:04.178675 359797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-27T05:07:06.641933+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-27T03:00:00+00:00 TriggerDagRunOperator 2023-03-27T04:32:59.085529+00:00 2023-03-27T04:32:59.616468+00:00 0:00:00.530939 359789 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T04:32:56.025258+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-27T03:00:00+00:00 TriggerDagRunOperator 2023-03-27T04:32:58.834491+00:00 2023-03-27T04:32:59.304628+00:00 0:00:00.470137 359788 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T04:32:56.025297+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-27T03:00:00+00:00 EmrJobFlowSensor 2023-03-27T04:02:09.890162+00:00 2023-03-27T04:12:11.751439+00:00 0:10:01.861277 359781 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-27T04:02:07.579155+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-27T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-27T04:01:49.742922+00:00 2023-03-27T04:01:50.794114+00:00 0:00:01.051192 359779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-27T04:01:47.563242+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-27T03:00:00+00:00 PythonOperator 2023-03-27T04:01:28.383039+00:00 2023-03-27T04:01:32.459623+00:00 0:00:04.076584 359777 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-27T04:01:25.447041+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-27T02:00:00+00:00 TriggerDagRunOperator 2023-03-27T03:11:18.110762+00:00 2023-03-27T03:11:18.656792+00:00 0:00:00.546030 359765 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T03:11:12.405488+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-27T02:00:00+00:00 TriggerDagRunOperator 2023-03-27T03:11:14.618581+00:00 2023-03-27T03:11:15.111811+00:00 0:00:00.493230 359764 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T03:11:12.405516+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-27T02:00:00+00:00 EmrJobFlowSensor 2023-03-27T03:01:05.683729+00:00 2023-03-27T03:11:07.564672+00:00 0:10:01.880943 359760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-27T03:01:03.530562+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-27T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-27T03:00:43.819538+00:00 2023-03-27T03:00:44.681181+00:00 0:00:00.861643 359758 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-27T03:00:41.493264+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-27T02:00:00+00:00 PythonOperator 2023-03-27T03:00:23.762669+00:00 2023-03-27T03:00:27.111434+00:00 0:00:03.348765 359756 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-27T03:00:21.458638+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-27T01:00:00+00:00 TriggerDagRunOperator 2023-03-27T02:19:26.377277+00:00 2023-03-27T02:19:26.818636+00:00 0:00:00.441359 359747 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T02:19:23.748289+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-27T01:00:00+00:00 TriggerDagRunOperator 2023-03-27T02:19:26.248472+00:00 2023-03-27T02:19:26.732171+00:00 0:00:00.483699 359746 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T02:19:23.748261+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-27T01:00:00+00:00 EmrJobFlowSensor 2023-03-27T02:10:15.137199+00:00 2023-03-27T02:19:17.154999+00:00 0:09:02.017800 359741 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-27T02:10:12.725021+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-27T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-27T02:09:55.511780+00:00 2023-03-27T02:09:56.639357+00:00 0:00:01.127577 359738 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-27T02:09:52.690809+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-27T01:00:00+00:00 PythonOperator 2023-03-27T02:09:33.121911+00:00 2023-03-27T02:09:39.425347+00:00 0:00:06.303436 359735 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-27T02:09:30.671110+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-27T00:00:00+00:00 TriggerDagRunOperator 2023-03-27T01:12:19.331562+00:00 2023-03-27T01:12:19.798071+00:00 0:00:00.466509 359720 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T01:12:16.692660+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-27T00:00:00+00:00 TriggerDagRunOperator 2023-03-27T01:12:19.335017+00:00 2023-03-27T01:12:19.853923+00:00 0:00:00.518906 359719 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T01:12:16.692630+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-27T00:00:00+00:00 EmrJobFlowSensor 2023-03-27T01:01:56.301259+00:00 2023-03-27T01:11:58.066017+00:00 0:10:01.764758 359712 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-27T01:01:53.576413+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-27T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-27T01:01:35.726918+00:00 2023-03-27T01:01:36.645173+00:00 0:00:00.918255 359710 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-27T01:01:33.556150+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-27T00:00:00+00:00 PythonOperator 2023-03-27T01:01:14.248222+00:00 2023-03-27T01:01:17.542758+00:00 0:00:03.294536 359708 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-27T01:01:11.534611+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-26T23:00:00+00:00 TriggerDagRunOperator 2023-03-27T00:46:35.796325+00:00 2023-03-27T00:46:36.362439+00:00 0:00:00.566114 359702 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T00:46:32.869503+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-26T23:00:00+00:00 TriggerDagRunOperator 2023-03-27T00:46:35.524725+00:00 2023-03-27T00:46:36.086104+00:00 0:00:00.561379 359701 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-27T00:46:32.869539+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-26T23:00:00+00:00 EmrJobFlowSensor 2023-03-27T00:07:36.283477+00:00 2023-03-27T00:17:38.006382+00:00 0:10:01.722905 359698 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-27T00:07:33.861838+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-26T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-27T00:07:15.628348+00:00 2023-03-27T00:07:16.971374+00:00 0:00:01.343026 359694 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-27T00:07:11.839524+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-26T23:00:00+00:00 PythonOperator 2023-03-27T00:06:54.350551+00:00 2023-03-27T00:06:57.759657+00:00 0:00:03.409106 359691 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-27T00:06:51.781062+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-26T22:00:00+00:00 TriggerDagRunOperator 2023-03-26T23:16:39.967493+00:00 2023-03-26T23:16:40.475132+00:00 0:00:00.507639 359678 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T23:16:36.973390+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-26T22:00:00+00:00 TriggerDagRunOperator 2023-03-26T23:16:39.697280+00:00 2023-03-26T23:16:40.191481+00:00 0:00:00.494201 359677 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T23:16:36.973360+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-26T22:00:00+00:00 EmrJobFlowSensor 2023-03-26T23:00:58.632122+00:00 2023-03-26T23:11:00.511381+00:00 0:10:01.879259 359673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-26T23:00:56.439646+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-26T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-26T23:00:36.641258+00:00 2023-03-26T23:00:37.509424+00:00 0:00:00.868166 359670 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-26T23:00:34.412195+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-26T22:00:00+00:00 PythonOperator 2023-03-26T23:00:14.634384+00:00 2023-03-26T23:00:21.650281+00:00 0:00:07.015897 359667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-26T23:00:12.404061+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-26T21:00:00+00:00 TriggerDagRunOperator 2023-03-26T22:10:57.066054+00:00 2023-03-26T22:10:57.563437+00:00 0:00:00.497383 359655 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T22:10:54.612111+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-26T21:00:00+00:00 TriggerDagRunOperator 2023-03-26T22:10:56.916114+00:00 2023-03-26T22:10:57.371615+00:00 0:00:00.455501 359654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T22:10:54.612067+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-26T21:00:00+00:00 EmrJobFlowSensor 2023-03-26T22:00:48.951900+00:00 2023-03-26T22:10:50.846676+00:00 0:10:01.894776 359647 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-26T22:00:46.393393+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-26T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-26T22:00:26.929593+00:00 2023-03-26T22:00:27.721072+00:00 0:00:00.791479 359645 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-26T22:00:24.323147+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-26T21:00:00+00:00 PythonOperator 2023-03-26T22:00:04.773683+00:00 2023-03-26T22:00:07.889773+00:00 0:00:03.116090 359643 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-26T22:00:02.296637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-26T20:00:00+00:00 TriggerDagRunOperator 2023-03-26T21:11:30.274497+00:00 2023-03-26T21:11:30.765316+00:00 0:00:00.490819 359633 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T21:11:27.318153+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-26T20:00:00+00:00 TriggerDagRunOperator 2023-03-26T21:11:29.994535+00:00 2023-03-26T21:11:30.544085+00:00 0:00:00.549550 359632 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T21:11:27.318124+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-26T20:00:00+00:00 EmrJobFlowSensor 2023-03-26T21:01:06.746814+00:00 2023-03-26T21:11:08.674256+00:00 0:10:01.927442 359625 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-26T21:01:04.093591+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-26T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-26T21:00:46.507726+00:00 2023-03-26T21:00:47.362840+00:00 0:00:00.855114 359623 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-26T21:00:44.021022+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-26T20:00:00+00:00 PythonOperator 2023-03-26T21:00:25.251604+00:00 2023-03-26T21:00:29.472272+00:00 0:00:04.220668 359621 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-26T21:00:22.012498+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-26T19:00:00+00:00 TriggerDagRunOperator 2023-03-26T20:11:07.057194+00:00 2023-03-26T20:11:07.550847+00:00 0:00:00.493653 359610 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T20:11:04.781862+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-26T19:00:00+00:00 TriggerDagRunOperator 2023-03-26T20:11:07.038855+00:00 2023-03-26T20:11:07.566681+00:00 0:00:00.527826 359609 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T20:11:04.781830+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-26T19:00:00+00:00 EmrJobFlowSensor 2023-03-26T20:00:59.366345+00:00 2023-03-26T20:11:01.240313+00:00 0:10:01.873968 359603 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-26T20:00:57.060145+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-26T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-26T20:00:37.243934+00:00 2023-03-26T20:00:38.086442+00:00 0:00:00.842508 359601 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-26T20:00:35.040957+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-26T19:00:00+00:00 PythonOperator 2023-03-26T20:00:15.244898+00:00 2023-03-26T20:00:18.686611+00:00 0:00:03.441713 359599 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-26T20:00:12.951981+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-26T18:00:00+00:00 TriggerDagRunOperator 2023-03-26T19:11:10.972304+00:00 2023-03-26T19:11:11.578053+00:00 0:00:00.605749 359588 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T19:11:08.450148+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-26T18:00:00+00:00 TriggerDagRunOperator 2023-03-26T19:11:10.920361+00:00 2023-03-26T19:11:11.398791+00:00 0:00:00.478430 359587 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T19:11:08.450180+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-26T18:00:00+00:00 EmrJobFlowSensor 2023-03-26T19:00:57.946423+00:00 2023-03-26T19:10:59.652118+00:00 0:10:01.705695 359581 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-26T19:00:55.349338+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-26T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-26T19:00:35.704993+00:00 2023-03-26T19:00:36.679199+00:00 0:00:00.974206 359579 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-26T19:00:33.322474+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-26T18:00:00+00:00 PythonOperator 2023-03-26T19:00:15.673031+00:00 2023-03-26T19:00:19.758954+00:00 0:00:04.085923 359577 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-26T19:00:13.303668+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-26T17:00:00+00:00 TriggerDagRunOperator 2023-03-26T18:38:36.291611+00:00 2023-03-26T18:38:36.749705+00:00 0:00:00.458094 359569 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T18:38:33.288239+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-26T17:00:00+00:00 TriggerDagRunOperator 2023-03-26T18:38:36.014818+00:00 2023-03-26T18:38:36.695757+00:00 0:00:00.680939 359568 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T18:38:33.288267+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-26T17:00:00+00:00 EmrJobFlowSensor 2023-03-26T18:14:15.953974+00:00 2023-03-26T18:24:17.691389+00:00 0:10:01.737415 359564 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-26T18:14:13.781633+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-26T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-26T18:13:56.350976+00:00 2023-03-26T18:13:57.274083+00:00 0:00:00.923107 359562 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-26T18:13:53.763418+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-26T17:00:00+00:00 PythonOperator 2023-03-26T18:13:34.101156+00:00 2023-03-26T18:13:37.242206+00:00 0:00:03.141050 359559 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-26T18:13:31.741834+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-26T16:00:00+00:00 TriggerDagRunOperator 2023-03-26T17:11:05.315977+00:00 2023-03-26T17:11:05.783801+00:00 0:00:00.467824 359547 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T17:11:02.866636+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-26T16:00:00+00:00 TriggerDagRunOperator 2023-03-26T17:11:05.261422+00:00 2023-03-26T17:11:05.701260+00:00 0:00:00.439838 359546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T17:11:02.866602+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-26T16:00:00+00:00 EmrJobFlowSensor 2023-03-26T17:00:57.854602+00:00 2023-03-26T17:10:59.758356+00:00 0:10:01.903754 359538 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-26T17:00:55.534480+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-26T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-26T17:00:37.936856+00:00 2023-03-26T17:00:39.125927+00:00 0:00:01.189071 359536 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-26T17:00:35.504821+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-26T16:00:00+00:00 PythonOperator 2023-03-26T17:00:16.120173+00:00 2023-03-26T17:00:20.088774+00:00 0:00:03.968601 359534 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-26T17:00:13.462926+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-26T15:00:00+00:00 TriggerDagRunOperator 2023-03-26T16:11:23.884777+00:00 2023-03-26T16:11:24.359892+00:00 0:00:00.475115 359526 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T16:11:20.903118+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-26T15:00:00+00:00 TriggerDagRunOperator 2023-03-26T16:11:23.686239+00:00 2023-03-26T16:11:24.160135+00:00 0:00:00.473896 359525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T16:11:20.903158+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-26T15:00:00+00:00 EmrJobFlowSensor 2023-03-26T16:01:08.294844+00:00 2023-03-26T16:11:10.142986+00:00 0:10:01.848142 359518 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-26T16:01:05.984095+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-26T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-26T16:00:46.357829+00:00 2023-03-26T16:00:47.176841+00:00 0:00:00.819012 359516 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-26T16:00:43.953879+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-26T15:00:00+00:00 PythonOperator 2023-03-26T16:00:24.722473+00:00 2023-03-26T16:00:30.389868+00:00 0:00:05.667395 359514 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-26T16:00:21.932733+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-26T14:00:00+00:00 TriggerDagRunOperator 2023-03-26T15:17:46.681603+00:00 2023-03-26T15:17:47.140259+00:00 0:00:00.458656 359504 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T15:17:43.633787+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-26T14:00:00+00:00 TriggerDagRunOperator 2023-03-26T15:17:46.541700+00:00 2023-03-26T15:17:47.051052+00:00 0:00:00.509352 359503 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T15:17:43.633827+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-26T14:00:00+00:00 EmrJobFlowSensor 2023-03-26T15:00:54.158970+00:00 2023-03-26T15:10:55.968068+00:00 0:10:01.809098 359495 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-26T15:00:52.010252+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-26T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-26T15:00:34.299456+00:00 2023-03-26T15:00:35.187522+00:00 0:00:00.888066 359493 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-26T15:00:31.992747+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-26T14:00:00+00:00 PythonOperator 2023-03-26T15:00:12.387719+00:00 2023-03-26T15:00:18.165537+00:00 0:00:05.777818 359491 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-26T15:00:09.997439+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-26T13:00:00+00:00 TriggerDagRunOperator 2023-03-26T14:15:51.510723+00:00 2023-03-26T14:15:51.976518+00:00 0:00:00.465795 359482 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T14:15:48.082480+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-26T13:00:00+00:00 TriggerDagRunOperator 2023-03-26T14:15:50.479263+00:00 2023-03-26T14:15:50.992186+00:00 0:00:00.512923 359481 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T14:15:48.082452+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-26T13:00:00+00:00 EmrJobFlowSensor 2023-03-26T14:05:24.557691+00:00 2023-03-26T14:15:26.255813+00:00 0:10:01.698122 359475 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-26T14:05:22.305348+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-26T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-26T14:05:04.512369+00:00 2023-03-26T14:05:05.392351+00:00 0:00:00.879982 359472 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-26T14:05:02.255426+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-26T13:00:00+00:00 PythonOperator 2023-03-26T14:04:43.020533+00:00 2023-03-26T14:04:49.110154+00:00 0:00:06.089621 359470 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-26T14:04:40.282333+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-26T12:00:00+00:00 TriggerDagRunOperator 2023-03-26T13:40:03.386001+00:00 2023-03-26T13:40:03.921361+00:00 0:00:00.535360 359465 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T13:40:00.412318+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-26T12:00:00+00:00 TriggerDagRunOperator 2023-03-26T13:40:03.044877+00:00 2023-03-26T13:40:03.556907+00:00 0:00:00.512030 359464 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T13:40:00.412288+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-26T12:00:00+00:00 EmrJobFlowSensor 2023-03-26T13:29:55.425233+00:00 2023-03-26T13:39:57.375934+00:00 0:10:01.950701 359459 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-26T13:29:53.192138+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-26T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-26T13:29:33.501257+00:00 2023-03-26T13:29:34.430201+00:00 0:00:00.928944 359456 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-26T13:29:31.170749+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-26T12:00:00+00:00 PythonOperator 2023-03-26T13:29:13.509238+00:00 2023-03-26T13:29:17.840022+00:00 0:00:04.330784 359453 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-26T13:29:11.154526+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-26T11:00:00+00:00 TriggerDagRunOperator 2023-03-26T12:16:28.917677+00:00 2023-03-26T12:16:29.637837+00:00 0:00:00.720160 359443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T12:16:24.554217+00:00 2 default_pool