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-02-19T17:00:00+00:00 EmrJobFlowSensor 2023-02-19T18:00:50.976601+00:00 2023-02-19T18:10:52.844326+00:00 0:10:01.867725 342798 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-19T18:00:48.643963+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-19T17:00:00+00:00 EmrCreateJobFlowOperator 2023-02-19T18:00:31.128029+00:00 2023-02-19T18:00:32.016208+00:00 0:00:00.888179 342797 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-19T18:00:28.627170+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-19T17:00:00+00:00 PythonOperator 2023-02-19T18:00:09.031962+00:00 2023-02-19T18:00:12.054853+00:00 0:00:03.022891 342795 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-19T18:00:06.583936+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-19T16:00:00+00:00 TriggerDagRunOperator 2023-02-19T17:11:25.842458+00:00 2023-02-19T17:11:26.322547+00:00 0:00:00.480089 342780 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T17:11:23.393024+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-19T16:00:00+00:00 TriggerDagRunOperator 2023-02-19T17:11:25.628376+00:00 2023-02-19T17:11:26.645536+00:00 0:00:01.017160 342779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T17:11:23.393059+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-19T16:00:00+00:00 EmrJobFlowSensor 2023-02-19T17:01:04.861881+00:00 2023-02-19T17:11:06.629974+00:00 0:10:01.768093 342775 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-19T17:01:02.528001+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-19T16:00:00+00:00 EmrCreateJobFlowOperator 2023-02-19T17:00:45.228832+00:00 2023-02-19T17:00:46.153942+00:00 0:00:00.925110 342773 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-19T17:00:42.507344+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-19T16:00:00+00:00 PythonOperator 2023-02-19T17:00:22.723569+00:00 2023-02-19T17:00:26.609608+00:00 0:00:03.886039 342771 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-19T17:00:20.486506+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-19T15:00:00+00:00 TriggerDagRunOperator 2023-02-19T16:11:00.774260+00:00 2023-02-19T16:11:01.397060+00:00 0:00:00.622800 342757 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T16:10:57.694625+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-19T15:00:00+00:00 TriggerDagRunOperator 2023-02-19T16:11:00.606103+00:00 2023-02-19T16:11:01.234971+00:00 0:00:00.628868 342756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T16:10:57.694595+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-19T15:00:00+00:00 EmrJobFlowSensor 2023-02-19T16:00:53.308481+00:00 2023-02-19T16:10:55.104286+00:00 0:10:01.795805 342750 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-19T16:00:50.807149+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-19T15:00:00+00:00 EmrCreateJobFlowOperator 2023-02-19T16:00:33.169313+00:00 2023-02-19T16:00:34.343650+00:00 0:00:01.174337 342748 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-19T16:00:28.700498+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-19T15:00:00+00:00 PythonOperator 2023-02-19T16:00:10.917989+00:00 2023-02-19T16:00:14.704226+00:00 0:00:03.786237 342746 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-19T16:00:08.574108+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-19T14:00:00+00:00 TriggerDagRunOperator 2023-02-19T15:11:07.997925+00:00 2023-02-19T15:11:08.456637+00:00 0:00:00.458712 342732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T15:11:05.207906+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-19T14:00:00+00:00 TriggerDagRunOperator 2023-02-19T15:11:07.794973+00:00 2023-02-19T15:11:08.281214+00:00 0:00:00.486241 342731 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T15:11:05.207950+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-19T14:00:00+00:00 EmrJobFlowSensor 2023-02-19T15:00:54.548419+00:00 2023-02-19T15:10:56.404698+00:00 0:10:01.856279 342724 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-19T15:00:52.326727+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-19T14:00:00+00:00 EmrCreateJobFlowOperator 2023-02-19T15:00:32.844795+00:00 2023-02-19T15:00:33.707902+00:00 0:00:00.863107 342722 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-19T15:00:30.305734+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-19T14:00:00+00:00 PythonOperator 2023-02-19T15:00:13.142140+00:00 2023-02-19T15:00:16.075248+00:00 0:00:02.933108 342721 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-19T15:00:10.289059+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-19T13:00:00+00:00 TriggerDagRunOperator 2023-02-19T14:11:06.660698+00:00 2023-02-19T14:11:07.173735+00:00 0:00:00.513037 342708 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T14:11:04.214826+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-19T13:00:00+00:00 TriggerDagRunOperator 2023-02-19T14:11:06.636462+00:00 2023-02-19T14:11:07.127230+00:00 0:00:00.490768 342707 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T14:11:04.214797+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-19T13:00:00+00:00 EmrJobFlowSensor 2023-02-19T14:00:51.327345+00:00 2023-02-19T14:10:53.043179+00:00 0:10:01.715834 342699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-19T14:00:49.009066+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-19T13:00:00+00:00 EmrCreateJobFlowOperator 2023-02-19T14:00:31.424321+00:00 2023-02-19T14:00:32.283405+00:00 0:00:00.859084 342697 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-19T14:00:28.895154+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-19T13:00:00+00:00 PythonOperator 2023-02-19T14:00:09.677158+00:00 2023-02-19T14:00:12.619988+00:00 0:00:02.942830 342695 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-19T14:00:06.790061+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-19T12:00:00+00:00 TriggerDagRunOperator 2023-02-19T13:12:16.691989+00:00 2023-02-19T13:12:17.181379+00:00 0:00:00.489390 342683 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T13:12:13.855969+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-19T12:00:00+00:00 TriggerDagRunOperator 2023-02-19T13:12:16.402439+00:00 2023-02-19T13:12:16.873168+00:00 0:00:00.470729 342682 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T13:12:13.855939+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-19T12:00:00+00:00 EmrJobFlowSensor 2023-02-19T13:00:53.153852+00:00 2023-02-19T13:10:55.158155+00:00 0:10:02.004303 342674 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-19T13:00:50.846126+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-19T12:00:00+00:00 EmrCreateJobFlowOperator 2023-02-19T13:00:33.166483+00:00 2023-02-19T13:00:34.291107+00:00 0:00:01.124624 342672 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-19T13:00:30.830590+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-19T12:00:00+00:00 PythonOperator 2023-02-19T13:00:11.318409+00:00 2023-02-19T13:00:14.426393+00:00 0:00:03.107984 342670 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-19T13:00:08.809783+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-19T11:00:00+00:00 TriggerDagRunOperator 2023-02-19T12:11:05.178044+00:00 2023-02-19T12:11:05.671034+00:00 0:00:00.492990 342659 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T12:11:02.113700+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-19T11:00:00+00:00 TriggerDagRunOperator 2023-02-19T12:11:04.841882+00:00 2023-02-19T12:11:05.310115+00:00 0:00:00.468233 342658 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T12:11:02.113657+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-19T11:00:00+00:00 EmrJobFlowSensor 2023-02-19T12:00:59.006875+00:00 2023-02-19T12:11:00.973339+00:00 0:10:01.966464 342651 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-19T12:00:56.773605+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-19T11:00:00+00:00 EmrCreateJobFlowOperator 2023-02-19T12:00:38.987087+00:00 2023-02-19T12:00:39.877262+00:00 0:00:00.890175 342649 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-19T12:00:36.754382+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-19T11:00:00+00:00 PythonOperator 2023-02-19T12:00:16.922378+00:00 2023-02-19T12:00:20.803733+00:00 0:00:03.881355 342647 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-19T12:00:14.733923+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-19T10:00:00+00:00 TriggerDagRunOperator 2023-02-19T11:11:44.721070+00:00 2023-02-19T11:11:45.687067+00:00 0:00:00.965997 342634 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T11:11:41.696487+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-19T10:00:00+00:00 TriggerDagRunOperator 2023-02-19T11:11:44.468771+00:00 2023-02-19T11:11:45.600670+00:00 0:00:01.131899 342633 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T11:11:41.696456+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-19T10:00:00+00:00 EmrJobFlowSensor 2023-02-19T11:00:56.738123+00:00 2023-02-19T11:10:58.549006+00:00 0:10:01.810883 342625 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-19T11:00:54.477882+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-19T10:00:00+00:00 EmrCreateJobFlowOperator 2023-02-19T11:00:36.676483+00:00 2023-02-19T11:00:37.505616+00:00 0:00:00.829133 342623 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-19T11:00:34.454397+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-19T10:00:00+00:00 PythonOperator 2023-02-19T11:00:14.997007+00:00 2023-02-19T11:00:18.156316+00:00 0:00:03.159309 342621 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-19T11:00:12.434328+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-19T09:00:00+00:00 TriggerDagRunOperator 2023-02-19T10:11:28.969166+00:00 2023-02-19T10:11:29.511244+00:00 0:00:00.542078 342608 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T10:11:26.649611+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-19T09:00:00+00:00 TriggerDagRunOperator 2023-02-19T10:11:28.879604+00:00 2023-02-19T10:11:29.360798+00:00 0:00:00.481194 342607 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T10:11:26.649582+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-19T09:00:00+00:00 EmrJobFlowSensor 2023-02-19T10:01:02.858760+00:00 2023-02-19T10:11:04.606792+00:00 0:10:01.748032 342601 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-19T10:01:00.553129+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-19T09:00:00+00:00 EmrCreateJobFlowOperator 2023-02-19T10:00:40.855069+00:00 2023-02-19T10:00:41.764037+00:00 0:00:00.908968 342599 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-19T10:00:38.531603+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-19T09:00:00+00:00 PythonOperator 2023-02-19T10:00:18.962361+00:00 2023-02-19T10:00:21.880717+00:00 0:00:02.918356 342597 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-19T10:00:16.522923+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-19T08:00:00+00:00 TriggerDagRunOperator 2023-02-19T09:15:58.653469+00:00 2023-02-19T09:15:59.104529+00:00 0:00:00.451060 342584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T09:15:55.734703+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-19T08:00:00+00:00 TriggerDagRunOperator 2023-02-19T09:15:58.118117+00:00 2023-02-19T09:15:58.603860+00:00 0:00:00.485743 342583 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T09:15:55.734736+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-19T08:00:00+00:00 EmrJobFlowSensor 2023-02-19T09:02:29.667757+00:00 2023-02-19T09:12:31.598809+00:00 0:10:01.931052 342576 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-19T09:02:27.236123+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-19T08:00:00+00:00 EmrCreateJobFlowOperator 2023-02-19T09:02:07.688138+00:00 2023-02-19T09:02:08.542168+00:00 0:00:00.854030 342574 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-19T09:02:05.212280+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-19T08:00:00+00:00 PythonOperator 2023-02-19T09:01:48.166621+00:00 2023-02-19T09:01:51.310003+00:00 0:00:03.143382 342572 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-19T09:01:45.204746+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-19T07:00:00+00:00 TriggerDagRunOperator 2023-02-19T08:14:44.858132+00:00 2023-02-19T08:14:45.681172+00:00 0:00:00.823040 342559 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T08:14:42.048965+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-19T07:00:00+00:00 TriggerDagRunOperator 2023-02-19T08:14:44.713098+00:00 2023-02-19T08:14:45.571614+00:00 0:00:00.858516 342558 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T08:14:42.048994+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-19T07:00:00+00:00 EmrJobFlowSensor 2023-02-19T08:04:32.005351+00:00 2023-02-19T08:14:33.744079+00:00 0:10:01.738728 342551 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-19T08:04:29.687501+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-19T07:00:00+00:00 EmrCreateJobFlowOperator 2023-02-19T08:04:09.824075+00:00 2023-02-19T08:04:10.701676+00:00 0:00:00.877601 342549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-19T08:04:07.627049+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-19T07:00:00+00:00 PythonOperator 2023-02-19T08:03:48.056888+00:00 2023-02-19T08:03:52.213942+00:00 0:00:04.157054 342547 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-19T08:03:45.598294+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-19T06:00:00+00:00 TriggerDagRunOperator 2023-02-19T07:12:24.934675+00:00 2023-02-19T07:12:25.429173+00:00 0:00:00.494498 342535 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T07:12:22.311970+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-19T06:00:00+00:00 TriggerDagRunOperator 2023-02-19T07:12:24.758775+00:00 2023-02-19T07:12:25.220571+00:00 0:00:00.461796 342534 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T07:12:22.311940+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-19T06:00:00+00:00 EmrJobFlowSensor 2023-02-19T07:01:58.423151+00:00 2023-02-19T07:12:00.332423+00:00 0:10:01.909272 342528 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-19T07:01:56.082089+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-19T06:00:00+00:00 EmrCreateJobFlowOperator 2023-02-19T07:01:38.444286+00:00 2023-02-19T07:01:39.641998+00:00 0:00:01.197712 342526 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-19T07:01:34.101405+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-19T06:00:00+00:00 PythonOperator 2023-02-19T07:01:16.276550+00:00 2023-02-19T07:01:20.660858+00:00 0:00:04.384308 342524 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-19T07:01:14.043532+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-19T05:00:00+00:00 TriggerDagRunOperator 2023-02-19T06:11:28.362087+00:00 2023-02-19T06:11:28.859296+00:00 0:00:00.497209 342509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T06:11:25.717496+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-19T05:00:00+00:00 TriggerDagRunOperator 2023-02-19T06:11:27.953571+00:00 2023-02-19T06:11:28.472060+00:00 0:00:00.518489 342508 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T06:11:25.717523+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-19T05:00:00+00:00 EmrJobFlowSensor 2023-02-19T06:01:04.336483+00:00 2023-02-19T06:11:06.145358+00:00 0:10:01.808875 342503 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-19T06:01:02.008134+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-19T05:00:00+00:00 EmrCreateJobFlowOperator 2023-02-19T06:00:44.326895+00:00 2023-02-19T06:00:45.346996+00:00 0:00:01.020101 342501 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-19T06:00:41.922481+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-19T05:00:00+00:00 PythonOperator 2023-02-19T06:00:22.069333+00:00 2023-02-19T06:00:25.896366+00:00 0:00:03.827033 342499 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-19T06:00:19.900387+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-19T04:00:00+00:00 TriggerDagRunOperator 2023-02-19T05:12:52.102111+00:00 2023-02-19T05:12:52.634236+00:00 0:00:00.532125 342487 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T05:12:49.528976+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-19T04:00:00+00:00 TriggerDagRunOperator 2023-02-19T05:12:51.998255+00:00 2023-02-19T05:12:52.466277+00:00 0:00:00.468022 342486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T05:12:49.528948+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-19T04:00:00+00:00 EmrJobFlowSensor 2023-02-19T05:02:35.354916+00:00 2023-02-19T05:12:37.089570+00:00 0:10:01.734654 342480 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-19T05:02:32.784435+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-19T04:00:00+00:00 EmrCreateJobFlowOperator 2023-02-19T05:02:14.084795+00:00 2023-02-19T05:02:15.124261+00:00 0:00:01.039466 342478 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-19T05:02:10.768725+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-19T04:00:00+00:00 PythonOperator 2023-02-19T05:00:13.876478+00:00 2023-02-19T05:00:16.852049+00:00 0:00:02.975571 342475 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-19T05:00:11.466149+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-19T03:00:00+00:00 TriggerDagRunOperator 2023-02-19T04:12:07.317791+00:00 2023-02-19T04:12:07.783881+00:00 0:00:00.466090 342461 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T04:12:04.259208+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-19T03:00:00+00:00 TriggerDagRunOperator 2023-02-19T04:12:07.314573+00:00 2023-02-19T04:12:07.861684+00:00 0:00:00.547111 342460 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T04:12:04.259162+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-19T03:00:00+00:00 EmrJobFlowSensor 2023-02-19T04:01:52.639899+00:00 2023-02-19T04:11:54.570809+00:00 0:10:01.930910 342453 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-19T04:01:50.403374+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-19T03:00:00+00:00 EmrCreateJobFlowOperator 2023-02-19T04:01:30.571344+00:00 2023-02-19T04:01:31.457976+00:00 0:00:00.886632 342451 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-19T04:01:28.378990+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-19T03:00:00+00:00 PythonOperator 2023-02-19T04:01:11.394310+00:00 2023-02-19T04:01:14.676115+00:00 0:00:03.281805 342449 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-19T04:01:08.413284+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-19T02:00:00+00:00 TriggerDagRunOperator 2023-02-19T03:11:23.452091+00:00 2023-02-19T03:11:23.909594+00:00 0:00:00.457503 342437 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T03:11:20.431427+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-19T02:00:00+00:00 TriggerDagRunOperator 2023-02-19T03:11:22.918543+00:00 2023-02-19T03:11:23.402163+00:00 0:00:00.483620 342436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T03:11:20.431470+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-19T02:00:00+00:00 EmrJobFlowSensor 2023-02-19T03:01:01.366985+00:00 2023-02-19T03:11:03.211540+00:00 0:10:01.844555 342429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-19T03:00:58.991998+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-19T02:00:00+00:00 EmrCreateJobFlowOperator 2023-02-19T03:00:39.512602+00:00 2023-02-19T03:00:40.412231+00:00 0:00:00.899629 342427 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-19T03:00:36.993685+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-19T02:00:00+00:00 PythonOperator 2023-02-19T03:00:17.380852+00:00 2023-02-19T03:00:20.291721+00:00 0:00:02.910869 342425 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-19T03:00:14.924066+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-19T01:00:00+00:00 TriggerDagRunOperator 2023-02-19T02:11:04.395258+00:00 2023-02-19T02:11:04.896026+00:00 0:00:00.500768 342411 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T02:11:01.512789+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-19T01:00:00+00:00 TriggerDagRunOperator 2023-02-19T02:11:04.258666+00:00 2023-02-19T02:11:04.722106+00:00 0:00:00.463440 342410 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T02:11:01.512832+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-19T01:00:00+00:00 EmrJobFlowSensor 2023-02-19T02:00:56.259609+00:00 2023-02-19T02:10:58.099807+00:00 0:10:01.840198 342404 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-19T02:00:53.790238+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-19T01:00:00+00:00 EmrCreateJobFlowOperator 2023-02-19T02:00:37.950531+00:00 2023-02-19T02:00:39.006869+00:00 0:00:01.056338 342402 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-19T02:00:33.694680+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-19T01:00:00+00:00 PythonOperator 2023-02-19T02:00:14.016666+00:00 2023-02-19T02:00:17.046151+00:00 0:00:03.029485 342400 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-19T02:00:11.676743+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-19T00:00:00+00:00 TriggerDagRunOperator 2023-02-19T01:11:05.583476+00:00 2023-02-19T01:11:06.259224+00:00 0:00:00.675748 342379 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T01:11:03.244746+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-19T00:00:00+00:00 TriggerDagRunOperator 2023-02-19T01:11:05.438672+00:00 2023-02-19T01:11:06.134196+00:00 0:00:00.695524 342378 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T01:11:03.244775+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-19T00:00:00+00:00 EmrJobFlowSensor 2023-02-19T01:00:59.914149+00:00 2023-02-19T01:11:01.908436+00:00 0:10:01.994287 342371 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-19T01:00:57.588640+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-19T00:00:00+00:00 EmrCreateJobFlowOperator 2023-02-19T01:00:39.808534+00:00 2023-02-19T01:00:41.027894+00:00 0:00:01.219360 342369 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-19T01:00:37.567045+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-19T00:00:00+00:00 PythonOperator 2023-02-19T01:00:17.999502+00:00 2023-02-19T01:00:21.039109+00:00 0:00:03.039607 342367 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-19T01:00:15.548844+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-18T23:00:00+00:00 TriggerDagRunOperator 2023-02-19T00:11:08.795505+00:00 2023-02-19T00:11:09.274020+00:00 0:00:00.478515 342353 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T00:11:06.535697+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-18T23:00:00+00:00 TriggerDagRunOperator 2023-02-19T00:11:08.766532+00:00 2023-02-19T00:11:09.252825+00:00 0:00:00.486293 342352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-19T00:11:06.535730+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-18T23:00:00+00:00 EmrJobFlowSensor 2023-02-19T00:00:58.292003+00:00 2023-02-19T00:11:00.143570+00:00 0:10:01.851567 342346 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-19T00:00:55.816925+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-18T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-19T00:00:36.126926+00:00 2023-02-19T00:00:36.994401+00:00 0:00:00.867475 342343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-19T00:00:33.800400+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-18T23:00:00+00:00 PythonOperator 2023-02-19T00:00:16.517875+00:00 2023-02-19T00:00:20.052179+00:00 0:00:03.534304 342342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-19T00:00:13.740005+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-18T22:00:00+00:00 TriggerDagRunOperator 2023-02-18T23:11:13.977054+00:00 2023-02-18T23:11:14.671295+00:00 0:00:00.694241 342326 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-18T23:11:11.464364+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-18T22:00:00+00:00 TriggerDagRunOperator 2023-02-18T23:11:13.686847+00:00 2023-02-18T23:11:14.199211+00:00 0:00:00.512364 342325 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-18T23:11:11.464332+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-18T22:00:00+00:00 EmrJobFlowSensor 2023-02-18T23:00:48.715616+00:00 2023-02-18T23:10:50.374686+00:00 0:10:01.659070 342318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-18T23:00:46.325781+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-18T22:00:00+00:00 EmrCreateJobFlowOperator 2023-02-18T23:00:28.670398+00:00 2023-02-18T23:00:29.534335+00:00 0:00:00.863937 342315 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-18T23:00:26.310841+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-18T22:00:00+00:00 PythonOperator 2023-02-18T23:00:06.721718+00:00 2023-02-18T23:00:10.499952+00:00 0:00:03.778234 342312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-18T23:00:04.291201+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-18T21:00:00+00:00 TriggerDagRunOperator 2023-02-18T22:10:56.499300+00:00 2023-02-18T22:10:57.052155+00:00 0:00:00.552855 342296 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-18T22:10:54.237661+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-18T21:00:00+00:00 TriggerDagRunOperator 2023-02-18T22:10:56.451438+00:00 2023-02-18T22:10:56.901613+00:00 0:00:00.450175 342295 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-18T22:10:54.237692+00:00 2 default_pool