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 create_emr_steps 2021-03-23T10:00:00+00:00 PythonOperator 2021-03-23T11:00:21.093093+00:00 2021-03-23T11:00:23.833502+00:00 0:00:02.740409 10858 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T11:00:18.773965+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-23T09:00:00+00:00 EmrJobFlowSensor 2021-03-23T10:12:39.467798+00:00 2021-03-23T10:23:42.307652+00:00 0:11:02.839854 10856 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T10:12:37.144480+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T09:00:00+00:00 EmrJobFlowSensor 2021-03-23T10:12:35.545498+00:00 2021-03-23T10:29:39.260680+00:00 0:17:03.715182 10855 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T10:12:33.159797+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-23T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T10:12:19.317699+00:00 2021-03-23T10:12:21.059070+00:00 0:00:01.741371 10854 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T10:12:17.048342+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T10:12:13.186493+00:00 2021-03-23T10:12:14.881086+00:00 0:00:01.694593 10853 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T10:12:11.047504+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-23T09:00:00+00:00 PythonOperator 2021-03-23T10:11:57.295098+00:00 2021-03-23T10:12:00.219910+00:00 0:00:02.924812 10852 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T10:11:55.025213+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T09:00:00+00:00 PythonOperator 2021-03-23T10:11:51.186975+00:00 2021-03-23T10:11:53.929992+00:00 0:00:02.743017 10851 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T10:11:49.023528+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T09:00:00+00:00 TriggerDagRunOperator 2021-03-23T10:11:33.376158+00:00 2021-03-23T10:11:33.813840+00:00 0:00:00.437682 10850 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T10:11:31.006043+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T09:00:00+00:00 TriggerDagRunOperator 2021-03-23T10:11:33.273176+00:00 2021-03-23T10:11:33.802328+00:00 0:00:00.529152 10849 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T10:11:31.006092+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T09:05:00+00:00 EmrJobFlowSensor 2021-03-23T10:05:56.592115+00:00 2021-03-23T10:15:59.214547+00:00 0:10:02.622432 10848 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T10:05:54.344460+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T09:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T10:05:34.697031+00:00 2021-03-23T10:05:36.445934+00:00 0:00:01.748903 10847 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T10:05:32.327279+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T09:05:00+00:00 PythonOperator 2021-03-23T10:05:12.479574+00:00 2021-03-23T10:05:15.176626+00:00 0:00:02.697052 10846 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T10:05:10.306328+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T09:00:00+00:00 EmrJobFlowSensor 2021-03-23T10:01:08.251383+00:00 2021-03-23T10:11:11.060165+00:00 0:10:02.808782 10845 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T10:01:05.924815+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T10:00:46.332833+00:00 2021-03-23T10:00:48.043296+00:00 0:00:01.710463 10844 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T10:00:43.957183+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T09:00:00+00:00 PythonOperator 2021-03-23T10:00:24.334470+00:00 2021-03-23T10:00:27.036828+00:00 0:00:02.702358 10843 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T10:00:21.886301+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T08:00:00+00:00 EmrJobFlowSensor 2021-03-23T09:12:02.274397+00:00 2021-03-23T09:21:04.932591+00:00 0:09:02.658194 10841 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T09:11:59.556748+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-23T08:00:00+00:00 EmrJobFlowSensor 2021-03-23T09:12:00.101685+00:00 2021-03-23T09:23:03.332942+00:00 0:11:03.231257 10840 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T09:11:57.577688+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T09:11:39.821660+00:00 2021-03-23T09:11:41.616470+00:00 0:00:01.794810 10839 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T09:11:37.518258+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-23T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T09:11:39.701923+00:00 2021-03-23T09:11:41.410983+00:00 0:00:01.709060 10838 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T09:11:37.518294+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T08:00:00+00:00 PythonOperator 2021-03-23T09:11:19.984614+00:00 2021-03-23T09:11:22.853647+00:00 0:00:02.869033 10837 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T09:11:17.504058+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-23T08:00:00+00:00 PythonOperator 2021-03-23T09:11:17.716178+00:00 2021-03-23T09:11:20.671916+00:00 0:00:02.955738 10836 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T09:11:15.504151+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T08:00:00+00:00 TriggerDagRunOperator 2021-03-23T09:11:07.898754+00:00 2021-03-23T09:11:08.392546+00:00 0:00:00.493792 10835 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T09:11:05.493438+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T08:00:00+00:00 TriggerDagRunOperator 2021-03-23T09:11:07.725597+00:00 2021-03-23T09:11:08.142252+00:00 0:00:00.416655 10834 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T09:11:05.493477+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T08:05:00+00:00 EmrJobFlowSensor 2021-03-23T09:05:55.455025+00:00 2021-03-23T09:16:58.276506+00:00 0:11:02.821481 10833 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T09:05:52.952477+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T08:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T09:05:34.977255+00:00 2021-03-23T09:05:36.617574+00:00 0:00:01.640319 10832 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T09:05:32.830697+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T08:05:00+00:00 PythonOperator 2021-03-23T09:05:12.960560+00:00 2021-03-23T09:05:15.623294+00:00 0:00:02.662734 10831 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T09:05:10.806947+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T08:00:00+00:00 EmrJobFlowSensor 2021-03-23T09:01:01.021181+00:00 2021-03-23T09:11:04.019425+00:00 0:10:02.998244 10830 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T09:00:58.650300+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T09:00:38.999344+00:00 2021-03-23T09:00:40.688084+00:00 0:00:01.688740 10829 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T09:00:36.559007+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T08:00:00+00:00 PythonOperator 2021-03-23T09:00:18.719131+00:00 2021-03-23T09:00:21.467466+00:00 0:00:02.748335 10828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T09:00:16.398654+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-23T07:00:00+00:00 EmrJobFlowSensor 2021-03-23T08:12:28.074027+00:00 2021-03-23T08:23:31.008097+00:00 0:11:02.934070 10826 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T08:12:25.834843+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T07:00:00+00:00 EmrJobFlowSensor 2021-03-23T08:12:24.141670+00:00 2021-03-23T08:21:26.809146+00:00 0:09:02.667476 10825 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T08:12:21.831886+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-23T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T08:12:08.251491+00:00 2021-03-23T08:12:10.056360+00:00 0:00:01.804869 10824 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T08:12:05.815754+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T08:12:00.277403+00:00 2021-03-23T08:12:02.022166+00:00 0:00:01.744763 10823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T08:11:57.857315+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-23T07:00:00+00:00 PythonOperator 2021-03-23T08:11:40.365721+00:00 2021-03-23T08:11:44.251307+00:00 0:00:03.885586 10822 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T08:11:37.855834+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T07:00:00+00:00 PythonOperator 2021-03-23T08:11:36.391345+00:00 2021-03-23T08:11:39.329371+00:00 0:00:02.938026 10821 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T08:11:33.796490+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T07:00:00+00:00 TriggerDagRunOperator 2021-03-23T08:11:24.237820+00:00 2021-03-23T08:11:24.680289+00:00 0:00:00.442469 10820 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T08:11:21.735040+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T07:00:00+00:00 TriggerDagRunOperator 2021-03-23T08:11:24.037876+00:00 2021-03-23T08:11:24.662164+00:00 0:00:00.624288 10819 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T08:11:21.735005+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T07:05:00+00:00 EmrJobFlowSensor 2021-03-23T08:05:53.578088+00:00 2021-03-23T08:16:56.397766+00:00 0:11:02.819678 10818 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T08:05:51.252864+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T07:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T08:05:33.476534+00:00 2021-03-23T08:05:35.218132+00:00 0:00:01.741598 10817 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T08:05:31.159696+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T07:05:00+00:00 PythonOperator 2021-03-23T08:05:11.249196+00:00 2021-03-23T08:05:13.928098+00:00 0:00:02.678902 10816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T08:05:09.121029+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T07:00:00+00:00 EmrJobFlowSensor 2021-03-23T08:00:57.004460+00:00 2021-03-23T08:10:59.877060+00:00 0:10:02.872600 10815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T08:00:54.653219+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T08:00:36.843434+00:00 2021-03-23T08:00:38.635579+00:00 0:00:01.792145 10814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T08:00:34.591846+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T07:00:00+00:00 PythonOperator 2021-03-23T08:00:15.147308+00:00 2021-03-23T08:00:17.926896+00:00 0:00:02.779588 10813 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T08:00:12.561327+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T06:00:00+00:00 EmrJobFlowSensor 2021-03-23T07:11:06.877394+00:00 2021-03-23T07:20:09.488589+00:00 0:09:02.611195 10811 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T07:11:04.704819+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-23T06:00:00+00:00 EmrJobFlowSensor 2021-03-23T07:11:05.256885+00:00 2021-03-23T07:47:11.366548+00:00 0:36:06.109663 10810 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T07:11:02.712335+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T07:10:45.060992+00:00 2021-03-23T07:10:46.900351+00:00 0:00:01.839359 10809 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T07:10:42.744359+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-23T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T07:10:42.971346+00:00 2021-03-23T07:10:44.705265+00:00 0:00:01.733919 10808 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T07:10:40.683376+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T06:00:00+00:00 PythonOperator 2021-03-23T07:10:25.350362+00:00 2021-03-23T07:10:28.190311+00:00 0:00:02.839949 10807 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T07:10:22.655980+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-23T06:00:00+00:00 PythonOperator 2021-03-23T07:10:23.017572+00:00 2021-03-23T07:10:26.496708+00:00 0:00:03.479136 10806 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T07:10:20.657151+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T06:00:00+00:00 TriggerDagRunOperator 2021-03-23T07:10:08.930914+00:00 2021-03-23T07:10:09.432390+00:00 0:00:00.501476 10805 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T07:10:06.585550+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T06:00:00+00:00 TriggerDagRunOperator 2021-03-23T07:10:08.833089+00:00 2021-03-23T07:10:09.286959+00:00 0:00:00.453870 10804 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T07:10:06.585582+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T06:05:00+00:00 EmrJobFlowSensor 2021-03-23T07:05:58.495462+00:00 2021-03-23T07:16:01.192580+00:00 0:10:02.697118 10803 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T07:05:56.306354+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T06:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T07:05:36.684544+00:00 2021-03-23T07:05:38.346131+00:00 0:00:01.661587 10802 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T07:05:34.360012+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T06:05:00+00:00 PythonOperator 2021-03-23T07:05:14.635839+00:00 2021-03-23T07:05:17.325809+00:00 0:00:02.689970 10801 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T07:05:12.350039+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T06:00:00+00:00 EmrJobFlowSensor 2021-03-23T07:00:50.028392+00:00 2021-03-23T07:09:52.772611+00:00 0:09:02.744219 10800 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T07:00:47.722505+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T07:00:28.347051+00:00 2021-03-23T07:00:30.069536+00:00 0:00:01.722485 10799 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T07:00:25.757958+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T06:00:00+00:00 PythonOperator 2021-03-23T07:00:06.012441+00:00 2021-03-23T07:00:08.840317+00:00 0:00:02.827876 10798 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T07:00:03.704508+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-22T23:00:00+00:00 EmrJobFlowSensor 2021-03-23T06:44:26.586371+00:00 2021-03-23T07:19:32.632694+00:00 0:35:06.046323 10797 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T06:44:24.270552+00:00 3 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-22T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T06:44:04.663347+00:00 2021-03-23T06:44:06.444463+00:00 0:00:01.781116 10796 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T06:44:02.264813+00:00 3 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-23T03:00:00+00:00 PythonOperator 2021-03-23T06:44:04.629289+00:00 2021-03-23T06:44:07.688156+00:00 0:00:03.058867 10795 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T06:44:02.264784+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T23:00:00+00:00 PythonOperator 2021-03-23T06:43:42.539031+00:00 2021-03-23T06:43:45.647579+00:00 0:00:03.108548 10794 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T06:43:40.192749+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T05:00:00+00:00 EmrJobFlowSensor 2021-03-23T06:12:55.551298+00:00 2021-03-23T06:20:58.044095+00:00 0:08:02.492797 10792 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T06:12:53.253518+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T06:12:31.656802+00:00 2021-03-23T06:12:33.446867+00:00 0:00:01.790065 10791 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T06:12:29.289747+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T05:00:00+00:00 PythonOperator 2021-03-23T06:12:09.449376+00:00 2021-03-23T06:12:12.285957+00:00 0:00:02.836581 10790 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T06:12:07.211949+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T05:00:00+00:00 TriggerDagRunOperator 2021-03-23T06:12:04.153308+00:00 2021-03-23T06:12:04.529261+00:00 0:00:00.375953 10789 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T06:12:01.266521+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T05:00:00+00:00 TriggerDagRunOperator 2021-03-23T06:12:03.771301+00:00 2021-03-23T06:12:04.319144+00:00 0:00:00.547843 10788 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T06:12:01.266557+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T05:05:00+00:00 EmrJobFlowSensor 2021-03-23T06:05:50.846636+00:00 2021-03-23T06:16:53.814608+00:00 0:11:02.967972 10787 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T06:05:48.582265+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T05:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T06:05:28.662315+00:00 2021-03-23T06:05:30.304388+00:00 0:00:01.642073 10786 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T06:05:26.507950+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T05:05:00+00:00 PythonOperator 2021-03-23T06:05:06.755755+00:00 2021-03-23T06:05:09.468766+00:00 0:00:02.713011 10785 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T06:05:04.559024+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T05:00:00+00:00 EmrJobFlowSensor 2021-03-23T06:01:50.582112+00:00 2021-03-23T06:11:53.327189+00:00 0:10:02.745077 10784 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T06:01:48.240326+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T06:01:22.364785+00:00 2021-03-23T06:01:24.327936+00:00 0:00:01.963151 10783 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T06:01:20.101053+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T05:00:00+00:00 PythonOperator 2021-03-23T06:00:04.316586+00:00 2021-03-23T06:00:07.037810+00:00 0:00:02.721224 10782 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T06:00:01.996634+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T04:00:00+00:00 EmrJobFlowSensor 2021-03-23T05:13:12.531506+00:00 2021-03-23T05:21:15.212428+00:00 0:08:02.680922 10780 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T05:13:10.354710+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T05:12:50.500553+00:00 2021-03-23T05:12:52.153785+00:00 0:00:01.653232 10779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T05:12:48.336230+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T04:00:00+00:00 PythonOperator 2021-03-23T05:12:30.911283+00:00 2021-03-23T05:12:33.670744+00:00 0:00:02.759461 10778 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T05:12:28.366101+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T04:00:00+00:00 TriggerDagRunOperator 2021-03-23T05:12:23.070421+00:00 2021-03-23T05:12:23.751624+00:00 0:00:00.681203 10777 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T05:12:20.370362+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T04:00:00+00:00 TriggerDagRunOperator 2021-03-23T05:12:22.930586+00:00 2021-03-23T05:12:23.329876+00:00 0:00:00.399290 10776 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T05:12:20.370331+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T04:05:00+00:00 EmrJobFlowSensor 2021-03-23T05:06:00.307889+00:00 2021-03-23T05:16:03.112099+00:00 0:10:02.804210 10775 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T05:05:57.965012+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T04:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T05:05:38.030371+00:00 2021-03-23T05:05:39.806961+00:00 0:00:01.776590 10774 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T05:05:35.811945+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T04:05:00+00:00 PythonOperator 2021-03-23T05:05:15.978429+00:00 2021-03-23T05:05:18.673014+00:00 0:00:02.694585 10773 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T05:05:13.791719+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T04:00:00+00:00 EmrJobFlowSensor 2021-03-23T05:01:03.705731+00:00 2021-03-23T05:12:06.737324+00:00 0:11:03.031593 10772 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T05:01:01.335389+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T05:00:41.600413+00:00 2021-03-23T05:00:43.400695+00:00 0:00:01.800282 10771 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T05:00:39.231996+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T04:00:00+00:00 PythonOperator 2021-03-23T05:00:19.751760+00:00 2021-03-23T05:00:22.627792+00:00 0:00:02.876032 10770 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T05:00:17.213966+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T03:00:00+00:00 EmrJobFlowSensor 2021-03-23T04:11:26.013437+00:00 2021-03-23T04:21:28.761252+00:00 0:10:02.747815 10768 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T04:11:23.796599+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T03:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T04:11:04.097876+00:00 2021-03-23T04:11:05.778094+00:00 0:00:01.680218 10767 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T04:11:01.775621+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T03:00:00+00:00 PythonOperator 2021-03-23T04:10:42.015682+00:00 2021-03-23T04:10:44.737328+00:00 0:00:02.721646 10766 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T04:10:39.755657+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T03:00:00+00:00 TriggerDagRunOperator 2021-03-23T04:10:24.330420+00:00 2021-03-23T04:10:24.760048+00:00 0:00:00.429628 10765 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T04:10:21.687787+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T03:00:00+00:00 TriggerDagRunOperator 2021-03-23T04:10:24.067713+00:00 2021-03-23T04:10:24.671149+00:00 0:00:00.603436 10764 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T04:10:21.687754+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T03:05:00+00:00 EmrJobFlowSensor 2021-03-23T04:05:57.456616+00:00 2021-03-23T04:15:00.232640+00:00 0:09:02.776024 10763 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T04:05:55.265259+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T03:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T04:05:33.401151+00:00 2021-03-23T04:05:35.151338+00:00 0:00:01.750187 10762 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T04:05:31.236000+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T03:05:00+00:00 PythonOperator 2021-03-23T04:05:11.323465+00:00 2021-03-23T04:05:14.062074+00:00 0:00:02.738609 10761 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T04:05:09.191056+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T03:00:00+00:00 EmrJobFlowSensor 2021-03-23T04:01:14.888044+00:00 2021-03-23T04:10:17.561146+00:00 0:09:02.673102 10760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T04:01:12.717049+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T03:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T04:00:54.905277+00:00 2021-03-23T04:00:56.656716+00:00 0:00:01.751439 10759 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T04:00:52.706173+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T03:00:00+00:00 PythonOperator 2021-03-23T04:00:33.103305+00:00 2021-03-23T04:00:35.879847+00:00 0:00:02.776542 10758 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T04:00:30.740769+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T02:00:00+00:00 EmrJobFlowSensor 2021-03-23T03:13:20.272622+00:00 2021-03-23T03:22:22.794847+00:00 0:09:02.522225 10757 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T03:13:17.954596+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T02:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T03:12:57.976564+00:00 2021-03-23T03:12:59.669657+00:00 0:00:01.693093 10756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T03:12:55.835997+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T02:00:00+00:00 PythonOperator 2021-03-23T03:12:38.061030+00:00 2021-03-23T03:12:40.800783+00:00 0:00:02.739753 10755 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T03:12:35.818318+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T02:00:00+00:00 TriggerDagRunOperator 2021-03-23T03:12:12.519579+00:00 2021-03-23T03:12:13.009634+00:00 0:00:00.490055 10754 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T03:12:09.601261+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T02:00:00+00:00 TriggerDagRunOperator 2021-03-23T03:12:12.424785+00:00 2021-03-23T03:12:12.898437+00:00 0:00:00.473652 10753 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T03:12:09.601298+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T02:05:00+00:00 EmrJobFlowSensor 2021-03-23T03:05:52.271689+00:00 2021-03-23T03:15:54.943087+00:00 0:10:02.671398 10751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T03:05:50.104477+00:00 2 default_pool