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 check_cluster_status 2023-03-02T05:00:00+00:00 EmrJobFlowSensor 2023-03-02T06:01:03.526632+00:00 2023-03-02T06:11:05.375986+00:00 0:10:01.849354 347269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-02T06:01:00.949672+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-02T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-02T06:00:41.179809+00:00 2023-03-02T06:00:41.999125+00:00 0:00:00.819316 347267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-02T06:00:38.904443+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-02T05:00:00+00:00 PythonOperator 2023-03-02T06:00:19.644305+00:00 2023-03-02T06:00:22.940742+00:00 0:00:03.296437 347265 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-02T06:00:16.883906+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-02T04:00:00+00:00 TriggerDagRunOperator 2023-03-02T05:18:59.165834+00:00 2023-03-02T05:18:59.632797+00:00 0:00:00.466963 347258 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T05:18:56.384660+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-02T04:00:00+00:00 TriggerDagRunOperator 2023-03-02T05:18:59.044416+00:00 2023-03-02T05:18:59.499106+00:00 0:00:00.454690 347257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T05:18:56.384688+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-02T04:00:00+00:00 EmrJobFlowSensor 2023-03-02T05:00:55.403577+00:00 2023-03-02T05:10:57.196921+00:00 0:10:01.793344 347250 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-02T05:00:53.148028+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-02T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-02T05:00:33.341146+00:00 2023-03-02T05:00:34.215602+00:00 0:00:00.874456 347248 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-02T05:00:31.129690+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-02T04:00:00+00:00 PythonOperator 2023-03-02T05:00:11.406295+00:00 2023-03-02T05:00:15.248397+00:00 0:00:03.842102 347246 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-02T05:00:09.065872+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-02T03:00:00+00:00 TriggerDagRunOperator 2023-03-02T04:10:21.815280+00:00 2023-03-02T04:10:22.319026+00:00 0:00:00.503746 347238 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T04:10:19.556686+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-02T03:00:00+00:00 TriggerDagRunOperator 2023-03-02T04:10:21.781758+00:00 2023-03-02T04:10:22.243364+00:00 0:00:00.461606 347237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T04:10:19.556714+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-02T03:00:00+00:00 EmrJobFlowSensor 2023-03-02T04:01:02.386787+00:00 2023-03-02T04:10:04.367229+00:00 0:09:01.980442 347231 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-02T04:01:00.168230+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-02T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-02T04:00:40.425785+00:00 2023-03-02T04:00:41.280915+00:00 0:00:00.855130 347229 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-02T04:00:38.124998+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-02T03:00:00+00:00 PythonOperator 2023-03-02T04:00:18.370161+00:00 2023-03-02T04:00:22.288013+00:00 0:00:03.917852 347227 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-02T04:00:16.059592+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-02T02:00:00+00:00 TriggerDagRunOperator 2023-03-02T03:16:43.168386+00:00 2023-03-02T03:16:43.657213+00:00 0:00:00.488827 347218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T03:16:40.693380+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-02T02:00:00+00:00 TriggerDagRunOperator 2023-03-02T03:16:43.143618+00:00 2023-03-02T03:16:43.661958+00:00 0:00:00.518340 347217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T03:16:40.693410+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-02T02:00:00+00:00 EmrJobFlowSensor 2023-03-02T03:06:31.163636+00:00 2023-03-02T03:16:32.867312+00:00 0:10:01.703676 347214 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-02T03:06:28.722685+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-02T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-02T03:06:08.997445+00:00 2023-03-02T03:06:09.842528+00:00 0:00:00.845083 347211 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-02T03:06:06.639705+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-02T02:00:00+00:00 PythonOperator 2023-03-02T03:05:46.924135+00:00 2023-03-02T03:05:49.863020+00:00 0:00:02.938885 347207 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-02T03:05:44.644944+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-02T01:00:00+00:00 TriggerDagRunOperator 2023-03-02T02:47:58.715937+00:00 2023-03-02T02:47:59.198741+00:00 0:00:00.482804 347201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T02:47:56.172536+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-02T01:00:00+00:00 TriggerDagRunOperator 2023-03-02T02:47:58.693322+00:00 2023-03-02T02:47:59.209503+00:00 0:00:00.516181 347200 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T02:47:56.172565+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-02T01:00:00+00:00 EmrJobFlowSensor 2023-03-02T02:37:49.395648+00:00 2023-03-02T02:47:51.103499+00:00 0:10:01.707851 347195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-02T02:37:47.208835+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-02T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-02T02:37:27.436485+00:00 2023-03-02T02:37:28.284528+00:00 0:00:00.848043 347192 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-02T02:37:25.184636+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-02T01:00:00+00:00 PythonOperator 2023-03-02T02:37:08.149779+00:00 2023-03-02T02:37:15.697430+00:00 0:00:07.547651 347189 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-02T02:37:05.178291+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-02T00:00:00+00:00 TriggerDagRunOperator 2023-03-02T01:14:49.324077+00:00 2023-03-02T01:14:49.821788+00:00 0:00:00.497711 347175 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T01:14:46.942509+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-02T00:00:00+00:00 TriggerDagRunOperator 2023-03-02T01:14:49.327194+00:00 2023-03-02T01:14:49.791987+00:00 0:00:00.464793 347174 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T01:14:46.942478+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-02T00:00:00+00:00 EmrJobFlowSensor 2023-03-02T01:00:55.507197+00:00 2023-03-02T01:10:57.237884+00:00 0:10:01.730687 347167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-02T01:00:53.141516+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-02T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-02T01:00:38.883445+00:00 2023-03-02T01:00:39.755051+00:00 0:00:00.871606 347165 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-02T01:00:33.093048+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-02T00:00:00+00:00 PythonOperator 2023-03-02T01:00:13.412754+00:00 2023-03-02T01:00:17.313153+00:00 0:00:03.900399 347163 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-02T01:00:11.090803+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-01T23:00:00+00:00 TriggerDagRunOperator 2023-03-02T00:11:16.113031+00:00 2023-03-02T00:11:16.612900+00:00 0:00:00.499869 347156 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T00:11:13.635647+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-01T23:00:00+00:00 TriggerDagRunOperator 2023-03-02T00:11:15.957966+00:00 2023-03-02T00:11:16.442380+00:00 0:00:00.484414 347155 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T00:11:13.635682+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-01T23:00:00+00:00 EmrJobFlowSensor 2023-03-02T00:00:53.511142+00:00 2023-03-02T00:10:55.361141+00:00 0:10:01.849999 347148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-02T00:00:51.082208+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-01T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-02T00:00:31.412875+00:00 2023-03-02T00:00:32.296953+00:00 0:00:00.884078 347146 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-02T00:00:29.051220+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-01T23:00:00+00:00 PythonOperator 2023-03-02T00:00:10.088745+00:00 2023-03-02T00:00:13.651236+00:00 0:00:03.562491 347144 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-02T00:00:07.015191+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-01T22:00:00+00:00 TriggerDagRunOperator 2023-03-01T23:25:08.793497+00:00 2023-03-01T23:25:09.293350+00:00 0:00:00.499853 347137 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T23:25:05.988819+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-01T22:00:00+00:00 TriggerDagRunOperator 2023-03-01T23:25:08.508010+00:00 2023-03-01T23:25:09.020084+00:00 0:00:00.512074 347136 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T23:25:05.988851+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-01T22:00:00+00:00 EmrJobFlowSensor 2023-03-01T23:11:13.145595+00:00 2023-03-01T23:21:15.057359+00:00 0:10:01.911764 347130 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-01T23:11:10.652018+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-01T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-01T23:10:52.063271+00:00 2023-03-01T23:10:52.893852+00:00 0:00:00.830581 347126 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-01T23:10:48.629959+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-01T22:00:00+00:00 PythonOperator 2023-03-01T23:10:31.609480+00:00 2023-03-01T23:10:35.399513+00:00 0:00:03.790033 347122 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-01T23:10:28.617225+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-01T21:00:00+00:00 TriggerDagRunOperator 2023-03-01T22:16:55.421200+00:00 2023-03-01T22:16:56.279023+00:00 0:00:00.857823 347111 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T22:16:52.462052+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-01T21:00:00+00:00 TriggerDagRunOperator 2023-03-01T22:16:55.093305+00:00 2023-03-01T22:16:55.651667+00:00 0:00:00.558362 347110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T22:16:52.462080+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-01T21:00:00+00:00 EmrJobFlowSensor 2023-03-01T22:00:57.853363+00:00 2023-03-01T22:10:59.687299+00:00 0:10:01.833936 347106 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-01T22:00:55.596421+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-01T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-01T22:00:36.124884+00:00 2023-03-01T22:00:37.041911+00:00 0:00:00.917027 347104 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-01T22:00:33.542875+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-01T21:00:00+00:00 PythonOperator 2023-03-01T22:00:13.839698+00:00 2023-03-01T22:00:17.878254+00:00 0:00:04.038556 347102 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-01T22:00:11.520359+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-01T20:00:00+00:00 TriggerDagRunOperator 2023-03-01T21:17:07.644375+00:00 2023-03-01T21:17:08.246932+00:00 0:00:00.602557 347095 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T21:17:04.700744+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-01T20:00:00+00:00 TriggerDagRunOperator 2023-03-01T21:17:07.530492+00:00 2023-03-01T21:17:08.090806+00:00 0:00:00.560314 347094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T21:17:04.700706+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-01T20:00:00+00:00 EmrJobFlowSensor 2023-03-01T21:05:24.560027+00:00 2023-03-01T21:15:26.383453+00:00 0:10:01.823426 347089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-01T21:05:22.332668+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-01T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-01T21:05:02.495852+00:00 2023-03-01T21:05:03.469226+00:00 0:00:00.973374 347086 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-01T21:05:00.264638+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-01T20:00:00+00:00 PythonOperator 2023-03-01T21:04:42.428269+00:00 2023-03-01T21:04:45.664206+00:00 0:00:03.235937 347084 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-01T21:04:40.246626+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-01T19:00:00+00:00 TriggerDagRunOperator 2023-03-01T20:24:07.422362+00:00 2023-03-01T20:24:07.945511+00:00 0:00:00.523149 347074 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T20:24:04.843476+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-01T19:00:00+00:00 TriggerDagRunOperator 2023-03-01T20:24:07.393658+00:00 2023-03-01T20:24:07.904718+00:00 0:00:00.511060 347073 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T20:24:04.843447+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-01T19:00:00+00:00 EmrJobFlowSensor 2023-03-01T20:13:59.074090+00:00 2023-03-01T20:24:00.885609+00:00 0:10:01.811519 347070 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-01T20:13:56.872104+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-01T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-01T20:13:37.168385+00:00 2023-03-01T20:13:38.042475+00:00 0:00:00.874090 347067 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-01T20:13:34.856516+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-01T19:00:00+00:00 PythonOperator 2023-03-01T20:13:17.359619+00:00 2023-03-01T20:13:20.405295+00:00 0:00:03.045676 347064 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-01T20:13:14.793539+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-01T18:00:00+00:00 TriggerDagRunOperator 2023-03-01T19:21:22.822301+00:00 2023-03-01T19:21:23.381006+00:00 0:00:00.558705 347053 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T19:21:20.223836+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-01T18:00:00+00:00 TriggerDagRunOperator 2023-03-01T19:21:22.807235+00:00 2023-03-01T19:21:23.368580+00:00 0:00:00.561345 347052 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T19:21:20.223876+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-01T18:00:00+00:00 EmrJobFlowSensor 2023-03-01T19:11:11.797047+00:00 2023-03-01T19:21:13.653879+00:00 0:10:01.856832 347048 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-01T19:11:09.398916+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-01T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-01T19:10:49.693540+00:00 2023-03-01T19:10:50.897567+00:00 0:00:01.204027 347044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-01T19:10:47.378171+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-01T18:00:00+00:00 PythonOperator 2023-03-01T19:10:30.356479+00:00 2023-03-01T19:10:34.535290+00:00 0:00:04.178811 347041 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-01T19:10:27.315440+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-01T17:00:00+00:00 TriggerDagRunOperator 2023-03-01T18:10:17.766477+00:00 2023-03-01T18:10:18.253341+00:00 0:00:00.486864 347031 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T18:10:14.971023+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-01T17:00:00+00:00 TriggerDagRunOperator 2023-03-01T18:10:17.263383+00:00 2023-03-01T18:10:17.766647+00:00 0:00:00.503264 347030 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T18:10:14.971055+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-01T17:00:00+00:00 EmrJobFlowSensor 2023-03-01T18:00:51.410585+00:00 2023-03-01T18:09:53.008496+00:00 0:09:01.597911 347024 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-01T18:00:48.941751+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-01T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-01T18:00:29.497278+00:00 2023-03-01T18:00:31.075312+00:00 0:00:01.578034 347022 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-01T18:00:26.804665+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-01T17:00:00+00:00 PythonOperator 2023-03-01T18:00:09.816232+00:00 2023-03-01T18:00:13.910283+00:00 0:00:04.094051 347021 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-01T18:00:06.693466+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-01T16:00:00+00:00 TriggerDagRunOperator 2023-03-01T17:35:47.442588+00:00 2023-03-01T17:35:47.978252+00:00 0:00:00.535664 347014 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T17:35:44.665737+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-01T16:00:00+00:00 TriggerDagRunOperator 2023-03-01T17:35:47.343762+00:00 2023-03-01T17:35:47.840958+00:00 0:00:00.497196 347013 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T17:35:44.665707+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-01T16:00:00+00:00 EmrJobFlowSensor 2023-03-01T17:00:59.313116+00:00 2023-03-01T17:11:01.072869+00:00 0:10:01.759753 347005 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-01T17:00:56.785274+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-01T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-01T17:00:39.284080+00:00 2023-03-01T17:00:40.097234+00:00 0:00:00.813154 347003 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-01T17:00:36.825379+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-01T16:00:00+00:00 PythonOperator 2023-03-01T17:00:17.219742+00:00 2023-03-01T17:00:21.107643+00:00 0:00:03.887901 347001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-01T17:00:14.763906+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-01T15:00:00+00:00 TriggerDagRunOperator 2023-03-01T16:24:31.833292+00:00 2023-03-01T16:24:32.341620+00:00 0:00:00.508328 346995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T16:24:29.355239+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-01T15:00:00+00:00 TriggerDagRunOperator 2023-03-01T16:24:31.816203+00:00 2023-03-01T16:24:32.334024+00:00 0:00:00.517821 346994 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T16:24:29.355211+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-01T15:00:00+00:00 EmrJobFlowSensor 2023-03-01T16:11:55.627547+00:00 2023-03-01T16:21:57.732219+00:00 0:10:02.104672 346990 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-01T16:11:52.836773+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-01T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-01T16:11:35.221299+00:00 2023-03-01T16:11:36.278542+00:00 0:00:01.057243 346987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-01T16:11:32.797863+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-01T15:00:00+00:00 PythonOperator 2023-03-01T16:11:15.341599+00:00 2023-03-01T16:11:19.517742+00:00 0:00:04.176143 346985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-01T16:11:10.783984+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-01T14:00:00+00:00 TriggerDagRunOperator 2023-03-01T15:24:11.749237+00:00 2023-03-01T15:24:12.258346+00:00 0:00:00.509109 346976 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T15:24:08.945017+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-01T14:00:00+00:00 TriggerDagRunOperator 2023-03-01T15:24:11.640587+00:00 2023-03-01T15:24:12.137395+00:00 0:00:00.496808 346975 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T15:24:08.945046+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-01T14:00:00+00:00 EmrJobFlowSensor 2023-03-01T15:11:52.437748+00:00 2023-03-01T15:21:54.278116+00:00 0:10:01.840368 346972 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-01T15:11:50.152020+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-01T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-01T15:11:30.492231+00:00 2023-03-01T15:11:31.460450+00:00 0:00:00.968219 346969 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-01T15:11:28.131585+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-01T14:00:00+00:00 PythonOperator 2023-03-01T15:11:08.328041+00:00 2023-03-01T15:11:12.218614+00:00 0:00:03.890573 346966 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-01T15:11:06.080870+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-01T13:00:00+00:00 TriggerDagRunOperator 2023-03-01T14:17:14.019899+00:00 2023-03-01T14:17:14.786650+00:00 0:00:00.766751 346957 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T14:17:11.503706+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-01T13:00:00+00:00 TriggerDagRunOperator 2023-03-01T14:17:14.008290+00:00 2023-03-01T14:17:14.703523+00:00 0:00:00.695233 346956 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T14:17:11.503735+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-01T13:00:00+00:00 EmrJobFlowSensor 2023-03-01T14:01:06.739163+00:00 2023-03-01T14:11:08.578979+00:00 0:10:01.839816 346949 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-01T14:01:03.738746+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-01T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-01T14:00:44.540492+00:00 2023-03-01T14:00:45.777384+00:00 0:00:01.236892 346947 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-01T14:00:41.732892+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-01T13:00:00+00:00 PythonOperator 2023-03-01T14:00:22.029844+00:00 2023-03-01T14:00:26.069072+00:00 0:00:04.039228 346945 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-01T14:00:19.648036+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-01T12:00:00+00:00 TriggerDagRunOperator 2023-03-01T13:48:47.594146+00:00 2023-03-01T13:48:48.126572+00:00 0:00:00.532426 346939 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T13:48:44.620750+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-01T12:00:00+00:00 TriggerDagRunOperator 2023-03-01T13:48:47.406013+00:00 2023-03-01T13:48:47.899328+00:00 0:00:00.493315 346938 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T13:48:44.620779+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-01T12:00:00+00:00 EmrJobFlowSensor 2023-03-01T13:00:54.060142+00:00 2023-03-01T13:10:56.071284+00:00 0:10:02.011142 346930 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-01T13:00:51.736423+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-01T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-01T13:00:31.867885+00:00 2023-03-01T13:00:32.760621+00:00 0:00:00.892736 346928 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-01T13:00:29.659258+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-01T12:00:00+00:00 PythonOperator 2023-03-01T13:00:11.996606+00:00 2023-03-01T13:00:16.245292+00:00 0:00:04.248686 346926 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-01T13:00:09.640643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-01T11:00:00+00:00 TriggerDagRunOperator 2023-03-01T12:23:03.367199+00:00 2023-03-01T12:23:03.959053+00:00 0:00:00.591854 346919 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T12:23:00.201499+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-01T11:00:00+00:00 TriggerDagRunOperator 2023-03-01T12:23:03.145593+00:00 2023-03-01T12:23:03.641356+00:00 0:00:00.495763 346918 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T12:23:00.201460+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-01T11:00:00+00:00 EmrJobFlowSensor 2023-03-01T12:05:40.339360+00:00 2023-03-01T12:15:42.087441+00:00 0:10:01.748081 346913 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-01T12:05:37.832422+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-01T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-01T12:05:18.013904+00:00 2023-03-01T12:05:18.850854+00:00 0:00:00.836950 346910 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-01T12:05:15.784089+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-01T11:00:00+00:00 PythonOperator 2023-03-01T12:04:58.628110+00:00 2023-03-01T12:05:01.587873+00:00 0:00:02.959763 346908 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-01T12:04:55.740073+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-01T10:00:00+00:00 TriggerDagRunOperator 2023-03-01T11:12:01.294253+00:00 2023-03-01T11:12:01.781833+00:00 0:00:00.487580 346900 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T11:11:58.451143+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-01T10:00:00+00:00 TriggerDagRunOperator 2023-03-01T11:12:01.189575+00:00 2023-03-01T11:12:01.706249+00:00 0:00:00.516674 346899 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T11:11:58.451115+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-01T10:00:00+00:00 EmrJobFlowSensor 2023-03-01T11:01:08.153621+00:00 2023-03-01T11:11:10.029601+00:00 0:10:01.875980 346892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-01T11:01:05.614071+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-01T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-01T11:00:45.992548+00:00 2023-03-01T11:00:46.877872+00:00 0:00:00.885324 346890 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-01T11:00:43.594400+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-01T10:00:00+00:00 PythonOperator 2023-03-01T11:00:23.829460+00:00 2023-03-01T11:00:27.878067+00:00 0:00:04.048607 346888 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-01T11:00:21.522098+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-01T09:00:00+00:00 TriggerDagRunOperator 2023-03-01T10:11:12.854379+00:00 2023-03-01T10:11:13.333909+00:00 0:00:00.479530 346880 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T10:11:09.990220+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-01T09:00:00+00:00 TriggerDagRunOperator 2023-03-01T10:11:12.646798+00:00 2023-03-01T10:11:13.117380+00:00 0:00:00.470582 346879 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-01T10:11:09.990248+00:00 2 default_pool