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_campaign-history-job_v002 2021-04-02T12:00:00+00:00 TriggerDagRunOperator 2021-04-02T13:11:27.328018+00:00 2021-04-02T13:11:27.841904+00:00 0:00:00.513886 12771 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T13:11:24.250815+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T12:00:00+00:00 TriggerDagRunOperator 2021-04-02T13:11:27.112662+00:00 2021-04-02T13:11:27.544956+00:00 0:00:00.432294 12770 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T13:11:24.250859+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T12:05:00+00:00 EmrJobFlowSensor 2021-04-02T13:06:04.862674+00:00 2021-04-02T13:14:07.434846+00:00 0:08:02.572172 12768 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T13:06:02.459255+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T13:05:42.530629+00:00 2021-04-02T13:05:44.284438+00:00 0:00:01.753809 12767 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T13:05:40.316100+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T12:05:00+00:00 PythonOperator 2021-04-02T13:05:22.484969+00:00 2021-04-02T13:05:25.154582+00:00 0:00:02.669613 12766 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T13:05:20.299305+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T12:00:00+00:00 EmrJobFlowSensor 2021-04-02T13:01:06.130918+00:00 2021-04-02T13:11:09.022565+00:00 0:10:02.891647 12765 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T13:01:03.891095+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T13:00:44.389820+00:00 2021-04-02T13:00:46.212868+00:00 0:00:01.823048 12764 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T13:00:41.846724+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T12:00:00+00:00 PythonOperator 2021-04-02T13:00:24.269985+00:00 2021-04-02T13:00:27.014844+00:00 0:00:02.744859 12763 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T13:00:21.828320+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T11:00:00+00:00 EmrJobFlowSensor 2021-04-02T12:11:26.921367+00:00 2021-04-02T12:19:29.579157+00:00 0:08:02.657790 12762 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T12:11:24.709032+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T11:00:00+00:00 EmrJobFlowSensor 2021-04-02T12:11:23.045606+00:00 2021-04-02T12:21:26.119976+00:00 0:10:03.074370 12761 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T12:11:20.705396+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T12:11:04.987732+00:00 2021-04-02T12:11:06.688871+00:00 0:00:01.701139 12760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T12:11:02.687975+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T12:11:01.140821+00:00 2021-04-02T12:11:02.999189+00:00 0:00:01.858368 12759 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T12:10:58.756657+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T11:00:00+00:00 PythonOperator 2021-04-02T12:10:43.029611+00:00 2021-04-02T12:10:45.896559+00:00 0:00:02.866948 12758 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T12:10:40.671786+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T11:00:00+00:00 PythonOperator 2021-04-02T12:10:38.903303+00:00 2021-04-02T12:10:41.851726+00:00 0:00:02.948423 12757 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T12:10:36.686654+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T11:00:00+00:00 TriggerDagRunOperator 2021-04-02T12:10:23.014831+00:00 2021-04-02T12:10:23.611397+00:00 0:00:00.596566 12756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T12:10:20.648208+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T11:00:00+00:00 TriggerDagRunOperator 2021-04-02T12:10:22.961913+00:00 2021-04-02T12:10:23.717311+00:00 0:00:00.755398 12755 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T12:10:20.648172+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T11:05:00+00:00 EmrJobFlowSensor 2021-04-02T12:07:03.089641+00:00 2021-04-02T12:15:05.565625+00:00 0:08:02.475984 12754 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T12:07:00.463472+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T12:05:42.185741+00:00 2021-04-02T12:05:43.888031+00:00 0:00:01.702290 12752 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T12:05:39.925482+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T11:05:00+00:00 PythonOperator 2021-04-02T12:05:22.334776+00:00 2021-04-02T12:05:25.120156+00:00 0:00:02.785380 12751 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T12:05:19.960258+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T11:00:00+00:00 EmrJobFlowSensor 2021-04-02T12:00:55.835701+00:00 2021-04-02T12:09:58.483537+00:00 0:09:02.647836 12750 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T12:00:53.497831+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T12:00:33.748113+00:00 2021-04-02T12:00:35.619507+00:00 0:00:01.871394 12749 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T12:00:31.467926+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T11:00:00+00:00 PythonOperator 2021-04-02T12:00:13.711940+00:00 2021-04-02T12:00:16.552626+00:00 0:00:02.840686 12748 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T12:00:11.446146+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T10:00:00+00:00 EmrJobFlowSensor 2021-04-02T11:18:04.009608+00:00 2021-04-02T11:30:07.086151+00:00 0:12:03.076543 12747 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T11:18:01.610556+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T10:00:00+00:00 EmrJobFlowSensor 2021-04-02T11:17:59.910409+00:00 2021-04-02T11:26:02.464646+00:00 0:08:02.554237 12746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T11:17:57.657254+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T11:17:41.891033+00:00 2021-04-02T11:17:43.572600+00:00 0:00:01.681567 12745 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T11:17:39.593759+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T11:17:37.823293+00:00 2021-04-02T11:17:39.569882+00:00 0:00:01.746589 12744 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T11:17:35.606313+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T10:00:00+00:00 PythonOperator 2021-04-02T11:17:20.197067+00:00 2021-04-02T11:17:23.154946+00:00 0:00:02.957879 12743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T11:17:17.548172+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T10:00:00+00:00 PythonOperator 2021-04-02T11:17:18.063930+00:00 2021-04-02T11:17:21.067634+00:00 0:00:03.003704 12742 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T11:17:15.551772+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T10:00:00+00:00 TriggerDagRunOperator 2021-04-02T11:17:07.890021+00:00 2021-04-02T11:17:08.453716+00:00 0:00:00.563695 12741 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T11:17:05.536078+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T10:00:00+00:00 TriggerDagRunOperator 2021-04-02T11:17:07.820343+00:00 2021-04-02T11:17:08.242677+00:00 0:00:00.422334 12740 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T11:17:05.536046+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T10:05:00+00:00 EmrJobFlowSensor 2021-04-02T11:06:59.201469+00:00 2021-04-02T11:16:01.871547+00:00 0:09:02.670078 12739 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T11:06:56.671961+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T10:00:00+00:00 EmrJobFlowSensor 2021-04-02T11:06:53.017134+00:00 2021-04-02T11:16:55.738134+00:00 0:10:02.721000 12738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T11:06:50.661705+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T11:06:38.875619+00:00 2021-04-02T11:06:40.514580+00:00 0:00:01.638961 12737 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T11:06:36.584553+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T11:06:31.251215+00:00 2021-04-02T11:06:32.953802+00:00 0:00:01.702587 12736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T11:06:28.660441+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T10:05:00+00:00 PythonOperator 2021-04-02T11:06:14.724033+00:00 2021-04-02T11:06:17.373011+00:00 0:00:02.648978 12735 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T11:06:12.525588+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T10:00:00+00:00 PythonOperator 2021-04-02T11:06:08.986307+00:00 2021-04-02T11:06:11.827470+00:00 0:00:02.841163 12734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T11:06:06.509926+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T09:00:00+00:00 EmrJobFlowSensor 2021-04-02T10:11:10.249566+00:00 2021-04-02T10:21:13.026319+00:00 0:10:02.776753 12732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T10:11:07.827311+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T09:00:00+00:00 EmrJobFlowSensor 2021-04-02T10:10:56.011821+00:00 2021-04-02T10:19:58.582838+00:00 0:09:02.571017 12731 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T10:10:53.745424+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T10:10:47.920872+00:00 2021-04-02T10:10:49.601820+00:00 0:00:01.680948 12730 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T10:10:45.732551+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T10:10:33.906909+00:00 2021-04-02T10:10:35.682414+00:00 0:00:01.775505 12729 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T10:10:31.718915+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T09:00:00+00:00 PythonOperator 2021-04-02T10:10:27.972311+00:00 2021-04-02T10:10:30.869664+00:00 0:00:02.897353 12728 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T10:10:25.721098+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T09:00:00+00:00 PythonOperator 2021-04-02T10:10:11.945821+00:00 2021-04-02T10:10:14.662637+00:00 0:00:02.716816 12727 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T10:10:09.701769+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T09:00:00+00:00 TriggerDagRunOperator 2021-04-02T10:10:02.365595+00:00 2021-04-02T10:10:02.917735+00:00 0:00:00.552140 12726 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T10:09:59.757512+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T09:00:00+00:00 TriggerDagRunOperator 2021-04-02T10:10:02.282973+00:00 2021-04-02T10:10:02.733031+00:00 0:00:00.450058 12725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T10:09:59.757470+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T09:05:00+00:00 EmrJobFlowSensor 2021-04-02T10:06:00.064741+00:00 2021-04-02T10:15:02.781543+00:00 0:09:02.716802 12724 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T10:05:57.370054+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T10:05:37.676353+00:00 2021-04-02T10:05:39.325930+00:00 0:00:01.649577 12723 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T10:05:35.386853+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T09:05:00+00:00 PythonOperator 2021-04-02T10:05:17.489221+00:00 2021-04-02T10:05:20.177191+00:00 0:00:02.687970 12722 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T10:05:15.324324+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T09:00:00+00:00 EmrJobFlowSensor 2021-04-02T10:00:49.337984+00:00 2021-04-02T10:09:52.133984+00:00 0:09:02.796000 12721 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T10:00:46.950777+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T10:00:29.247624+00:00 2021-04-02T10:00:31.051850+00:00 0:00:01.804226 12720 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T10:00:26.848665+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T09:00:00+00:00 PythonOperator 2021-04-02T10:00:07.096809+00:00 2021-04-02T10:00:09.800667+00:00 0:00:02.703858 12719 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T10:00:04.831944+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T08:00:00+00:00 EmrJobFlowSensor 2021-04-02T09:12:11.077325+00:00 2021-04-02T09:21:13.830037+00:00 0:09:02.752712 12717 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T09:12:08.777822+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T08:00:00+00:00 EmrJobFlowSensor 2021-04-02T09:11:59.110793+00:00 2021-04-02T09:20:01.766960+00:00 0:08:02.656167 12716 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T09:11:56.707216+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T09:11:49.237556+00:00 2021-04-02T09:11:50.944355+00:00 0:00:01.706799 12715 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T09:11:46.752479+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T09:11:36.905980+00:00 2021-04-02T09:11:38.597481+00:00 0:00:01.691501 12714 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T09:11:34.690713+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T08:00:00+00:00 PythonOperator 2021-04-02T09:11:29.071183+00:00 2021-04-02T09:11:32.075956+00:00 0:00:03.004773 12713 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T09:11:26.656593+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T08:00:00+00:00 PythonOperator 2021-04-02T09:11:15.254304+00:00 2021-04-02T09:11:18.025911+00:00 0:00:02.771607 12712 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T09:11:12.648058+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T08:00:00+00:00 TriggerDagRunOperator 2021-04-02T09:11:07.099283+00:00 2021-04-02T09:11:07.550423+00:00 0:00:00.451140 12711 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T09:11:04.663719+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T08:00:00+00:00 TriggerDagRunOperator 2021-04-02T09:11:07.109499+00:00 2021-04-02T09:11:07.682388+00:00 0:00:00.572889 12710 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T09:11:04.663687+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T08:05:00+00:00 EmrJobFlowSensor 2021-04-02T09:05:52.204440+00:00 2021-04-02T09:14:54.903351+00:00 0:09:02.698911 12709 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T09:05:49.883780+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T09:05:31.963916+00:00 2021-04-02T09:05:33.603441+00:00 0:00:01.639525 12708 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T09:05:29.823629+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T08:05:00+00:00 PythonOperator 2021-04-02T09:05:10.067990+00:00 2021-04-02T09:05:12.780402+00:00 0:00:02.712412 12707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T09:05:07.807300+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T08:00:00+00:00 EmrJobFlowSensor 2021-04-02T09:00:53.625739+00:00 2021-04-02T09:10:56.391087+00:00 0:10:02.765348 12706 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T09:00:51.419677+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T09:00:31.802460+00:00 2021-04-02T09:00:33.507334+00:00 0:00:01.704874 12705 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T09:00:29.459286+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T08:00:00+00:00 PythonOperator 2021-04-02T09:00:11.652756+00:00 2021-04-02T09:00:14.382514+00:00 0:00:02.729758 12704 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T09:00:09.384512+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T07:00:00+00:00 EmrJobFlowSensor 2021-04-02T08:11:16.343751+00:00 2021-04-02T08:19:18.977029+00:00 0:08:02.633278 12702 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T08:11:14.081247+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T07:00:00+00:00 EmrJobFlowSensor 2021-04-02T08:11:08.306435+00:00 2021-04-02T08:23:11.408930+00:00 0:12:03.102495 12701 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T08:11:06.042924+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T08:10:46.202284+00:00 2021-04-02T08:10:47.935638+00:00 0:00:01.733354 12700 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T08:10:44.023718+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T08:10:44.424875+00:00 2021-04-02T08:10:46.276937+00:00 0:00:01.852062 12699 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T08:10:42.025402+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T07:00:00+00:00 PythonOperator 2021-04-02T08:10:22.225627+00:00 2021-04-02T08:10:25.017670+00:00 0:00:02.792043 12698 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T08:10:20.002927+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T07:00:00+00:00 PythonOperator 2021-04-02T08:10:22.268757+00:00 2021-04-02T08:10:25.461501+00:00 0:00:03.192744 12697 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T08:10:20.002897+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T07:00:00+00:00 TriggerDagRunOperator 2021-04-02T08:10:16.329769+00:00 2021-04-02T08:10:16.843850+00:00 0:00:00.514081 12696 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T08:10:13.997629+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T07:00:00+00:00 TriggerDagRunOperator 2021-04-02T08:10:16.193497+00:00 2021-04-02T08:10:16.618600+00:00 0:00:00.425103 12695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T08:10:13.997580+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T07:05:00+00:00 EmrJobFlowSensor 2021-04-02T08:05:47.577850+00:00 2021-04-02T08:13:50.039542+00:00 0:08:02.461692 12694 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T08:05:45.395951+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T08:05:27.494716+00:00 2021-04-02T08:05:29.142763+00:00 0:00:01.648047 12693 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T08:05:25.356821+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T07:05:00+00:00 PythonOperator 2021-04-02T08:05:03.525377+00:00 2021-04-02T08:05:06.206606+00:00 0:00:02.681229 12692 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T08:05:01.334790+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T07:00:00+00:00 EmrJobFlowSensor 2021-04-02T08:00:55.023635+00:00 2021-04-02T08:09:57.742465+00:00 0:09:02.718830 12691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T08:00:52.657401+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T08:00:32.845899+00:00 2021-04-02T08:00:34.641999+00:00 0:00:01.796100 12690 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T08:00:30.580484+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T07:00:00+00:00 PythonOperator 2021-04-02T08:00:12.970410+00:00 2021-04-02T08:00:15.795428+00:00 0:00:02.825018 12689 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T08:00:10.563007+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T06:00:00+00:00 EmrJobFlowSensor 2021-04-02T07:12:47.322501+00:00 2021-04-02T07:21:49.943002+00:00 0:09:02.620501 12687 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T07:12:45.099374+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T06:00:00+00:00 EmrJobFlowSensor 2021-04-02T07:12:35.837491+00:00 2021-04-02T07:21:38.689420+00:00 0:09:02.851929 12686 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T07:12:33.090074+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T07:12:25.512046+00:00 2021-04-02T07:12:27.287188+00:00 0:00:01.775142 12685 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T07:12:23.028461+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T07:12:13.519293+00:00 2021-04-02T07:12:15.227181+00:00 0:00:01.707888 12684 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T07:12:11.062235+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T06:00:00+00:00 PythonOperator 2021-04-02T07:12:05.615256+00:00 2021-04-02T07:12:08.525407+00:00 0:00:02.910151 12683 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T07:12:02.965729+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T06:00:00+00:00 PythonOperator 2021-04-02T07:11:53.214066+00:00 2021-04-02T07:11:55.998921+00:00 0:00:02.784855 12682 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T07:11:50.955652+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T06:00:00+00:00 TriggerDagRunOperator 2021-04-02T07:11:35.389598+00:00 2021-04-02T07:11:35.953481+00:00 0:00:00.563883 12681 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T07:11:32.948162+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T06:00:00+00:00 TriggerDagRunOperator 2021-04-02T07:11:35.201457+00:00 2021-04-02T07:11:35.663377+00:00 0:00:00.461920 12680 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T07:11:32.948196+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T06:05:00+00:00 EmrJobFlowSensor 2021-04-02T07:05:52.584005+00:00 2021-04-02T07:14:55.245427+00:00 0:09:02.661422 12679 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T07:05:50.431279+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T07:05:28.669421+00:00 2021-04-02T07:05:30.299668+00:00 0:00:01.630247 12678 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T07:05:26.404267+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T06:05:00+00:00 PythonOperator 2021-04-02T07:05:06.605219+00:00 2021-04-02T07:05:09.376243+00:00 0:00:02.771024 12677 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T07:05:04.389053+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T06:00:00+00:00 EmrJobFlowSensor 2021-04-02T07:01:12.400048+00:00 2021-04-02T07:11:15.248339+00:00 0:10:02.848291 12676 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T07:01:10.046970+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T07:00:50.233517+00:00 2021-04-02T07:00:52.014626+00:00 0:00:01.781109 12675 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T07:00:47.948158+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T06:00:00+00:00 PythonOperator 2021-04-02T07:00:24.607429+00:00 2021-04-02T07:00:27.347663+00:00 0:00:02.740234 12674 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T07:00:21.925973+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T05:00:00+00:00 EmrJobFlowSensor 2021-04-02T06:12:39.433633+00:00 2021-04-02T06:22:42.157487+00:00 0:10:02.723854 12672 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T06:12:37.059069+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T05:00:00+00:00 EmrJobFlowSensor 2021-04-02T06:12:25.317288+00:00 2021-04-02T06:24:28.512736+00:00 0:12:03.195448 12671 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T06:12:22.951210+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T06:12:17.099463+00:00 2021-04-02T06:12:18.778442+00:00 0:00:01.678979 12670 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T06:12:14.945799+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T06:12:03.342534+00:00 2021-04-02T06:12:05.225661+00:00 0:00:01.883127 12669 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T06:12:00.934024+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T05:00:00+00:00 PythonOperator 2021-04-02T06:11:43.237154+00:00 2021-04-02T06:11:45.957533+00:00 0:00:02.720379 12668 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T06:11:40.911466+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T05:00:00+00:00 PythonOperator 2021-04-02T06:11:37.384825+00:00 2021-04-02T06:11:40.492419+00:00 0:00:03.107594 12667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T06:11:34.965283+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T05:00:00+00:00 TriggerDagRunOperator 2021-04-02T06:11:27.674338+00:00 2021-04-02T06:11:28.202674+00:00 0:00:00.528336 12666 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T06:11:24.967265+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T05:00:00+00:00 TriggerDagRunOperator 2021-04-02T06:11:27.575904+00:00 2021-04-02T06:11:28.029259+00:00 0:00:00.453355 12665 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T06:11:24.967230+00:00 2 default_pool