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 trigger_dagrun_booking-processing-job_v002 2021-04-08T07:00:00+00:00 TriggerDagRunOperator 2021-04-08T08:11:10.513173+00:00 2021-04-08T08:11:10.924099+00:00 0:00:00.410926 14858 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T08:11:08.192674+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T07:05:00+00:00 EmrJobFlowSensor 2021-04-08T08:05:50.179971+00:00 2021-04-08T08:14:52.762264+00:00 0:09:02.582293 14857 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T08:05:47.859742+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T08:05:30.413798+00:00 2021-04-08T08:05:32.116033+00:00 0:00:01.702235 14856 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T08:05:27.862086+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T07:05:00+00:00 PythonOperator 2021-04-08T08:05:07.852778+00:00 2021-04-08T08:05:10.528597+00:00 0:00:02.675819 14855 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T08:05:05.711724+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T07:00:00+00:00 EmrJobFlowSensor 2021-04-08T08:00:49.699891+00:00 2021-04-08T08:10:52.650156+00:00 0:10:02.950265 14854 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T08:00:47.257211+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T08:00:29.464003+00:00 2021-04-08T08:00:31.166649+00:00 0:00:01.702646 14853 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T08:00:27.114545+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T07:00:00+00:00 PythonOperator 2021-04-08T08:00:07.657977+00:00 2021-04-08T08:00:10.578107+00:00 0:00:02.920130 14852 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T08:00:05.087675+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T06:00:00+00:00 EmrJobFlowSensor 2021-04-08T07:13:39.900422+00:00 2021-04-08T07:21:42.445798+00:00 0:08:02.545376 14850 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T07:13:36.997785+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T06:00:00+00:00 EmrJobFlowSensor 2021-04-08T07:13:37.358751+00:00 2021-04-08T07:23:40.675997+00:00 0:10:03.317246 14849 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T07:13:34.988648+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T07:13:11.169380+00:00 2021-04-08T07:13:12.925609+00:00 0:00:01.756229 14848 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T07:13:08.946230+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T07:13:09.405686+00:00 2021-04-08T07:13:11.205363+00:00 0:00:01.799677 14847 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T07:13:06.956875+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T06:00:00+00:00 PythonOperator 2021-04-08T07:12:49.211431+00:00 2021-04-08T07:12:52.005709+00:00 0:00:02.794278 14846 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T07:12:46.853012+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T06:00:00+00:00 PythonOperator 2021-04-08T07:12:47.394858+00:00 2021-04-08T07:12:50.369733+00:00 0:00:02.974875 14845 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T07:12:44.870776+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T06:00:00+00:00 TriggerDagRunOperator 2021-04-08T07:12:35.121543+00:00 2021-04-08T07:12:35.657370+00:00 0:00:00.535827 14844 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T07:12:32.806656+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T06:00:00+00:00 TriggerDagRunOperator 2021-04-08T07:12:34.995032+00:00 2021-04-08T07:12:35.444453+00:00 0:00:00.449421 14843 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T07:12:32.806688+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T06:05:00+00:00 EmrJobFlowSensor 2021-04-08T07:05:56.386653+00:00 2021-04-08T07:13:58.845130+00:00 0:08:02.458477 14842 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T07:05:54.164812+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T07:05:34.415185+00:00 2021-04-08T07:05:36.327148+00:00 0:00:01.911963 14841 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T07:05:32.041740+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T06:05:00+00:00 PythonOperator 2021-04-08T07:05:12.093469+00:00 2021-04-08T07:05:14.759850+00:00 0:00:02.666381 14840 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T07:05:09.960867+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T06:00:00+00:00 EmrJobFlowSensor 2021-04-08T07:01:09.928140+00:00 2021-04-08T07:12:12.992092+00:00 0:11:03.063952 14839 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T07:01:07.538751+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T07:00:35.817836+00:00 2021-04-08T07:00:37.662403+00:00 0:00:01.844567 14838 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T07:00:33.504026+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T06:00:00+00:00 PythonOperator 2021-04-08T07:00:11.934258+00:00 2021-04-08T07:00:14.637584+00:00 0:00:02.703326 14837 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T07:00:09.494139+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T05:00:00+00:00 EmrJobFlowSensor 2021-04-08T06:12:17.559181+00:00 2021-04-08T06:20:20.045287+00:00 0:08:02.486106 14835 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T06:12:14.923767+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T05:00:00+00:00 EmrJobFlowSensor 2021-04-08T06:12:15.306756+00:00 2021-04-08T06:22:18.464380+00:00 0:10:03.157624 14834 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T06:12:12.924154+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T06:11:55.217400+00:00 2021-04-08T06:11:56.993066+00:00 0:00:01.775666 14833 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T06:11:52.902847+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T06:11:53.165303+00:00 2021-04-08T06:11:54.873644+00:00 0:00:01.708341 14832 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T06:11:50.955313+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T05:00:00+00:00 PythonOperator 2021-04-08T06:11:33.217013+00:00 2021-04-08T06:11:36.580926+00:00 0:00:03.363913 14831 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T06:11:30.883372+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T05:00:00+00:00 PythonOperator 2021-04-08T06:11:31.220028+00:00 2021-04-08T06:11:34.208738+00:00 0:00:02.988710 14830 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T06:11:28.947944+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T05:00:00+00:00 TriggerDagRunOperator 2021-04-08T06:11:13.150696+00:00 2021-04-08T06:11:13.700076+00:00 0:00:00.549380 14829 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T06:11:10.793868+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T05:00:00+00:00 TriggerDagRunOperator 2021-04-08T06:11:13.015966+00:00 2021-04-08T06:11:13.433772+00:00 0:00:00.417806 14828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T06:11:10.793832+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T05:05:00+00:00 EmrJobFlowSensor 2021-04-08T06:05:46.640801+00:00 2021-04-08T06:14:49.419955+00:00 0:09:02.779154 14827 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T06:05:44.261740+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T06:05:26.357858+00:00 2021-04-08T06:05:28.013618+00:00 0:00:01.655760 14826 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T06:05:24.205524+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T05:05:00+00:00 PythonOperator 2021-04-08T06:05:04.588323+00:00 2021-04-08T06:05:07.315242+00:00 0:00:02.726919 14825 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T06:05:02.253792+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T05:00:00+00:00 EmrJobFlowSensor 2021-04-08T06:00:48.290229+00:00 2021-04-08T06:10:51.181650+00:00 0:10:02.891421 14824 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T06:00:45.809004+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T06:00:26.055870+00:00 2021-04-08T06:00:27.810385+00:00 0:00:01.754515 14823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T06:00:23.796157+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T05:00:00+00:00 PythonOperator 2021-04-08T06:00:06.282762+00:00 2021-04-08T06:00:09.154444+00:00 0:00:02.871682 14822 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T06:00:03.781449+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T04:00:00+00:00 EmrJobFlowSensor 2021-04-08T05:12:47.801684+00:00 2021-04-08T05:20:50.281193+00:00 0:08:02.479509 14820 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T05:12:45.631397+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T04:00:00+00:00 EmrJobFlowSensor 2021-04-08T05:12:37.937107+00:00 2021-04-08T05:23:41.066115+00:00 0:11:03.129008 14819 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T05:12:35.614730+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T05:12:11.815184+00:00 2021-04-08T05:12:13.510428+00:00 0:00:01.695244 14818 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T05:12:09.591042+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T05:12:08.008686+00:00 2021-04-08T05:12:09.723936+00:00 0:00:01.715250 14817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T05:12:05.651522+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T04:00:00+00:00 PythonOperator 2021-04-08T05:11:48.497550+00:00 2021-04-08T05:11:51.224722+00:00 0:00:02.727172 14816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T05:11:45.586754+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T04:00:00+00:00 PythonOperator 2021-04-08T05:11:45.994121+00:00 2021-04-08T05:11:49.302220+00:00 0:00:03.308099 14815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T05:11:43.577591+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T04:00:00+00:00 TriggerDagRunOperator 2021-04-08T05:11:27.817554+00:00 2021-04-08T05:11:28.325893+00:00 0:00:00.508339 14814 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T05:11:25.496549+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T04:00:00+00:00 TriggerDagRunOperator 2021-04-08T05:11:27.704929+00:00 2021-04-08T05:11:28.112722+00:00 0:00:00.407793 14813 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T05:11:25.496515+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T04:05:00+00:00 EmrJobFlowSensor 2021-04-08T05:05:53.438340+00:00 2021-04-08T05:14:56.147596+00:00 0:09:02.709256 14812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T05:05:50.959720+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T05:05:33.345563+00:00 2021-04-08T05:05:35.080337+00:00 0:00:01.734774 14811 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T05:05:30.886719+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T04:05:00+00:00 PythonOperator 2021-04-08T05:05:10.921912+00:00 2021-04-08T05:05:13.597205+00:00 0:00:02.675293 14810 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T05:05:08.761489+00:00 2 default_pool
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