Task Instances

  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 trigger_dagrun_campaign-history-job_v002 2021-03-22T11:00:00+00:00 TriggerDagRunOperator 2021-03-22T12:11:05.867996+00:00 2021-03-22T12:11:06.256655+00:00 0:00:00.388659 10507 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T12:11:03.560829+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T11:00:00+00:00 EmrJobFlowSensor 2021-03-22T12:00:53.021475+00:00 2021-03-22T12:10:55.926430+00:00 0:10:02.904955 10506 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T12:00:50.651694+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T12:00:31.205093+00:00 2021-03-22T12:00:32.918650+00:00 0:00:01.713557 10505 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T12:00:28.843212+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T11:00:00+00:00 PythonOperator 2021-03-22T12:00:09.008214+00:00 2021-03-22T12:00:11.757483+00:00 0:00:02.749269 10504 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T12:00:06.603122+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T10:00:00+00:00 EmrJobFlowSensor 2021-03-22T11:10:51.215432+00:00 2021-03-22T11:19:53.769931+00:00 0:09:02.554499 10502 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T11:10:48.996914+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T11:10:29.161229+00:00 2021-03-22T11:10:30.963712+00:00 0:00:01.802483 10501 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T11:10:26.959410+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T10:00:00+00:00 PythonOperator 2021-03-22T11:10:07.204140+00:00 2021-03-22T11:10:09.928655+00:00 0:00:02.724515 10500 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T11:10:04.917392+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T10:00:00+00:00 TriggerDagRunOperator 2021-03-22T11:09:57.248241+00:00 2021-03-22T11:09:57.662552+00:00 0:00:00.414311 10499 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T11:09:54.916021+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T10:00:00+00:00 TriggerDagRunOperator 2021-03-22T11:09:57.195953+00:00 2021-03-22T11:09:57.753350+00:00 0:00:00.557397 10498 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T11:09:54.915979+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T10:00:00+00:00 EmrJobFlowSensor 2021-03-22T11:00:48.478256+00:00 2021-03-22T11:09:51.248483+00:00 0:09:02.770227 10497 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T11:00:46.119802+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T11:00:26.665293+00:00 2021-03-22T11:00:28.499333+00:00 0:00:01.834040 10496 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T11:00:24.158024+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T10:00:00+00:00 PythonOperator 2021-03-22T11:00:06.589460+00:00 2021-03-22T11:00:09.484445+00:00 0:00:02.894985 10495 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T11:00:04.086721+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T09:00:00+00:00 EmrJobFlowSensor 2021-03-22T10:11:12.663633+00:00 2021-03-22T10:20:15.369209+00:00 0:09:02.705576 10493 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T10:11:10.239426+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T10:10:56.285973+00:00 2021-03-22T10:10:57.965790+00:00 0:00:01.679817 10492 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T10:10:54.165399+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T09:00:00+00:00 PythonOperator 2021-03-22T10:10:40.351395+00:00 2021-03-22T10:10:43.201457+00:00 0:00:02.850062 10491 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T10:10:38.098612+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T09:00:00+00:00 TriggerDagRunOperator 2021-03-22T10:10:23.023256+00:00 2021-03-22T10:10:23.742718+00:00 0:00:00.719462 10490 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T10:10:20.136821+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T09:00:00+00:00 TriggerDagRunOperator 2021-03-22T10:10:22.634182+00:00 2021-03-22T10:10:23.054005+00:00 0:00:00.419823 10489 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T10:10:20.136775+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T09:00:00+00:00 EmrJobFlowSensor 2021-03-22T10:02:07.693694+00:00 2021-03-22T10:10:10.362649+00:00 0:08:02.668955 10488 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T10:02:05.228152+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T10:01:51.216974+00:00 2021-03-22T10:01:52.920962+00:00 0:00:01.703988 10487 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T10:01:49.081192+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T09:00:00+00:00 PythonOperator 2021-03-22T10:01:35.339091+00:00 2021-03-22T10:01:38.068946+00:00 0:00:02.729855 10486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T10:01:33.066750+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T08:00:00+00:00 EmrJobFlowSensor 2021-03-22T09:12:02.206387+00:00 2021-03-22T09:22:05.088209+00:00 0:10:02.881822 10484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T09:12:00.096348+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T09:11:46.280399+00:00 2021-03-22T09:11:47.945314+00:00 0:00:01.664915 10483 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T09:11:44.074928+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T08:00:00+00:00 PythonOperator 2021-03-22T09:11:30.598080+00:00 2021-03-22T09:11:33.344800+00:00 0:00:02.746720 10482 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T09:11:28.130009+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T08:00:00+00:00 TriggerDagRunOperator 2021-03-22T09:11:24.548409+00:00 2021-03-22T09:11:25.087441+00:00 0:00:00.539032 10481 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T09:11:22.056509+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T08:00:00+00:00 TriggerDagRunOperator 2021-03-22T09:11:24.294048+00:00 2021-03-22T09:11:24.721398+00:00 0:00:00.427350 10480 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T09:11:22.056480+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T08:00:00+00:00 EmrJobFlowSensor 2021-03-22T09:00:41.074570+00:00 2021-03-22T09:10:43.890607+00:00 0:10:02.816037 10479 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T09:00:38.918484+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T09:00:21.333999+00:00 2021-03-22T09:00:23.037133+00:00 0:00:01.703134 10478 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T09:00:18.947776+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T08:00:00+00:00 PythonOperator 2021-03-22T09:00:05.694429+00:00 2021-03-22T09:00:08.646505+00:00 0:00:02.952076 10477 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T09:00:03.015301+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T07:00:00+00:00 EmrJobFlowSensor 2021-03-22T08:11:03.887853+00:00 2021-03-22T08:21:06.808352+00:00 0:10:02.920499 10475 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T08:11:01.528316+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T08:10:47.642886+00:00 2021-03-22T08:10:49.316692+00:00 0:00:01.673806 10474 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T08:10:45.482419+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T07:00:00+00:00 PythonOperator 2021-03-22T08:10:31.920356+00:00 2021-03-22T08:10:34.809116+00:00 0:00:02.888760 10473 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T08:10:29.518270+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T07:00:00+00:00 TriggerDagRunOperator 2021-03-22T08:10:13.767230+00:00 2021-03-22T08:10:14.292710+00:00 0:00:00.525480 10472 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T08:10:11.401064+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T07:00:00+00:00 TriggerDagRunOperator 2021-03-22T08:10:13.765158+00:00 2021-03-22T08:10:14.292674+00:00 0:00:00.527516 10471 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T08:10:11.401033+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T07:00:00+00:00 EmrJobFlowSensor 2021-03-22T08:00:50.708480+00:00 2021-03-22T08:09:53.390147+00:00 0:09:02.681667 10470 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T08:00:48.459921+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T08:00:34.826340+00:00 2021-03-22T08:00:36.668320+00:00 0:00:01.841980 10469 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T08:00:32.409451+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T07:00:00+00:00 PythonOperator 2021-03-22T08:00:18.928446+00:00 2021-03-22T08:00:21.822829+00:00 0:00:02.894383 10468 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T08:00:16.394198+00:00 2 default_pool
success Custom-EMR-cluster_v001 create_cluster_n_add_steps 2021-03-22T07:19:14.382187+00:00 PythonOperator 2021-03-22T07:19:27.445222+00:00 2021-03-22T07:19:30.222057+00:00 0:00:02.776835 10466 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T07:19:25.285542+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T06:00:00+00:00 EmrJobFlowSensor 2021-03-22T07:12:10.737165+00:00 2021-03-22T07:22:13.709167+00:00 0:10:02.972002 10465 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T07:12:08.460136+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T07:11:48.866579+00:00 2021-03-22T07:11:50.679532+00:00 0:00:01.812953 10464 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T07:11:46.434352+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T06:00:00+00:00 PythonOperator 2021-03-22T07:11:30.814367+00:00 2021-03-22T07:11:33.686783+00:00 0:00:02.872416 10463 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T07:11:28.427106+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T06:00:00+00:00 TriggerDagRunOperator 2021-03-22T07:11:13.085468+00:00 2021-03-22T07:11:13.531429+00:00 0:00:00.445961 10462 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T07:11:10.439361+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T06:00:00+00:00 TriggerDagRunOperator 2021-03-22T07:11:12.812743+00:00 2021-03-22T07:11:13.353511+00:00 0:00:00.540768 10461 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T07:11:10.439323+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T06:00:00+00:00 EmrJobFlowSensor 2021-03-22T07:00:57.611998+00:00 2021-03-22T07:11:00.380876+00:00 0:10:02.768878 10460 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T07:00:55.320602+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T07:00:41.543668+00:00 2021-03-22T07:00:43.229118+00:00 0:00:01.685450 10459 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T07:00:39.259481+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T06:00:00+00:00 PythonOperator 2021-03-22T07:00:25.609097+00:00 2021-03-22T07:00:28.324927+00:00 0:00:02.715830 10458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T07:00:23.222929+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T05:00:00+00:00 EmrJobFlowSensor 2021-03-22T06:11:44.388661+00:00 2021-03-22T06:20:46.916183+00:00 0:09:02.527522 10456 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T06:11:41.985127+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T06:11:28.519245+00:00 2021-03-22T06:11:30.251915+00:00 0:00:01.732670 10455 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T06:11:26.036377+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T05:00:00+00:00 PythonOperator 2021-03-22T06:11:12.449896+00:00 2021-03-22T06:11:15.309522+00:00 0:00:02.859626 10454 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T06:11:10.028052+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T05:00:00+00:00 TriggerDagRunOperator 2021-03-22T06:10:58.266815+00:00 2021-03-22T06:10:58.806556+00:00 0:00:00.539741 10453 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T06:10:55.889396+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T05:00:00+00:00 TriggerDagRunOperator 2021-03-22T06:10:58.070590+00:00 2021-03-22T06:10:58.463842+00:00 0:00:00.393252 10452 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T06:10:55.889426+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T05:00:00+00:00 EmrJobFlowSensor 2021-03-22T06:00:36.886841+00:00 2021-03-22T06:10:39.654447+00:00 0:10:02.767606 10451 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T06:00:34.783054+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T06:00:21.302710+00:00 2021-03-22T06:00:23.020600+00:00 0:00:01.717890 10450 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T06:00:18.843940+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T05:00:00+00:00 PythonOperator 2021-03-22T06:00:05.712930+00:00 2021-03-22T06:00:08.595848+00:00 0:00:02.882918 10449 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T06:00:02.763115+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T04:00:00+00:00 EmrJobFlowSensor 2021-03-22T05:11:34.962588+00:00 2021-03-22T05:21:37.889159+00:00 0:10:02.926571 10447 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T05:11:32.496631+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T05:11:18.908453+00:00 2021-03-22T05:11:20.710269+00:00 0:00:01.801816 10446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T05:11:16.540356+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T04:00:00+00:00 PythonOperator 2021-03-22T05:11:02.734530+00:00 2021-03-22T05:11:05.443490+00:00 0:00:02.708960 10445 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T05:11:00.473210+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T04:00:00+00:00 TriggerDagRunOperator 2021-03-22T05:10:46.775644+00:00 2021-03-22T05:10:47.312784+00:00 0:00:00.537140 10444 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T05:10:44.433280+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T04:00:00+00:00 TriggerDagRunOperator 2021-03-22T05:10:46.698023+00:00 2021-03-22T05:10:47.093819+00:00 0:00:00.395796 10443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T05:10:44.433237+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T04:00:00+00:00 EmrJobFlowSensor 2021-03-22T05:00:35.881863+00:00 2021-03-22T05:10:38.594377+00:00 0:10:02.712514 10442 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T05:00:33.532412+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T05:00:19.986352+00:00 2021-03-22T05:00:21.891215+00:00 0:00:01.904863 10441 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T05:00:17.429801+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T04:00:00+00:00 PythonOperator 2021-03-22T05:00:03.812537+00:00 2021-03-22T05:00:06.667898+00:00 0:00:02.855361 10440 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T05:00:01.386840+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T03:00:00+00:00 EmrJobFlowSensor 2021-03-22T04:11:50.472603+00:00 2021-03-22T04:21:53.150539+00:00 0:10:02.677936 10438 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T04:11:48.326054+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T03:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T04:11:32.752249+00:00 2021-03-22T04:11:34.436330+00:00 0:00:01.684081 10437 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T04:11:30.326304+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T03:00:00+00:00 PythonOperator 2021-03-22T04:11:16.774755+00:00 2021-03-22T04:11:19.605875+00:00 0:00:02.831120 10436 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T04:11:14.322678+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T03:00:00+00:00 TriggerDagRunOperator 2021-03-22T04:10:58.598947+00:00 2021-03-22T04:10:59.131255+00:00 0:00:00.532308 10435 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T04:10:56.189312+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T03:00:00+00:00 TriggerDagRunOperator 2021-03-22T04:10:58.383154+00:00 2021-03-22T04:10:58.794232+00:00 0:00:00.411078 10434 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T04:10:56.189342+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T03:00:00+00:00 EmrJobFlowSensor 2021-03-22T04:00:41.309641+00:00 2021-03-22T04:10:44.192472+00:00 0:10:02.882831 10433 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T04:00:38.967369+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T03:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T04:00:25.203110+00:00 2021-03-22T04:00:26.993316+00:00 0:00:01.790206 10432 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T04:00:22.922097+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T03:00:00+00:00 PythonOperator 2021-03-22T04:00:09.199208+00:00 2021-03-22T04:00:11.899770+00:00 0:00:02.700562 10431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T04:00:06.877219+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T02:00:00+00:00 EmrJobFlowSensor 2021-03-22T03:11:42.260489+00:00 2021-03-22T03:19:44.868070+00:00 0:08:02.607581 10429 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T03:11:40.038820+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T02:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T03:11:26.187316+00:00 2021-03-22T03:11:27.953891+00:00 0:00:01.766575 10428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T03:11:24.026839+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T02:00:00+00:00 PythonOperator 2021-03-22T03:11:10.495564+00:00 2021-03-22T03:11:13.221745+00:00 0:00:02.726181 10427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T03:11:08.124240+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T02:00:00+00:00 TriggerDagRunOperator 2021-03-22T03:10:56.466147+00:00 2021-03-22T03:10:57.007727+00:00 0:00:00.541580 10426 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T03:10:54.057944+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T02:00:00+00:00 TriggerDagRunOperator 2021-03-22T03:10:56.274565+00:00 2021-03-22T03:10:56.690184+00:00 0:00:00.415619 10425 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T03:10:54.057981+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T02:00:00+00:00 EmrJobFlowSensor 2021-03-22T03:00:48.922331+00:00 2021-03-22T03:10:51.709365+00:00 0:10:02.787034 10424 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T03:00:46.668754+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T02:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T03:00:33.102953+00:00 2021-03-22T03:00:34.995774+00:00 0:00:01.892821 10423 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T03:00:30.724224+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T02:00:00+00:00 PythonOperator 2021-03-22T03:00:17.358625+00:00 2021-03-22T03:00:20.250647+00:00 0:00:02.892022 10422 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T03:00:14.724019+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T01:00:00+00:00 EmrJobFlowSensor 2021-03-22T02:10:57.585464+00:00 2021-03-22T02:19:00.076373+00:00 0:08:02.490909 10420 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T02:10:55.421520+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T02:10:41.575257+00:00 2021-03-22T02:10:43.385112+00:00 0:00:01.809855 10419 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T02:10:39.270643+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T01:00:00+00:00 PythonOperator 2021-03-22T02:10:25.670553+00:00 2021-03-22T02:10:28.369406+00:00 0:00:02.698853 10418 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T02:10:23.256583+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T01:00:00+00:00 TriggerDagRunOperator 2021-03-22T02:10:13.858346+00:00 2021-03-22T02:10:14.384315+00:00 0:00:00.525969 10417 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T02:10:11.223354+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T01:00:00+00:00 TriggerDagRunOperator 2021-03-22T02:10:13.593654+00:00 2021-03-22T02:10:14.016225+00:00 0:00:00.422571 10416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T02:10:11.223311+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T01:00:00+00:00 EmrJobFlowSensor 2021-03-22T02:00:52.510952+00:00 2021-03-22T02:09:55.145202+00:00 0:09:02.634250 10415 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T02:00:50.159072+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T02:00:34.461289+00:00 2021-03-22T02:00:36.162819+00:00 0:00:01.701530 10414 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T02:00:32.134582+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T01:00:00+00:00 PythonOperator 2021-03-22T02:00:18.813553+00:00 2021-03-22T02:00:21.699055+00:00 0:00:02.885502 10413 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T02:00:16.060516+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T00:00:00+00:00 EmrJobFlowSensor 2021-03-22T01:11:53.692242+00:00 2021-03-22T01:20:56.417591+00:00 0:09:02.725349 10411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T01:11:51.526614+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T01:11:37.677236+00:00 2021-03-22T01:11:39.517348+00:00 0:00:01.840112 10410 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T01:11:35.402429+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T00:00:00+00:00 PythonOperator 2021-03-22T01:11:21.667300+00:00 2021-03-22T01:11:24.578523+00:00 0:00:02.911223 10409 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T01:11:19.386746+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T00:00:00+00:00 TriggerDagRunOperator 2021-03-22T01:11:08.009342+00:00 2021-03-22T01:11:08.676979+00:00 0:00:00.667637 10408 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T01:11:05.425243+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T00:00:00+00:00 TriggerDagRunOperator 2021-03-22T01:11:07.994892+00:00 2021-03-22T01:11:08.429368+00:00 0:00:00.434476 10407 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T01:11:05.425279+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T00:00:00+00:00 EmrJobFlowSensor 2021-03-22T01:00:54.591968+00:00 2021-03-22T01:10:57.437315+00:00 0:10:02.845347 10406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T01:00:52.155715+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T01:00:30.416670+00:00 2021-03-22T01:00:32.283991+00:00 0:00:01.867321 10405 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T01:00:28.112686+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T00:00:00+00:00 PythonOperator 2021-03-22T01:00:12.701874+00:00 2021-03-22T01:00:15.603819+00:00 0:00:02.901945 10404 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T01:00:10.098243+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-21T23:00:00+00:00 EmrJobFlowSensor 2021-03-22T00:09:58.673187+00:00 2021-03-22T00:18:01.265461+00:00 0:08:02.592274 10402 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T00:09:56.268619+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-21T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T00:09:42.431876+00:00 2021-03-22T00:09:44.140773+00:00 0:00:01.708897 10401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T00:09:40.251568+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-21T23:00:00+00:00 PythonOperator 2021-03-22T00:09:26.446273+00:00 2021-03-22T00:09:29.200853+00:00 0:00:02.754580 10400 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T00:09:24.237946+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-21T23:00:00+00:00 TriggerDagRunOperator 2021-03-22T00:09:18.881538+00:00 2021-03-22T00:09:19.439166+00:00 0:00:00.557628 10399 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T00:09:16.237253+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-21T23:00:00+00:00 TriggerDagRunOperator 2021-03-22T00:09:18.615555+00:00 2021-03-22T00:09:19.038137+00:00 0:00:00.422582 10398 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T00:09:16.237211+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-21T23:00:00+00:00 EmrJobFlowSensor 2021-03-22T00:00:59.776223+00:00 2021-03-22T00:09:02.565790+00:00 0:08:02.789567 10397 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T00:00:57.377615+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-21T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T00:00:31.586583+00:00 2021-03-22T00:00:33.281976+00:00 0:00:01.695393 10396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T00:00:29.417787+00:00 2 default_pool