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-flow-job_v002 check_cluster_status 2021-04-08T04:00:00+00:00 EmrJobFlowSensor 2021-04-08T05:01:00.815826+00:00 2021-04-08T05:11:03.671270+00:00 0:10:02.855444 14809 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T05:00:58.357519+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T05:00:38.493089+00:00 2021-04-08T05:00:40.329257+00:00 0:00:01.836168 14808 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T05:00:36.188715+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T04:00:00+00:00 PythonOperator 2021-04-08T05:00:18.424753+00:00 2021-04-08T05:00:21.203064+00:00 0:00:02.778311 14807 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T05:00:16.134308+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T03:00:00+00:00 EmrJobFlowSensor 2021-04-08T04:12:13.830842+00:00 2021-04-08T04:21:16.603675+00:00 0:09:02.772833 14805 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T04:12:11.361344+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T03:00:00+00:00 EmrJobFlowSensor 2021-04-08T04:11:59.712901+00:00 2021-04-08T04:22:02.707866+00:00 0:10:02.994965 14804 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T04:11:57.293571+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T04:11:51.533468+00:00 2021-04-08T04:11:53.213556+00:00 0:00:01.680088 14803 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T04:11:49.285343+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T04:11:37.437725+00:00 2021-04-08T04:11:39.158042+00:00 0:00:01.720317 14802 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T04:11:35.270029+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T03:00:00+00:00 PythonOperator 2021-04-08T04:11:31.608602+00:00 2021-04-08T04:11:34.430582+00:00 0:00:02.821980 14801 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T04:11:29.268940+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T03:00:00+00:00 PythonOperator 2021-04-08T04:11:17.640777+00:00 2021-04-08T04:11:20.686455+00:00 0:00:03.045678 14800 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T04:11:15.251510+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T03:00:00+00:00 TriggerDagRunOperator 2021-04-08T04:11:07.864552+00:00 2021-04-08T04:11:08.437433+00:00 0:00:00.572881 14799 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T04:11:05.244456+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T03:00:00+00:00 TriggerDagRunOperator 2021-04-08T04:11:07.642314+00:00 2021-04-08T04:11:08.077316+00:00 0:00:00.435002 14798 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T04:11:05.244491+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T03:05:00+00:00 EmrJobFlowSensor 2021-04-08T04:05:53.064756+00:00 2021-04-08T04:14:55.670883+00:00 0:09:02.606127 14797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T04:05:50.760558+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T04:05:31.279480+00:00 2021-04-08T04:05:32.921396+00:00 0:00:01.641916 14796 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T04:05:28.570021+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T03:05:00+00:00 PythonOperator 2021-04-08T04:05:10.615591+00:00 2021-04-08T04:05:13.385434+00:00 0:00:02.769843 14795 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T04:05:08.413606+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T03:00:00+00:00 EmrJobFlowSensor 2021-04-08T04:01:00.497029+00:00 2021-04-08T04:11:03.463424+00:00 0:10:02.966395 14794 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T04:00:57.959781+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T04:00:40.016073+00:00 2021-04-08T04:00:41.678181+00:00 0:00:01.662108 14793 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T04:00:37.787627+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T03:00:00+00:00 PythonOperator 2021-04-08T04:00:18.062303+00:00 2021-04-08T04:00:21.033309+00:00 0:00:02.971006 14792 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T04:00:15.733956+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T02:00:00+00:00 EmrJobFlowSensor 2021-04-08T03:12:03.291081+00:00 2021-04-08T03:22:06.116576+00:00 0:10:02.825495 14790 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T03:12:00.784041+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T02:00:00+00:00 EmrJobFlowSensor 2021-04-08T03:11:58.984593+00:00 2021-04-08T03:22:01.774140+00:00 0:10:02.789547 14789 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T03:11:56.746294+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T03:11:41.055149+00:00 2021-04-08T03:11:42.739828+00:00 0:00:01.684679 14788 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T03:11:38.746772+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T03:11:37.181089+00:00 2021-04-08T03:11:38.885686+00:00 0:00:01.704597 14787 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T03:11:34.674361+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T02:00:00+00:00 PythonOperator 2021-04-08T03:11:20.810790+00:00 2021-04-08T03:11:23.702998+00:00 0:00:02.892208 14786 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T03:11:18.630090+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T02:00:00+00:00 PythonOperator 2021-04-08T03:11:16.955687+00:00 2021-04-08T03:11:20.086414+00:00 0:00:03.130727 14785 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T03:11:14.679565+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T02:00:00+00:00 TriggerDagRunOperator 2021-04-08T03:11:06.920133+00:00 2021-04-08T03:11:07.553640+00:00 0:00:00.633507 14784 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T03:11:04.617324+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T02:00:00+00:00 TriggerDagRunOperator 2021-04-08T03:11:06.914122+00:00 2021-04-08T03:11:07.510105+00:00 0:00:00.595983 14783 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T03:11:04.617297+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T02:05:00+00:00 EmrJobFlowSensor 2021-04-08T03:05:54.625063+00:00 2021-04-08T03:14:57.272054+00:00 0:09:02.646991 14782 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T03:05:52.256425+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T03:05:34.414974+00:00 2021-04-08T03:05:36.148732+00:00 0:00:01.733758 14781 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T03:05:32.171591+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T02:05:00+00:00 PythonOperator 2021-04-08T03:05:12.287522+00:00 2021-04-08T03:05:14.964384+00:00 0:00:02.676862 14780 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T03:05:10.149432+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T02:00:00+00:00 EmrJobFlowSensor 2021-04-08T03:00:53.792222+00:00 2021-04-08T03:10:56.657733+00:00 0:10:02.865511 14779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T03:00:51.637096+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T03:00:34.117385+00:00 2021-04-08T03:00:35.949184+00:00 0:00:01.831799 14778 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T03:00:31.621208+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T02:00:00+00:00 PythonOperator 2021-04-08T03:00:12.137015+00:00 2021-04-08T03:00:14.873458+00:00 0:00:02.736443 14777 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T03:00:09.597448+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T01:00:00+00:00 EmrJobFlowSensor 2021-04-08T02:10:33.372546+00:00 2021-04-08T02:19:35.979742+00:00 0:09:02.607196 14775 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T02:10:31.114094+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T01:00:00+00:00 EmrJobFlowSensor 2021-04-08T02:10:29.363825+00:00 2021-04-08T02:19:32.009518+00:00 0:09:02.645693 14774 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T02:10:27.115697+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T02:10:09.821367+00:00 2021-04-08T02:10:11.530346+00:00 0:00:01.708979 14773 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T02:10:07.093796+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T02:10:07.353349+00:00 2021-04-08T02:10:09.511629+00:00 0:00:02.158280 14772 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T02:10:05.094706+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T01:00:00+00:00 PythonOperator 2021-04-08T02:09:41.369282+00:00 2021-04-08T02:09:44.319875+00:00 0:00:02.950593 14771 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T02:09:39.070912+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T01:00:00+00:00 PythonOperator 2021-04-08T02:09:37.212345+00:00 2021-04-08T02:09:40.013710+00:00 0:00:02.801365 14770 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T02:09:35.068669+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T01:00:00+00:00 TriggerDagRunOperator 2021-04-08T02:09:15.296341+00:00 2021-04-08T02:09:15.810495+00:00 0:00:00.514154 14769 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T02:09:12.995185+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T01:00:00+00:00 TriggerDagRunOperator 2021-04-08T02:09:15.310634+00:00 2021-04-08T02:09:15.979902+00:00 0:00:00.669268 14768 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T02:09:12.995213+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T01:05:00+00:00 EmrJobFlowSensor 2021-04-08T02:05:58.956136+00:00 2021-04-08T02:15:01.652829+00:00 0:09:02.696693 14767 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T02:05:56.708014+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T02:05:37.018961+00:00 2021-04-08T02:05:38.731908+00:00 0:00:01.712947 14766 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T02:05:34.751415+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T01:05:00+00:00 PythonOperator 2021-04-08T02:05:14.825668+00:00 2021-04-08T02:05:17.539094+00:00 0:00:02.713426 14765 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T02:05:12.593867+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T01:00:00+00:00 EmrJobFlowSensor 2021-04-08T02:01:00.609006+00:00 2021-04-08T02:09:03.282936+00:00 0:08:02.673930 14764 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T02:00:58.051359+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T02:00:30.212117+00:00 2021-04-08T02:00:31.913048+00:00 0:00:01.700931 14763 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T02:00:27.966757+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T01:00:00+00:00 PythonOperator 2021-04-08T02:00:08.606018+00:00 2021-04-08T02:00:11.385849+00:00 0:00:02.779831 14762 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T02:00:05.947615+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T00:00:00+00:00 EmrJobFlowSensor 2021-04-08T01:11:32.612012+00:00 2021-04-08T01:20:35.189358+00:00 0:09:02.577346 14760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T01:11:30.383384+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T00:00:00+00:00 EmrJobFlowSensor 2021-04-08T01:11:26.699879+00:00 2021-04-08T01:20:29.519626+00:00 0:09:02.819747 14759 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T01:11:24.329045+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T01:11:10.920433+00:00 2021-04-08T01:11:12.741843+00:00 0:00:01.821410 14758 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T01:11:08.359270+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T01:11:04.830456+00:00 2021-04-08T01:11:06.658880+00:00 0:00:01.828424 14757 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T01:11:02.318035+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T00:00:00+00:00 PythonOperator 2021-04-08T01:10:48.848514+00:00 2021-04-08T01:10:51.563020+00:00 0:00:02.714506 14756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T01:10:46.358245+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T00:00:00+00:00 PythonOperator 2021-04-08T01:10:42.583789+00:00 2021-04-08T01:10:45.576018+00:00 0:00:02.992229 14755 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T01:10:40.300074+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T00:00:00+00:00 TriggerDagRunOperator 2021-04-08T01:10:26.554216+00:00 2021-04-08T01:10:27.104732+00:00 0:00:00.550516 14754 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T01:10:24.263267+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T00:00:00+00:00 TriggerDagRunOperator 2021-04-08T01:10:26.464903+00:00 2021-04-08T01:10:26.889276+00:00 0:00:00.424373 14753 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T01:10:24.263316+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T00:05:00+00:00 EmrJobFlowSensor 2021-04-08T01:06:05.997535+00:00 2021-04-08T01:14:08.413822+00:00 0:08:02.416287 14752 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T01:06:03.860893+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T01:05:44.343515+00:00 2021-04-08T01:05:46.021682+00:00 0:00:01.678167 14751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T01:05:41.837226+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T00:05:00+00:00 PythonOperator 2021-04-08T01:05:22.033571+00:00 2021-04-08T01:05:24.818285+00:00 0:00:02.784714 14750 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T01:05:19.816885+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T00:00:00+00:00 EmrJobFlowSensor 2021-04-08T01:01:01.747149+00:00 2021-04-08T01:10:04.475623+00:00 0:09:02.728474 14749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T01:00:59.473659+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T01:00:37.693638+00:00 2021-04-08T01:00:39.377031+00:00 0:00:01.683393 14748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T01:00:35.404663+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T00:00:00+00:00 PythonOperator 2021-04-08T01:00:16.020460+00:00 2021-04-08T01:00:18.752730+00:00 0:00:02.732270 14747 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T01:00:13.340732+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T23:00:00+00:00 EmrJobFlowSensor 2021-04-08T00:11:23.733717+00:00 2021-04-08T00:19:26.373033+00:00 0:08:02.639316 14745 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T00:11:21.151742+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T23:00:00+00:00 EmrJobFlowSensor 2021-04-08T00:11:13.321552+00:00 2021-04-08T00:20:16.209252+00:00 0:09:02.887700 14744 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T00:11:11.092939+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T00:11:03.903204+00:00 2021-04-08T00:11:05.638216+00:00 0:00:01.735012 14743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T00:11:01.063006+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T00:10:51.219606+00:00 2021-04-08T00:10:52.957021+00:00 0:00:01.737415 14742 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T00:10:49.054376+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T23:00:00+00:00 PythonOperator 2021-04-08T00:10:27.720246+00:00 2021-04-08T00:10:30.414762+00:00 0:00:02.694516 14741 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T00:10:25.046154+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T23:00:00+00:00 PythonOperator 2021-04-08T00:10:23.775487+00:00 2021-04-08T00:10:27.152786+00:00 0:00:03.377299 14740 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T00:10:21.144177+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T23:00:00+00:00 TriggerDagRunOperator 2021-04-08T00:10:17.710542+00:00 2021-04-08T00:10:18.245700+00:00 0:00:00.535158 14739 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T00:10:15.072196+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T23:00:00+00:00 TriggerDagRunOperator 2021-04-08T00:10:17.539391+00:00 2021-04-08T00:10:17.944407+00:00 0:00:00.405016 14738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T00:10:15.072235+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T23:05:00+00:00 EmrJobFlowSensor 2021-04-08T00:05:51.139227+00:00 2021-04-08T00:14:53.650028+00:00 0:09:02.510801 14737 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T00:05:48.753772+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T00:05:31.187441+00:00 2021-04-08T00:05:32.830850+00:00 0:00:01.643409 14736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T00:05:28.744080+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T23:05:00+00:00 PythonOperator 2021-04-08T00:05:08.890413+00:00 2021-04-08T00:05:11.657580+00:00 0:00:02.767167 14735 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T00:05:06.518259+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T23:00:00+00:00 EmrJobFlowSensor 2021-04-08T00:00:54.576508+00:00 2021-04-08T00:09:57.415698+00:00 0:09:02.839190 14734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T00:00:52.099732+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T00:00:32.299414+00:00 2021-04-08T00:00:34.046353+00:00 0:00:01.746939 14733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T00:00:30.082625+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T23:00:00+00:00 PythonOperator 2021-04-08T00:00:04.714600+00:00 2021-04-08T00:00:07.455527+00:00 0:00:02.740927 14732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T00:00:02.077902+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T22:00:00+00:00 EmrJobFlowSensor 2021-04-07T23:11:41.336643+00:00 2021-04-07T23:21:44.038648+00:00 0:10:02.702005 14730 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T23:11:38.424420+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T22:00:00+00:00 EmrJobFlowSensor 2021-04-07T23:11:39.243875+00:00 2021-04-07T23:20:42.096311+00:00 0:09:02.852436 14729 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T23:11:36.425154+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T23:11:19.348995+00:00 2021-04-07T23:11:21.034276+00:00 0:00:01.685281 14728 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T23:11:16.465799+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T23:11:17.047413+00:00 2021-04-07T23:11:19.157648+00:00 0:00:02.110235 14727 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T23:11:14.475977+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T22:00:00+00:00 PythonOperator 2021-04-07T23:10:57.135317+00:00 2021-04-07T23:10:59.830025+00:00 0:00:02.694708 14726 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T23:10:54.387875+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T22:00:00+00:00 PythonOperator 2021-04-07T23:10:54.657149+00:00 2021-04-07T23:10:58.017268+00:00 0:00:03.360119 14725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T23:10:52.387856+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T22:00:00+00:00 TriggerDagRunOperator 2021-04-07T23:10:34.630654+00:00 2021-04-07T23:10:35.091523+00:00 0:00:00.460869 14724 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T23:10:32.368493+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T22:00:00+00:00 TriggerDagRunOperator 2021-04-07T23:10:34.627738+00:00 2021-04-07T23:10:35.191776+00:00 0:00:00.564038 14723 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T23:10:32.368531+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T22:05:00+00:00 EmrJobFlowSensor 2021-04-07T23:06:04.696049+00:00 2021-04-07T23:15:07.365788+00:00 0:09:02.669739 14722 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T23:06:01.931130+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T23:05:42.172512+00:00 2021-04-07T23:05:43.815591+00:00 0:00:01.643079 14721 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T23:05:39.905876+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T22:05:00+00:00 PythonOperator 2021-04-07T23:05:20.236506+00:00 2021-04-07T23:05:22.953887+00:00 0:00:02.717381 14720 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T23:05:17.956125+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T22:00:00+00:00 EmrJobFlowSensor 2021-04-07T23:01:07.522893+00:00 2021-04-07T23:10:10.353374+00:00 0:09:02.830481 14719 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T23:01:05.210021+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T23:00:45.417531+00:00 2021-04-07T23:00:47.145592+00:00 0:00:01.728061 14718 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T23:00:43.192369+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T22:00:00+00:00 PythonOperator 2021-04-07T23:00:25.401283+00:00 2021-04-07T23:00:28.202873+00:00 0:00:02.801590 14717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T23:00:23.085870+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T21:00:00+00:00 EmrJobFlowSensor 2021-04-07T22:10:13.623451+00:00 2021-04-07T22:19:16.251810+00:00 0:09:02.628359 14715 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T22:10:11.357397+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T21:00:00+00:00 EmrJobFlowSensor 2021-04-07T22:10:07.643409+00:00 2021-04-07T22:19:10.358200+00:00 0:09:02.714791 14714 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T22:10:05.282338+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T22:09:51.410132+00:00 2021-04-07T22:09:53.084951+00:00 0:00:01.674819 14713 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T22:09:49.262591+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T22:09:47.508726+00:00 2021-04-07T22:09:49.299205+00:00 0:00:01.790479 14712 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T22:09:45.261410+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T21:00:00+00:00 PythonOperator 2021-04-07T22:09:31.810144+00:00 2021-04-07T22:09:34.866130+00:00 0:00:03.055986 14711 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T22:09:29.257896+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T21:00:00+00:00 PythonOperator 2021-04-07T22:09:25.492903+00:00 2021-04-07T22:09:28.375290+00:00 0:00:02.882387 14710 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T22:09:23.201959+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T21:00:00+00:00 TriggerDagRunOperator 2021-04-07T22:09:11.643471+00:00 2021-04-07T22:09:12.193643+00:00 0:00:00.550172 14709 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T22:09:09.192921+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T21:00:00+00:00 TriggerDagRunOperator 2021-04-07T22:09:11.593429+00:00 2021-04-07T22:09:12.006216+00:00 0:00:00.412787 14708 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T22:09:09.192985+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T21:05:00+00:00 EmrJobFlowSensor 2021-04-07T22:06:07.088204+00:00 2021-04-07T22:14:09.500766+00:00 0:08:02.412562 14707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T22:06:04.957676+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T22:05:43.175454+00:00 2021-04-07T22:05:44.873846+00:00 0:00:01.698392 14706 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T22:05:40.895137+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T21:05:00+00:00 PythonOperator 2021-04-07T22:05:21.114392+00:00 2021-04-07T22:05:23.817242+00:00 0:00:02.702850 14705 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T22:05:18.822647+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T21:00:00+00:00 EmrJobFlowSensor 2021-04-07T22:01:01.041002+00:00 2021-04-07T22:09:03.843829+00:00 0:08:02.802827 14704 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T22:00:58.578737+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T22:00:38.979827+00:00 2021-04-07T22:00:40.686889+00:00 0:00:01.707062 14703 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T22:00:36.440828+00:00 2 default_pool