Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-history-job_v002 create_emr_steps 2021-05-14T10:00:00+00:00 PythonOperator 2021-05-14T11:09:08.981685+00:00 2021-05-14T11:09:12.519322+00:00 0:00:03.537637 27979 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T11:09:06.073921+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T10:00:00+00:00 TriggerDagRunOperator 2021-05-14T11:09:04.411677+00:00 2021-05-14T11:09:04.936599+00:00 0:00:00.524922 27978 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T11:09:02.071906+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T10:00:00+00:00 TriggerDagRunOperator 2021-05-14T11:09:04.179677+00:00 2021-05-14T11:09:04.624766+00:00 0:00:00.445089 27977 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T11:09:02.071875+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-14T10:05:00+00:00 EmrJobFlowSensor 2021-05-14T11:06:00.325525+00:00 2021-05-14T11:14:02.956134+00:00 0:08:02.630609 27976 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T11:05:57.860152+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-14T10:05:00+00:00 EmrCreateJobFlowOperator 2021-05-14T11:05:37.938849+00:00 2021-05-14T11:05:39.570892+00:00 0:00:01.632043 27975 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T11:05:35.815379+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-14T10:05:00+00:00 PythonOperator 2021-05-14T11:05:16.046743+00:00 2021-05-14T11:05:19.238086+00:00 0:00:03.191343 27974 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T11:05:13.799438+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T10:00:00+00:00 EmrJobFlowSensor 2021-05-14T11:00:57.648602+00:00 2021-05-14T11:09:00.380692+00:00 0:08:02.732090 27973 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T11:00:55.389343+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T11:00:35.621991+00:00 2021-05-14T11:00:37.452708+00:00 0:00:01.830717 27972 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T11:00:33.355323+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T10:00:00+00:00 PythonOperator 2021-05-14T11:00:13.751801+00:00 2021-05-14T11:00:16.887183+00:00 0:00:03.135382 27971 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T11:00:11.333080+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-14T09:00:00+00:00 EmrJobFlowSensor 2021-05-14T10:11:11.706242+00:00 2021-05-14T10:19:14.286632+00:00 0:08:02.580390 27969 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T10:11:09.058498+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-14T09:00:00+00:00 EmrJobFlowSensor 2021-05-14T10:11:09.267957+00:00 2021-05-14T10:21:12.490618+00:00 0:10:03.222661 27968 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T10:11:07.031584+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-14T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T10:10:49.409099+00:00 2021-05-14T10:10:51.199151+00:00 0:00:01.790052 27967 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T10:10:47.008508+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-14T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T10:10:49.295229+00:00 2021-05-14T10:10:50.998880+00:00 0:00:01.703651 27966 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T10:10:47.008557+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-14T09:00:00+00:00 PythonOperator 2021-05-14T10:10:27.558914+00:00 2021-05-14T10:10:30.783255+00:00 0:00:03.224341 27965 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T10:10:25.048576+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-14T09:00:00+00:00 PythonOperator 2021-05-14T10:10:27.312043+00:00 2021-05-14T10:10:30.712013+00:00 0:00:03.399970 27964 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T10:10:25.048624+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T09:00:00+00:00 TriggerDagRunOperator 2021-05-14T10:10:03.486070+00:00 2021-05-14T10:10:04.185765+00:00 0:00:00.699695 27963 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T10:10:00.942324+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T09:00:00+00:00 TriggerDagRunOperator 2021-05-14T10:10:03.296226+00:00 2021-05-14T10:10:03.730691+00:00 0:00:00.434465 27962 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T10:10:00.942273+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-14T09:05:00+00:00 EmrJobFlowSensor 2021-05-14T10:05:52.678541+00:00 2021-05-14T10:14:55.337262+00:00 0:09:02.658721 27961 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T10:05:50.416778+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-14T09:05:00+00:00 EmrCreateJobFlowOperator 2021-05-14T10:05:30.546109+00:00 2021-05-14T10:05:32.170834+00:00 0:00:01.624725 27960 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T10:05:28.396631+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-14T09:05:00+00:00 PythonOperator 2021-05-14T10:05:04.570155+00:00 2021-05-14T10:05:07.580632+00:00 0:00:03.010477 27959 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T10:05:02.349457+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T09:00:00+00:00 EmrJobFlowSensor 2021-05-14T10:00:49.985524+00:00 2021-05-14T10:09:52.740509+00:00 0:09:02.754985 27958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T10:00:47.808192+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T10:00:28.413135+00:00 2021-05-14T10:00:30.283083+00:00 0:00:01.869948 27957 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T10:00:25.857365+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T09:00:00+00:00 PythonOperator 2021-05-14T10:00:05.973405+00:00 2021-05-14T10:00:09.203652+00:00 0:00:03.230247 27956 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T10:00:03.764644+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-14T08:00:00+00:00 EmrJobFlowSensor 2021-05-14T09:14:25.193440+00:00 2021-05-14T09:24:27.963302+00:00 0:10:02.769862 27955 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T09:14:23.021687+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-14T08:00:00+00:00 EmrJobFlowSensor 2021-05-14T09:14:21.292555+00:00 2021-05-14T09:22:23.873729+00:00 0:08:02.581174 27954 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T09:14:19.035366+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-14T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T09:14:03.457160+00:00 2021-05-14T09:14:05.300518+00:00 0:00:01.843358 27953 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T09:14:01.073136+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-14T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T09:13:59.307507+00:00 2021-05-14T09:14:01.087821+00:00 0:00:01.780314 27952 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T09:13:57.061712+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-14T08:00:00+00:00 PythonOperator 2021-05-14T09:13:41.744793+00:00 2021-05-14T09:13:45.190760+00:00 0:00:03.445967 27951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T09:13:38.986510+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-14T08:00:00+00:00 PythonOperator 2021-05-14T09:13:37.244795+00:00 2021-05-14T09:13:40.998952+00:00 0:00:03.754157 27950 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T09:13:34.968356+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T08:00:00+00:00 TriggerDagRunOperator 2021-05-14T09:13:23.621015+00:00 2021-05-14T09:13:24.215273+00:00 0:00:00.594258 27949 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T09:13:20.941361+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T08:00:00+00:00 TriggerDagRunOperator 2021-05-14T09:13:23.292802+00:00 2021-05-14T09:13:23.684426+00:00 0:00:00.391624 27948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T09:13:20.941391+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-14T08:05:00+00:00 EmrJobFlowSensor 2021-05-14T09:05:58.984530+00:00 2021-05-14T09:14:01.451160+00:00 0:08:02.466630 27946 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T09:05:56.861250+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-14T08:05:00+00:00 EmrCreateJobFlowOperator 2021-05-14T09:05:39.176965+00:00 2021-05-14T09:05:40.881288+00:00 0:00:01.704323 27945 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T09:05:36.872751+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-14T08:05:00+00:00 PythonOperator 2021-05-14T09:05:17.014299+00:00 2021-05-14T09:05:20.108522+00:00 0:00:03.094223 27944 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T09:05:14.859960+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T08:00:00+00:00 EmrJobFlowSensor 2021-05-14T09:00:52.731424+00:00 2021-05-14T09:12:55.963396+00:00 0:12:03.231972 27943 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T09:00:50.430264+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T09:00:30.956962+00:00 2021-05-14T09:00:32.801771+00:00 0:00:01.844809 27942 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T09:00:28.546143+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T08:00:00+00:00 PythonOperator 2021-05-14T09:00:08.581295+00:00 2021-05-14T09:00:11.789437+00:00 0:00:03.208142 27941 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T09:00:06.361598+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-14T07:00:00+00:00 EmrJobFlowSensor 2021-05-14T08:12:49.900901+00:00 2021-05-14T08:20:52.425350+00:00 0:08:02.524449 27940 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T08:12:47.603358+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-14T07:00:00+00:00 EmrJobFlowSensor 2021-05-14T08:12:06.131515+00:00 2021-05-14T08:22:09.192601+00:00 0:10:03.061086 27938 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T08:12:03.859088+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-14T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T08:11:54.051762+00:00 2021-05-14T08:11:55.737682+00:00 0:00:01.685920 27937 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T08:11:51.738656+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-14T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T08:11:42.480404+00:00 2021-05-14T08:11:44.302173+00:00 0:00:01.821769 27936 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T08:11:39.726239+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-14T07:00:00+00:00 PythonOperator 2021-05-14T08:11:34.151070+00:00 2021-05-14T08:11:37.337782+00:00 0:00:03.186712 27935 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T08:11:31.686303+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-14T07:00:00+00:00 PythonOperator 2021-05-14T08:11:21.802843+00:00 2021-05-14T08:11:25.232228+00:00 0:00:03.429385 27934 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T08:11:19.636598+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T07:00:00+00:00 TriggerDagRunOperator 2021-05-14T08:11:16.039131+00:00 2021-05-14T08:11:16.599810+00:00 0:00:00.560679 27933 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T08:11:13.631749+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T07:00:00+00:00 TriggerDagRunOperator 2021-05-14T08:11:15.899822+00:00 2021-05-14T08:11:16.332793+00:00 0:00:00.432971 27932 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T08:11:13.631706+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-14T07:05:00+00:00 EmrJobFlowSensor 2021-05-14T08:06:03.510334+00:00 2021-05-14T08:14:06.200946+00:00 0:08:02.690612 27931 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T08:06:01.099732+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-14T07:05:00+00:00 EmrCreateJobFlowOperator 2021-05-14T08:05:41.285833+00:00 2021-05-14T08:05:42.930839+00:00 0:00:01.645006 27930 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T08:05:39.140814+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-14T07:05:00+00:00 PythonOperator 2021-05-14T08:05:19.342113+00:00 2021-05-14T08:05:22.385170+00:00 0:00:03.043057 27929 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T08:05:17.024713+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T07:00:00+00:00 EmrJobFlowSensor 2021-05-14T08:00:58.689816+00:00 2021-05-14T08:11:01.556759+00:00 0:10:02.866943 27928 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T08:00:56.599521+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T08:00:36.793585+00:00 2021-05-14T08:00:38.487858+00:00 0:00:01.694273 27927 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T08:00:34.557936+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T07:00:00+00:00 PythonOperator 2021-05-14T08:00:14.664474+00:00 2021-05-14T08:00:17.814951+00:00 0:00:03.150477 27926 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T08:00:12.483789+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-14T06:00:00+00:00 EmrJobFlowSensor 2021-05-14T07:22:17.004778+00:00 2021-05-14T07:32:19.792150+00:00 0:10:02.787372 27925 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T07:22:14.854887+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-14T06:00:00+00:00 EmrJobFlowSensor 2021-05-14T07:21:28.941244+00:00 2021-05-14T07:30:31.598040+00:00 0:09:02.656796 27924 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T07:21:26.712174+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-14T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T07:21:04.855395+00:00 2021-05-14T07:21:06.629034+00:00 0:00:01.773639 27923 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T07:21:02.695086+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-14T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T07:20:59.018147+00:00 2021-05-14T07:21:00.809119+00:00 0:00:01.790972 27922 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T07:20:56.687698+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-14T06:00:00+00:00 PythonOperator 2021-05-14T07:20:43.010552+00:00 2021-05-14T07:20:46.186143+00:00 0:00:03.175591 27921 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T07:20:40.672738+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-14T06:00:00+00:00 PythonOperator 2021-05-14T07:20:36.887059+00:00 2021-05-14T07:20:40.275625+00:00 0:00:03.388566 27920 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T07:20:34.675318+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T06:00:00+00:00 TriggerDagRunOperator 2021-05-14T07:20:25.159743+00:00 2021-05-14T07:20:25.686201+00:00 0:00:00.526458 27919 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T07:20:22.655792+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T06:00:00+00:00 TriggerDagRunOperator 2021-05-14T07:20:24.975863+00:00 2021-05-14T07:20:25.442307+00:00 0:00:00.466444 27918 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T07:20:22.655766+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-14T06:05:00+00:00 EmrJobFlowSensor 2021-05-14T07:05:50.977322+00:00 2021-05-14T07:14:53.819309+00:00 0:09:02.841987 27916 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T07:05:48.754987+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-14T06:05:00+00:00 EmrCreateJobFlowOperator 2021-05-14T07:05:28.786489+00:00 2021-05-14T07:05:30.425087+00:00 0:00:01.638598 27915 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T07:05:26.709224+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-14T06:05:00+00:00 PythonOperator 2021-05-14T07:05:08.905666+00:00 2021-05-14T07:05:11.987029+00:00 0:00:03.081363 27914 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T07:05:06.689316+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T06:00:00+00:00 EmrJobFlowSensor 2021-05-14T07:01:00.710869+00:00 2021-05-14T07:20:05.080632+00:00 0:19:04.369763 27913 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T07:00:58.262472+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T07:00:38.397420+00:00 2021-05-14T07:00:40.084251+00:00 0:00:01.686831 27912 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T07:00:36.197833+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T06:00:00+00:00 PythonOperator 2021-05-14T07:00:18.511401+00:00 2021-05-14T07:00:21.637976+00:00 0:00:03.126575 27911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T07:00:16.244772+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-14T05:00:00+00:00 EmrJobFlowSensor 2021-05-14T06:11:27.517840+00:00 2021-05-14T06:20:30.430417+00:00 0:09:02.912577 27910 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T06:11:25.247305+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-14T05:00:00+00:00 EmrJobFlowSensor 2021-05-14T06:11:07.513713+00:00 2021-05-14T06:23:10.691743+00:00 0:12:03.178030 27909 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T06:11:05.226957+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-14T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T06:11:05.398976+00:00 2021-05-14T06:11:07.114637+00:00 0:00:01.715661 27908 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T06:11:03.225817+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-14T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T06:10:45.758804+00:00 2021-05-14T06:10:47.589785+00:00 0:00:01.830981 27907 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T06:10:43.259945+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-14T05:00:00+00:00 PythonOperator 2021-05-14T06:10:43.596313+00:00 2021-05-14T06:10:46.718470+00:00 0:00:03.122157 27906 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T06:10:41.269462+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-14T05:00:00+00:00 PythonOperator 2021-05-14T06:10:25.541506+00:00 2021-05-14T06:10:28.919715+00:00 0:00:03.378209 27905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T06:10:23.260362+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T05:00:00+00:00 TriggerDagRunOperator 2021-05-14T06:10:20.036330+00:00 2021-05-14T06:10:20.563824+00:00 0:00:00.527494 27904 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T06:10:17.260543+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T05:00:00+00:00 TriggerDagRunOperator 2021-05-14T06:10:19.784230+00:00 2021-05-14T06:10:20.200037+00:00 0:00:00.415807 27903 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T06:10:17.260573+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-14T05:05:00+00:00 EmrJobFlowSensor 2021-05-14T06:06:06.467139+00:00 2021-05-14T06:14:09.057223+00:00 0:08:02.590084 27901 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T06:06:04.350878+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-14T05:05:00+00:00 EmrCreateJobFlowOperator 2021-05-14T06:05:46.357239+00:00 2021-05-14T06:05:47.951332+00:00 0:00:01.594093 27900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T06:05:44.256712+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-14T05:05:00+00:00 PythonOperator 2021-05-14T06:05:24.715598+00:00 2021-05-14T06:05:27.796307+00:00 0:00:03.080709 27899 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T06:05:22.259457+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T05:00:00+00:00 EmrJobFlowSensor 2021-05-14T06:01:04.032995+00:00 2021-05-14T06:10:06.752136+00:00 0:09:02.719141 27898 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T06:01:01.889552+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T06:00:42.103289+00:00 2021-05-14T06:00:43.934040+00:00 0:00:01.830751 27897 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T06:00:39.821339+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T05:00:00+00:00 PythonOperator 2021-05-14T06:00:19.976349+00:00 2021-05-14T06:00:23.117914+00:00 0:00:03.141565 27896 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T06:00:17.802500+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-14T04:00:00+00:00 EmrJobFlowSensor 2021-05-14T05:11:35.367457+00:00 2021-05-14T05:20:38.033642+00:00 0:09:02.666185 27895 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T05:11:32.746958+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-14T04:00:00+00:00 EmrJobFlowSensor 2021-05-14T05:11:32.997661+00:00 2021-05-14T05:24:36.419149+00:00 0:13:03.421488 27894 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T05:11:30.671839+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-14T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T05:11:12.960457+00:00 2021-05-14T05:11:14.689461+00:00 0:00:01.729004 27893 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T05:11:10.655771+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-14T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T05:11:10.908998+00:00 2021-05-14T05:11:12.799701+00:00 0:00:01.890703 27892 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T05:11:08.599616+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-14T04:00:00+00:00 PythonOperator 2021-05-14T05:10:50.845934+00:00 2021-05-14T05:10:54.055520+00:00 0:00:03.209586 27891 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T05:10:48.559791+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-14T04:00:00+00:00 PythonOperator 2021-05-14T05:10:50.766745+00:00 2021-05-14T05:10:54.151592+00:00 0:00:03.384847 27890 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T05:10:48.559830+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T04:00:00+00:00 TriggerDagRunOperator 2021-05-14T05:10:37.065982+00:00 2021-05-14T05:10:37.489326+00:00 0:00:00.423344 27889 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T05:10:34.536140+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T04:00:00+00:00 TriggerDagRunOperator 2021-05-14T05:10:36.992580+00:00 2021-05-14T05:10:37.559032+00:00 0:00:00.566452 27888 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T05:10:34.536183+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-14T04:05:00+00:00 EmrJobFlowSensor 2021-05-14T05:05:46.651360+00:00 2021-05-14T05:14:49.329796+00:00 0:09:02.678436 27886 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T05:05:44.550862+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-14T04:05:00+00:00 EmrCreateJobFlowOperator 2021-05-14T05:05:26.899440+00:00 2021-05-14T05:05:28.672012+00:00 0:00:01.772572 27885 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T05:05:24.581309+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-14T04:05:00+00:00 PythonOperator 2021-05-14T05:05:04.889895+00:00 2021-05-14T05:05:07.935244+00:00 0:00:03.045349 27884 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T05:05:02.501973+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T04:00:00+00:00 EmrJobFlowSensor 2021-05-14T05:01:10.385641+00:00 2021-05-14T05:10:13.076707+00:00 0:09:02.691066 27883 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T05:01:08.147120+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T05:00:44.566174+00:00 2021-05-14T05:00:46.396691+00:00 0:00:01.830517 27882 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T05:00:42.147172+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T04:00:00+00:00 PythonOperator 2021-05-14T05:00:16.428413+00:00 2021-05-14T05:00:19.537510+00:00 0:00:03.109097 27881 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T05:00:14.094090+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-14T03:00:00+00:00 EmrJobFlowSensor 2021-05-14T04:23:54.663124+00:00 2021-05-14T04:23:56.280151+00:00 0:00:01.617027 27880 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T04:23:52.238954+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-14T03:00:00+00:00 EmrJobFlowSensor 2021-05-14T04:11:21.614043+00:00 2021-05-14T04:20:24.353590+00:00 0:09:02.739547 27878 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T04:11:18.835144+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-14T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T04:11:13.010472+00:00 2021-05-14T04:11:14.753034+00:00 0:00:01.742562 27877 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T04:11:10.829633+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-14T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T04:10:59.374431+00:00 2021-05-14T04:11:01.051234+00:00 0:00:01.676803 27876 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T04:10:56.816505+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-14T03:00:00+00:00 PythonOperator 2021-05-14T04:10:51.082598+00:00 2021-05-14T04:10:54.454393+00:00 0:00:03.371795 27875 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T04:10:48.806365+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-14T03:00:00+00:00 PythonOperator 2021-05-14T04:10:38.919119+00:00 2021-05-14T04:10:42.048562+00:00 0:00:03.129443 27874 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T04:10:36.794578+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T03:00:00+00:00 TriggerDagRunOperator 2021-05-14T04:10:27.350454+00:00 2021-05-14T04:10:27.888773+00:00 0:00:00.538319 27873 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T04:10:24.843734+00:00 2 default_pool