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 vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T01:05:44.436538+00:00 2021-04-11T01:05:46.177437+00:00 0:00:01.740899 15830 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T01:05:42.024039+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T00:05:00+00:00 PythonOperator 2021-04-11T01:05:22.387340+00:00 2021-04-11T01:05:25.073975+00:00 0:00:02.686635 15829 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T01:05:20.063614+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T00:00:00+00:00 EmrJobFlowSensor 2021-04-11T01:00:54.176770+00:00 2021-04-11T01:09:56.924696+00:00 0:09:02.747926 15828 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T01:00:51.678723+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T01:00:33.839856+00:00 2021-04-11T01:00:35.560607+00:00 0:00:01.720751 15827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T01:00:31.608062+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T00:00:00+00:00 PythonOperator 2021-04-11T01:00:12.013877+00:00 2021-04-11T01:00:14.716460+00:00 0:00:02.702583 15826 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T01:00:09.589734+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T23:00:00+00:00 EmrJobFlowSensor 2021-04-11T00:11:16.617539+00:00 2021-04-11T00:20:19.263328+00:00 0:09:02.645789 15824 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T00:11:13.847856+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T23:00:00+00:00 EmrJobFlowSensor 2021-04-11T00:11:14.160484+00:00 2021-04-11T00:20:17.237286+00:00 0:09:03.076802 15823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T00:11:11.788342+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T00:10:55.990859+00:00 2021-04-11T00:10:57.665438+00:00 0:00:01.674579 15822 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T00:10:53.734498+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T00:10:51.923126+00:00 2021-04-11T00:10:53.606368+00:00 0:00:01.683242 15821 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T00:10:49.728286+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T23:00:00+00:00 PythonOperator 2021-04-11T00:10:34.043815+00:00 2021-04-11T00:10:37.098060+00:00 0:00:03.054245 15820 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T00:10:31.710895+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T23:00:00+00:00 PythonOperator 2021-04-11T00:10:30.324225+00:00 2021-04-11T00:10:33.210205+00:00 0:00:02.885980 15819 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T00:10:27.857507+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T23:00:00+00:00 TriggerDagRunOperator 2021-04-11T00:10:16.051605+00:00 2021-04-11T00:10:16.591724+00:00 0:00:00.540119 15818 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T00:10:13.699023+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T23:00:00+00:00 TriggerDagRunOperator 2021-04-11T00:10:15.926279+00:00 2021-04-11T00:10:16.335725+00:00 0:00:00.409446 15817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T00:10:13.698987+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T23:05:00+00:00 EmrJobFlowSensor 2021-04-11T00:06:07.379616+00:00 2021-04-11T00:15:10.027904+00:00 0:09:02.648288 15816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T00:06:05.263895+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T00:05:45.488369+00:00 2021-04-11T00:05:47.140598+00:00 0:00:01.652229 15815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T00:05:43.215649+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T23:05:00+00:00 PythonOperator 2021-04-11T00:05:23.661960+00:00 2021-04-11T00:05:26.507302+00:00 0:00:02.845342 15814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T00:05:21.201842+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T23:00:00+00:00 EmrJobFlowSensor 2021-04-11T00:00:51.161308+00:00 2021-04-11T00:09:53.989871+00:00 0:09:02.828563 15813 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T00:00:48.667133+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T00:00:28.827940+00:00 2021-04-11T00:00:30.532200+00:00 0:00:01.704260 15812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T00:00:26.608180+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T23:00:00+00:00 PythonOperator 2021-04-11T00:00:09.082594+00:00 2021-04-11T00:00:12.033753+00:00 0:00:02.951159 15811 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T00:00:06.589686+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T22:00:00+00:00 EmrJobFlowSensor 2021-04-10T23:11:06.982304+00:00 2021-04-10T23:19:09.517557+00:00 0:08:02.535253 15809 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T23:11:04.717832+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T22:00:00+00:00 EmrJobFlowSensor 2021-04-10T23:11:05.017138+00:00 2021-04-10T23:21:07.651835+00:00 0:10:02.634697 15808 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T23:11:02.759377+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T23:10:46.814933+00:00 2021-04-10T23:10:48.519347+00:00 0:00:01.704414 15807 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T23:10:44.704100+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T23:10:42.907324+00:00 2021-04-10T23:10:44.581101+00:00 0:00:01.673777 15806 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T23:10:40.700914+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T22:00:00+00:00 PythonOperator 2021-04-10T23:10:25.195048+00:00 2021-04-10T23:10:27.932665+00:00 0:00:02.737617 15805 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T23:10:22.683500+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T22:00:00+00:00 PythonOperator 2021-04-10T23:10:21.392566+00:00 2021-04-10T23:10:24.908172+00:00 0:00:03.515606 15804 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T23:10:18.683450+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T22:00:00+00:00 TriggerDagRunOperator 2021-04-10T23:10:09.421960+00:00 2021-04-10T23:10:09.895828+00:00 0:00:00.473868 15803 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T23:10:06.662217+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T22:00:00+00:00 TriggerDagRunOperator 2021-04-10T23:10:09.312245+00:00 2021-04-10T23:10:09.858732+00:00 0:00:00.546487 15802 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T23:10:06.662263+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T22:05:00+00:00 EmrJobFlowSensor 2021-04-10T23:06:20.454387+00:00 2021-04-10T23:15:23.190211+00:00 0:09:02.735824 15801 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T23:06:18.220131+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T23:05:59.002291+00:00 2021-04-10T23:06:00.749259+00:00 0:00:01.746968 15800 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T23:05:56.267793+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T22:05:00+00:00 PythonOperator 2021-04-10T23:05:36.589371+00:00 2021-04-10T23:05:39.293697+00:00 0:00:02.704326 15799 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T23:05:34.189537+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T22:00:00+00:00 EmrJobFlowSensor 2021-04-10T23:00:58.023954+00:00 2021-04-10T23:10:00.638291+00:00 0:09:02.614337 15798 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T23:00:55.787276+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T23:00:36.497768+00:00 2021-04-10T23:00:38.232486+00:00 0:00:01.734718 15797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T23:00:33.761992+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T22:00:00+00:00 PythonOperator 2021-04-10T23:00:16.118967+00:00 2021-04-10T23:00:19.086491+00:00 0:00:02.967524 15796 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T23:00:13.638220+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T21:00:00+00:00 EmrJobFlowSensor 2021-04-10T22:09:56.335475+00:00 2021-04-10T22:18:59.092607+00:00 0:09:02.757132 15794 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T22:09:53.915925+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T21:00:00+00:00 EmrJobFlowSensor 2021-04-10T22:09:56.283759+00:00 2021-04-10T22:18:58.884947+00:00 0:09:02.601188 15793 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T22:09:53.915959+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T22:09:34.349258+00:00 2021-04-10T22:09:36.097371+00:00 0:00:01.748113 15792 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T22:09:31.891353+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T22:09:34.392162+00:00 2021-04-10T22:09:36.232490+00:00 0:00:01.840328 15791 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T22:09:31.891320+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T21:00:00+00:00 PythonOperator 2021-04-10T22:09:12.213703+00:00 2021-04-10T22:09:15.410314+00:00 0:00:03.196611 15790 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T22:09:09.823545+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T21:00:00+00:00 PythonOperator 2021-04-10T22:09:12.097761+00:00 2021-04-10T22:09:14.860916+00:00 0:00:02.763155 15789 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T22:09:09.823511+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T21:00:00+00:00 TriggerDagRunOperator 2021-04-10T22:09:06.349584+00:00 2021-04-10T22:09:06.813614+00:00 0:00:00.464030 15788 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T22:09:03.830603+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T21:00:00+00:00 TriggerDagRunOperator 2021-04-10T22:09:06.229977+00:00 2021-04-10T22:09:06.801403+00:00 0:00:00.571426 15787 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T22:09:03.830568+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T21:05:00+00:00 EmrJobFlowSensor 2021-04-10T22:05:49.677678+00:00 2021-04-10T22:14:52.107864+00:00 0:09:02.430186 15786 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T22:05:47.525244+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T22:05:27.888849+00:00 2021-04-10T22:05:29.531189+00:00 0:00:01.642340 15785 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T22:05:25.553422+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T21:05:00+00:00 PythonOperator 2021-04-10T22:05:07.941950+00:00 2021-04-10T22:05:10.763976+00:00 0:00:02.822026 15784 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T22:05:05.546324+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T21:00:00+00:00 EmrJobFlowSensor 2021-04-10T22:00:55.414548+00:00 2021-04-10T22:08:57.975644+00:00 0:08:02.561096 15783 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T22:00:53.060365+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T22:00:33.457722+00:00 2021-04-10T22:00:35.195246+00:00 0:00:01.737524 15782 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T22:00:31.045937+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T21:00:00+00:00 PythonOperator 2021-04-10T22:00:11.327703+00:00 2021-04-10T22:00:14.075137+00:00 0:00:02.747434 15781 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T22:00:09.021267+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T20:00:00+00:00 EmrJobFlowSensor 2021-04-10T21:11:59.336192+00:00 2021-04-10T21:22:02.189314+00:00 0:10:02.853122 15779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T21:11:57.032371+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T20:00:00+00:00 EmrJobFlowSensor 2021-04-10T21:11:49.352172+00:00 2021-04-10T21:21:52.501945+00:00 0:10:03.149773 15778 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T21:11:47.030968+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T21:11:39.379698+00:00 2021-04-10T21:11:41.154972+00:00 0:00:01.775274 15777 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T21:11:37.014622+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T21:11:27.246128+00:00 2021-04-10T21:11:29.011830+00:00 0:00:01.765702 15776 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T21:11:25.004777+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T20:00:00+00:00 PythonOperator 2021-04-10T21:11:17.515847+00:00 2021-04-10T21:11:20.372013+00:00 0:00:02.856166 15775 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T21:11:15.061561+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T20:00:00+00:00 PythonOperator 2021-04-10T21:11:05.320219+00:00 2021-04-10T21:11:08.308684+00:00 0:00:02.988465 15774 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T21:11:03.043516+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T20:00:00+00:00 TriggerDagRunOperator 2021-04-10T21:10:59.650675+00:00 2021-04-10T21:11:00.164312+00:00 0:00:00.513637 15773 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T21:10:56.991755+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T20:00:00+00:00 TriggerDagRunOperator 2021-04-10T21:10:59.443438+00:00 2021-04-10T21:10:59.879253+00:00 0:00:00.435815 15772 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T21:10:56.991711+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T20:05:00+00:00 EmrJobFlowSensor 2021-04-10T21:06:06.693248+00:00 2021-04-10T21:14:09.207340+00:00 0:08:02.514092 15771 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T21:06:04.527626+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T21:05:46.892780+00:00 2021-04-10T21:05:48.618956+00:00 0:00:01.726176 15770 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T21:05:44.515237+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T20:05:00+00:00 PythonOperator 2021-04-10T21:05:24.666491+00:00 2021-04-10T21:05:27.355674+00:00 0:00:02.689183 15769 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T21:05:22.498040+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T20:00:00+00:00 EmrJobFlowSensor 2021-04-10T21:00:52.213311+00:00 2021-04-10T21:10:55.114059+00:00 0:10:02.900748 15768 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T21:00:49.938168+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T21:00:30.761381+00:00 2021-04-10T21:00:32.502851+00:00 0:00:01.741470 15767 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T21:00:28.059484+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T20:00:00+00:00 PythonOperator 2021-04-10T21:00:08.378676+00:00 2021-04-10T21:00:11.299079+00:00 0:00:02.920403 15766 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T21:00:05.892266+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T19:00:00+00:00 EmrJobFlowSensor 2021-04-10T20:11:50.113812+00:00 2021-04-10T20:20:52.701170+00:00 0:09:02.587358 15764 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T20:11:47.747355+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T19:00:00+00:00 EmrJobFlowSensor 2021-04-10T20:11:45.966192+00:00 2021-04-10T20:20:48.585002+00:00 0:09:02.618810 15763 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T20:11:43.749112+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T20:11:27.927352+00:00 2021-04-10T20:11:29.746032+00:00 0:00:01.818680 15762 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T20:11:25.610209+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T20:11:19.788074+00:00 2021-04-10T20:11:21.558298+00:00 0:00:01.770224 15761 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T20:11:17.604395+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T19:00:00+00:00 PythonOperator 2021-04-10T20:10:54.675469+00:00 2021-04-10T20:10:57.505006+00:00 0:00:02.829537 15760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T20:10:51.558603+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T19:00:00+00:00 PythonOperator 2021-04-10T20:10:52.629669+00:00 2021-04-10T20:10:55.934327+00:00 0:00:03.304658 15759 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T20:10:49.558049+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T19:00:00+00:00 TriggerDagRunOperator 2021-04-10T20:10:40.040008+00:00 2021-04-10T20:10:40.586446+00:00 0:00:00.546438 15758 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T20:10:37.547651+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T19:00:00+00:00 TriggerDagRunOperator 2021-04-10T20:10:39.776322+00:00 2021-04-10T20:10:40.218976+00:00 0:00:00.442654 15757 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T20:10:37.547620+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T19:05:00+00:00 EmrJobFlowSensor 2021-04-10T20:05:53.361371+00:00 2021-04-10T20:14:56.051300+00:00 0:09:02.689929 15756 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T20:05:51.103772+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T20:05:31.468404+00:00 2021-04-10T20:05:33.205384+00:00 0:00:01.736980 15755 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T20:05:29.140650+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T19:05:00+00:00 PythonOperator 2021-04-10T20:05:05.257130+00:00 2021-04-10T20:05:08.066656+00:00 0:00:02.809526 15754 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T20:05:03.015411+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T19:00:00+00:00 EmrJobFlowSensor 2021-04-10T20:00:53.034307+00:00 2021-04-10T20:09:55.620004+00:00 0:09:02.585697 15753 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T20:00:50.582452+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T20:00:30.920618+00:00 2021-04-10T20:00:32.637704+00:00 0:00:01.717086 15752 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T20:00:28.564723+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T19:00:00+00:00 PythonOperator 2021-04-10T20:00:10.702459+00:00 2021-04-10T20:00:13.639588+00:00 0:00:02.937129 15751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T20:00:08.445655+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T18:00:00+00:00 EmrJobFlowSensor 2021-04-10T19:11:20.252172+00:00 2021-04-10T19:19:22.794476+00:00 0:08:02.542304 15749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T19:11:17.059602+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T18:00:00+00:00 EmrJobFlowSensor 2021-04-10T19:11:18.317830+00:00 2021-04-10T19:20:21.482743+00:00 0:09:03.164913 15748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T19:11:15.082343+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T19:10:59.396291+00:00 2021-04-10T19:11:01.188918+00:00 0:00:01.792627 15747 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T19:10:57.029968+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T19:10:55.591220+00:00 2021-04-10T19:10:57.424921+00:00 0:00:01.833701 15746 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T19:10:53.022773+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T18:00:00+00:00 PythonOperator 2021-04-10T19:10:37.908005+00:00 2021-04-10T19:10:40.613482+00:00 0:00:02.705477 15745 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T19:10:35.009656+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T18:00:00+00:00 PythonOperator 2021-04-10T19:10:35.291804+00:00 2021-04-10T19:10:38.747190+00:00 0:00:03.455386 15744 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T19:10:33.008298+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T18:00:00+00:00 TriggerDagRunOperator 2021-04-10T19:10:29.334216+00:00 2021-04-10T19:10:29.885170+00:00 0:00:00.550954 15743 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T19:10:27.002352+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T18:00:00+00:00 TriggerDagRunOperator 2021-04-10T19:10:29.213565+00:00 2021-04-10T19:10:29.674239+00:00 0:00:00.460674 15742 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T19:10:27.002320+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T18:05:00+00:00 EmrJobFlowSensor 2021-04-10T19:06:06.818516+00:00 2021-04-10T19:14:09.252847+00:00 0:08:02.434331 15741 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T19:06:04.479201+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T19:05:46.484147+00:00 2021-04-10T19:05:48.169458+00:00 0:00:01.685311 15740 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T19:05:44.398600+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T18:05:00+00:00 PythonOperator 2021-04-10T19:05:24.716364+00:00 2021-04-10T19:05:27.535856+00:00 0:00:02.819492 15739 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T19:05:22.314050+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T18:00:00+00:00 EmrJobFlowSensor 2021-04-10T19:01:10.356918+00:00 2021-04-10T19:10:13.056766+00:00 0:09:02.699848 15738 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T19:01:07.770245+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T19:00:47.843457+00:00 2021-04-10T19:00:49.531868+00:00 0:00:01.688411 15737 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T19:00:45.702308+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T18:00:00+00:00 PythonOperator 2021-04-10T19:00:20.028506+00:00 2021-04-10T19:00:22.728018+00:00 0:00:02.699512 15736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T19:00:17.677956+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T17:00:00+00:00 EmrJobFlowSensor 2021-04-10T18:12:18.673168+00:00 2021-04-10T18:22:21.551631+00:00 0:10:02.878463 15734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T18:12:15.766227+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T17:00:00+00:00 EmrJobFlowSensor 2021-04-10T18:12:18.582349+00:00 2021-04-10T18:21:21.237358+00:00 0:09:02.655009 15733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T18:12:15.766268+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T18:11:58.599234+00:00 2021-04-10T18:12:00.270458+00:00 0:00:01.671224 15732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T18:11:55.770324+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T18:11:56.291398+00:00 2021-04-10T18:11:58.320442+00:00 0:00:02.029044 15731 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T18:11:53.772918+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T17:00:00+00:00 PythonOperator 2021-04-10T18:11:36.145442+00:00 2021-04-10T18:11:39.286805+00:00 0:00:03.141363 15730 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T18:11:33.692473+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T17:00:00+00:00 PythonOperator 2021-04-10T18:11:36.080159+00:00 2021-04-10T18:11:38.846382+00:00 0:00:02.766223 15729 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T18:11:33.692445+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T17:00:00+00:00 TriggerDagRunOperator 2021-04-10T18:11:16.098775+00:00 2021-04-10T18:11:16.544913+00:00 0:00:00.446138 15728 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T18:11:13.647989+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T17:00:00+00:00 TriggerDagRunOperator 2021-04-10T18:11:16.059945+00:00 2021-04-10T18:11:16.640575+00:00 0:00:00.580630 15727 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T18:11:13.648022+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T17:05:00+00:00 EmrJobFlowSensor 2021-04-10T18:05:47.568954+00:00 2021-04-10T18:13:50.036330+00:00 0:08:02.467376 15726 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T18:05:45.239199+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-10T18:05:25.640734+00:00 2021-04-10T18:05:27.355055+00:00 0:00:01.714321 15725 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T18:05:23.253003+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T17:05:00+00:00 PythonOperator 2021-04-10T18:05:05.635988+00:00 2021-04-10T18:05:08.357301+00:00 0:00:02.721313 15724 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T18:05:03.253303+00:00 2 default_pool