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_cluster_and_add_emr_steps 2021-04-07T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T12:12:08.174417+00:00 2021-04-07T12:12:10.042772+00:00 0:00:01.868355 14564 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T12:12:05.725444+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T12:12:04.131337+00:00 2021-04-07T12:12:05.936492+00:00 0:00:01.805155 14563 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T12:12:01.717730+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T11:00:00+00:00 PythonOperator 2021-04-07T12:11:44.313567+00:00 2021-04-07T12:11:47.230412+00:00 0:00:02.916845 14562 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T12:11:41.760328+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T11:00:00+00:00 PythonOperator 2021-04-07T12:11:40.240357+00:00 2021-04-07T12:11:43.102104+00:00 0:00:02.861747 14561 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T12:11:37.766992+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T11:00:00+00:00 TriggerDagRunOperator 2021-04-07T12:11:20.350434+00:00 2021-04-07T12:11:20.879230+00:00 0:00:00.528796 14560 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T12:11:17.681929+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T11:00:00+00:00 TriggerDagRunOperator 2021-04-07T12:11:20.193644+00:00 2021-04-07T12:11:20.620359+00:00 0:00:00.426715 14559 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T12:11:17.681963+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T11:05:00+00:00 EmrJobFlowSensor 2021-04-07T12:05:55.775067+00:00 2021-04-07T12:14:58.407533+00:00 0:09:02.632466 14558 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T12:05:53.286726+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T12:05:35.498603+00:00 2021-04-07T12:05:37.134935+00:00 0:00:01.636332 14557 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T12:05:33.263342+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T11:05:00+00:00 PythonOperator 2021-04-07T12:05:13.410631+00:00 2021-04-07T12:05:16.284937+00:00 0:00:02.874306 14556 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T12:05:11.187535+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T11:00:00+00:00 EmrJobFlowSensor 2021-04-07T12:01:03.140080+00:00 2021-04-07T12:11:05.984918+00:00 0:10:02.844838 14555 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T12:01:00.760605+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T12:00:40.997337+00:00 2021-04-07T12:00:42.800283+00:00 0:00:01.802946 14554 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T12:00:38.752297+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T11:00:00+00:00 PythonOperator 2021-04-07T12:00:21.022448+00:00 2021-04-07T12:00:23.938129+00:00 0:00:02.915681 14553 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T12:00:18.655083+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T10:00:00+00:00 EmrJobFlowSensor 2021-04-07T11:11:18.762930+00:00 2021-04-07T11:22:21.797600+00:00 0:11:03.034670 14551 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T11:11:16.100663+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T10:00:00+00:00 EmrJobFlowSensor 2021-04-07T11:11:08.704899+00:00 2021-04-07T11:20:11.500805+00:00 0:09:02.795906 14550 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T11:11:06.147044+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T11:10:58.223804+00:00 2021-04-07T11:10:59.905360+00:00 0:00:01.681556 14549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T11:10:56.054902+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T11:10:48.795786+00:00 2021-04-07T11:10:50.587741+00:00 0:00:01.791955 14548 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T11:10:46.045092+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T10:00:00+00:00 PythonOperator 2021-04-07T11:10:36.327086+00:00 2021-04-07T11:10:39.331649+00:00 0:00:03.004563 14547 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T11:10:34.032661+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T10:00:00+00:00 PythonOperator 2021-04-07T11:10:26.306547+00:00 2021-04-07T11:10:29.028042+00:00 0:00:02.721495 14546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T11:10:24.037303+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T10:00:00+00:00 TriggerDagRunOperator 2021-04-07T11:10:16.790766+00:00 2021-04-07T11:10:17.237405+00:00 0:00:00.446639 14545 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T11:10:14.019938+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T10:00:00+00:00 TriggerDagRunOperator 2021-04-07T11:10:16.349241+00:00 2021-04-07T11:10:16.944517+00:00 0:00:00.595276 14544 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T11:10:14.019980+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T10:05:00+00:00 EmrJobFlowSensor 2021-04-07T11:06:05.783966+00:00 2021-04-07T11:15:08.319963+00:00 0:09:02.535997 14543 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T11:06:03.579474+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T11:05:43.877489+00:00 2021-04-07T11:05:45.523072+00:00 0:00:01.645583 14542 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T11:05:41.571044+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T10:05:00+00:00 PythonOperator 2021-04-07T11:05:21.824925+00:00 2021-04-07T11:05:24.495696+00:00 0:00:02.670771 14541 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T11:05:19.507371+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T10:00:00+00:00 EmrJobFlowSensor 2021-04-07T11:01:01.534633+00:00 2021-04-07T11:10:04.157757+00:00 0:09:02.623124 14540 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T11:00:58.870347+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T11:00:39.208831+00:00 2021-04-07T11:00:41.036319+00:00 0:00:01.827488 14539 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T11:00:36.759173+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T10:00:00+00:00 PythonOperator 2021-04-07T11:00:19.485326+00:00 2021-04-07T11:00:22.199323+00:00 0:00:02.713997 14538 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T11:00:16.658706+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T09:00:00+00:00 EmrJobFlowSensor 2021-04-07T10:11:43.305505+00:00 2021-04-07T10:19:45.685056+00:00 0:08:02.379551 14536 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T10:11:41.193149+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T09:00:00+00:00 EmrJobFlowSensor 2021-04-07T10:11:35.422335+00:00 2021-04-07T10:23:38.507714+00:00 0:12:03.085379 14535 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T10:11:33.187126+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T10:11:21.292176+00:00 2021-04-07T10:11:22.983057+00:00 0:00:01.690881 14534 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T10:11:19.129705+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T10:11:13.468735+00:00 2021-04-07T10:11:15.306170+00:00 0:00:01.837435 14533 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T10:11:11.075431+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T09:00:00+00:00 PythonOperator 2021-04-07T10:10:59.506326+00:00 2021-04-07T10:11:02.324728+00:00 0:00:02.818402 14532 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T10:10:57.033536+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T09:00:00+00:00 PythonOperator 2021-04-07T10:10:51.406434+00:00 2021-04-07T10:10:54.520381+00:00 0:00:03.113947 14531 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T10:10:49.082090+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T09:00:00+00:00 TriggerDagRunOperator 2021-04-07T10:10:33.450085+00:00 2021-04-07T10:10:33.985974+00:00 0:00:00.535889 14530 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T10:10:31.013003+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T09:00:00+00:00 TriggerDagRunOperator 2021-04-07T10:10:33.277697+00:00 2021-04-07T10:10:33.715910+00:00 0:00:00.438213 14529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T10:10:31.013041+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T09:05:00+00:00 EmrJobFlowSensor 2021-04-07T10:05:50.609108+00:00 2021-04-07T10:14:53.131637+00:00 0:09:02.522529 14528 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T10:05:48.439355+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T10:05:30.798132+00:00 2021-04-07T10:05:32.527360+00:00 0:00:01.729228 14527 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T10:05:28.486111+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T09:05:00+00:00 PythonOperator 2021-04-07T10:05:08.794146+00:00 2021-04-07T10:05:11.520863+00:00 0:00:02.726717 14526 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T10:05:06.474108+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T09:00:00+00:00 EmrJobFlowSensor 2021-04-07T10:01:06.139782+00:00 2021-04-07T10:10:08.856840+00:00 0:09:02.717058 14525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T10:01:03.834476+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T10:00:44.083411+00:00 2021-04-07T10:00:45.766369+00:00 0:00:01.682958 14524 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T10:00:41.817968+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T09:00:00+00:00 PythonOperator 2021-04-07T10:00:22.105460+00:00 2021-04-07T10:00:24.850437+00:00 0:00:02.744977 14523 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T10:00:19.799146+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T08:00:00+00:00 EmrJobFlowSensor 2021-04-07T09:11:50.927938+00:00 2021-04-07T09:20:53.652864+00:00 0:09:02.724926 14521 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T09:11:48.766403+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T08:00:00+00:00 EmrJobFlowSensor 2021-04-07T09:11:45.324448+00:00 2021-04-07T09:20:47.850462+00:00 0:09:02.526014 14520 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T09:11:42.781076+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T09:11:29.018166+00:00 2021-04-07T09:11:30.687657+00:00 0:00:01.669491 14519 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T09:11:26.744056+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T09:11:25.036030+00:00 2021-04-07T09:11:26.830804+00:00 0:00:01.794774 14518 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T09:11:22.757922+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T08:00:00+00:00 PythonOperator 2021-04-07T09:11:09.129376+00:00 2021-04-07T09:11:12.136990+00:00 0:00:03.007614 14517 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T09:11:06.726928+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T08:00:00+00:00 PythonOperator 2021-04-07T09:11:03.311531+00:00 2021-04-07T09:11:06.004541+00:00 0:00:02.693010 14516 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T09:11:00.843839+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T08:00:00+00:00 TriggerDagRunOperator 2021-04-07T09:10:57.074067+00:00 2021-04-07T09:10:57.635311+00:00 0:00:00.561244 14515 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T09:10:54.719643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T08:00:00+00:00 TriggerDagRunOperator 2021-04-07T09:10:57.035387+00:00 2021-04-07T09:10:57.437564+00:00 0:00:00.402177 14514 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T09:10:54.719608+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T08:05:00+00:00 EmrJobFlowSensor 2021-04-07T09:05:48.400997+00:00 2021-04-07T09:14:51.040508+00:00 0:09:02.639511 14513 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T09:05:46.245691+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T09:05:26.427014+00:00 2021-04-07T09:05:28.150043+00:00 0:00:01.723029 14512 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T09:05:24.224069+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T08:05:00+00:00 PythonOperator 2021-04-07T09:05:06.427467+00:00 2021-04-07T09:05:09.235089+00:00 0:00:02.807622 14511 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T09:05:04.202973+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T08:00:00+00:00 EmrJobFlowSensor 2021-04-07T09:00:50.035268+00:00 2021-04-07T09:10:52.729833+00:00 0:10:02.694565 14510 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T09:00:47.733630+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T09:00:30.267206+00:00 2021-04-07T09:00:31.996537+00:00 0:00:01.729331 14509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T09:00:27.764323+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T08:00:00+00:00 PythonOperator 2021-04-07T09:00:08.166449+00:00 2021-04-07T09:00:11.100132+00:00 0:00:02.933683 14508 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T09:00:05.693709+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T07:00:00+00:00 EmrJobFlowSensor 2021-04-07T08:11:14.487041+00:00 2021-04-07T08:23:17.572657+00:00 0:12:03.085616 14506 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T08:11:11.655315+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T07:00:00+00:00 EmrJobFlowSensor 2021-04-07T08:11:12.031066+00:00 2021-04-07T08:19:14.875193+00:00 0:08:02.844127 14505 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T08:11:09.652991+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T08:10:51.949251+00:00 2021-04-07T08:10:53.696929+00:00 0:00:01.747678 14504 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T08:10:49.583453+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T08:10:51.867221+00:00 2021-04-07T08:10:53.539315+00:00 0:00:01.672094 14503 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T08:10:49.583421+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T07:00:00+00:00 PythonOperator 2021-04-07T08:10:31.693739+00:00 2021-04-07T08:10:34.623096+00:00 0:00:02.929357 14502 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T08:10:29.546278+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T07:00:00+00:00 PythonOperator 2021-04-07T08:10:29.944690+00:00 2021-04-07T08:10:32.833837+00:00 0:00:02.889147 14501 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T08:10:27.546447+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T07:00:00+00:00 TriggerDagRunOperator 2021-04-07T08:10:08.195609+00:00 2021-04-07T08:10:08.625845+00:00 0:00:00.430236 14500 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T08:10:05.507896+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T07:00:00+00:00 TriggerDagRunOperator 2021-04-07T08:10:08.093626+00:00 2021-04-07T08:10:08.701149+00:00 0:00:00.607523 14499 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T08:10:05.507934+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T07:05:00+00:00 EmrJobFlowSensor 2021-04-07T08:06:05.407887+00:00 2021-04-07T08:14:07.912585+00:00 0:08:02.504698 14498 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T08:06:03.108617+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T08:05:41.290455+00:00 2021-04-07T08:05:43.018593+00:00 0:00:01.728138 14497 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T08:05:39.088840+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T07:05:00+00:00 PythonOperator 2021-04-07T08:05:21.223612+00:00 2021-04-07T08:05:23.973109+00:00 0:00:02.749497 14496 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T08:05:18.997219+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T07:00:00+00:00 EmrJobFlowSensor 2021-04-07T08:00:54.825760+00:00 2021-04-07T08:09:57.496014+00:00 0:09:02.670254 14495 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T08:00:52.512250+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T08:00:28.745915+00:00 2021-04-07T08:00:30.394034+00:00 0:00:01.648119 14494 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T08:00:26.430877+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T07:00:00+00:00 PythonOperator 2021-04-07T08:00:06.727492+00:00 2021-04-07T08:00:09.580941+00:00 0:00:02.853449 14493 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T08:00:04.413277+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T06:00:00+00:00 EmrJobFlowSensor 2021-04-07T07:11:23.331048+00:00 2021-04-07T07:20:26.052025+00:00 0:09:02.720977 14491 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T07:11:21.027107+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T06:00:00+00:00 EmrJobFlowSensor 2021-04-07T07:11:17.254200+00:00 2021-04-07T07:20:19.927581+00:00 0:09:02.673381 14490 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T07:11:15.028044+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T07:11:01.387629+00:00 2021-04-07T07:11:03.111825+00:00 0:00:01.724196 14489 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T07:10:59.010442+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T07:10:55.228035+00:00 2021-04-07T07:10:56.915106+00:00 0:00:01.687071 14488 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T07:10:53.005238+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T06:00:00+00:00 PythonOperator 2021-04-07T07:10:39.682965+00:00 2021-04-07T07:10:42.386788+00:00 0:00:02.703823 14487 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T07:10:37.047765+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T06:00:00+00:00 PythonOperator 2021-04-07T07:10:35.222599+00:00 2021-04-07T07:10:38.543848+00:00 0:00:03.321249 14486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T07:10:32.981667+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T06:00:00+00:00 TriggerDagRunOperator 2021-04-07T07:10:19.421021+00:00 2021-04-07T07:10:19.954052+00:00 0:00:00.533031 14485 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T07:10:16.981565+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T06:00:00+00:00 TriggerDagRunOperator 2021-04-07T07:10:19.274388+00:00 2021-04-07T07:10:19.746768+00:00 0:00:00.472380 14484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T07:10:16.981533+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T06:05:00+00:00 EmrJobFlowSensor 2021-04-07T07:05:58.561096+00:00 2021-04-07T07:15:01.148489+00:00 0:09:02.587393 14483 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T07:05:56.464380+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T07:05:38.592104+00:00 2021-04-07T07:05:40.261678+00:00 0:00:01.669574 14482 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T07:05:36.447238+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T06:05:00+00:00 PythonOperator 2021-04-07T07:05:16.577332+00:00 2021-04-07T07:05:19.250485+00:00 0:00:02.673153 14481 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T07:05:14.422792+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T06:00:00+00:00 EmrJobFlowSensor 2021-04-07T07:00:54.673548+00:00 2021-04-07T07:09:57.507966+00:00 0:09:02.834418 14480 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T07:00:52.130010+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T07:00:34.315744+00:00 2021-04-07T07:00:36.003966+00:00 0:00:01.688222 14479 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T07:00:32.112543+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T06:00:00+00:00 PythonOperator 2021-04-07T07:00:06.292336+00:00 2021-04-07T07:00:09.024982+00:00 0:00:02.732646 14478 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T07:00:04.086747+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T05:00:00+00:00 EmrJobFlowSensor 2021-04-07T06:14:45.738814+00:00 2021-04-07T06:26:48.921278+00:00 0:12:03.182464 14477 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T06:14:43.261952+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T05:00:00+00:00 EmrJobFlowSensor 2021-04-07T06:14:39.747166+00:00 2021-04-07T06:24:42.391817+00:00 0:10:02.644651 14476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T06:14:37.266018+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T06:14:23.590073+00:00 2021-04-07T06:14:25.453879+00:00 0:00:01.863806 14475 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T06:14:21.183555+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T06:14:17.567528+00:00 2021-04-07T06:14:19.326339+00:00 0:00:01.758811 14474 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T06:14:15.244227+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T05:00:00+00:00 PythonOperator 2021-04-07T06:14:03.517562+00:00 2021-04-07T06:14:06.595860+00:00 0:00:03.078298 14473 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T06:14:01.174969+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T05:00:00+00:00 PythonOperator 2021-04-07T06:13:57.296577+00:00 2021-04-07T06:14:00.078051+00:00 0:00:02.781474 14472 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T06:13:55.118082+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T05:00:00+00:00 TriggerDagRunOperator 2021-04-07T06:13:39.931218+00:00 2021-04-07T06:13:40.459814+00:00 0:00:00.528596 14471 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T06:13:37.090180+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T05:00:00+00:00 TriggerDagRunOperator 2021-04-07T06:13:39.788061+00:00 2021-04-07T06:13:40.210419+00:00 0:00:00.422358 14470 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T06:13:37.090153+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T05:05:00+00:00 EmrJobFlowSensor 2021-04-07T06:05:56.699764+00:00 2021-04-07T06:14:59.286694+00:00 0:09:02.586930 14468 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T06:05:54.452139+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T06:05:34.602048+00:00 2021-04-07T06:05:36.263844+00:00 0:00:01.661796 14467 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T06:05:32.432759+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T05:05:00+00:00 PythonOperator 2021-04-07T06:05:12.928153+00:00 2021-04-07T06:05:15.613118+00:00 0:00:02.684965 14466 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T06:05:10.487597+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T05:00:00+00:00 EmrJobFlowSensor 2021-04-07T06:01:12.360461+00:00 2021-04-07T06:10:15.153125+00:00 0:09:02.792664 14465 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T06:01:10.022996+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T06:00:44.479813+00:00 2021-04-07T06:00:46.289402+00:00 0:00:01.809589 14464 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T06:00:41.995372+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T05:00:00+00:00 PythonOperator 2021-04-07T06:00:22.136366+00:00 2021-04-07T06:00:24.904330+00:00 0:00:02.767964 14463 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T06:00:19.943916+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T04:00:00+00:00 EmrJobFlowSensor 2021-04-07T05:10:33.200304+00:00 2021-04-07T05:19:35.833779+00:00 0:09:02.633475 14462 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T05:10:30.984218+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T04:00:00+00:00 EmrJobFlowSensor 2021-04-07T05:10:25.134395+00:00 2021-04-07T05:20:27.946732+00:00 0:10:02.812337 14461 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T05:10:22.908512+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T05:10:11.230336+00:00 2021-04-07T05:10:13.043852+00:00 0:00:01.813516 14460 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T05:10:08.896346+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T05:10:05.243608+00:00 2021-04-07T05:10:06.986302+00:00 0:00:01.742694 14459 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T05:10:02.889116+00:00 2 default_pool