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 check_cluster_status 2021-04-11T05:00:00+00:00 EmrJobFlowSensor 2021-04-11T06:10:16.135391+00:00 2021-04-11T06:19:18.882208+00:00 0:09:02.746817 15913 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T06:10:13.824991+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T06:10:02.643851+00:00 2021-04-11T06:10:04.366490+00:00 0:00:01.722639 15912 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T06:09:59.962962+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T06:09:55.999580+00:00 2021-04-11T06:09:57.756038+00:00 0:00:01.756458 15911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T06:09:53.820650+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T05:00:00+00:00 PythonOperator 2021-04-11T06:09:40.283196+00:00 2021-04-11T06:09:43.220929+00:00 0:00:02.937733 15910 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T06:09:37.851096+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T05:00:00+00:00 PythonOperator 2021-04-11T06:09:34.243886+00:00 2021-04-11T06:09:37.049353+00:00 0:00:02.805467 15909 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T06:09:31.846535+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T05:00:00+00:00 TriggerDagRunOperator 2021-04-11T06:09:16.489744+00:00 2021-04-11T06:09:16.971327+00:00 0:00:00.481583 15908 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T06:09:13.781497+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T05:00:00+00:00 TriggerDagRunOperator 2021-04-11T06:09:16.209583+00:00 2021-04-11T06:09:16.771574+00:00 0:00:00.561991 15907 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T06:09:13.781452+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T05:05:00+00:00 EmrJobFlowSensor 2021-04-11T06:06:00.170286+00:00 2021-04-11T06:15:02.976647+00:00 0:09:02.806361 15906 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T06:05:57.570035+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T06:05:39.680764+00:00 2021-04-11T06:05:41.413773+00:00 0:00:01.733009 15905 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T06:05:37.404595+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T05:05:00+00:00 PythonOperator 2021-04-11T06:05:15.690243+00:00 2021-04-11T06:05:18.388620+00:00 0:00:02.698377 15904 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T06:05:13.381026+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T05:00:00+00:00 EmrJobFlowSensor 2021-04-11T06:01:03.123715+00:00 2021-04-11T06:09:06.134832+00:00 0:08:03.011117 15903 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T06:01:00.803622+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T06:00:40.904605+00:00 2021-04-11T06:00:42.619688+00:00 0:00:01.715083 15902 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T06:00:38.782333+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T05:00:00+00:00 PythonOperator 2021-04-11T06:00:19.710959+00:00 2021-04-11T06:00:22.845896+00:00 0:00:03.134937 15901 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T06:00:16.685338+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T04:00:00+00:00 EmrJobFlowSensor 2021-04-11T05:21:00.199353+00:00 2021-04-11T05:37:03.904049+00:00 0:16:03.704696 15899 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T05:20:57.766108+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T04:00:00+00:00 EmrJobFlowSensor 2021-04-11T05:20:07.902894+00:00 2021-04-11T05:30:10.780837+00:00 0:10:02.877943 15898 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T05:20:05.586309+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T05:19:46.547836+00:00 2021-04-11T05:19:48.259639+00:00 0:00:01.711803 15897 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T05:19:43.581570+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T05:19:43.925498+00:00 2021-04-11T05:19:46.106809+00:00 0:00:02.181311 15896 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T05:19:41.526095+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T04:00:00+00:00 PythonOperator 2021-04-11T05:19:24.392689+00:00 2021-04-11T05:19:27.341089+00:00 0:00:02.948400 15895 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T05:19:21.507334+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T04:00:00+00:00 PythonOperator 2021-04-11T05:19:21.918124+00:00 2021-04-11T05:19:25.022325+00:00 0:00:03.104201 15894 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T05:19:19.506303+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T04:00:00+00:00 TriggerDagRunOperator 2021-04-11T05:19:05.937964+00:00 2021-04-11T05:19:06.457662+00:00 0:00:00.519698 15893 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T05:19:03.498673+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T04:00:00+00:00 TriggerDagRunOperator 2021-04-11T05:19:05.775622+00:00 2021-04-11T05:19:06.176819+00:00 0:00:00.401197 15892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T05:19:03.498639+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T04:05:00+00:00 EmrJobFlowSensor 2021-04-11T05:05:58.274605+00:00 2021-04-11T05:15:00.803058+00:00 0:09:02.528453 15891 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T05:05:56.053632+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T05:05:36.162528+00:00 2021-04-11T05:05:37.797473+00:00 0:00:01.634945 15890 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T05:05:34.038602+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T04:05:00+00:00 PythonOperator 2021-04-11T05:05:14.319579+00:00 2021-04-11T05:05:16.994184+00:00 0:00:02.674605 15889 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T05:05:12.058407+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T04:00:00+00:00 EmrJobFlowSensor 2021-04-11T05:00:50.228507+00:00 2021-04-11T05:18:54.240654+00:00 0:18:04.012147 15888 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T05:00:47.607704+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T05:00:29.889587+00:00 2021-04-11T05:00:31.555949+00:00 0:00:01.666362 15887 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T05:00:27.588790+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T04:00:00+00:00 PythonOperator 2021-04-11T05:00:07.949978+00:00 2021-04-11T05:00:10.949202+00:00 0:00:02.999224 15886 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T05:00:05.557448+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T03:00:00+00:00 EmrJobFlowSensor 2021-04-11T04:11:10.527427+00:00 2021-04-11T04:21:13.410373+00:00 0:10:02.882946 15884 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T04:11:08.318298+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T03:00:00+00:00 EmrJobFlowSensor 2021-04-11T04:10:58.759863+00:00 2021-04-11T04:20:01.437023+00:00 0:09:02.677160 15883 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T04:10:56.305774+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T04:10:50.530948+00:00 2021-04-11T04:10:52.201466+00:00 0:00:01.670518 15882 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T04:10:48.300079+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T04:10:36.704844+00:00 2021-04-11T04:10:38.543976+00:00 0:00:01.839132 15881 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T04:10:34.343539+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T03:00:00+00:00 PythonOperator 2021-04-11T04:10:28.523694+00:00 2021-04-11T04:10:31.255579+00:00 0:00:02.731885 15880 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T04:10:26.241188+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T03:00:00+00:00 PythonOperator 2021-04-11T04:10:16.524548+00:00 2021-04-11T04:10:19.880788+00:00 0:00:03.356240 15879 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T04:10:14.230390+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T03:00:00+00:00 TriggerDagRunOperator 2021-04-11T04:10:10.551659+00:00 2021-04-11T04:10:11.110152+00:00 0:00:00.558493 15878 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T04:10:08.226161+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T03:00:00+00:00 TriggerDagRunOperator 2021-04-11T04:10:10.466452+00:00 2021-04-11T04:10:10.872740+00:00 0:00:00.406288 15877 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T04:10:08.226193+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T03:05:00+00:00 EmrJobFlowSensor 2021-04-11T04:05:57.986636+00:00 2021-04-11T04:15:00.576839+00:00 0:09:02.590203 15876 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T04:05:55.840314+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T04:05:37.979707+00:00 2021-04-11T04:05:39.732975+00:00 0:00:01.753268 15875 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T04:05:35.711573+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T03:05:00+00:00 PythonOperator 2021-04-11T04:05:15.842055+00:00 2021-04-11T04:05:18.519332+00:00 0:00:02.677277 15874 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T04:05:13.689370+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T03:00:00+00:00 EmrJobFlowSensor 2021-04-11T04:00:55.539679+00:00 2021-04-11T04:09:58.446268+00:00 0:09:02.906589 15873 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T04:00:53.175871+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T04:00:35.651427+00:00 2021-04-11T04:00:37.324609+00:00 0:00:01.673182 15872 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T04:00:33.161081+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T03:00:00+00:00 PythonOperator 2021-04-11T04:00:13.820033+00:00 2021-04-11T04:00:16.637963+00:00 0:00:02.817930 15871 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T04:00:11.176734+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T02:00:00+00:00 EmrJobFlowSensor 2021-04-11T03:10:08.167623+00:00 2021-04-11T03:20:10.990204+00:00 0:10:02.822581 15869 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T03:10:05.488519+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T02:00:00+00:00 EmrJobFlowSensor 2021-04-11T03:10:05.934834+00:00 2021-04-11T03:20:08.989888+00:00 0:10:03.055054 15868 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T03:10:03.544010+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T03:09:45.667255+00:00 2021-04-11T03:09:47.397230+00:00 0:00:01.729975 15867 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T03:09:43.423572+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T03:09:43.736894+00:00 2021-04-11T03:09:45.569886+00:00 0:00:01.832992 15866 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T03:09:41.425748+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T02:00:00+00:00 PythonOperator 2021-04-11T03:09:23.821633+00:00 2021-04-11T03:09:26.895398+00:00 0:00:03.073765 15865 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T03:09:21.410118+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T02:00:00+00:00 PythonOperator 2021-04-11T03:09:21.776362+00:00 2021-04-11T03:09:24.666862+00:00 0:00:02.890500 15864 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T03:09:19.405555+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T02:00:00+00:00 TriggerDagRunOperator 2021-04-11T03:09:16.061384+00:00 2021-04-11T03:09:16.625558+00:00 0:00:00.564174 15863 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T03:09:13.470450+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T02:00:00+00:00 TriggerDagRunOperator 2021-04-11T03:09:16.037478+00:00 2021-04-11T03:09:16.430618+00:00 0:00:00.393140 15862 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T03:09:13.470499+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T02:05:00+00:00 EmrJobFlowSensor 2021-04-11T03:06:05.575780+00:00 2021-04-11T03:15:08.187786+00:00 0:09:02.612006 15861 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T03:06:03.250268+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T03:05:45.283637+00:00 2021-04-11T03:05:46.950197+00:00 0:00:01.666560 15860 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T03:05:43.096221+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T02:05:00+00:00 PythonOperator 2021-04-11T03:05:23.269939+00:00 2021-04-11T03:05:26.209215+00:00 0:00:02.939276 15859 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T03:05:21.068243+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T02:00:00+00:00 EmrJobFlowSensor 2021-04-11T03:00:56.703310+00:00 2021-04-11T03:08:59.161763+00:00 0:08:02.458453 15858 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T03:00:54.574322+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T03:00:36.760813+00:00 2021-04-11T03:00:38.475313+00:00 0:00:01.714500 15857 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T03:00:34.557722+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T02:00:00+00:00 PythonOperator 2021-04-11T03:00:15.509322+00:00 2021-04-11T03:00:18.308391+00:00 0:00:02.799069 15856 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T03:00:12.568159+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T01:00:00+00:00 EmrJobFlowSensor 2021-04-11T02:12:20.611310+00:00 2021-04-11T02:22:23.622185+00:00 0:10:03.010875 15854 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T02:12:18.364351+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T01:00:00+00:00 EmrJobFlowSensor 2021-04-11T02:12:14.765234+00:00 2021-04-11T02:21:17.448553+00:00 0:09:02.683319 15853 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T02:12:12.357003+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T02:12:00.747061+00:00 2021-04-11T02:12:02.581150+00:00 0:00:01.834089 15852 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T02:11:58.367462+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T02:11:52.552486+00:00 2021-04-11T02:11:54.264224+00:00 0:00:01.711738 15851 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T02:11:50.335939+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T01:00:00+00:00 PythonOperator 2021-04-11T02:11:38.521146+00:00 2021-04-11T02:11:41.704475+00:00 0:00:03.183329 15850 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T02:11:36.321512+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T01:00:00+00:00 PythonOperator 2021-04-11T02:11:31.245636+00:00 2021-04-11T02:11:34.110972+00:00 0:00:02.865336 15849 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T02:11:28.444495+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T01:00:00+00:00 TriggerDagRunOperator 2021-04-11T02:11:18.616728+00:00 2021-04-11T02:11:19.117913+00:00 0:00:00.501185 15848 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T02:11:16.215005+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T01:00:00+00:00 TriggerDagRunOperator 2021-04-11T02:11:18.529814+00:00 2021-04-11T02:11:18.956261+00:00 0:00:00.426447 15847 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T02:11:16.214958+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T01:05:00+00:00 EmrJobFlowSensor 2021-04-11T02:06:11.979005+00:00 2021-04-11T02:14:14.538694+00:00 0:08:02.559689 15846 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T02:06:09.755827+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T02:05:45.870299+00:00 2021-04-11T02:05:47.508428+00:00 0:00:01.638129 15845 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T02:05:43.735020+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T01:05:00+00:00 PythonOperator 2021-04-11T02:05:24.264620+00:00 2021-04-11T02:05:27.109758+00:00 0:00:02.845138 15844 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T02:05:21.763067+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T01:00:00+00:00 EmrJobFlowSensor 2021-04-11T02:01:00.198740+00:00 2021-04-11T02:11:03.155901+00:00 0:10:02.957161 15843 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T02:00:57.472728+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T02:00:37.684071+00:00 2021-04-11T02:00:39.396827+00:00 0:00:01.712756 15842 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T02:00:35.455031+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T01:00:00+00:00 PythonOperator 2021-04-11T02:00:17.715488+00:00 2021-04-11T02:00:20.760334+00:00 0:00:03.044846 15841 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T02:00:15.341548+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-11T00:00:00+00:00 EmrJobFlowSensor 2021-04-11T01:11:19.074423+00:00 2021-04-11T01:22:21.976773+00:00 0:11:02.902350 15839 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T01:11:16.801055+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-11T00:00:00+00:00 EmrJobFlowSensor 2021-04-11T01:11:09.453388+00:00 2021-04-11T01:19:11.888974+00:00 0:08:02.435586 15838 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T01:11:06.790364+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-11T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T01:10:58.995758+00:00 2021-04-11T01:11:00.674264+00:00 0:00:01.678506 15837 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T01:10:56.735797+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-11T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T01:10:49.294924+00:00 2021-04-11T01:10:51.082894+00:00 0:00:01.787970 15836 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T01:10:46.726201+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-11T00:00:00+00:00 PythonOperator 2021-04-11T01:10:37.197037+00:00 2021-04-11T01:10:40.524511+00:00 0:00:03.327474 15835 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T01:10:34.715900+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-11T00:00:00+00:00 PythonOperator 2021-04-11T01:10:26.876731+00:00 2021-04-11T01:10:29.565896+00:00 0:00:02.689165 15834 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T01:10:24.706237+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T00:00:00+00:00 TriggerDagRunOperator 2021-04-11T01:10:11.244742+00:00 2021-04-11T01:10:11.779115+00:00 0:00:00.534373 15833 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T01:10:08.691005+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T00:00:00+00:00 TriggerDagRunOperator 2021-04-11T01:10:11.214571+00:00 2021-04-11T01:10:11.654659+00:00 0:00:00.440088 15832 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T01:10:08.690978+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-11T00:05:00+00:00 EmrJobFlowSensor 2021-04-11T01:06:04.378386+00:00 2021-04-11T01:15:06.963995+00:00 0:09:02.585609 15831 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T01:06:02.037154+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-11T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T01:05:44.436538+00:00 2021-04-11T01:05:46.177437+00:00 0:00:01.740899 15830 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T01:05:42.024039+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-11T00:05:00+00:00 PythonOperator 2021-04-11T01:05:22.387340+00:00 2021-04-11T01:05:25.073975+00:00 0:00:02.686635 15829 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T01:05:20.063614+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T00:00:00+00:00 EmrJobFlowSensor 2021-04-11T01:00:54.176770+00:00 2021-04-11T01:09:56.924696+00:00 0:09:02.747926 15828 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T01:00:51.678723+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T01:00:33.839856+00:00 2021-04-11T01:00:35.560607+00:00 0:00:01.720751 15827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T01:00:31.608062+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T00:00:00+00:00 PythonOperator 2021-04-11T01:00:12.013877+00:00 2021-04-11T01:00:14.716460+00:00 0:00:02.702583 15826 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T01:00:09.589734+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T23:00:00+00:00 EmrJobFlowSensor 2021-04-11T00:11:16.617539+00:00 2021-04-11T00:20:19.263328+00:00 0:09:02.645789 15824 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T00:11:13.847856+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T23:00:00+00:00 EmrJobFlowSensor 2021-04-11T00:11:14.160484+00:00 2021-04-11T00:20:17.237286+00:00 0:09:03.076802 15823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T00:11:11.788342+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-10T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T00:10:55.990859+00:00 2021-04-11T00:10:57.665438+00:00 0:00:01.674579 15822 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T00:10:53.734498+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T00:10:51.923126+00:00 2021-04-11T00:10:53.606368+00:00 0:00:01.683242 15821 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T00:10:49.728286+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-10T23:00:00+00:00 PythonOperator 2021-04-11T00:10:34.043815+00:00 2021-04-11T00:10:37.098060+00:00 0:00:03.054245 15820 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T00:10:31.710895+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-10T23:00:00+00:00 PythonOperator 2021-04-11T00:10:30.324225+00:00 2021-04-11T00:10:33.210205+00:00 0:00:02.885980 15819 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T00:10:27.857507+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T23:00:00+00:00 TriggerDagRunOperator 2021-04-11T00:10:16.051605+00:00 2021-04-11T00:10:16.591724+00:00 0:00:00.540119 15818 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T00:10:13.699023+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T23:00:00+00:00 TriggerDagRunOperator 2021-04-11T00:10:15.926279+00:00 2021-04-11T00:10:16.335725+00:00 0:00:00.409446 15817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T00:10:13.698987+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-10T23:05:00+00:00 EmrJobFlowSensor 2021-04-11T00:06:07.379616+00:00 2021-04-11T00:15:10.027904+00:00 0:09:02.648288 15816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T00:06:05.263895+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-10T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-11T00:05:45.488369+00:00 2021-04-11T00:05:47.140598+00:00 0:00:01.652229 15815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-11T00:05:43.215649+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-10T23:05:00+00:00 PythonOperator 2021-04-11T00:05:23.661960+00:00 2021-04-11T00:05:26.507302+00:00 0:00:02.845342 15814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T00:05:21.201842+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T23:00:00+00:00 EmrJobFlowSensor 2021-04-11T00:00:51.161308+00:00 2021-04-11T00:09:53.989871+00:00 0:09:02.828563 15813 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T00:00:48.667133+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T00:00:28.827940+00:00 2021-04-11T00:00:30.532200+00:00 0:00:01.704260 15812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T00:00:26.608180+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T23:00:00+00:00 PythonOperator 2021-04-11T00:00:09.082594+00:00 2021-04-11T00:00:12.033753+00:00 0:00:02.951159 15811 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T00:00:06.589686+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-10T22:00:00+00:00 EmrJobFlowSensor 2021-04-10T23:11:06.982304+00:00 2021-04-10T23:19:09.517557+00:00 0:08:02.535253 15809 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T23:11:04.717832+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-10T22:00:00+00:00 EmrJobFlowSensor 2021-04-10T23:11:05.017138+00:00 2021-04-10T23:21:07.651835+00:00 0:10:02.634697 15808 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T23:11:02.759377+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-10T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T23:10:46.814933+00:00 2021-04-10T23:10:48.519347+00:00 0:00:01.704414 15807 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-10T23:10:44.704100+00:00 2 default_pool