Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T15:00:00+00:00 TriggerDagRunOperator 2021-05-05T16:13:08.302699+00:00 2021-05-05T16:13:08.707889+00:00 0:00:00.405190 24787 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T16:13:06.004909+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-05T15:05:00+00:00 EmrJobFlowSensor 2021-05-05T16:06:03.379746+00:00 2021-05-05T16:14:05.857376+00:00 0:08:02.477630 24786 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T16:06:01.304491+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T15:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T16:05:39.660812+00:00 2021-05-05T16:05:41.320711+00:00 0:00:01.659899 24785 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T16:05:37.358655+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T15:05:00+00:00 PythonOperator 2021-05-05T16:05:17.278983+00:00 2021-05-05T16:05:20.271626+00:00 0:00:02.992643 24784 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T16:05:15.203285+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T15:00:00+00:00 EmrJobFlowSensor 2021-05-05T16:03:59.730698+00:00 2021-05-05T16:13:02.517646+00:00 0:09:02.786948 24783 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T16:03:57.152924+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T16:03:39.251244+00:00 2021-05-05T16:03:41.015255+00:00 0:00:01.764011 24782 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T16:03:37.023420+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T15:00:00+00:00 PythonOperator 2021-05-05T16:03:07.297391+00:00 2021-05-05T16:03:10.391271+00:00 0:00:03.093880 24781 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T16:03:04.993193+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-05T14:00:00+00:00 EmrJobFlowSensor 2021-05-05T15:12:25.201104+00:00 2021-05-05T15:22:27.958642+00:00 0:10:02.757538 24779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T15:12:22.963273+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-05T14:00:00+00:00 EmrJobFlowSensor 2021-05-05T15:12:07.346138+00:00 2021-05-05T15:20:09.743628+00:00 0:08:02.397490 24778 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T15:12:04.893551+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T15:12:05.103141+00:00 2021-05-05T15:12:07.052328+00:00 0:00:01.949187 24777 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T15:12:02.889782+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T15:11:43.049359+00:00 2021-05-05T15:11:44.810002+00:00 0:00:01.760643 24776 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T15:11:40.816165+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T14:00:00+00:00 PythonOperator 2021-05-05T15:11:29.225125+00:00 2021-05-05T15:11:32.574916+00:00 0:00:03.349791 24775 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T15:11:26.804445+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T14:00:00+00:00 PythonOperator 2021-05-05T15:11:19.604056+00:00 2021-05-05T15:11:22.764422+00:00 0:00:03.160366 24774 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T15:11:16.861332+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T14:00:00+00:00 TriggerDagRunOperator 2021-05-05T15:11:11.357564+00:00 2021-05-05T15:11:11.876483+00:00 0:00:00.518919 24773 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T15:11:08.860879+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T14:00:00+00:00 TriggerDagRunOperator 2021-05-05T15:11:11.171692+00:00 2021-05-05T15:11:11.616123+00:00 0:00:00.444431 24772 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T15:11:08.860922+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-05T14:05:00+00:00 EmrJobFlowSensor 2021-05-05T15:06:06.376217+00:00 2021-05-05T15:14:08.864026+00:00 0:08:02.487809 24771 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T15:06:04.288101+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T14:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T15:05:44.581696+00:00 2021-05-05T15:05:46.210468+00:00 0:00:01.628772 24770 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T15:05:42.263843+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T14:05:00+00:00 PythonOperator 2021-05-05T15:05:24.548696+00:00 2021-05-05T15:05:27.570090+00:00 0:00:03.021394 24769 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T15:05:22.259082+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T14:00:00+00:00 EmrJobFlowSensor 2021-05-05T15:01:04.321579+00:00 2021-05-05T15:11:07.175035+00:00 0:10:02.853456 24768 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T15:01:01.947242+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T15:00:44.000351+00:00 2021-05-05T15:00:45.670781+00:00 0:00:01.670430 24767 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T15:00:41.835536+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T14:00:00+00:00 PythonOperator 2021-05-05T15:00:22.640930+00:00 2021-05-05T15:00:25.687594+00:00 0:00:03.046664 24766 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T15:00:19.843503+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-05T13:00:00+00:00 EmrJobFlowSensor 2021-05-05T14:12:06.710892+00:00 2021-05-05T14:24:09.898774+00:00 0:12:03.187882 24764 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T14:12:04.365292+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-05T13:00:00+00:00 EmrJobFlowSensor 2021-05-05T14:11:54.961359+00:00 2021-05-05T14:31:59.117210+00:00 0:20:04.155851 24763 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T14:11:52.284494+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T14:11:46.420515+00:00 2021-05-05T14:11:48.068485+00:00 0:00:01.647970 24762 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T14:11:44.264565+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T14:11:32.413766+00:00 2021-05-05T14:11:34.078548+00:00 0:00:01.664782 24761 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T14:11:30.253041+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T13:00:00+00:00 PythonOperator 2021-05-05T14:11:24.519210+00:00 2021-05-05T14:11:27.753376+00:00 0:00:03.234166 24760 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T14:11:22.133527+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T13:00:00+00:00 PythonOperator 2021-05-05T14:11:06.714342+00:00 2021-05-05T14:11:10.094244+00:00 0:00:03.379902 24759 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T14:11:04.118629+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T13:00:00+00:00 TriggerDagRunOperator 2021-05-05T14:11:02.557671+00:00 2021-05-05T14:11:03.160755+00:00 0:00:00.603084 24758 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T14:11:00.119350+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T13:00:00+00:00 TriggerDagRunOperator 2021-05-05T14:11:02.394211+00:00 2021-05-05T14:11:02.830288+00:00 0:00:00.436077 24757 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T14:11:00.119379+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-05T13:05:00+00:00 EmrJobFlowSensor 2021-05-05T14:06:01.927290+00:00 2021-05-05T14:15:04.529278+00:00 0:09:02.601988 24756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T14:05:59.754553+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T13:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T14:05:39.806009+00:00 2021-05-05T14:05:41.475820+00:00 0:00:01.669811 24755 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T14:05:37.655233+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T13:05:00+00:00 PythonOperator 2021-05-05T14:05:19.719596+00:00 2021-05-05T14:05:22.697519+00:00 0:00:02.977923 24754 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T14:05:17.577355+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T13:00:00+00:00 EmrJobFlowSensor 2021-05-05T14:00:55.320258+00:00 2021-05-05T14:10:58.148559+00:00 0:10:02.828301 24753 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T14:00:53.141122+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T14:00:33.480726+00:00 2021-05-05T14:00:35.352033+00:00 0:00:01.871307 24752 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T14:00:31.122277+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T13:00:00+00:00 PythonOperator 2021-05-05T14:00:11.618914+00:00 2021-05-05T14:00:14.689151+00:00 0:00:03.070237 24751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T14:00:09.171179+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-05T12:00:00+00:00 EmrJobFlowSensor 2021-05-05T13:11:56.001904+00:00 2021-05-05T13:22:58.963126+00:00 0:11:02.961222 24749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T13:11:53.610403+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-05T12:00:00+00:00 EmrJobFlowSensor 2021-05-05T13:11:51.814846+00:00 2021-05-05T13:21:54.636627+00:00 0:10:02.821781 24748 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T13:11:49.607515+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T13:11:33.918100+00:00 2021-05-05T13:11:35.604698+00:00 0:00:01.686598 24747 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T13:11:31.667627+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T13:11:30.222667+00:00 2021-05-05T13:11:31.962322+00:00 0:00:01.739655 24746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T13:11:27.744011+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T12:00:00+00:00 PythonOperator 2021-05-05T13:11:11.888697+00:00 2021-05-05T13:11:15.166789+00:00 0:00:03.278092 24745 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T13:11:09.557354+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T12:00:00+00:00 PythonOperator 2021-05-05T13:11:09.897023+00:00 2021-05-05T13:11:12.973087+00:00 0:00:03.076064 24744 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T13:11:07.573482+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T12:00:00+00:00 TriggerDagRunOperator 2021-05-05T13:11:00.355872+00:00 2021-05-05T13:11:00.872163+00:00 0:00:00.516291 24743 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T13:10:57.644412+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T12:00:00+00:00 TriggerDagRunOperator 2021-05-05T13:11:00.208179+00:00 2021-05-05T13:11:00.636430+00:00 0:00:00.428251 24742 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T13:10:57.644457+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-05T12:05:00+00:00 EmrJobFlowSensor 2021-05-05T13:06:39.279598+00:00 2021-05-05T13:14:41.733225+00:00 0:08:02.453627 24741 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T13:06:37.135670+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T12:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T13:06:17.285058+00:00 2021-05-05T13:06:19.069947+00:00 0:00:01.784889 24740 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T13:06:15.094360+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T12:05:00+00:00 PythonOperator 2021-05-05T13:05:03.278945+00:00 2021-05-05T13:05:06.336205+00:00 0:00:03.057260 24739 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T13:05:01.056633+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T12:00:00+00:00 EmrJobFlowSensor 2021-05-05T13:00:50.814031+00:00 2021-05-05T13:10:53.692356+00:00 0:10:02.878325 24738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T13:00:48.579803+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T13:00:28.604899+00:00 2021-05-05T13:00:30.362024+00:00 0:00:01.757125 24737 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T13:00:26.517406+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T12:00:00+00:00 PythonOperator 2021-05-05T13:00:08.781446+00:00 2021-05-05T13:00:11.873840+00:00 0:00:03.092394 24736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T13:00:06.487333+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-05T11:00:00+00:00 EmrJobFlowSensor 2021-05-05T12:11:19.429308+00:00 2021-05-05T12:20:22.170548+00:00 0:09:02.741240 24734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T12:11:16.858314+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-05T11:00:00+00:00 EmrJobFlowSensor 2021-05-05T12:11:12.998101+00:00 2021-05-05T12:20:15.645862+00:00 0:09:02.647761 24733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T12:11:10.792996+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T12:10:57.018306+00:00 2021-05-05T12:10:58.797949+00:00 0:00:01.779643 24732 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T12:10:54.743449+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T12:10:52.967737+00:00 2021-05-05T12:10:54.684702+00:00 0:00:01.716965 24731 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T12:10:50.741155+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T11:00:00+00:00 PythonOperator 2021-05-05T12:10:36.970231+00:00 2021-05-05T12:10:40.110046+00:00 0:00:03.139815 24730 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T12:10:34.728142+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T11:00:00+00:00 PythonOperator 2021-05-05T12:10:31.217734+00:00 2021-05-05T12:10:34.522659+00:00 0:00:03.304925 24729 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T12:10:28.850934+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T11:00:00+00:00 TriggerDagRunOperator 2021-05-05T12:10:21.199829+00:00 2021-05-05T12:10:21.627113+00:00 0:00:00.427284 24728 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T12:10:18.713442+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T11:00:00+00:00 TriggerDagRunOperator 2021-05-05T12:10:20.995349+00:00 2021-05-05T12:10:21.521687+00:00 0:00:00.526338 24727 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T12:10:18.713409+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-05T11:05:00+00:00 EmrJobFlowSensor 2021-05-05T12:05:54.547622+00:00 2021-05-05T12:14:57.058765+00:00 0:09:02.511143 24726 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T12:05:52.250072+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T11:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T12:05:30.545144+00:00 2021-05-05T12:05:32.139617+00:00 0:00:01.594473 24725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T12:05:28.272242+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T11:05:00+00:00 PythonOperator 2021-05-05T12:05:08.445409+00:00 2021-05-05T12:05:11.491937+00:00 0:00:03.046528 24724 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T12:05:06.258149+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T11:00:00+00:00 EmrJobFlowSensor 2021-05-05T12:01:06.332310+00:00 2021-05-05T12:10:09.195057+00:00 0:09:02.862747 24723 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T12:01:03.879214+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T12:00:43.869133+00:00 2021-05-05T12:00:45.599938+00:00 0:00:01.730805 24722 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T12:00:41.730351+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T11:00:00+00:00 PythonOperator 2021-05-05T12:00:22.403240+00:00 2021-05-05T12:00:25.513263+00:00 0:00:03.110023 24721 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T12:00:19.755249+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-05T10:00:00+00:00 EmrJobFlowSensor 2021-05-05T11:12:09.144041+00:00 2021-05-05T11:21:11.644365+00:00 0:09:02.500324 24719 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T11:12:06.889269+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-05T10:00:00+00:00 EmrJobFlowSensor 2021-05-05T11:12:07.270860+00:00 2021-05-05T11:23:10.262637+00:00 0:11:02.991777 24718 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T11:12:04.889672+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T11:11:49.167563+00:00 2021-05-05T11:11:50.948328+00:00 0:00:01.780765 24717 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T11:11:46.831322+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T11:11:45.297843+00:00 2021-05-05T11:11:47.167856+00:00 0:00:01.870013 24716 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T11:11:42.833250+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T10:00:00+00:00 PythonOperator 2021-05-05T11:11:28.095745+00:00 2021-05-05T11:11:31.147179+00:00 0:00:03.051434 24715 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T11:11:24.889184+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T10:00:00+00:00 PythonOperator 2021-05-05T11:11:23.118379+00:00 2021-05-05T11:11:26.921533+00:00 0:00:03.803154 24714 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T11:11:20.801969+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T10:00:00+00:00 TriggerDagRunOperator 2021-05-05T11:11:17.127169+00:00 2021-05-05T11:11:17.656902+00:00 0:00:00.529733 24713 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T11:11:14.796800+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T10:00:00+00:00 TriggerDagRunOperator 2021-05-05T11:11:16.990589+00:00 2021-05-05T11:11:17.413122+00:00 0:00:00.422533 24712 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T11:11:14.796752+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-05T10:05:00+00:00 EmrJobFlowSensor 2021-05-05T11:06:04.388378+00:00 2021-05-05T11:14:06.833170+00:00 0:08:02.444792 24711 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T11:06:02.190383+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T10:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T11:05:44.380525+00:00 2021-05-05T11:05:45.990805+00:00 0:00:01.610280 24710 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T11:05:42.158691+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T10:05:00+00:00 PythonOperator 2021-05-05T11:05:22.259386+00:00 2021-05-05T11:05:25.257729+00:00 0:00:02.998343 24709 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T11:05:20.117918+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T10:00:00+00:00 EmrJobFlowSensor 2021-05-05T11:00:50.148892+00:00 2021-05-05T11:10:53.165551+00:00 0:10:03.016659 24708 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T11:00:47.721896+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T11:00:28.139750+00:00 2021-05-05T11:00:29.846656+00:00 0:00:01.706906 24707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T11:00:25.785508+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T10:00:00+00:00 PythonOperator 2021-05-05T11:00:08.167412+00:00 2021-05-05T11:00:11.310720+00:00 0:00:03.143308 24706 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T11:00:05.747616+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-05T09:00:00+00:00 EmrJobFlowSensor 2021-05-05T10:12:01.119561+00:00 2021-05-05T10:22:03.906857+00:00 0:10:02.787296 24704 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T10:11:58.763464+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-05T09:00:00+00:00 EmrJobFlowSensor 2021-05-05T10:11:57.015013+00:00 2021-05-05T10:21:59.805337+00:00 0:10:02.790324 24703 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T10:11:54.734083+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T10:11:38.936121+00:00 2021-05-05T10:11:40.626038+00:00 0:00:01.689917 24702 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T10:11:36.705437+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T10:11:35.225712+00:00 2021-05-05T10:11:37.065904+00:00 0:00:01.840192 24701 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T10:11:32.769836+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T09:00:00+00:00 PythonOperator 2021-05-05T10:11:19.509294+00:00 2021-05-05T10:11:22.594587+00:00 0:00:03.085293 24700 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T10:11:16.694543+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T09:00:00+00:00 PythonOperator 2021-05-05T10:11:15.263431+00:00 2021-05-05T10:11:19.189630+00:00 0:00:03.926199 24699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T10:11:12.757363+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T09:00:00+00:00 TriggerDagRunOperator 2021-05-05T10:11:01.026380+00:00 2021-05-05T10:11:01.510106+00:00 0:00:00.483726 24698 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T10:10:58.652590+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T09:00:00+00:00 TriggerDagRunOperator 2021-05-05T10:11:01.025951+00:00 2021-05-05T10:11:01.592570+00:00 0:00:00.566619 24697 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T10:10:58.652553+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-05T09:05:00+00:00 EmrJobFlowSensor 2021-05-05T10:06:12.417475+00:00 2021-05-05T10:15:15.176834+00:00 0:09:02.759359 24696 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T10:06:10.191859+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T09:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T10:05:50.354790+00:00 2021-05-05T10:05:52.124673+00:00 0:00:01.769883 24695 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T10:05:48.161635+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T09:05:00+00:00 PythonOperator 2021-05-05T10:05:22.344484+00:00 2021-05-05T10:05:25.425445+00:00 0:00:03.080961 24694 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T10:05:20.134912+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T09:00:00+00:00 EmrJobFlowSensor 2021-05-05T10:00:51.947335+00:00 2021-05-05T10:10:54.771638+00:00 0:10:02.824303 24693 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T10:00:49.699054+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T10:00:31.979321+00:00 2021-05-05T10:00:33.722112+00:00 0:00:01.742791 24692 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T10:00:29.756181+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T09:00:00+00:00 PythonOperator 2021-05-05T10:00:10.261878+00:00 2021-05-05T10:00:13.291940+00:00 0:00:03.030062 24691 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T10:00:07.619496+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-05T08:00:00+00:00 EmrJobFlowSensor 2021-05-05T09:12:46.492436+00:00 2021-05-05T09:22:49.083250+00:00 0:10:02.590814 24689 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T09:12:43.725602+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-05T08:00:00+00:00 EmrJobFlowSensor 2021-05-05T09:12:44.092555+00:00 2021-05-05T09:22:47.081620+00:00 0:10:02.989065 24688 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T09:12:41.733121+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T09:12:23.952448+00:00 2021-05-05T09:12:25.647731+00:00 0:00:01.695283 24687 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T09:12:21.712912+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T09:12:15.907212+00:00 2021-05-05T09:12:17.767114+00:00 0:00:01.859902 24686 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T09:12:13.705421+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T08:00:00+00:00 PythonOperator 2021-05-05T09:11:58.068305+00:00 2021-05-05T09:12:01.192346+00:00 0:00:03.124041 24685 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T09:11:55.760590+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T08:00:00+00:00 PythonOperator 2021-05-05T09:11:50.104459+00:00 2021-05-05T09:11:53.395485+00:00 0:00:03.291026 24684 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T09:11:47.651908+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T08:00:00+00:00 TriggerDagRunOperator 2021-05-05T09:11:34.137954+00:00 2021-05-05T09:11:34.709537+00:00 0:00:00.571583 24683 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T09:11:31.591971+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T08:00:00+00:00 TriggerDagRunOperator 2021-05-05T09:11:33.806450+00:00 2021-05-05T09:11:34.234684+00:00 0:00:00.428234 24682 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T09:11:31.591923+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-05T08:05:00+00:00 EmrJobFlowSensor 2021-05-05T09:06:05.356949+00:00 2021-05-05T09:15:08.005881+00:00 0:09:02.648932 24681 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T09:06:03.067869+00:00 2 default_pool