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-history-job_v002 create_cluster_and_add_emr_steps 2021-04-23T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T09:11:45.155460+00:00 2021-04-23T09:11:46.820532+00:00 0:00:01.665072 20331 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T09:11:42.409096+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-23T08:00:00+00:00 PythonOperator 2021-04-23T09:11:33.138286+00:00 2021-04-23T09:11:36.243879+00:00 0:00:03.105593 20330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T09:11:30.383374+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-23T08:00:00+00:00 PythonOperator 2021-04-23T09:11:23.158393+00:00 2021-04-23T09:11:26.362386+00:00 0:00:03.203993 20329 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T09:11:20.324833+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T08:00:00+00:00 TriggerDagRunOperator 2021-04-23T09:11:06.837462+00:00 2021-04-23T09:11:07.368608+00:00 0:00:00.531146 20328 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T09:11:04.364669+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T08:00:00+00:00 TriggerDagRunOperator 2021-04-23T09:11:06.745603+00:00 2021-04-23T09:11:07.170056+00:00 0:00:00.424453 20327 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T09:11:04.364711+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-23T08:05:00+00:00 EmrJobFlowSensor 2021-04-23T09:05:54.198022+00:00 2021-04-23T09:14:56.887443+00:00 0:09:02.689421 20326 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T09:05:51.831251+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-23T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-23T09:05:34.023607+00:00 2021-04-23T09:05:35.664097+00:00 0:00:01.640490 20325 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T09:05:31.814578+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-23T08:05:00+00:00 PythonOperator 2021-04-23T09:05:11.979416+00:00 2021-04-23T09:05:14.921559+00:00 0:00:02.942143 20324 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T09:05:09.794767+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T08:00:00+00:00 EmrJobFlowSensor 2021-04-23T09:00:55.697818+00:00 2021-04-23T09:10:58.447578+00:00 0:10:02.749760 20323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T09:00:53.362924+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T09:00:35.736579+00:00 2021-04-23T09:00:37.662602+00:00 0:00:01.926023 20322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T09:00:33.340800+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T08:00:00+00:00 PythonOperator 2021-04-23T09:00:13.705783+00:00 2021-04-23T09:00:16.677920+00:00 0:00:02.972137 20321 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T09:00:11.280186+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-23T07:00:00+00:00 EmrJobFlowSensor 2021-04-23T08:12:24.702642+00:00 2021-04-23T08:21:27.203534+00:00 0:09:02.500892 20319 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T08:12:22.528083+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-23T07:00:00+00:00 EmrJobFlowSensor 2021-04-23T08:12:10.733960+00:00 2021-04-23T08:22:13.541343+00:00 0:10:02.807383 20318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T08:12:08.522211+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-23T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T08:12:04.953497+00:00 2021-04-23T08:12:06.832848+00:00 0:00:01.879351 20317 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T08:12:02.511284+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-23T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T08:11:48.883020+00:00 2021-04-23T08:11:50.586063+00:00 0:00:01.703043 20316 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T08:11:46.499074+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-23T07:00:00+00:00 PythonOperator 2021-04-23T08:11:42.683659+00:00 2021-04-23T08:11:45.664917+00:00 0:00:02.981258 20315 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T08:11:40.493150+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-23T07:00:00+00:00 PythonOperator 2021-04-23T08:11:28.793450+00:00 2021-04-23T08:11:32.142134+00:00 0:00:03.348684 20314 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T08:11:26.433513+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T07:00:00+00:00 TriggerDagRunOperator 2021-04-23T08:11:22.882635+00:00 2021-04-23T08:11:23.386287+00:00 0:00:00.503652 20313 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T08:11:20.424733+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T07:00:00+00:00 TriggerDagRunOperator 2021-04-23T08:11:22.690622+00:00 2021-04-23T08:11:23.102674+00:00 0:00:00.412052 20312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T08:11:20.424771+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-23T07:05:00+00:00 EmrJobFlowSensor 2021-04-23T08:05:56.189777+00:00 2021-04-23T08:13:58.945446+00:00 0:08:02.755669 20311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T08:05:54.049456+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-23T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-23T08:05:34.218007+00:00 2021-04-23T08:05:35.944538+00:00 0:00:01.726531 20310 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T08:05:31.940379+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-23T07:05:00+00:00 PythonOperator 2021-04-23T08:05:12.064313+00:00 2021-04-23T08:05:14.977542+00:00 0:00:02.913229 20309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T08:05:09.917849+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T07:00:00+00:00 EmrJobFlowSensor 2021-04-23T08:01:05.844037+00:00 2021-04-23T08:11:08.651209+00:00 0:10:02.807172 20308 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T08:01:03.624125+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T08:00:44.094149+00:00 2021-04-23T08:00:45.902663+00:00 0:00:01.808514 20307 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T08:00:41.662558+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T07:00:00+00:00 PythonOperator 2021-04-23T08:00:22.029579+00:00 2021-04-23T08:00:24.991579+00:00 0:00:02.962000 20306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T08:00:19.589297+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-23T06:00:00+00:00 EmrJobFlowSensor 2021-04-23T07:11:10.716409+00:00 2021-04-23T07:21:14.033997+00:00 0:10:03.317588 20304 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T07:11:08.542841+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-23T06:00:00+00:00 EmrJobFlowSensor 2021-04-23T07:11:06.723897+00:00 2021-04-23T07:19:09.169879+00:00 0:08:02.445982 20303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T07:11:04.537241+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-23T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T07:10:50.996912+00:00 2021-04-23T07:10:52.856939+00:00 0:00:01.860027 20302 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T07:10:48.527594+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-23T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T07:10:46.782647+00:00 2021-04-23T07:10:48.601261+00:00 0:00:01.818614 20301 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T07:10:44.523020+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-23T06:00:00+00:00 PythonOperator 2021-04-23T07:10:29.228096+00:00 2021-04-23T07:10:32.593352+00:00 0:00:03.365256 20300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T07:10:26.578224+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-23T06:00:00+00:00 PythonOperator 2021-04-23T07:10:24.911426+00:00 2021-04-23T07:10:28.496397+00:00 0:00:03.584971 20299 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T07:10:22.570664+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T06:00:00+00:00 TriggerDagRunOperator 2021-04-23T07:10:13.210539+00:00 2021-04-23T07:10:13.699956+00:00 0:00:00.489417 20298 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T07:10:10.562144+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T06:00:00+00:00 TriggerDagRunOperator 2021-04-23T07:10:13.048964+00:00 2021-04-23T07:10:13.593421+00:00 0:00:00.544457 20297 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T07:10:10.562179+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-23T06:05:00+00:00 EmrJobFlowSensor 2021-04-23T07:05:50.387051+00:00 2021-04-23T07:14:53.171805+00:00 0:09:02.784754 20296 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T07:05:48.103341+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-23T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-23T07:05:28.205505+00:00 2021-04-23T07:05:29.847071+00:00 0:00:01.641566 20295 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T07:05:26.021515+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-23T06:05:00+00:00 PythonOperator 2021-04-23T07:05:06.303290+00:00 2021-04-23T07:05:09.468414+00:00 0:00:03.165124 20294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T07:05:04.049286+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T06:00:00+00:00 EmrJobFlowSensor 2021-04-23T07:01:05.633985+00:00 2021-04-23T07:10:08.365358+00:00 0:09:02.731373 20293 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T07:01:03.421710+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T07:00:41.794661+00:00 2021-04-23T07:00:43.537496+00:00 0:00:01.742835 20292 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T07:00:39.459523+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T06:00:00+00:00 PythonOperator 2021-04-23T07:00:13.631581+00:00 2021-04-23T07:00:16.584854+00:00 0:00:02.953273 20291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T07:00:11.382034+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-23T05:00:00+00:00 EmrJobFlowSensor 2021-04-23T06:12:07.512056+00:00 2021-04-23T06:22:10.343139+00:00 0:10:02.831083 20289 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T06:12:05.252092+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-23T05:00:00+00:00 EmrJobFlowSensor 2021-04-23T06:11:59.425677+00:00 2021-04-23T06:22:02.277942+00:00 0:10:02.852265 20288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T06:11:57.276764+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-23T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T06:11:47.399965+00:00 2021-04-23T06:11:49.104250+00:00 0:00:01.704285 20287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T06:11:45.230305+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-23T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T06:11:37.782570+00:00 2021-04-23T06:11:39.461901+00:00 0:00:01.679331 20286 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T06:11:35.340823+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-23T05:00:00+00:00 PythonOperator 2021-04-23T06:11:25.641790+00:00 2021-04-23T06:11:28.667646+00:00 0:00:03.025856 20285 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T06:11:23.188210+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-23T05:00:00+00:00 PythonOperator 2021-04-23T06:11:17.705108+00:00 2021-04-23T06:11:21.215483+00:00 0:00:03.510375 20284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T06:11:15.190875+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T05:00:00+00:00 TriggerDagRunOperator 2021-04-23T06:11:11.852296+00:00 2021-04-23T06:11:12.310753+00:00 0:00:00.458457 20283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T06:11:09.179917+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T05:00:00+00:00 TriggerDagRunOperator 2021-04-23T06:11:11.799300+00:00 2021-04-23T06:11:12.391049+00:00 0:00:00.591749 20282 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T06:11:09.179964+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-23T05:05:00+00:00 EmrJobFlowSensor 2021-04-23T06:05:48.821655+00:00 2021-04-23T06:14:51.409657+00:00 0:09:02.588002 20281 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T06:05:46.497106+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-23T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-23T06:05:26.731897+00:00 2021-04-23T06:05:28.487834+00:00 0:00:01.755937 20280 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T06:05:24.404255+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-23T05:05:00+00:00 PythonOperator 2021-04-23T06:05:04.877629+00:00 2021-04-23T06:05:07.875219+00:00 0:00:02.997590 20279 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T06:05:02.450231+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T05:00:00+00:00 EmrJobFlowSensor 2021-04-23T06:00:50.300993+00:00 2021-04-23T06:10:53.291308+00:00 0:10:02.990315 20278 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T06:00:47.979944+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T06:00:28.103090+00:00 2021-04-23T06:00:29.794321+00:00 0:00:01.691231 20277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T06:00:25.905285+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T05:00:00+00:00 PythonOperator 2021-04-23T06:00:06.256135+00:00 2021-04-23T06:00:09.241968+00:00 0:00:02.985833 20276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T06:00:03.885579+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-23T04:00:00+00:00 EmrJobFlowSensor 2021-04-23T05:12:06.221257+00:00 2021-04-23T05:21:09.062942+00:00 0:09:02.841685 20274 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T05:12:03.855412+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-23T04:00:00+00:00 EmrJobFlowSensor 2021-04-23T05:11:51.953488+00:00 2021-04-23T05:21:54.795261+00:00 0:10:02.841773 20273 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T05:11:49.741210+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-23T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T05:11:43.921296+00:00 2021-04-23T05:11:45.607421+00:00 0:00:01.686125 20272 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T05:11:41.738988+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-23T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T05:11:32.118772+00:00 2021-04-23T05:11:33.822449+00:00 0:00:01.703677 20271 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T05:11:29.724570+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-23T04:00:00+00:00 PythonOperator 2021-04-23T05:11:21.908158+00:00 2021-04-23T05:11:24.886362+00:00 0:00:02.978204 20270 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T05:11:19.697141+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-23T04:00:00+00:00 PythonOperator 2021-04-23T05:11:08.092328+00:00 2021-04-23T05:11:11.307184+00:00 0:00:03.214856 20269 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T05:11:05.752797+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T04:00:00+00:00 TriggerDagRunOperator 2021-04-23T05:11:04.838461+00:00 2021-04-23T05:11:05.436037+00:00 0:00:00.597576 20268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T05:11:01.744516+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T04:00:00+00:00 TriggerDagRunOperator 2021-04-23T05:11:04.078236+00:00 2021-04-23T05:11:04.466722+00:00 0:00:00.388486 20267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T05:11:01.744551+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-23T04:05:00+00:00 EmrJobFlowSensor 2021-04-23T05:06:03.384481+00:00 2021-04-23T05:15:05.931379+00:00 0:09:02.546898 20266 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T05:06:01.246774+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-23T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-23T05:05:41.580897+00:00 2021-04-23T05:05:43.338267+00:00 0:00:01.757370 20265 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T05:05:39.254845+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-23T04:05:00+00:00 PythonOperator 2021-04-23T05:05:19.402729+00:00 2021-04-23T05:05:22.556335+00:00 0:00:03.153606 20264 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T05:05:17.190924+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T04:00:00+00:00 EmrJobFlowSensor 2021-04-23T05:00:52.865767+00:00 2021-04-23T05:10:55.656403+00:00 0:10:02.790636 20263 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T05:00:50.505796+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T05:00:30.902966+00:00 2021-04-23T05:00:32.641940+00:00 0:00:01.738974 20262 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T05:00:28.543404+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T04:00:00+00:00 PythonOperator 2021-04-23T05:00:08.867272+00:00 2021-04-23T05:00:11.903371+00:00 0:00:03.036099 20261 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T05:00:06.421859+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-23T03:00:00+00:00 EmrJobFlowSensor 2021-04-23T04:13:30.112440+00:00 2021-04-23T04:23:32.831719+00:00 0:10:02.719279 20259 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T04:13:27.914164+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-23T03:00:00+00:00 EmrJobFlowSensor 2021-04-23T04:13:26.084619+00:00 2021-04-23T04:23:28.818866+00:00 0:10:02.734247 20258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T04:13:23.906992+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-23T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T04:13:08.391266+00:00 2021-04-23T04:13:10.123831+00:00 0:00:01.732565 20257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T04:13:05.957566+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-23T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T04:13:04.348425+00:00 2021-04-23T04:13:06.238336+00:00 0:00:01.889911 20256 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T04:13:01.964235+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-23T03:00:00+00:00 PythonOperator 2021-04-23T04:12:42.423452+00:00 2021-04-23T04:12:45.942968+00:00 0:00:03.519516 20255 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T04:12:39.866695+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-23T03:00:00+00:00 PythonOperator 2021-04-23T04:12:38.175035+00:00 2021-04-23T04:12:41.770445+00:00 0:00:03.595410 20254 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T04:12:35.861799+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T03:00:00+00:00 TriggerDagRunOperator 2021-04-23T04:12:18.578824+00:00 2021-04-23T04:12:19.132544+00:00 0:00:00.553720 20253 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T04:12:15.943567+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T03:00:00+00:00 TriggerDagRunOperator 2021-04-23T04:12:18.512932+00:00 2021-04-23T04:12:18.947025+00:00 0:00:00.434093 20252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T04:12:15.943603+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-23T03:05:00+00:00 EmrJobFlowSensor 2021-04-23T04:06:01.394643+00:00 2021-04-23T04:14:03.880397+00:00 0:08:02.485754 20251 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T04:05:59.097541+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-23T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-23T04:05:39.359812+00:00 2021-04-23T04:05:40.989464+00:00 0:00:01.629652 20250 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T04:05:37.081011+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-23T03:05:00+00:00 PythonOperator 2021-04-23T04:05:19.255725+00:00 2021-04-23T04:05:22.197108+00:00 0:00:02.941383 20249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T04:05:17.032580+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T03:00:00+00:00 EmrJobFlowSensor 2021-04-23T04:01:05.496134+00:00 2021-04-23T04:12:08.567387+00:00 0:11:03.071253 20248 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T04:01:02.547607+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T04:00:42.879652+00:00 2021-04-23T04:00:45.125753+00:00 0:00:02.246101 20247 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T04:00:40.490755+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T03:00:00+00:00 PythonOperator 2021-04-23T04:00:20.723855+00:00 2021-04-23T04:00:23.684432+00:00 0:00:02.960577 20246 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T04:00:18.378252+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-23T02:00:00+00:00 EmrJobFlowSensor 2021-04-23T03:13:15.327956+00:00 2021-04-23T03:23:18.435345+00:00 0:10:03.107389 20244 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T03:13:13.004013+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-23T02:00:00+00:00 EmrJobFlowSensor 2021-04-23T03:13:09.319627+00:00 2021-04-23T03:22:12.088935+00:00 0:09:02.769308 20243 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T03:13:06.999953+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-23T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T03:12:53.235904+00:00 2021-04-23T03:12:55.115301+00:00 0:00:01.879397 20242 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T03:12:50.986269+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-23T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T03:12:47.296760+00:00 2021-04-23T03:12:48.991063+00:00 0:00:01.694303 20241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T03:12:45.065492+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-23T02:00:00+00:00 PythonOperator 2021-04-23T03:12:31.609542+00:00 2021-04-23T03:12:34.829289+00:00 0:00:03.219747 20240 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T03:12:29.047051+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-23T02:00:00+00:00 PythonOperator 2021-04-23T03:12:27.031702+00:00 2021-04-23T03:12:30.096990+00:00 0:00:03.065288 20239 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T03:12:24.901649+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T02:00:00+00:00 TriggerDagRunOperator 2021-04-23T03:12:15.436566+00:00 2021-04-23T03:12:15.944947+00:00 0:00:00.508381 20238 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T03:12:12.953086+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T02:00:00+00:00 TriggerDagRunOperator 2021-04-23T03:12:15.290589+00:00 2021-04-23T03:12:15.723975+00:00 0:00:00.433386 20237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T03:12:12.953133+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-23T02:05:00+00:00 EmrJobFlowSensor 2021-04-23T03:06:00.264707+00:00 2021-04-23T03:15:02.996077+00:00 0:09:02.731370 20236 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T03:05:57.864945+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-23T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-23T03:05:37.881102+00:00 2021-04-23T03:05:39.644279+00:00 0:00:01.763177 20235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T03:05:35.647053+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-23T02:05:00+00:00 PythonOperator 2021-04-23T03:05:10.049306+00:00 2021-04-23T03:05:12.955806+00:00 0:00:02.906500 20234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T03:05:07.620109+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T02:00:00+00:00 EmrJobFlowSensor 2021-04-23T03:00:57.204942+00:00 2021-04-23T03:12:00.153573+00:00 0:11:02.948631 20233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T03:00:55.087742+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T03:00:35.295982+00:00 2021-04-23T03:00:37.011384+00:00 0:00:01.715402 20232 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T03:00:33.037209+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T02:00:00+00:00 PythonOperator 2021-04-23T03:00:13.371519+00:00 2021-04-23T03:00:16.689279+00:00 0:00:03.317760 20231 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T03:00:11.019888+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-23T01:00:00+00:00 EmrJobFlowSensor 2021-04-23T02:13:22.370766+00:00 2021-04-23T02:22:25.225726+00:00 0:09:02.854960 20229 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T02:13:20.127307+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-23T01:00:00+00:00 EmrJobFlowSensor 2021-04-23T02:13:14.333757+00:00 2021-04-23T02:23:17.251720+00:00 0:10:02.917963 20228 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T02:13:12.118694+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-23T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T02:12:58.471833+00:00 2021-04-23T02:13:00.288270+00:00 0:00:01.816437 20227 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T02:12:56.166779+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-23T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T02:12:54.509630+00:00 2021-04-23T02:12:56.268775+00:00 0:00:01.759145 20226 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-23T02:12:52.170980+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-23T01:00:00+00:00 PythonOperator 2021-04-23T02:12:38.320549+00:00 2021-04-23T02:12:41.610971+00:00 0:00:03.290422 20225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T02:12:36.087850+00:00 2 default_pool