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 check_cluster_status 2021-04-09T22:00:00+00:00 EmrJobFlowSensor 2021-04-09T23:00:54.675106+00:00 2021-04-09T23:10:57.459066+00:00 0:10:02.783960 15437 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T23:00:52.275849+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T23:00:32.535743+00:00 2021-04-09T23:00:34.227093+00:00 0:00:01.691350 15436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T23:00:30.248870+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T22:00:00+00:00 PythonOperator 2021-04-09T23:00:10.677877+00:00 2021-04-09T23:00:13.638772+00:00 0:00:02.960895 15435 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T23:00:08.150358+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T21:00:00+00:00 EmrJobFlowSensor 2021-04-09T22:12:18.758593+00:00 2021-04-09T22:20:21.354955+00:00 0:08:02.596362 15433 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T22:12:16.239856+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T21:00:00+00:00 EmrJobFlowSensor 2021-04-09T22:12:12.394933+00:00 2021-04-09T22:21:15.722249+00:00 0:09:03.327316 15432 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T22:12:10.234507+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T22:11:58.517718+00:00 2021-04-09T22:12:00.393004+00:00 0:00:01.875286 15431 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T22:11:56.209527+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T22:11:50.363274+00:00 2021-04-09T22:11:52.039787+00:00 0:00:01.676513 15430 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T22:11:48.201472+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T21:00:00+00:00 PythonOperator 2021-04-09T22:11:36.570883+00:00 2021-04-09T22:11:39.309470+00:00 0:00:02.738587 15429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T22:11:34.187776+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T21:00:00+00:00 PythonOperator 2021-04-09T22:11:30.692845+00:00 2021-04-09T22:11:33.717896+00:00 0:00:03.025051 15428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T22:11:28.340801+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T21:00:00+00:00 TriggerDagRunOperator 2021-04-09T22:11:12.429467+00:00 2021-04-09T22:11:12.874946+00:00 0:00:00.445479 15427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T22:11:10.101843+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T21:00:00+00:00 TriggerDagRunOperator 2021-04-09T22:11:12.302508+00:00 2021-04-09T22:11:12.887775+00:00 0:00:00.585267 15426 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T22:11:10.101811+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T21:05:00+00:00 EmrJobFlowSensor 2021-04-09T22:05:49.878798+00:00 2021-04-09T22:14:52.407853+00:00 0:09:02.529055 15425 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T22:05:47.652660+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T22:05:27.770929+00:00 2021-04-09T22:05:29.398521+00:00 0:00:01.627592 15424 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T22:05:25.533728+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T21:05:00+00:00 PythonOperator 2021-04-09T22:05:05.666041+00:00 2021-04-09T22:05:08.371954+00:00 0:00:02.705913 15423 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T22:05:03.513705+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T21:00:00+00:00 EmrJobFlowSensor 2021-04-09T22:00:47.517995+00:00 2021-04-09T22:10:50.253941+00:00 0:10:02.735946 15422 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T22:00:45.202721+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T22:00:27.483664+00:00 2021-04-09T22:00:29.318389+00:00 0:00:01.834725 15421 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T22:00:25.182384+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T21:00:00+00:00 PythonOperator 2021-04-09T22:00:05.688752+00:00 2021-04-09T22:00:09.210055+00:00 0:00:03.521303 15420 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T22:00:03.162752+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T20:00:00+00:00 EmrJobFlowSensor 2021-04-09T21:12:20.318296+00:00 2021-04-09T21:21:23.077696+00:00 0:09:02.759400 15418 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T21:12:18.021740+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T20:00:00+00:00 EmrJobFlowSensor 2021-04-09T21:12:16.189651+00:00 2021-04-09T21:22:18.948165+00:00 0:10:02.758514 15417 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T21:12:14.018725+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T21:11:58.408652+00:00 2021-04-09T21:12:00.126686+00:00 0:00:01.718034 15416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T21:11:56.054311+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T21:11:54.507196+00:00 2021-04-09T21:11:56.200571+00:00 0:00:01.693375 15415 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T21:11:52.066772+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T20:00:00+00:00 PythonOperator 2021-04-09T21:11:36.456299+00:00 2021-04-09T21:11:39.251294+00:00 0:00:02.794995 15414 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T21:11:34.067571+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T20:00:00+00:00 PythonOperator 2021-04-09T21:11:34.563839+00:00 2021-04-09T21:11:37.548512+00:00 0:00:02.984673 15413 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T21:11:32.044832+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T20:00:00+00:00 TriggerDagRunOperator 2021-04-09T21:11:20.306732+00:00 2021-04-09T21:11:20.899998+00:00 0:00:00.593266 15412 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T21:11:17.942584+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T20:00:00+00:00 TriggerDagRunOperator 2021-04-09T21:11:20.157970+00:00 2021-04-09T21:11:20.580037+00:00 0:00:00.422067 15411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T21:11:17.942551+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T20:05:00+00:00 EmrJobFlowSensor 2021-04-09T21:06:01.773816+00:00 2021-04-09T21:14:04.331262+00:00 0:08:02.557446 15410 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T21:05:59.460127+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T21:05:39.766365+00:00 2021-04-09T21:05:41.418935+00:00 0:00:01.652570 15409 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T21:05:37.473474+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T20:05:00+00:00 PythonOperator 2021-04-09T21:05:17.578495+00:00 2021-04-09T21:05:20.366533+00:00 0:00:02.788038 15408 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T21:05:15.365971+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T20:00:00+00:00 EmrJobFlowSensor 2021-04-09T21:00:59.255753+00:00 2021-04-09T21:11:02.057148+00:00 0:10:02.801395 15407 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T21:00:56.971900+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T21:00:39.331224+00:00 2021-04-09T21:00:41.137568+00:00 0:00:01.806344 15406 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T21:00:36.896786+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T20:00:00+00:00 PythonOperator 2021-04-09T21:00:17.214445+00:00 2021-04-09T21:00:20.085058+00:00 0:00:02.870613 15405 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T21:00:14.823645+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T19:00:00+00:00 EmrJobFlowSensor 2021-04-09T20:11:23.837449+00:00 2021-04-09T20:20:26.558908+00:00 0:09:02.721459 15403 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T20:11:21.633377+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T19:00:00+00:00 EmrJobFlowSensor 2021-04-09T20:11:08.010059+00:00 2021-04-09T20:20:10.580377+00:00 0:09:02.570318 15402 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T20:11:05.621673+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T20:11:03.937539+00:00 2021-04-09T20:11:05.661514+00:00 0:00:01.723975 15401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T20:11:01.615237+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T20:10:45.920739+00:00 2021-04-09T20:10:47.586092+00:00 0:00:01.665353 15400 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T20:10:43.605440+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T19:00:00+00:00 PythonOperator 2021-04-09T20:10:40.084699+00:00 2021-04-09T20:10:42.789985+00:00 0:00:02.705286 15399 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T20:10:37.592701+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T19:00:00+00:00 PythonOperator 2021-04-09T20:10:26.229431+00:00 2021-04-09T20:10:29.555564+00:00 0:00:03.326133 15398 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T20:10:23.670820+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T19:00:00+00:00 TriggerDagRunOperator 2021-04-09T20:10:15.997848+00:00 2021-04-09T20:10:16.562789+00:00 0:00:00.564941 15397 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T20:10:13.528505+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T19:00:00+00:00 TriggerDagRunOperator 2021-04-09T20:10:15.789502+00:00 2021-04-09T20:10:16.191416+00:00 0:00:00.401914 15396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T20:10:13.528535+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T19:05:00+00:00 EmrJobFlowSensor 2021-04-09T20:05:53.274586+00:00 2021-04-09T20:14:55.856263+00:00 0:09:02.581677 15395 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T20:05:51.082871+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T20:05:33.374863+00:00 2021-04-09T20:05:35.136372+00:00 0:00:01.761509 15394 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T20:05:31.074762+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T19:05:00+00:00 PythonOperator 2021-04-09T20:05:11.190246+00:00 2021-04-09T20:05:13.977712+00:00 0:00:02.787466 15393 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T20:05:09.004192+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T19:00:00+00:00 EmrJobFlowSensor 2021-04-09T20:00:58.827933+00:00 2021-04-09T20:10:02.050418+00:00 0:09:03.222485 15392 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T20:00:56.430716+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T20:00:32.585021+00:00 2021-04-09T20:00:34.330855+00:00 0:00:01.745834 15391 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T20:00:30.407010+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T19:00:00+00:00 PythonOperator 2021-04-09T20:00:10.831616+00:00 2021-04-09T20:00:13.707212+00:00 0:00:02.875596 15390 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T20:00:08.456712+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T18:00:00+00:00 EmrJobFlowSensor 2021-04-09T19:15:32.019733+00:00 2021-04-09T19:25:34.802230+00:00 0:10:02.782497 15389 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T19:15:29.709188+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T19:15:11.863057+00:00 2021-04-09T19:15:13.771949+00:00 0:00:01.908892 15388 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T19:15:09.690128+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T18:00:00+00:00 EmrJobFlowSensor 2021-04-09T19:14:18.168842+00:00 2021-04-09T19:21:20.636534+00:00 0:07:02.467692 15387 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T19:14:15.629177+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T19:11:39.757321+00:00 2021-04-09T19:11:41.456235+00:00 0:00:01.698914 15385 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T19:11:37.210195+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T18:00:00+00:00 PythonOperator 2021-04-09T19:11:27.915046+00:00 2021-04-09T19:11:30.870669+00:00 0:00:02.955623 15384 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T19:11:25.266813+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T18:00:00+00:00 PythonOperator 2021-04-09T19:11:15.652999+00:00 2021-04-09T19:11:18.344453+00:00 0:00:02.691454 15383 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T19:11:13.256100+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T18:00:00+00:00 TriggerDagRunOperator 2021-04-09T19:11:08.043985+00:00 2021-04-09T19:11:08.595848+00:00 0:00:00.551863 15382 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T19:11:05.252131+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T18:00:00+00:00 TriggerDagRunOperator 2021-04-09T19:11:07.592814+00:00 2021-04-09T19:11:08.005447+00:00 0:00:00.412633 15381 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T19:11:05.252084+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T18:05:00+00:00 EmrJobFlowSensor 2021-04-09T19:05:53.232455+00:00 2021-04-09T19:14:55.804022+00:00 0:09:02.571567 15380 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T19:05:50.716749+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T19:05:32.937522+00:00 2021-04-09T19:05:34.621756+00:00 0:00:01.684234 15379 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T19:05:30.700081+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T18:05:00+00:00 PythonOperator 2021-04-09T19:05:10.870313+00:00 2021-04-09T19:05:13.707187+00:00 0:00:02.836874 15378 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T19:05:08.678808+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T18:00:00+00:00 EmrJobFlowSensor 2021-04-09T19:00:54.569111+00:00 2021-04-09T19:10:57.723971+00:00 0:10:03.154860 15377 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T19:00:52.129415+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T19:00:32.338728+00:00 2021-04-09T19:00:34.250695+00:00 0:00:01.911967 15376 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T19:00:30.113397+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T18:00:00+00:00 PythonOperator 2021-04-09T19:00:10.345114+00:00 2021-04-09T19:00:13.711243+00:00 0:00:03.366129 15375 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T19:00:08.096281+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T17:00:00+00:00 EmrJobFlowSensor 2021-04-09T18:12:53.397390+00:00 2021-04-09T18:22:56.305507+00:00 0:10:02.908117 15374 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T18:12:50.753844+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T17:00:00+00:00 EmrJobFlowSensor 2021-04-09T18:12:53.202087+00:00 2021-04-09T18:22:55.938121+00:00 0:10:02.736034 15373 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T18:12:50.753805+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T18:12:31.013445+00:00 2021-04-09T18:12:32.833130+00:00 0:00:01.819685 15372 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T18:12:28.670113+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T18:12:30.948704+00:00 2021-04-09T18:12:32.705512+00:00 0:00:01.756808 15371 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T18:12:28.670141+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T17:00:00+00:00 PythonOperator 2021-04-09T18:12:10.948158+00:00 2021-04-09T18:12:13.929513+00:00 0:00:02.981355 15370 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T18:12:08.613346+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T17:00:00+00:00 PythonOperator 2021-04-09T18:12:10.831697+00:00 2021-04-09T18:12:13.778611+00:00 0:00:02.946914 15369 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T18:12:08.613315+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T17:00:00+00:00 TriggerDagRunOperator 2021-04-09T18:11:57.290499+00:00 2021-04-09T18:11:57.844824+00:00 0:00:00.554325 15368 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T18:11:54.601827+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T17:00:00+00:00 TriggerDagRunOperator 2021-04-09T18:11:57.242479+00:00 2021-04-09T18:11:57.662614+00:00 0:00:00.420135 15367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T18:11:54.601855+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T17:05:00+00:00 EmrJobFlowSensor 2021-04-09T18:05:46.603038+00:00 2021-04-09T18:14:49.249422+00:00 0:09:02.646384 15365 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T18:05:44.260903+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T18:05:26.422141+00:00 2021-04-09T18:05:28.185607+00:00 0:00:01.763466 15364 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T18:05:24.182520+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T17:05:00+00:00 PythonOperator 2021-04-09T18:05:04.435661+00:00 2021-04-09T18:05:07.177507+00:00 0:00:02.741846 15363 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T18:05:02.152707+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T17:00:00+00:00 EmrJobFlowSensor 2021-04-09T18:01:06.141053+00:00 2021-04-09T18:10:08.874939+00:00 0:09:02.733886 15362 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T18:01:03.793984+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T18:00:44.143045+00:00 2021-04-09T18:00:46.049083+00:00 0:00:01.906038 15361 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T18:00:41.721607+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T17:00:00+00:00 PythonOperator 2021-04-09T18:00:22.053726+00:00 2021-04-09T18:00:24.947225+00:00 0:00:02.893499 15360 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T18:00:19.743650+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T16:00:00+00:00 EmrJobFlowSensor 2021-04-09T17:11:27.161522+00:00 2021-04-09T17:19:29.573090+00:00 0:08:02.411568 15359 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T17:11:24.867793+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T16:00:00+00:00 EmrJobFlowSensor 2021-04-09T17:11:13.259751+00:00 2021-04-09T17:20:16.107347+00:00 0:09:02.847596 15358 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T17:11:10.857615+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T17:11:07.164291+00:00 2021-04-09T17:11:09.034797+00:00 0:00:01.870506 15357 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T17:11:04.844161+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T17:10:47.196037+00:00 2021-04-09T17:10:49.284982+00:00 0:00:02.088945 15356 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T17:10:44.744359+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T16:00:00+00:00 PythonOperator 2021-04-09T17:10:35.091058+00:00 2021-04-09T17:10:37.791585+00:00 0:00:02.700527 15355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T17:10:32.747065+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T16:00:00+00:00 PythonOperator 2021-04-09T17:10:25.042776+00:00 2021-04-09T17:10:27.937639+00:00 0:00:02.894863 15354 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T17:10:22.769938+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T16:00:00+00:00 TriggerDagRunOperator 2021-04-09T17:10:15.733924+00:00 2021-04-09T17:10:16.259805+00:00 0:00:00.525881 15353 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T17:10:12.641007+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T16:00:00+00:00 TriggerDagRunOperator 2021-04-09T17:10:15.626847+00:00 2021-04-09T17:10:16.036759+00:00 0:00:00.409912 15352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T17:10:12.641053+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T16:05:00+00:00 EmrJobFlowSensor 2021-04-09T17:06:13.362651+00:00 2021-04-09T17:15:15.916828+00:00 0:09:02.554177 15350 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T17:06:11.157710+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T17:05:51.290189+00:00 2021-04-09T17:05:52.963208+00:00 0:00:01.673019 15349 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T17:05:49.139268+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T16:05:00+00:00 PythonOperator 2021-04-09T17:05:21.259316+00:00 2021-04-09T17:05:24.043209+00:00 0:00:02.783893 15348 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T17:05:19.113563+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T16:00:00+00:00 EmrJobFlowSensor 2021-04-09T17:00:49.443467+00:00 2021-04-09T17:09:52.167398+00:00 0:09:02.723931 15347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T17:00:46.461496+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T17:00:28.824629+00:00 2021-04-09T17:00:30.636945+00:00 0:00:01.812316 15346 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T17:00:26.415990+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T16:00:00+00:00 PythonOperator 2021-04-09T17:00:06.663325+00:00 2021-04-09T17:00:09.802737+00:00 0:00:03.139412 15345 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T17:00:04.386875+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-09T15:00:00+00:00 EmrJobFlowSensor 2021-04-09T16:19:44.841386+00:00 2021-04-09T16:27:47.465240+00:00 0:08:02.623854 15344 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T16:19:42.348947+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-09T15:00:00+00:00 EmrJobFlowSensor 2021-04-09T16:19:42.508742+00:00 2021-04-09T16:28:45.223226+00:00 0:09:02.714484 15343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T16:19:40.346524+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-09T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T16:19:16.588234+00:00 2021-04-09T16:19:18.457426+00:00 0:00:01.869192 15342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T16:19:14.301919+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-09T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T16:19:12.575577+00:00 2021-04-09T16:19:14.394525+00:00 0:00:01.818948 15341 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T16:19:10.296006+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-09T15:00:00+00:00 PythonOperator 2021-04-09T16:18:54.787673+00:00 2021-04-09T16:18:57.513110+00:00 0:00:02.725437 15340 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T16:18:52.236779+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-09T15:00:00+00:00 PythonOperator 2021-04-09T16:18:50.445718+00:00 2021-04-09T16:18:53.718512+00:00 0:00:03.272794 15339 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T16:18:48.232378+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T15:00:00+00:00 TriggerDagRunOperator 2021-04-09T16:18:31.167631+00:00 2021-04-09T16:18:31.890748+00:00 0:00:00.723117 15338 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T16:18:28.218466+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T15:00:00+00:00 TriggerDagRunOperator 2021-04-09T16:18:30.664329+00:00 2021-04-09T16:18:31.108684+00:00 0:00:00.444355 15337 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T16:18:28.218430+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-09T15:05:00+00:00 EmrJobFlowSensor 2021-04-09T16:09:19.820900+00:00 2021-04-09T16:18:22.426534+00:00 0:09:02.605634 15336 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T16:09:17.506234+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T15:00:00+00:00 EmrJobFlowSensor 2021-04-09T16:09:15.767339+00:00 2021-04-09T16:18:18.437947+00:00 0:09:02.670608 15335 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T16:09:13.498999+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-09T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T16:08:59.596515+00:00 2021-04-09T16:09:01.257160+00:00 0:00:01.660645 15334 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T16:08:57.461240+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T16:08:55.644023+00:00 2021-04-09T16:08:57.318368+00:00 0:00:01.674345 15333 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T16:08:53.457321+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-09T15:05:00+00:00 PythonOperator 2021-04-09T16:08:37.662402+00:00 2021-04-09T16:08:40.315365+00:00 0:00:02.652963 15332 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T16:08:35.438215+00:00 2 default_pool