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-10T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T11:12:36.717019+00:00 2021-04-10T11:12:38.574020+00:00 0:00:01.857001 15628 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T11:12:34.335008+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T11:12:16.621393+00:00 2021-04-10T11:12:18.352016+00:00 0:00:01.730623 15627 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T11:12:14.319934+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T10:00:00+00:00 PythonOperator 2021-04-10T11:12:12.542738+00:00 2021-04-10T11:12:15.406618+00:00 0:00:02.863880 15626 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T11:12:10.316617+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T10:00:00+00:00 PythonOperator 2021-04-10T11:11:56.684735+00:00 2021-04-10T11:12:00.089132+00:00 0:00:03.404397 15625 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T11:11:54.305451+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T10:00:00+00:00 TriggerDagRunOperator 2021-04-10T11:11:51.006556+00:00 2021-04-10T11:11:51.446509+00:00 0:00:00.439953 15624 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T11:11:48.366693+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T10:00:00+00:00 TriggerDagRunOperator 2021-04-10T11:11:50.860654+00:00 2021-04-10T11:11:51.388044+00:00 0:00:00.527390 15623 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T11:11:48.366743+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T10:05:00+00:00 EmrJobFlowSensor 2021-04-10T11:05:50.016223+00:00 2021-04-10T11:14:52.700799+00:00 0:09:02.684576 15622 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T11:05:47.643356+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T11:05:29.861410+00:00 2021-04-10T11:05:31.507067+00:00 0:00:01.645657 15621 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T11:05:27.643495+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T10:05:00+00:00 PythonOperator 2021-04-10T11:05:07.828220+00:00 2021-04-10T11:05:10.594232+00:00 0:00:02.766012 15620 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T11:05:05.605834+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T10:00:00+00:00 EmrJobFlowSensor 2021-04-10T11:01:27.597398+00:00 2021-04-10T11:11:30.365183+00:00 0:10:02.767785 15619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T11:01:25.313672+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T11:01:07.539030+00:00 2021-04-10T11:01:09.380376+00:00 0:00:01.841346 15618 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T11:01:05.296172+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T10:00:00+00:00 PythonOperator 2021-04-10T11:00:45.956974+00:00 2021-04-10T11:00:48.838144+00:00 0:00:02.881170 15617 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T11:00:43.284350+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T09:00:00+00:00 EmrJobFlowSensor 2021-04-10T10:12:20.305671+00:00 2021-04-10T10:22:23.231446+00:00 0:10:02.925775 15615 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T10:12:18.059749+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T09:00:00+00:00 EmrJobFlowSensor 2021-04-10T10:12:18.255132+00:00 2021-04-10T10:23:21.203357+00:00 0:11:02.948225 15614 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T10:12:16.058384+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T10:11:58.454931+00:00 2021-04-10T10:12:00.234170+00:00 0:00:01.779239 15613 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T10:11:56.046439+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T10:11:56.423416+00:00 2021-04-10T10:11:58.181367+00:00 0:00:01.757951 15612 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T10:11:54.143990+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T09:00:00+00:00 PythonOperator 2021-04-10T10:11:36.619380+00:00 2021-04-10T10:11:39.660718+00:00 0:00:03.041338 15611 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T10:11:34.055618+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T09:00:00+00:00 PythonOperator 2021-04-10T10:11:36.550536+00:00 2021-04-10T10:11:39.306385+00:00 0:00:02.755849 15610 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T10:11:34.055589+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T09:00:00+00:00 TriggerDagRunOperator 2021-04-10T10:11:14.521293+00:00 2021-04-10T10:11:15.077761+00:00 0:00:00.556468 15609 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T10:11:11.997484+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T09:00:00+00:00 TriggerDagRunOperator 2021-04-10T10:11:14.400501+00:00 2021-04-10T10:11:14.839311+00:00 0:00:00.438810 15608 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T10:11:11.997447+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T09:05:00+00:00 EmrJobFlowSensor 2021-04-10T10:05:59.963636+00:00 2021-04-10T10:15:02.618716+00:00 0:09:02.655080 15607 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T10:05:57.655797+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T10:05:39.864362+00:00 2021-04-10T10:05:41.585288+00:00 0:00:01.720926 15606 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T10:05:37.515632+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T09:05:00+00:00 PythonOperator 2021-04-10T10:05:13.796744+00:00 2021-04-10T10:05:16.542570+00:00 0:00:02.745826 15605 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T10:05:11.502064+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T09:00:00+00:00 EmrJobFlowSensor 2021-04-10T10:00:55.361737+00:00 2021-04-10T10:10:58.020733+00:00 0:10:02.658996 15604 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T10:00:53.048525+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T10:00:33.320979+00:00 2021-04-10T10:00:35.455315+00:00 0:00:02.134336 15603 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T10:00:31.034198+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T09:00:00+00:00 PythonOperator 2021-04-10T10:00:13.700160+00:00 2021-04-10T10:00:16.539701+00:00 0:00:02.839541 15602 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T10:00:11.069343+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T08:00:00+00:00 EmrJobFlowSensor 2021-04-10T09:22:10.344522+00:00 2021-04-10T09:22:11.829719+00:00 0:00:01.485197 15600 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T09:22:08.073413+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T08:00:00+00:00 EmrJobFlowSensor 2021-04-10T09:17:04.517485+00:00 2021-04-10T09:20:06.521437+00:00 0:03:02.003952 15599 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T09:17:01.669592+00:00 3 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T09:10:17.637220+00:00 2021-04-10T09:10:19.351937+00:00 0:00:01.714717 15596 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T09:10:15.153911+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T09:10:11.375063+00:00 2021-04-10T09:10:13.112731+00:00 0:00:01.737668 15595 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T09:10:09.149450+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T08:00:00+00:00 PythonOperator 2021-04-10T09:09:53.573592+00:00 2021-04-10T09:09:56.315322+00:00 0:00:02.741730 15594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T09:09:51.009300+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T08:00:00+00:00 PythonOperator 2021-04-10T09:09:43.387357+00:00 2021-04-10T09:09:46.532662+00:00 0:00:03.145305 15593 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T09:09:40.998240+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T08:00:00+00:00 TriggerDagRunOperator 2021-04-10T09:09:21.221572+00:00 2021-04-10T09:09:21.687677+00:00 0:00:00.466105 15592 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T09:09:18.985421+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T08:00:00+00:00 TriggerDagRunOperator 2021-04-10T09:09:21.209913+00:00 2021-04-10T09:09:21.833784+00:00 0:00:00.623871 15591 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T09:09:18.985373+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T08:05:00+00:00 EmrJobFlowSensor 2021-04-10T09:05:59.186359+00:00 2021-04-10T09:15:01.746603+00:00 0:09:02.560244 15590 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T09:05:56.472068+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T09:05:36.741097+00:00 2021-04-10T09:05:39.025497+00:00 0:00:02.284400 15589 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T09:05:34.451324+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T08:05:00+00:00 PythonOperator 2021-04-10T09:05:16.731978+00:00 2021-04-10T09:05:19.416966+00:00 0:00:02.684988 15588 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T09:05:14.442846+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T08:00:00+00:00 EmrJobFlowSensor 2021-04-10T09:01:00.748939+00:00 2021-04-10T09:09:03.400240+00:00 0:08:02.651301 15587 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T09:00:58.064834+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T09:00:40.404390+00:00 2021-04-10T09:00:42.211483+00:00 0:00:01.807093 15586 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T09:00:37.958533+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T08:00:00+00:00 PythonOperator 2021-04-10T09:00:18.359194+00:00 2021-04-10T09:00:21.203175+00:00 0:00:02.843981 15585 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T09:00:15.891268+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T07:00:00+00:00 EmrJobFlowSensor 2021-04-10T08:12:45.387013+00:00 2021-04-10T08:21:48.100908+00:00 0:09:02.713895 15583 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T08:12:43.202749+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T07:00:00+00:00 EmrJobFlowSensor 2021-04-10T08:12:27.598764+00:00 2021-04-10T08:21:30.185608+00:00 0:09:02.586844 15582 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T08:12:25.256105+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T08:12:23.813298+00:00 2021-04-10T08:12:25.706758+00:00 0:00:01.893460 15581 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T08:12:21.252423+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T08:12:05.781065+00:00 2021-04-10T08:12:07.572906+00:00 0:00:01.791841 15580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T08:12:03.098256+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T07:00:00+00:00 PythonOperator 2021-04-10T08:12:03.533967+00:00 2021-04-10T08:12:06.552207+00:00 0:00:03.018240 15579 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T08:12:01.143800+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T07:00:00+00:00 PythonOperator 2021-04-10T08:11:39.661837+00:00 2021-04-10T08:11:42.701390+00:00 0:00:03.039553 15578 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T08:11:37.013556+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T07:00:00+00:00 TriggerDagRunOperator 2021-04-10T08:11:33.369591+00:00 2021-04-10T08:11:33.964777+00:00 0:00:00.595186 15577 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T08:11:31.011511+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T07:00:00+00:00 TriggerDagRunOperator 2021-04-10T08:11:33.263617+00:00 2021-04-10T08:11:33.685596+00:00 0:00:00.421979 15576 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T08:11:31.011542+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T07:05:00+00:00 EmrJobFlowSensor 2021-04-10T08:06:03.013119+00:00 2021-04-10T08:14:05.567045+00:00 0:08:02.553926 15575 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T08:06:00.454433+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T08:05:40.778075+00:00 2021-04-10T08:05:42.511452+00:00 0:00:01.733377 15574 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T08:05:38.440825+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T07:05:00+00:00 PythonOperator 2021-04-10T08:05:20.460562+00:00 2021-04-10T08:05:23.207956+00:00 0:00:02.747394 15573 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T08:05:18.300076+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T07:00:00+00:00 EmrJobFlowSensor 2021-04-10T08:01:06.411954+00:00 2021-04-10T08:11:09.381907+00:00 0:10:02.969953 15572 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T08:01:04.010216+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T08:00:44.225267+00:00 2021-04-10T08:00:45.933569+00:00 0:00:01.708302 15571 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T08:00:41.942558+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T07:00:00+00:00 PythonOperator 2021-04-10T08:00:20.709938+00:00 2021-04-10T08:00:23.423850+00:00 0:00:02.713912 15570 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T08:00:17.984418+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T06:00:00+00:00 EmrJobFlowSensor 2021-04-10T07:10:08.470953+00:00 2021-04-10T07:19:11.144993+00:00 0:09:02.674040 15568 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T07:10:06.188043+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T06:00:00+00:00 EmrJobFlowSensor 2021-04-10T07:09:54.439057+00:00 2021-04-10T07:19:57.107726+00:00 0:10:02.668669 15567 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T07:09:52.123590+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T07:09:46.482744+00:00 2021-04-10T07:09:48.559287+00:00 0:00:02.076543 15566 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T07:09:44.111481+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T07:09:34.334915+00:00 2021-04-10T07:09:36.313461+00:00 0:00:01.978546 15565 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T07:09:32.099237+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T06:00:00+00:00 PythonOperator 2021-04-10T07:09:24.628867+00:00 2021-04-10T07:09:27.470686+00:00 0:00:02.841819 15564 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T07:09:22.155244+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T06:00:00+00:00 PythonOperator 2021-04-10T07:09:10.552240+00:00 2021-04-10T07:09:13.911356+00:00 0:00:03.359116 15563 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T07:09:08.052884+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T06:00:00+00:00 TriggerDagRunOperator 2021-04-10T07:09:00.857496+00:00 2021-04-10T07:09:01.476865+00:00 0:00:00.619369 15562 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T07:08:58.066045+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T06:00:00+00:00 TriggerDagRunOperator 2021-04-10T07:09:00.646272+00:00 2021-04-10T07:09:01.067880+00:00 0:00:00.421608 15561 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T07:08:58.065999+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T06:05:00+00:00 EmrJobFlowSensor 2021-04-10T07:06:02.018988+00:00 2021-04-10T07:14:04.579136+00:00 0:08:02.560148 15560 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T07:05:59.783208+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T07:05:40.142587+00:00 2021-04-10T07:05:41.879762+00:00 0:00:01.737175 15559 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T07:05:37.725393+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T06:05:00+00:00 PythonOperator 2021-04-10T07:05:19.744070+00:00 2021-04-10T07:05:22.427945+00:00 0:00:02.683875 15558 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T07:05:17.627017+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T06:00:00+00:00 EmrJobFlowSensor 2021-04-10T07:00:51.401953+00:00 2021-04-10T07:08:54.060017+00:00 0:08:02.658064 15557 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T07:00:49.206219+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T07:00:29.423465+00:00 2021-04-10T07:00:31.147311+00:00 0:00:01.723846 15556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T07:00:27.157082+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T06:00:00+00:00 PythonOperator 2021-04-10T07:00:09.775057+00:00 2021-04-10T07:00:12.624379+00:00 0:00:02.849322 15555 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T07:00:07.133706+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T05:00:00+00:00 EmrJobFlowSensor 2021-04-10T06:10:57.390602+00:00 2021-04-10T06:19:59.975038+00:00 0:09:02.584436 15553 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T06:10:55.158410+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T05:00:00+00:00 EmrJobFlowSensor 2021-04-10T06:10:49.453537+00:00 2021-04-10T06:19:52.026528+00:00 0:09:02.572991 15552 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T06:10:47.154378+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T06:10:35.520509+00:00 2021-04-10T06:10:37.281003+00:00 0:00:01.760494 15551 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T06:10:33.159206+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T06:10:27.391432+00:00 2021-04-10T06:10:29.203208+00:00 0:00:01.811776 15550 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T06:10:25.111210+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T05:00:00+00:00 PythonOperator 2021-04-10T06:10:13.520577+00:00 2021-04-10T06:10:16.447639+00:00 0:00:02.927062 15549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T06:10:11.100283+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T05:00:00+00:00 PythonOperator 2021-04-10T06:10:07.401336+00:00 2021-04-10T06:10:10.143906+00:00 0:00:02.742570 15548 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T06:10:05.096158+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T05:00:00+00:00 TriggerDagRunOperator 2021-04-10T06:09:59.830981+00:00 2021-04-10T06:10:00.362335+00:00 0:00:00.531354 15547 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T06:09:57.163089+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T05:00:00+00:00 TriggerDagRunOperator 2021-04-10T06:09:59.524187+00:00 2021-04-10T06:09:59.940236+00:00 0:00:00.416049 15546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T06:09:57.163048+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T05:05:00+00:00 EmrJobFlowSensor 2021-04-10T06:05:57.010308+00:00 2021-04-10T06:14:59.579596+00:00 0:09:02.569288 15545 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T06:05:54.697953+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T06:05:35.276721+00:00 2021-04-10T06:05:36.973253+00:00 0:00:01.696532 15544 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T06:05:32.675657+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T05:05:00+00:00 PythonOperator 2021-04-10T06:05:12.759695+00:00 2021-04-10T06:05:15.417468+00:00 0:00:02.657773 15543 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T06:05:10.617192+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T05:00:00+00:00 EmrJobFlowSensor 2021-04-10T06:00:52.321989+00:00 2021-04-10T06:09:55.135472+00:00 0:09:02.813483 15542 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T06:00:50.081321+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T06:00:30.305038+00:00 2021-04-10T06:00:32.118912+00:00 0:00:01.813874 15541 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T06:00:28.045303+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T05:00:00+00:00 PythonOperator 2021-04-10T06:00:10.487772+00:00 2021-04-10T06:00:13.369265+00:00 0:00:02.881493 15540 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T06:00:08.013583+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T04:00:00+00:00 EmrJobFlowSensor 2021-04-10T05:10:58.869529+00:00 2021-04-10T05:21:01.700964+00:00 0:10:02.831435 15538 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T05:10:56.236441+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T04:00:00+00:00 EmrJobFlowSensor 2021-04-10T05:10:56.416364+00:00 2021-04-10T05:20:59.591210+00:00 0:10:03.174846 15537 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T05:10:54.236533+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T05:10:36.977857+00:00 2021-04-10T05:10:38.635480+00:00 0:00:01.657623 15536 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T05:10:34.274303+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T05:10:34.608655+00:00 2021-04-10T05:10:36.602607+00:00 0:00:01.993952 15535 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T05:10:32.018543+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T04:00:00+00:00 PythonOperator 2021-04-10T05:10:14.856758+00:00 2021-04-10T05:10:17.781120+00:00 0:00:02.924362 15534 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T05:10:12.068246+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T04:00:00+00:00 PythonOperator 2021-04-10T05:10:12.282112+00:00 2021-04-10T05:10:15.495126+00:00 0:00:03.213014 15533 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T05:10:09.999121+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T04:00:00+00:00 TriggerDagRunOperator 2021-04-10T05:10:04.877547+00:00 2021-04-10T05:10:05.403497+00:00 0:00:00.525950 15532 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T05:10:01.813948+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T04:00:00+00:00 TriggerDagRunOperator 2021-04-10T05:10:04.619132+00:00 2021-04-10T05:10:05.046593+00:00 0:00:00.427461 15531 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T05:10:01.813901+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T04:05:00+00:00 EmrJobFlowSensor 2021-04-10T05:05:59.849609+00:00 2021-04-10T05:15:02.694818+00:00 0:09:02.845209 15530 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T05:05:57.388350+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T05:05:37.555492+00:00 2021-04-10T05:05:39.194749+00:00 0:00:01.639257 15529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T05:05:35.337725+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T04:05:00+00:00 PythonOperator 2021-04-10T05:05:17.623206+00:00 2021-04-10T05:05:20.427025+00:00 0:00:02.803819 15528 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T05:05:15.262253+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T04:00:00+00:00 EmrJobFlowSensor 2021-04-10T05:00:56.823186+00:00 2021-04-10T05:09:59.361153+00:00 0:09:02.537967 15527 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T05:00:54.696059+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T05:00:36.884667+00:00 2021-04-10T05:00:38.582393+00:00 0:00:01.697726 15526 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T05:00:34.683375+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T04:00:00+00:00 PythonOperator 2021-04-10T05:00:13.007419+00:00 2021-04-10T05:00:15.877605+00:00 0:00:02.870186 15525 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T05:00:10.617372+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T03:00:00+00:00 EmrJobFlowSensor 2021-04-10T04:12:28.874904+00:00 2021-04-10T04:23:31.808371+00:00 0:11:02.933467 15523 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T04:12:26.607257+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T03:00:00+00:00 EmrJobFlowSensor 2021-04-10T04:12:25.007225+00:00 2021-04-10T04:21:27.674797+00:00 0:09:02.667572 15522 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T04:12:22.611000+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T04:12:06.772208+00:00 2021-04-10T04:12:08.502047+00:00 0:00:01.729839 15521 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T04:12:04.588058+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T04:12:03.130053+00:00 2021-04-10T04:12:04.859225+00:00 0:00:01.729172 15520 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T04:12:00.655804+00:00 2 default_pool