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 check_cluster_status 2023-02-25T10:00:00+00:00 EmrJobFlowSensor 2023-02-25T11:06:28.037426+00:00 2023-02-25T11:16:29.949777+00:00 0:10:01.912351 345270 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-25T11:06:25.745113+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-25T10:00:00+00:00 EmrCreateJobFlowOperator 2023-02-25T11:06:08.749618+00:00 2023-02-25T11:06:09.533725+00:00 0:00:00.784107 345267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-25T11:06:05.726024+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-25T09:00:00+00:00 TriggerDagRunOperator 2023-02-25T11:05:51.528176+00:00 2023-02-25T11:05:52.789925+00:00 0:00:01.261749 345263 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T11:05:43.742468+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-25T10:00:00+00:00 PythonOperator 2023-02-25T11:05:51.223480+00:00 2023-02-25T11:05:58.616776+00:00 0:00:07.393296 345262 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-25T11:05:43.742482+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-25T09:00:00+00:00 TriggerDagRunOperator 2023-02-25T11:05:46.214836+00:00 2023-02-25T11:05:46.667487+00:00 0:00:00.452651 345261 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T11:05:43.742438+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-25T09:00:00+00:00 EmrJobFlowSensor 2023-02-25T10:08:37.012428+00:00 2023-02-25T10:18:38.755969+00:00 0:10:01.743541 345256 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-25T10:08:34.761479+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-25T09:00:00+00:00 EmrCreateJobFlowOperator 2023-02-25T10:08:17.299802+00:00 2023-02-25T10:08:18.213946+00:00 0:00:00.914144 345254 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-25T10:08:14.749968+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-25T09:00:00+00:00 PythonOperator 2023-02-25T10:07:46.423618+00:00 2023-02-25T10:07:56.354110+00:00 0:00:09.930492 345247 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-25T10:07:32.700579+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-25T08:00:00+00:00 TriggerDagRunOperator 2023-02-25T10:07:45.929944+00:00 2023-02-25T10:07:47.539082+00:00 0:00:01.609138 345246 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T10:07:32.700565+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-25T08:00:00+00:00 TriggerDagRunOperator 2023-02-25T10:07:35.585348+00:00 2023-02-25T10:07:36.192503+00:00 0:00:00.607155 345244 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T10:07:32.700514+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-25T08:00:00+00:00 EmrJobFlowSensor 2023-02-25T09:31:06.592463+00:00 2023-02-25T09:41:08.297028+00:00 0:10:01.704565 345237 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-25T09:31:04.127708+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-25T08:00:00+00:00 EmrCreateJobFlowOperator 2023-02-25T09:30:46.518339+00:00 2023-02-25T09:30:47.657042+00:00 0:00:01.138703 345233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-25T09:30:42.078678+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-25T07:00:00+00:00 TriggerDagRunOperator 2023-02-25T09:30:26.311399+00:00 2023-02-25T09:30:26.928167+00:00 0:00:00.616768 345229 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T09:30:20.056260+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-25T08:00:00+00:00 PythonOperator 2023-02-25T09:30:26.045665+00:00 2023-02-25T09:30:30.695996+00:00 0:00:04.650331 345228 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-25T09:30:20.056305+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-25T07:00:00+00:00 TriggerDagRunOperator 2023-02-25T09:30:22.415597+00:00 2023-02-25T09:30:22.841676+00:00 0:00:00.426079 345227 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T09:30:20.056292+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-25T07:00:00+00:00 EmrJobFlowSensor 2023-02-25T08:43:09.189676+00:00 2023-02-25T08:53:10.962825+00:00 0:10:01.773149 345217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-25T08:43:06.590920+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-25T07:00:00+00:00 EmrCreateJobFlowOperator 2023-02-25T08:42:52.908554+00:00 2023-02-25T08:42:54.138451+00:00 0:00:01.229897 345212 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-25T08:42:44.520515+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-25T07:00:00+00:00 PythonOperator 2023-02-25T08:42:30.598913+00:00 2023-02-25T08:42:41.518065+00:00 0:00:10.919152 345208 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-25T08:42:23.929617+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-25T05:00:00+00:00 TriggerDagRunOperator 2023-02-25T08:42:30.428474+00:00 2023-02-25T08:42:31.813785+00:00 0:00:01.385311 345207 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T08:42:23.929603+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-25T05:00:00+00:00 TriggerDagRunOperator 2023-02-25T08:42:26.896293+00:00 2023-02-25T08:42:27.374644+00:00 0:00:00.478351 345206 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T08:42:23.929563+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-25T05:00:00+00:00 EmrJobFlowSensor 2023-02-25T06:28:43.007916+00:00 2023-02-25T06:38:44.740514+00:00 0:10:01.732598 345202 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-25T06:28:39.432152+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-25T05:00:00+00:00 EmrCreateJobFlowOperator 2023-02-25T06:28:22.157908+00:00 2023-02-25T06:28:23.005603+00:00 0:00:00.847695 345198 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-25T06:28:19.380342+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-25T05:00:00+00:00 PythonOperator 2023-02-25T06:28:05.890770+00:00 2023-02-25T06:28:10.216613+00:00 0:00:04.325843 345194 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-25T06:27:57.367441+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-25T04:00:00+00:00 TriggerDagRunOperator 2023-02-25T06:28:05.213568+00:00 2023-02-25T06:28:06.407492+00:00 0:00:01.193924 345193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T06:27:57.367392+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-25T04:00:00+00:00 TriggerDagRunOperator 2023-02-25T06:28:00.518367+00:00 2023-02-25T06:28:01.073345+00:00 0:00:00.554978 345192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T06:27:57.367424+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-25T04:00:00+00:00 EmrJobFlowSensor 2023-02-25T05:41:14.830749+00:00 2023-02-25T05:51:16.529251+00:00 0:10:01.698502 345183 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-25T05:41:12.401322+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-25T04:00:00+00:00 EmrCreateJobFlowOperator 2023-02-25T05:40:52.755650+00:00 2023-02-25T05:40:53.578280+00:00 0:00:00.822630 345179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-25T05:40:50.387576+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-25T03:00:00+00:00 TriggerDagRunOperator 2023-02-25T05:40:35.803827+00:00 2023-02-25T05:40:36.511338+00:00 0:00:00.707511 345176 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T05:40:29.841617+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-25T03:00:00+00:00 TriggerDagRunOperator 2023-02-25T05:40:35.721958+00:00 2023-02-25T05:40:36.364117+00:00 0:00:00.642159 345175 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T05:40:29.841646+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-25T04:00:00+00:00 PythonOperator 2023-02-25T05:40:32.701790+00:00 2023-02-25T05:40:36.610530+00:00 0:00:03.908740 345174 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-25T05:40:29.841660+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-25T03:00:00+00:00 EmrJobFlowSensor 2023-02-25T04:40:44.292917+00:00 2023-02-25T04:50:46.237907+00:00 0:10:01.944990 345167 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-25T04:40:41.477430+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-25T03:00:00+00:00 EmrCreateJobFlowOperator 2023-02-25T04:40:23.154060+00:00 2023-02-25T04:40:24.071259+00:00 0:00:00.917199 345162 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-25T04:40:19.459082+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-25T02:00:00+00:00 TriggerDagRunOperator 2023-02-25T04:40:05.029401+00:00 2023-02-25T04:40:05.833429+00:00 0:00:00.804028 345158 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T04:39:59.277516+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-25T03:00:00+00:00 PythonOperator 2023-02-25T04:40:04.990422+00:00 2023-02-25T04:40:15.236205+00:00 0:00:10.245783 345157 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-25T04:39:59.277557+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-25T02:00:00+00:00 TriggerDagRunOperator 2023-02-25T04:40:02.073893+00:00 2023-02-25T04:40:02.535096+00:00 0:00:00.461203 345156 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T04:39:59.277544+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-25T02:00:00+00:00 EmrJobFlowSensor 2023-02-25T03:46:01.750004+00:00 2023-02-25T03:56:03.838213+00:00 0:10:02.088209 345154 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-25T03:45:59.340254+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-25T02:00:00+00:00 EmrCreateJobFlowOperator 2023-02-25T03:45:39.661114+00:00 2023-02-25T03:45:40.515161+00:00 0:00:00.854047 345151 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-25T03:45:37.301331+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-25T02:00:00+00:00 PythonOperator 2023-02-25T03:45:20.223237+00:00 2023-02-25T03:45:23.370043+00:00 0:00:03.146806 345148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-25T03:45:17.344570+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-25T01:00:00+00:00 TriggerDagRunOperator 2023-02-25T02:23:18.552262+00:00 2023-02-25T02:23:19.175138+00:00 0:00:00.622876 345140 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T02:23:13.748737+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-25T01:00:00+00:00 TriggerDagRunOperator 2023-02-25T02:23:18.191224+00:00 2023-02-25T02:23:18.815002+00:00 0:00:00.623778 345138 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T02:23:13.748720+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-25T01:00:00+00:00 EmrJobFlowSensor 2023-02-25T02:22:54.232277+00:00 2023-02-25T02:22:54.772836+00:00 0:00:00.540559 345132 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-25T02:22:51.737385+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-25T01:00:00+00:00 EmrCreateJobFlowOperator 2023-02-25T02:10:10.321644+00:00 2023-02-25T02:10:12.093390+00:00 0:00:01.771746 345127 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-25T02:09:57.999933+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-25T01:00:00+00:00 PythonOperator 2023-02-25T02:09:39.735473+00:00 2023-02-25T02:09:50.427553+00:00 0:00:10.692080 345121 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-25T02:09:35.990617+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-24T23:00:00+00:00 TriggerDagRunOperator 2023-02-25T00:16:46.801493+00:00 2023-02-25T00:16:47.360619+00:00 0:00:00.559126 345114 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T00:16:43.842322+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-24T23:00:00+00:00 TriggerDagRunOperator 2023-02-25T00:16:46.773108+00:00 2023-02-25T00:16:47.266585+00:00 0:00:00.493477 345113 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T00:16:43.842283+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-24T23:00:00+00:00 EmrJobFlowSensor 2023-02-25T00:03:42.269167+00:00 2023-02-25T00:13:44.057451+00:00 0:10:01.788284 345106 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-25T00:03:39.391955+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-24T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-25T00:03:19.615121+00:00 2023-02-25T00:03:20.558473+00:00 0:00:00.943352 345104 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-25T00:03:17.361290+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-24T23:00:00+00:00 PythonOperator 2023-02-25T00:02:59.664664+00:00 2023-02-25T00:03:03.065860+00:00 0:00:03.401196 345102 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-25T00:02:57.292170+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-24T22:00:00+00:00 TriggerDagRunOperator 2023-02-24T23:26:58.309141+00:00 2023-02-24T23:26:58.753264+00:00 0:00:00.444123 345092 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-24T23:26:55.295604+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-24T22:00:00+00:00 TriggerDagRunOperator 2023-02-24T23:26:57.547153+00:00 2023-02-24T23:26:58.032912+00:00 0:00:00.485759 345091 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-24T23:26:55.295572+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-24T22:00:00+00:00 EmrJobFlowSensor 2023-02-24T23:01:01.858449+00:00 2023-02-24T23:11:03.654031+00:00 0:10:01.795582 345085 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-24T23:00:59.540987+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-24T22:00:00+00:00 EmrCreateJobFlowOperator 2023-02-24T23:00:39.745102+00:00 2023-02-24T23:00:40.817445+00:00 0:00:01.072343 345082 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-24T23:00:37.474517+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-24T22:00:00+00:00 PythonOperator 2023-02-24T23:00:20.182109+00:00 2023-02-24T23:00:24.731990+00:00 0:00:04.549881 345079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-24T23:00:17.460137+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-24T21:00:00+00:00 TriggerDagRunOperator 2023-02-24T22:21:20.175765+00:00 2023-02-24T22:21:20.648123+00:00 0:00:00.472358 345071 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-24T22:21:17.502688+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-24T21:00:00+00:00 TriggerDagRunOperator 2023-02-24T22:21:19.817381+00:00 2023-02-24T22:21:20.278342+00:00 0:00:00.460961 345070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-24T22:21:17.502659+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-24T21:00:00+00:00 EmrJobFlowSensor 2023-02-24T22:10:52.078825+00:00 2023-02-24T22:20:53.894427+00:00 0:10:01.815602 345067 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-24T22:10:49.490567+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-24T21:00:00+00:00 EmrCreateJobFlowOperator 2023-02-24T22:10:29.678569+00:00 2023-02-24T22:10:30.595933+00:00 0:00:00.917364 345064 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-24T22:10:27.469306+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-24T21:00:00+00:00 PythonOperator 2023-02-24T22:10:08.218539+00:00 2023-02-24T22:10:11.469056+00:00 0:00:03.250517 345061 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-24T22:10:05.450648+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-24T20:00:00+00:00 TriggerDagRunOperator 2023-02-24T21:13:19.950163+00:00 2023-02-24T21:13:20.490464+00:00 0:00:00.540301 345049 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-24T21:13:17.543183+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-24T20:00:00+00:00 TriggerDagRunOperator 2023-02-24T21:13:19.912045+00:00 2023-02-24T21:13:20.435328+00:00 0:00:00.523283 345048 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-24T21:13:17.543211+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-24T20:00:00+00:00 EmrJobFlowSensor 2023-02-24T21:03:11.347461+00:00 2023-02-24T21:13:13.156603+00:00 0:10:01.809142 345042 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-24T21:03:09.137628+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-24T20:00:00+00:00 EmrCreateJobFlowOperator 2023-02-24T21:02:49.245518+00:00 2023-02-24T21:02:50.199664+00:00 0:00:00.954146 345040 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-24T21:02:47.085951+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-24T20:00:00+00:00 PythonOperator 2023-02-24T21:02:27.227167+00:00 2023-02-24T21:02:30.196151+00:00 0:00:02.968984 345038 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-24T21:02:25.069250+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-24T19:00:00+00:00 TriggerDagRunOperator 2023-02-24T20:11:04.526756+00:00 2023-02-24T20:11:05.110003+00:00 0:00:00.583247 345029 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-24T20:11:02.297540+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-24T19:00:00+00:00 TriggerDagRunOperator 2023-02-24T20:11:04.511745+00:00 2023-02-24T20:11:05.024244+00:00 0:00:00.512499 345028 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-24T20:11:02.297575+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-24T19:00:00+00:00 EmrJobFlowSensor 2023-02-24T20:00:55.113016+00:00 2023-02-24T20:10:56.950471+00:00 0:10:01.837455 345022 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-24T20:00:52.423228+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-24T19:00:00+00:00 EmrCreateJobFlowOperator 2023-02-24T20:00:34.633381+00:00 2023-02-24T20:00:35.460662+00:00 0:00:00.827281 345020 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-24T20:00:32.422176+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-24T19:00:00+00:00 PythonOperator 2023-02-24T20:00:12.666738+00:00 2023-02-24T20:00:16.505577+00:00 0:00:03.838839 345018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-24T20:00:10.405822+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-24T18:00:00+00:00 TriggerDagRunOperator 2023-02-24T19:11:12.934954+00:00 2023-02-24T19:11:13.460689+00:00 0:00:00.525735 345008 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-24T19:11:10.634768+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-24T18:00:00+00:00 TriggerDagRunOperator 2023-02-24T19:11:12.832838+00:00 2023-02-24T19:11:13.320387+00:00 0:00:00.487549 345007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-24T19:11:10.634800+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-24T18:00:00+00:00 EmrJobFlowSensor 2023-02-24T19:01:02.773900+00:00 2023-02-24T19:11:04.586980+00:00 0:10:01.813080 344998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-24T19:01:00.442852+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-24T18:00:00+00:00 EmrCreateJobFlowOperator 2023-02-24T19:00:40.677977+00:00 2023-02-24T19:00:41.565451+00:00 0:00:00.887474 344997 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-24T19:00:38.412516+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-24T18:00:00+00:00 PythonOperator 2023-02-24T19:00:18.531832+00:00 2023-02-24T19:00:22.538278+00:00 0:00:04.006446 344996 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-24T19:00:16.332030+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-24T17:00:00+00:00 TriggerDagRunOperator 2023-02-24T18:20:47.168515+00:00 2023-02-24T18:20:47.739532+00:00 0:00:00.571017 344987 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-24T18:20:44.294321+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-24T17:00:00+00:00 TriggerDagRunOperator 2023-02-24T18:20:47.008230+00:00 2023-02-24T18:20:47.515118+00:00 0:00:00.506888 344986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-24T18:20:44.294349+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-24T17:00:00+00:00 EmrJobFlowSensor 2023-02-24T18:10:35.567826+00:00 2023-02-24T18:20:37.515654+00:00 0:10:01.947828 344983 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-24T18:10:33.109459+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-24T17:00:00+00:00 EmrCreateJobFlowOperator 2023-02-24T18:10:13.980275+00:00 2023-02-24T18:10:15.171743+00:00 0:00:01.191468 344980 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-24T18:10:10.978572+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-24T17:00:00+00:00 PythonOperator 2023-02-24T18:09:53.274205+00:00 2023-02-24T18:09:57.192382+00:00 0:00:03.918177 344977 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-24T18:09:50.978525+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-24T16:00:00+00:00 TriggerDagRunOperator 2023-02-24T17:27:15.140130+00:00 2023-02-24T17:27:15.753294+00:00 0:00:00.613164 344969 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-24T17:27:11.736467+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-24T16:00:00+00:00 TriggerDagRunOperator 2023-02-24T17:27:14.633758+00:00 2023-02-24T17:27:15.470053+00:00 0:00:00.836295 344968 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-24T17:27:11.736425+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-24T16:00:00+00:00 EmrJobFlowSensor 2023-02-24T17:06:19.369863+00:00 2023-02-24T17:16:21.232866+00:00 0:10:01.863003 344964 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-24T17:06:17.144857+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-24T16:00:00+00:00 EmrCreateJobFlowOperator 2023-02-24T17:05:58.087601+00:00 2023-02-24T17:05:58.898901+00:00 0:00:00.811300 344962 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-24T17:05:55.177382+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-24T16:00:00+00:00 PythonOperator 2023-02-24T17:05:40.095718+00:00 2023-02-24T17:05:44.414367+00:00 0:00:04.318649 344959 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-24T17:05:35.122102+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-24T15:00:00+00:00 TriggerDagRunOperator 2023-02-24T16:32:55.492837+00:00 2023-02-24T16:32:56.323337+00:00 0:00:00.830500 344947 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-24T16:32:50.605729+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-24T15:00:00+00:00 TriggerDagRunOperator 2023-02-24T16:32:53.123678+00:00 2023-02-24T16:32:53.549558+00:00 0:00:00.425880 344946 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-24T16:32:50.605778+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-24T15:00:00+00:00 EmrJobFlowSensor 2023-02-24T16:32:34.868478+00:00 2023-02-24T16:32:35.537114+00:00 0:00:00.668636 344943 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-24T16:32:29.917764+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-24T14:00:00+00:00 TriggerDagRunOperator 2023-02-24T16:32:34.794257+00:00 2023-02-24T16:32:35.330841+00:00 0:00:00.536584 344942 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-24T16:32:29.917749+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-24T14:00:00+00:00 TriggerDagRunOperator 2023-02-24T16:32:33.102268+00:00 2023-02-24T16:32:33.605214+00:00 0:00:00.502946 344941 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-24T16:32:29.917708+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-24T15:00:00+00:00 EmrCreateJobFlowOperator 2023-02-24T16:00:47.049913+00:00 2023-02-24T16:00:48.139191+00:00 0:00:01.089278 344926 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-24T16:00:43.403375+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-24T14:00:00+00:00 EmrJobFlowSensor 2023-02-24T16:00:45.901090+00:00 2023-02-24T16:11:48.216397+00:00 0:11:02.315307 344925 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-24T16:00:43.403341+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-24T15:00:00+00:00 PythonOperator 2023-02-24T16:00:29.712913+00:00 2023-02-24T16:00:35.844081+00:00 0:00:06.131168 344920 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-24T16:00:23.359992+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-24T14:00:00+00:00 EmrCreateJobFlowOperator 2023-02-24T16:00:28.955921+00:00 2023-02-24T16:00:29.984892+00:00 0:00:01.028971 344918 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-24T16:00:23.359918+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-24T14:00:00+00:00 PythonOperator 2023-02-24T16:00:08.819836+00:00 2023-02-24T16:00:16.044437+00:00 0:00:07.224601 344914 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-24T16:00:01.347822+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-24T11:00:00+00:00 TriggerDagRunOperator 2023-02-24T16:00:08.596750+00:00 2023-02-24T16:00:09.793855+00:00 0:00:01.197105 344913 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-24T16:00:01.347773+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-24T11:00:00+00:00 TriggerDagRunOperator 2023-02-24T16:00:03.646803+00:00 2023-02-24T16:00:04.107588+00:00 0:00:00.460785 344912 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-24T16:00:01.347808+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-24T11:00:00+00:00 EmrJobFlowSensor 2023-02-24T12:31:58.232473+00:00 2023-02-24T12:42:00.183744+00:00 0:10:01.951271 344905 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-24T12:31:55.978784+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-24T11:00:00+00:00 EmrCreateJobFlowOperator 2023-02-24T12:31:36.197187+00:00 2023-02-24T12:31:37.066828+00:00 0:00:00.869641 344901 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-24T12:31:33.948771+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-24T10:00:00+00:00 TriggerDagRunOperator 2023-02-24T12:31:19.359496+00:00 2023-02-24T12:31:20.027409+00:00 0:00:00.667913 344898 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-24T12:31:13.658614+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-24T11:00:00+00:00 PythonOperator 2023-02-24T12:31:19.254369+00:00 2023-02-24T12:31:22.945226+00:00 0:00:03.690857 344896 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-24T12:31:13.658628+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-24T10:00:00+00:00 TriggerDagRunOperator 2023-02-24T12:31:16.506798+00:00 2023-02-24T12:31:17.326608+00:00 0:00:00.819810 344895 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-24T12:31:13.658579+00:00 2 default_pool