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 booking-processing-job_v002 create_emr_steps 2021-04-04T13:00:00+00:00 PythonOperator 2021-04-04T14:09:27.479323+00:00 2021-04-04T14:09:30.429289+00:00 0:00:02.949966 13508 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T14:09:25.253142+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T13:00:00+00:00 TriggerDagRunOperator 2021-04-04T14:09:03.950092+00:00 2021-04-04T14:09:04.374602+00:00 0:00:00.424510 13507 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T14:09:01.246538+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T13:00:00+00:00 TriggerDagRunOperator 2021-04-04T14:09:03.594856+00:00 2021-04-04T14:09:04.173886+00:00 0:00:00.579030 13506 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T14:09:01.246510+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T13:05:00+00:00 EmrJobFlowSensor 2021-04-04T14:06:33.311413+00:00 2021-04-04T14:14:35.740139+00:00 0:08:02.428726 13505 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T14:06:31.074040+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T14:05:39.536729+00:00 2021-04-04T14:05:41.252872+00:00 0:00:01.716143 13503 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T14:05:36.987762+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T13:05:00+00:00 PythonOperator 2021-04-04T14:05:17.088854+00:00 2021-04-04T14:05:19.866581+00:00 0:00:02.777727 13502 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T14:05:14.908003+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T13:00:00+00:00 EmrJobFlowSensor 2021-04-04T14:00:48.685463+00:00 2021-04-04T14:08:51.177681+00:00 0:08:02.492218 13501 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T14:00:46.426055+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T14:00:28.620007+00:00 2021-04-04T14:00:30.322511+00:00 0:00:01.702504 13500 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T14:00:26.408728+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T13:00:00+00:00 PythonOperator 2021-04-04T14:00:06.746468+00:00 2021-04-04T14:00:09.562983+00:00 0:00:02.816515 13499 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T14:00:04.388665+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T12:00:00+00:00 EmrJobFlowSensor 2021-04-04T13:12:16.179782+00:00 2021-04-04T13:21:18.922900+00:00 0:09:02.743118 13498 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T13:12:13.793509+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T12:00:00+00:00 EmrJobFlowSensor 2021-04-04T13:12:04.068449+00:00 2021-04-04T13:22:06.889662+00:00 0:10:02.821213 13497 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T13:12:01.700014+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T13:11:56.051206+00:00 2021-04-04T13:11:57.697828+00:00 0:00:01.646622 13496 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T13:11:53.753144+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T13:11:41.948204+00:00 2021-04-04T13:11:43.743093+00:00 0:00:01.794889 13495 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T13:11:39.676799+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T12:00:00+00:00 PythonOperator 2021-04-04T13:11:33.917928+00:00 2021-04-04T13:11:36.935375+00:00 0:00:03.017447 13494 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T13:11:31.672764+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T12:00:00+00:00 PythonOperator 2021-04-04T13:11:21.936398+00:00 2021-04-04T13:11:24.766932+00:00 0:00:02.830534 13493 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T13:11:19.612404+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T12:00:00+00:00 TriggerDagRunOperator 2021-04-04T13:11:14.233283+00:00 2021-04-04T13:11:14.682388+00:00 0:00:00.449105 13492 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T13:11:11.607877+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T12:00:00+00:00 TriggerDagRunOperator 2021-04-04T13:11:14.085451+00:00 2021-04-04T13:11:14.667636+00:00 0:00:00.582185 13491 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T13:11:11.607913+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T12:05:00+00:00 EmrJobFlowSensor 2021-04-04T13:06:43.619241+00:00 2021-04-04T13:15:46.281566+00:00 0:09:02.662325 13490 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T13:06:41.233613+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T13:06:17.467868+00:00 2021-04-04T13:06:19.198898+00:00 0:00:01.731030 13489 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T13:06:15.217157+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T12:05:00+00:00 PythonOperator 2021-04-04T13:05:57.756022+00:00 2021-04-04T13:06:00.473722+00:00 0:00:02.717700 13488 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T13:05:55.249489+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T12:00:00+00:00 EmrJobFlowSensor 2021-04-04T13:01:04.038764+00:00 2021-04-04T13:11:06.764465+00:00 0:10:02.725701 13486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T13:01:01.745364+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T13:00:41.911778+00:00 2021-04-04T13:00:43.598166+00:00 0:00:01.686388 13485 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T13:00:39.693465+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T12:00:00+00:00 PythonOperator 2021-04-04T13:00:05.964176+00:00 2021-04-04T13:00:08.682362+00:00 0:00:02.718186 13484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T13:00:03.626304+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T11:00:00+00:00 EmrJobFlowSensor 2021-04-04T12:11:08.985588+00:00 2021-04-04T12:20:11.672550+00:00 0:09:02.686962 13483 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T12:11:06.745722+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T11:00:00+00:00 EmrJobFlowSensor 2021-04-04T12:11:05.161429+00:00 2021-04-04T12:20:07.920843+00:00 0:09:02.759414 13482 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T12:11:02.747219+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T12:10:46.855425+00:00 2021-04-04T12:10:48.636784+00:00 0:00:01.781359 13481 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T12:10:44.618262+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T12:10:42.801689+00:00 2021-04-04T12:10:44.475281+00:00 0:00:01.673592 13480 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T12:10:40.617030+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T11:00:00+00:00 PythonOperator 2021-04-04T12:10:25.106811+00:00 2021-04-04T12:10:28.243294+00:00 0:00:03.136483 13479 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T12:10:22.666098+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T11:00:00+00:00 PythonOperator 2021-04-04T12:10:20.897106+00:00 2021-04-04T12:10:23.691980+00:00 0:00:02.794874 13478 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T12:10:18.597093+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T11:00:00+00:00 TriggerDagRunOperator 2021-04-04T12:10:06.977972+00:00 2021-04-04T12:10:07.493044+00:00 0:00:00.515072 13477 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T12:10:04.586258+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T11:00:00+00:00 TriggerDagRunOperator 2021-04-04T12:10:06.789475+00:00 2021-04-04T12:10:07.196340+00:00 0:00:00.406865 13476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T12:10:04.586225+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T11:05:00+00:00 EmrJobFlowSensor 2021-04-04T12:06:04.697617+00:00 2021-04-04T12:15:07.312070+00:00 0:09:02.614453 13475 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T12:06:02.247621+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T12:05:44.583965+00:00 2021-04-04T12:05:46.317780+00:00 0:00:01.733815 13474 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T12:05:42.173790+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T11:05:00+00:00 PythonOperator 2021-04-04T12:05:22.488505+00:00 2021-04-04T12:05:25.161595+00:00 0:00:02.673090 13473 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T12:05:20.099972+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T11:00:00+00:00 EmrJobFlowSensor 2021-04-04T12:00:49.909403+00:00 2021-04-04T12:09:52.635361+00:00 0:09:02.725958 13471 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T12:00:47.622693+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T12:00:26.307259+00:00 2021-04-04T12:00:27.979414+00:00 0:00:01.672155 13470 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T12:00:23.680826+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T11:00:00+00:00 PythonOperator 2021-04-04T12:00:06.108440+00:00 2021-04-04T12:00:08.849909+00:00 0:00:02.741469 13469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T12:00:03.662635+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T10:00:00+00:00 EmrJobFlowSensor 2021-04-04T11:12:37.539582+00:00 2021-04-04T11:22:40.319906+00:00 0:10:02.780324 13468 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T11:12:34.967010+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T10:00:00+00:00 EmrJobFlowSensor 2021-04-04T11:12:31.136226+00:00 2021-04-04T11:21:33.692633+00:00 0:09:02.556407 13467 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T11:12:28.898314+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T11:12:15.521385+00:00 2021-04-04T11:12:17.408561+00:00 0:00:01.887176 13466 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T11:12:12.957795+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T11:12:09.312471+00:00 2021-04-04T11:12:11.143145+00:00 0:00:01.830674 13465 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T11:12:06.879091+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T10:00:00+00:00 PythonOperator 2021-04-04T11:11:53.315585+00:00 2021-04-04T11:11:56.208813+00:00 0:00:02.893228 13464 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T11:11:50.864754+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T10:00:00+00:00 PythonOperator 2021-04-04T11:11:49.067778+00:00 2021-04-04T11:11:52.002103+00:00 0:00:02.934325 13463 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T11:11:46.863230+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T10:00:00+00:00 TriggerDagRunOperator 2021-04-04T11:11:27.215319+00:00 2021-04-04T11:11:27.658391+00:00 0:00:00.443072 13462 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T11:11:24.816825+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T10:00:00+00:00 TriggerDagRunOperator 2021-04-04T11:11:27.125637+00:00 2021-04-04T11:11:27.683226+00:00 0:00:00.557589 13461 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T11:11:24.816853+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T10:05:00+00:00 EmrJobFlowSensor 2021-04-04T11:06:08.606634+00:00 2021-04-04T11:15:11.266567+00:00 0:09:02.659933 13460 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T11:06:06.317311+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T11:05:46.766121+00:00 2021-04-04T11:05:48.531415+00:00 0:00:01.765294 13459 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T11:05:44.363114+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T10:05:00+00:00 PythonOperator 2021-04-04T11:05:22.436429+00:00 2021-04-04T11:05:25.137008+00:00 0:00:02.700579 13458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T11:05:20.252234+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T10:00:00+00:00 EmrJobFlowSensor 2021-04-04T11:02:06.327398+00:00 2021-04-04T11:11:09.164528+00:00 0:09:02.837130 13457 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T11:02:03.957082+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T11:01:44.026062+00:00 2021-04-04T11:01:45.739923+00:00 0:00:01.713861 13456 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T11:01:41.857902+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T10:00:00+00:00 PythonOperator 2021-04-04T11:01:12.615693+00:00 2021-04-04T11:01:15.457791+00:00 0:00:02.842098 13455 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T11:01:09.874778+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T09:00:00+00:00 EmrJobFlowSensor 2021-04-04T10:11:24.109582+00:00 2021-04-04T10:21:27.023721+00:00 0:10:02.914139 13453 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T10:11:21.634613+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T09:00:00+00:00 EmrJobFlowSensor 2021-04-04T10:11:21.893042+00:00 2021-04-04T10:21:24.718195+00:00 0:10:02.825153 13452 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T10:11:19.632381+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T10:11:03.821994+00:00 2021-04-04T10:11:05.558398+00:00 0:00:01.736404 13451 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T10:11:01.617979+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T10:11:02.026956+00:00 2021-04-04T10:11:03.939901+00:00 0:00:01.912945 13450 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T10:10:59.663445+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T09:00:00+00:00 PythonOperator 2021-04-04T10:10:41.875010+00:00 2021-04-04T10:10:44.571687+00:00 0:00:02.696677 13449 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T10:10:39.602841+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T09:00:00+00:00 PythonOperator 2021-04-04T10:10:40.091859+00:00 2021-04-04T10:10:43.185132+00:00 0:00:03.093273 13448 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T10:10:37.654307+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T09:00:00+00:00 TriggerDagRunOperator 2021-04-04T10:10:26.087166+00:00 2021-04-04T10:10:26.538761+00:00 0:00:00.451595 13447 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T10:10:23.685384+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T09:00:00+00:00 TriggerDagRunOperator 2021-04-04T10:10:25.998394+00:00 2021-04-04T10:10:26.585282+00:00 0:00:00.586888 13446 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T10:10:23.685419+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T09:05:00+00:00 EmrJobFlowSensor 2021-04-04T10:05:57.497442+00:00 2021-04-04T10:15:00.109609+00:00 0:09:02.612167 13445 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T10:05:55.291410+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T10:05:35.587491+00:00 2021-04-04T10:05:37.314041+00:00 0:00:01.726550 13444 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T10:05:33.219525+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T09:05:00+00:00 PythonOperator 2021-04-04T10:05:13.389694+00:00 2021-04-04T10:05:16.079990+00:00 0:00:02.690296 13443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T10:05:11.193308+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T09:00:00+00:00 EmrJobFlowSensor 2021-04-04T10:01:14.847876+00:00 2021-04-04T10:10:17.620397+00:00 0:09:02.772521 13442 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T10:01:12.508789+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T10:00:54.799794+00:00 2021-04-04T10:00:56.581350+00:00 0:00:01.781556 13441 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T10:00:52.449908+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T09:00:00+00:00 PythonOperator 2021-04-04T10:00:22.815828+00:00 2021-04-04T10:00:25.590785+00:00 0:00:02.774957 13440 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T10:00:20.421534+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T08:00:00+00:00 EmrJobFlowSensor 2021-04-04T09:11:07.365009+00:00 2021-04-04T09:20:09.996243+00:00 0:09:02.631234 13438 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T09:11:05.113517+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T08:00:00+00:00 EmrJobFlowSensor 2021-04-04T09:10:53.586439+00:00 2021-04-04T09:20:56.267662+00:00 0:10:02.681223 13437 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T09:10:51.102321+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T09:10:45.313721+00:00 2021-04-04T09:10:46.973079+00:00 0:00:01.659358 13436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T09:10:43.098114+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T09:10:29.655529+00:00 2021-04-04T09:10:31.329546+00:00 0:00:01.674017 13435 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T09:10:27.153529+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T08:00:00+00:00 PythonOperator 2021-04-04T09:10:23.312322+00:00 2021-04-04T09:10:26.098052+00:00 0:00:02.785730 13434 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T09:10:21.038501+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T08:00:00+00:00 PythonOperator 2021-04-04T09:10:09.576118+00:00 2021-04-04T09:10:12.686232+00:00 0:00:03.110114 13433 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T09:10:07.058341+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T08:00:00+00:00 TriggerDagRunOperator 2021-04-04T09:09:59.537739+00:00 2021-04-04T09:10:00.156549+00:00 0:00:00.618810 13432 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T09:09:56.972171+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T08:00:00+00:00 TriggerDagRunOperator 2021-04-04T09:09:59.233914+00:00 2021-04-04T09:09:59.703864+00:00 0:00:00.469950 13431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T09:09:56.972206+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T08:05:00+00:00 EmrJobFlowSensor 2021-04-04T09:06:06.993908+00:00 2021-04-04T09:15:09.635426+00:00 0:09:02.641518 13430 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T09:06:04.570384+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T09:05:44.672611+00:00 2021-04-04T09:05:46.338086+00:00 0:00:01.665475 13429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T09:05:42.495380+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T08:05:00+00:00 PythonOperator 2021-04-04T09:05:14.652081+00:00 2021-04-04T09:05:17.369312+00:00 0:00:02.717231 13428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T09:05:12.464734+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T08:00:00+00:00 EmrJobFlowSensor 2021-04-04T09:00:50.302082+00:00 2021-04-04T09:09:53.002715+00:00 0:09:02.700633 13427 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T09:00:48.098629+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T09:00:30.551481+00:00 2021-04-04T09:00:32.366464+00:00 0:00:01.814983 13426 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T09:00:28.162253+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T08:00:00+00:00 PythonOperator 2021-04-04T09:00:08.720953+00:00 2021-04-04T09:00:11.554998+00:00 0:00:02.834045 13425 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T09:00:06.063625+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T07:00:00+00:00 EmrJobFlowSensor 2021-04-04T08:12:58.173263+00:00 2021-04-04T08:22:00.750760+00:00 0:09:02.577497 13423 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T08:12:55.989546+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T07:00:00+00:00 EmrJobFlowSensor 2021-04-04T08:12:48.290107+00:00 2021-04-04T08:22:51.127747+00:00 0:10:02.837640 13422 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T08:12:45.979290+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T08:12:32.322853+00:00 2021-04-04T08:12:34.160077+00:00 0:00:01.837224 13421 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T08:12:29.974263+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T08:12:24.298316+00:00 2021-04-04T08:12:25.995172+00:00 0:00:01.696856 13420 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T08:12:21.904749+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T07:00:00+00:00 PythonOperator 2021-04-04T08:12:10.533122+00:00 2021-04-04T08:12:13.331913+00:00 0:00:02.798791 13419 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T08:12:07.889573+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T07:00:00+00:00 PythonOperator 2021-04-04T08:12:04.459425+00:00 2021-04-04T08:12:07.433715+00:00 0:00:02.974290 13418 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T08:12:01.892330+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T07:00:00+00:00 TriggerDagRunOperator 2021-04-04T08:11:58.551752+00:00 2021-04-04T08:11:59.081946+00:00 0:00:00.530194 13417 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T08:11:55.952871+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T07:00:00+00:00 TriggerDagRunOperator 2021-04-04T08:11:58.402615+00:00 2021-04-04T08:11:58.840140+00:00 0:00:00.437525 13416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T08:11:55.952923+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T07:05:00+00:00 EmrJobFlowSensor 2021-04-04T08:06:01.855360+00:00 2021-04-04T08:15:04.467320+00:00 0:09:02.611960 13415 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T08:05:59.454683+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T08:05:41.639378+00:00 2021-04-04T08:05:43.382651+00:00 0:00:01.743273 13414 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T08:05:39.363025+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T07:05:00+00:00 PythonOperator 2021-04-04T08:05:19.726510+00:00 2021-04-04T08:05:22.406661+00:00 0:00:02.680151 13413 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T08:05:17.363088+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T07:00:00+00:00 EmrJobFlowSensor 2021-04-04T08:01:19.171818+00:00 2021-04-04T08:11:22.025393+00:00 0:10:02.853575 13412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T08:01:16.871976+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T08:00:45.417665+00:00 2021-04-04T08:00:47.143018+00:00 0:00:01.725353 13411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T08:00:42.824345+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T07:00:00+00:00 PythonOperator 2021-04-04T08:00:23.119192+00:00 2021-04-04T08:00:25.969827+00:00 0:00:02.850635 13410 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T08:00:20.807923+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T06:00:00+00:00 EmrJobFlowSensor 2021-04-04T07:13:27.737005+00:00 2021-04-04T07:23:30.573560+00:00 0:10:02.836555 13408 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T07:13:25.366021+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T07:13:05.576740+00:00 2021-04-04T07:13:07.261596+00:00 0:00:01.684856 13407 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T07:13:03.353234+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T06:00:00+00:00 PythonOperator 2021-04-04T07:12:45.621590+00:00 2021-04-04T07:12:48.576218+00:00 0:00:02.954628 13406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T07:12:43.258842+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T06:00:00+00:00 EmrJobFlowSensor 2021-04-04T07:12:33.592533+00:00 2021-04-04T07:21:36.198519+00:00 0:09:02.605986 13405 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T07:12:31.258434+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T07:12:09.564820+00:00 2021-04-04T07:12:11.247640+00:00 0:00:01.682820 13404 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T07:12:07.220526+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T06:00:00+00:00 PythonOperator 2021-04-04T07:11:43.412244+00:00 2021-04-04T07:11:46.148143+00:00 0:00:02.735899 13403 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T07:11:41.208691+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T06:00:00+00:00 TriggerDagRunOperator 2021-04-04T07:11:29.693685+00:00 2021-04-04T07:11:30.234429+00:00 0:00:00.540744 13402 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T07:11:27.189891+00:00 2 default_pool