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-17T16:00:00+00:00 TriggerDagRunOperator 2021-05-17T17:21:27.195975+00:00 2021-05-17T17:21:27.626955+00:00 0:00:00.430980 29155 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T17:21:24.448672+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-17T16:00:00+00:00 TriggerDagRunOperator 2021-05-17T17:21:26.827574+00:00 2021-05-17T17:21:27.404411+00:00 0:00:00.576837 29154 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T17:21:24.448627+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-17T16:00:00+00:00 EmrJobFlowSensor 2021-05-17T17:12:16.029670+00:00 2021-05-17T17:21:18.656813+00:00 0:09:02.627143 29153 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T17:12:13.297341+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-17T16:05:00+00:00 EmrJobFlowSensor 2021-05-17T17:12:13.613697+00:00 2021-05-17T17:20:16.395890+00:00 0:08:02.782193 29152 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T17:12:11.295748+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-17T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T17:11:53.528507+00:00 2021-05-17T17:11:55.401298+00:00 0:00:01.872791 29151 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-17T17:11:51.230045+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-17T16:05:00+00:00 EmrCreateJobFlowOperator 2021-05-17T17:11:51.433677+00:00 2021-05-17T17:11:53.073993+00:00 0:00:01.640316 29150 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T17:11:49.230963+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-17T16:00:00+00:00 PythonOperator 2021-05-17T17:11:33.596320+00:00 2021-05-17T17:11:36.819363+00:00 0:00:03.223043 29149 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-17T17:11:31.264400+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-17T16:05:00+00:00 PythonOperator 2021-05-17T17:11:31.989830+00:00 2021-05-17T17:11:35.107035+00:00 0:00:03.117205 29148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T17:11:28.989054+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-17T15:00:00+00:00 EmrJobFlowSensor 2021-05-17T16:12:24.140620+00:00 2021-05-17T16:22:26.937174+00:00 0:10:02.796554 29146 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T16:12:22.024863+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-17T15:00:00+00:00 EmrJobFlowSensor 2021-05-17T16:12:22.354014+00:00 2021-05-17T16:22:25.333322+00:00 0:10:02.979308 29145 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T16:12:20.028383+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-17T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T16:12:04.699293+00:00 2021-05-17T16:12:06.412557+00:00 0:00:01.713264 29144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T16:12:02.013431+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-17T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T16:12:02.197595+00:00 2021-05-17T16:12:04.415717+00:00 0:00:02.218122 29143 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T16:12:00.022234+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-17T15:00:00+00:00 PythonOperator 2021-05-17T16:11:42.541662+00:00 2021-05-17T16:11:45.929689+00:00 0:00:03.388027 29142 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T16:11:40.009210+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-17T15:00:00+00:00 PythonOperator 2021-05-17T16:11:40.140591+00:00 2021-05-17T16:11:43.730350+00:00 0:00:03.589759 29141 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T16:11:37.995271+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-17T15:00:00+00:00 TriggerDagRunOperator 2021-05-17T16:11:26.625956+00:00 2021-05-17T16:11:27.242863+00:00 0:00:00.616907 29140 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T16:11:24.050110+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-17T15:00:00+00:00 TriggerDagRunOperator 2021-05-17T16:11:26.403906+00:00 2021-05-17T16:11:26.911574+00:00 0:00:00.507668 29139 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T16:11:24.050063+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-17T15:05:00+00:00 EmrJobFlowSensor 2021-05-17T16:06:09.916231+00:00 2021-05-17T16:15:12.521603+00:00 0:09:02.605372 29138 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T16:06:07.555315+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-17T15:05:00+00:00 EmrCreateJobFlowOperator 2021-05-17T16:05:41.516093+00:00 2021-05-17T16:05:43.127141+00:00 0:00:01.611048 29137 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T16:05:39.434813+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-17T15:05:00+00:00 PythonOperator 2021-05-17T16:05:19.817351+00:00 2021-05-17T16:05:22.976749+00:00 0:00:03.159398 29136 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T16:05:17.417455+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-17T15:00:00+00:00 EmrJobFlowSensor 2021-05-17T16:00:59.487234+00:00 2021-05-17T16:11:02.355749+00:00 0:10:02.868515 29135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T16:00:57.136386+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-17T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T16:00:37.192207+00:00 2021-05-17T16:00:38.915518+00:00 0:00:01.723311 29134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-17T16:00:35.115422+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-17T15:00:00+00:00 PythonOperator 2021-05-17T16:00:15.414730+00:00 2021-05-17T16:00:18.585030+00:00 0:00:03.170300 29133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-17T16:00:13.097070+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-17T14:00:00+00:00 EmrJobFlowSensor 2021-05-17T15:11:38.936796+00:00 2021-05-17T15:21:41.665580+00:00 0:10:02.728784 29131 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T15:11:36.544096+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-17T14:00:00+00:00 EmrJobFlowSensor 2021-05-17T15:11:34.707840+00:00 2021-05-17T15:19:37.227864+00:00 0:08:02.520024 29130 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T15:11:32.488311+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-17T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T15:11:16.819924+00:00 2021-05-17T15:11:18.543529+00:00 0:00:01.723605 29129 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T15:11:14.540885+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-17T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T15:11:12.858234+00:00 2021-05-17T15:11:14.713896+00:00 0:00:01.855662 29128 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T15:11:10.488694+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-17T14:00:00+00:00 PythonOperator 2021-05-17T15:10:54.774359+00:00 2021-05-17T15:10:58.215516+00:00 0:00:03.441157 29127 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T15:10:52.406295+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-17T14:00:00+00:00 PythonOperator 2021-05-17T15:10:50.549670+00:00 2021-05-17T15:10:53.733015+00:00 0:00:03.183345 29126 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T15:10:48.405282+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-17T14:00:00+00:00 TriggerDagRunOperator 2021-05-17T15:10:34.795749+00:00 2021-05-17T15:10:35.328964+00:00 0:00:00.533215 29125 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T15:10:32.391168+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-17T14:00:00+00:00 TriggerDagRunOperator 2021-05-17T15:10:34.533241+00:00 2021-05-17T15:10:34.952809+00:00 0:00:00.419568 29124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T15:10:32.391131+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-17T14:05:00+00:00 EmrJobFlowSensor 2021-05-17T15:06:06.139476+00:00 2021-05-17T15:14:08.589926+00:00 0:08:02.450450 29123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T15:06:04.037643+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-17T14:05:00+00:00 EmrCreateJobFlowOperator 2021-05-17T15:05:44.315083+00:00 2021-05-17T15:05:45.910582+00:00 0:00:01.595499 29122 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T15:05:42.021301+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-17T14:05:00+00:00 PythonOperator 2021-05-17T15:05:22.300766+00:00 2021-05-17T15:05:25.403998+00:00 0:00:03.103232 29121 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T15:05:20.008828+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-17T14:00:00+00:00 EmrJobFlowSensor 2021-05-17T15:01:07.846338+00:00 2021-05-17T15:10:10.652596+00:00 0:09:02.806258 29120 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T15:01:05.640243+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-17T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T15:00:44.014163+00:00 2021-05-17T15:00:45.702403+00:00 0:00:01.688240 29119 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-17T15:00:41.684654+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-17T14:00:00+00:00 PythonOperator 2021-05-17T15:00:22.190239+00:00 2021-05-17T15:00:25.344764+00:00 0:00:03.154525 29118 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-17T15:00:19.667868+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-17T13:00:00+00:00 EmrJobFlowSensor 2021-05-17T14:12:11.498300+00:00 2021-05-17T14:21:14.205796+00:00 0:09:02.707496 29116 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T14:12:09.270846+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-17T13:00:00+00:00 EmrJobFlowSensor 2021-05-17T14:12:05.702219+00:00 2021-05-17T14:21:08.416057+00:00 0:09:02.713838 29115 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T14:12:03.264446+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-17T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T14:11:49.868779+00:00 2021-05-17T14:11:51.691471+00:00 0:00:01.822692 29114 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T14:11:47.276565+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-17T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T14:11:45.495662+00:00 2021-05-17T14:11:47.153786+00:00 0:00:01.658124 29113 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T14:11:43.268202+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-17T13:00:00+00:00 PythonOperator 2021-05-17T14:11:27.795257+00:00 2021-05-17T14:11:31.674191+00:00 0:00:03.878934 29112 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T14:11:25.109267+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-17T13:00:00+00:00 PythonOperator 2021-05-17T14:11:23.756507+00:00 2021-05-17T14:11:27.536493+00:00 0:00:03.779986 29111 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T14:11:21.101982+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-17T13:00:00+00:00 TriggerDagRunOperator 2021-05-17T14:11:15.538191+00:00 2021-05-17T14:11:15.953299+00:00 0:00:00.415108 29110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T14:11:13.097453+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-17T13:00:00+00:00 TriggerDagRunOperator 2021-05-17T14:11:15.408382+00:00 2021-05-17T14:11:15.971365+00:00 0:00:00.562983 29109 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T14:11:13.097419+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-17T13:05:00+00:00 EmrJobFlowSensor 2021-05-17T14:06:01.301700+00:00 2021-05-17T14:14:03.810690+00:00 0:08:02.508990 29108 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T14:05:58.763859+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-17T13:05:00+00:00 EmrCreateJobFlowOperator 2021-05-17T14:05:38.759902+00:00 2021-05-17T14:05:40.387084+00:00 0:00:01.627182 29107 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T14:05:36.626226+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-17T13:05:00+00:00 PythonOperator 2021-05-17T14:05:16.710467+00:00 2021-05-17T14:05:19.857043+00:00 0:00:03.146576 29106 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T14:05:14.605154+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-17T13:00:00+00:00 EmrJobFlowSensor 2021-05-17T14:01:06.353346+00:00 2021-05-17T14:11:09.329047+00:00 0:10:02.975701 29105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T14:01:04.184641+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-17T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T14:00:42.328318+00:00 2021-05-17T14:00:44.015027+00:00 0:00:01.686709 29104 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-17T14:00:40.136946+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-17T13:00:00+00:00 PythonOperator 2021-05-17T14:00:22.564043+00:00 2021-05-17T14:00:25.752783+00:00 0:00:03.188740 29103 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-17T14:00:20.122349+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-17T12:00:00+00:00 EmrJobFlowSensor 2021-05-17T13:21:07.341390+00:00 2021-05-17T13:30:10.136515+00:00 0:09:02.795125 29101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T13:21:04.364213+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-17T12:00:00+00:00 EmrJobFlowSensor 2021-05-17T13:21:05.053313+00:00 2021-05-17T13:31:08.247195+00:00 0:10:03.193882 29100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T13:21:02.356633+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-17T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T13:20:44.579027+00:00 2021-05-17T13:20:46.274218+00:00 0:00:01.695191 29099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T13:20:42.357494+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-17T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T13:20:42.677890+00:00 2021-05-17T13:20:44.441894+00:00 0:00:01.764004 29098 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T13:20:40.343844+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-17T12:00:00+00:00 PythonOperator 2021-05-17T13:20:25.709036+00:00 2021-05-17T13:20:29.050422+00:00 0:00:03.341386 29097 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T13:20:22.247666+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-17T12:00:00+00:00 PythonOperator 2021-05-17T13:20:20.418436+00:00 2021-05-17T13:20:24.418599+00:00 0:00:04.000163 29096 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T13:20:18.233102+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-17T12:00:00+00:00 TriggerDagRunOperator 2021-05-17T13:20:16.585353+00:00 2021-05-17T13:20:17.101219+00:00 0:00:00.515866 29095 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T13:20:14.226861+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-17T12:00:00+00:00 TriggerDagRunOperator 2021-05-17T13:20:16.394356+00:00 2021-05-17T13:20:16.805153+00:00 0:00:00.410797 29094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T13:20:14.226832+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-17T12:05:00+00:00 EmrJobFlowSensor 2021-05-17T13:06:16.960698+00:00 2021-05-17T13:14:19.517375+00:00 0:08:02.556677 29093 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T13:06:14.846949+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-17T12:05:00+00:00 EmrCreateJobFlowOperator 2021-05-17T13:05:55.198766+00:00 2021-05-17T13:05:56.971549+00:00 0:00:01.772783 29092 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T13:05:52.868552+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-17T12:05:00+00:00 PythonOperator 2021-05-17T13:05:35.048349+00:00 2021-05-17T13:05:38.162088+00:00 0:00:03.113739 29091 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T13:05:32.787935+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-17T12:00:00+00:00 EmrJobFlowSensor 2021-05-17T13:01:04.619910+00:00 2021-05-17T13:19:08.664702+00:00 0:18:04.044792 29090 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T13:01:02.254408+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-17T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T13:00:42.414527+00:00 2021-05-17T13:00:44.117301+00:00 0:00:01.702774 29089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-17T13:00:40.144798+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-17T12:00:00+00:00 PythonOperator 2021-05-17T13:00:20.682481+00:00 2021-05-17T13:00:23.914232+00:00 0:00:03.231751 29088 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-17T13:00:18.129736+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-17T11:00:00+00:00 EmrJobFlowSensor 2021-05-17T12:11:31.347806+00:00 2021-05-17T12:20:34.104445+00:00 0:09:02.756639 29086 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T12:11:28.785543+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-17T11:00:00+00:00 EmrJobFlowSensor 2021-05-17T12:11:31.113323+00:00 2021-05-17T12:21:33.859032+00:00 0:10:02.745709 29085 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T12:11:28.785496+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-17T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T12:11:11.392431+00:00 2021-05-17T12:11:13.130527+00:00 0:00:01.738096 29084 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T12:11:08.744081+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-17T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T12:11:08.953972+00:00 2021-05-17T12:11:11.088558+00:00 0:00:02.134586 29083 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T12:11:06.741271+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-17T11:00:00+00:00 PythonOperator 2021-05-17T12:10:40.903038+00:00 2021-05-17T12:10:44.222106+00:00 0:00:03.319068 29082 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T12:10:38.718356+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-17T11:00:00+00:00 PythonOperator 2021-05-17T12:10:38.893787+00:00 2021-05-17T12:10:42.198643+00:00 0:00:03.304856 29081 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T12:10:36.714538+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-17T11:00:00+00:00 TriggerDagRunOperator 2021-05-17T12:10:21.123591+00:00 2021-05-17T12:10:21.650520+00:00 0:00:00.526929 29080 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T12:10:18.768489+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-17T11:00:00+00:00 TriggerDagRunOperator 2021-05-17T12:10:20.989202+00:00 2021-05-17T12:10:21.419337+00:00 0:00:00.430135 29079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T12:10:18.768531+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-17T11:05:00+00:00 EmrJobFlowSensor 2021-05-17T12:06:06.396478+00:00 2021-05-17T12:15:09.089725+00:00 0:09:02.693247 29078 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T12:06:04.192368+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-17T11:05:00+00:00 EmrCreateJobFlowOperator 2021-05-17T12:05:46.286090+00:00 2021-05-17T12:05:47.909098+00:00 0:00:01.623008 29077 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T12:05:44.149270+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-17T11:05:00+00:00 PythonOperator 2021-05-17T12:05:24.432018+00:00 2021-05-17T12:05:27.505060+00:00 0:00:03.073042 29076 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T12:05:22.118759+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-17T11:00:00+00:00 EmrJobFlowSensor 2021-05-17T12:00:54.142624+00:00 2021-05-17T12:09:56.955465+00:00 0:09:02.812841 29075 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T12:00:51.751032+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-17T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T12:00:34.005704+00:00 2021-05-17T12:00:35.784221+00:00 0:00:01.778517 29074 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-17T12:00:31.637973+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-17T11:00:00+00:00 PythonOperator 2021-05-17T12:00:11.900332+00:00 2021-05-17T12:00:15.071107+00:00 0:00:03.170775 29073 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-17T12:00:09.544029+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-17T10:00:00+00:00 EmrJobFlowSensor 2021-05-17T11:10:55.906474+00:00 2021-05-17T11:19:58.888872+00:00 0:09:02.982398 29071 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T11:10:53.463791+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-17T10:00:00+00:00 EmrJobFlowSensor 2021-05-17T11:10:55.680257+00:00 2021-05-17T11:18:58.248182+00:00 0:08:02.567925 29070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T11:10:53.463753+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-17T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T11:10:35.906213+00:00 2021-05-17T11:10:37.738436+00:00 0:00:01.832223 29069 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T11:10:33.448266+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-17T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T11:10:33.912954+00:00 2021-05-17T11:10:35.675626+00:00 0:00:01.762672 29068 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T11:10:31.455507+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-17T10:00:00+00:00 PythonOperator 2021-05-17T11:10:14.612581+00:00 2021-05-17T11:10:17.844581+00:00 0:00:03.232000 29067 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T11:10:11.232412+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-17T10:00:00+00:00 PythonOperator 2021-05-17T11:10:12.460417+00:00 2021-05-17T11:10:16.260726+00:00 0:00:03.800309 29066 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T11:10:09.350407+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-17T10:00:00+00:00 TriggerDagRunOperator 2021-05-17T11:10:03.554212+00:00 2021-05-17T11:10:04.093756+00:00 0:00:00.539544 29065 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T11:10:01.222726+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-17T10:00:00+00:00 TriggerDagRunOperator 2021-05-17T11:10:03.457488+00:00 2021-05-17T11:10:03.922922+00:00 0:00:00.465434 29064 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T11:10:01.222687+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-17T10:05:00+00:00 EmrJobFlowSensor 2021-05-17T11:05:57.105244+00:00 2021-05-17T11:14:59.719361+00:00 0:09:02.614117 29063 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T11:05:54.683861+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-17T10:05:00+00:00 EmrCreateJobFlowOperator 2021-05-17T11:05:36.868897+00:00 2021-05-17T11:05:38.634261+00:00 0:00:01.765364 29062 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T11:05:34.621370+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-17T10:05:00+00:00 PythonOperator 2021-05-17T11:05:14.755297+00:00 2021-05-17T11:05:17.924491+00:00 0:00:03.169194 29061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T11:05:12.601542+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-17T10:00:00+00:00 EmrJobFlowSensor 2021-05-17T11:00:56.407472+00:00 2021-05-17T11:09:59.105926+00:00 0:09:02.698454 29060 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T11:00:54.204755+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-17T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T11:00:34.434111+00:00 2021-05-17T11:00:36.107238+00:00 0:00:01.673127 29059 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-17T11:00:32.256318+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-17T10:00:00+00:00 PythonOperator 2021-05-17T11:00:12.668627+00:00 2021-05-17T11:00:15.789544+00:00 0:00:03.120917 29058 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-17T11:00:10.143632+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-17T09:00:00+00:00 EmrJobFlowSensor 2021-05-17T10:24:18.858196+00:00 2021-05-17T10:33:21.666760+00:00 0:09:02.808564 29056 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T10:24:16.445876+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-17T09:00:00+00:00 EmrJobFlowSensor 2021-05-17T10:24:16.596085+00:00 2021-05-17T10:33:19.311596+00:00 0:09:02.715511 29055 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T10:24:14.381171+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-17T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T10:23:58.666472+00:00 2021-05-17T10:24:00.433393+00:00 0:00:01.766921 29054 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T10:23:56.326230+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-17T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-17T10:23:54.557637+00:00 2021-05-17T10:23:56.416556+00:00 0:00:01.858919 29053 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-17T10:23:52.304813+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-17T09:00:00+00:00 PythonOperator 2021-05-17T10:23:36.899445+00:00 2021-05-17T10:23:40.084942+00:00 0:00:03.185497 29052 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T10:23:34.287650+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-17T09:00:00+00:00 PythonOperator 2021-05-17T10:23:34.502561+00:00 2021-05-17T10:23:38.224565+00:00 0:00:03.722004 29051 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-17T10:23:32.287890+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-17T09:00:00+00:00 TriggerDagRunOperator 2021-05-17T10:23:20.518819+00:00 2021-05-17T10:23:21.046918+00:00 0:00:00.528099 29050 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T10:23:18.227638+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-17T09:00:00+00:00 TriggerDagRunOperator 2021-05-17T10:23:20.425601+00:00 2021-05-17T10:23:20.845228+00:00 0:00:00.419627 29049 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-17T10:23:18.227608+00:00 2 default_pool