Task Instances

Reset Filters
  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-03T05:00:00+00:00 EmrJobFlowSensor 2021-04-03T06:00:57.337755+00:00 2021-04-03T06:11:00.051453+00:00 0:10:02.713698 13020 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T06:00:55.060908+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T06:00:37.334256+00:00 2021-04-03T06:00:39.132760+00:00 0:00:01.798504 13019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T06:00:35.044927+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T05:00:00+00:00 PythonOperator 2021-04-03T06:00:15.678347+00:00 2021-04-03T06:00:18.404053+00:00 0:00:02.725706 13018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T06:00:13.155761+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T04:00:00+00:00 EmrJobFlowSensor 2021-04-03T05:10:08.850242+00:00 2021-04-03T05:19:11.551748+00:00 0:09:02.701506 13016 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T05:10:06.355467+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T04:00:00+00:00 EmrJobFlowSensor 2021-04-03T05:10:06.852820+00:00 2021-04-03T05:20:09.798340+00:00 0:10:02.945520 13015 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T05:10:04.346521+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T05:09:46.630107+00:00 2021-04-03T05:09:48.461028+00:00 0:00:01.830921 13014 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T05:09:44.258615+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T05:09:46.515288+00:00 2021-04-03T05:09:48.220357+00:00 0:00:01.705069 13013 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T05:09:44.258584+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T04:00:00+00:00 PythonOperator 2021-04-03T05:09:27.075088+00:00 2021-04-03T05:09:29.789598+00:00 0:00:02.714510 13012 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T05:09:24.238111+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T04:00:00+00:00 PythonOperator 2021-04-03T05:09:24.848226+00:00 2021-04-03T05:09:28.211853+00:00 0:00:03.363627 13011 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T05:09:22.242202+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T04:00:00+00:00 TriggerDagRunOperator 2021-04-03T05:09:10.853132+00:00 2021-04-03T05:09:11.365364+00:00 0:00:00.512232 13010 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T05:09:08.256520+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T04:00:00+00:00 TriggerDagRunOperator 2021-04-03T05:09:10.591837+00:00 2021-04-03T05:09:10.998800+00:00 0:00:00.406963 13009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T05:09:08.256488+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T04:05:00+00:00 EmrJobFlowSensor 2021-04-03T05:05:54.195843+00:00 2021-04-03T05:13:56.784631+00:00 0:08:02.588788 13008 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T05:05:51.704987+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T05:05:31.845624+00:00 2021-04-03T05:05:33.493087+00:00 0:00:01.647463 13007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T05:05:29.681395+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T04:05:00+00:00 PythonOperator 2021-04-03T05:05:09.887030+00:00 2021-04-03T05:05:12.610195+00:00 0:00:02.723165 13006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T05:05:07.643745+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T04:00:00+00:00 EmrJobFlowSensor 2021-04-03T05:01:01.325284+00:00 2021-04-03T05:09:04.084811+00:00 0:08:02.759527 13005 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T05:00:59.092593+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T05:00:39.201011+00:00 2021-04-03T05:00:40.963196+00:00 0:00:01.762185 13004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T05:00:37.015122+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T04:00:00+00:00 PythonOperator 2021-04-03T05:00:19.553062+00:00 2021-04-03T05:00:22.395218+00:00 0:00:02.842156 13003 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T05:00:16.996996+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T03:00:00+00:00 EmrJobFlowSensor 2021-04-03T04:12:29.112709+00:00 2021-04-03T04:22:31.920811+00:00 0:10:02.808102 13001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T04:12:26.856155+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T03:00:00+00:00 EmrJobFlowSensor 2021-04-03T04:12:25.258575+00:00 2021-04-03T04:22:28.120101+00:00 0:10:02.861526 13000 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T04:12:22.852807+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T04:12:07.008443+00:00 2021-04-03T04:12:08.842754+00:00 0:00:01.834311 12999 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T04:12:04.757381+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T04:12:03.076847+00:00 2021-04-03T04:12:04.815479+00:00 0:00:01.738632 12998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T04:12:00.756241+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T03:00:00+00:00 PythonOperator 2021-04-03T04:11:47.012017+00:00 2021-04-03T04:11:49.932972+00:00 0:00:02.920955 12997 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T04:11:44.744052+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T03:00:00+00:00 PythonOperator 2021-04-03T04:11:41.092889+00:00 2021-04-03T04:11:43.939350+00:00 0:00:02.846461 12996 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T04:11:38.722980+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T03:00:00+00:00 TriggerDagRunOperator 2021-04-03T04:11:21.258220+00:00 2021-04-03T04:11:21.810953+00:00 0:00:00.552733 12995 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T04:11:18.754095+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T03:00:00+00:00 TriggerDagRunOperator 2021-04-03T04:11:21.215493+00:00 2021-04-03T04:11:21.648865+00:00 0:00:00.433372 12994 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T04:11:18.754143+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T03:05:00+00:00 EmrJobFlowSensor 2021-04-03T04:05:50.348373+00:00 2021-04-03T04:14:53.005461+00:00 0:09:02.657088 12993 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T04:05:48.152674+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T04:05:28.389750+00:00 2021-04-03T04:05:30.123449+00:00 0:00:01.733699 12992 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T04:05:26.163040+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T03:05:00+00:00 PythonOperator 2021-04-03T04:05:08.463353+00:00 2021-04-03T04:05:11.364263+00:00 0:00:02.900910 12991 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T04:05:06.048827+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T03:00:00+00:00 EmrJobFlowSensor 2021-04-03T04:00:57.818546+00:00 2021-04-03T04:11:00.619075+00:00 0:10:02.800529 12990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T04:00:55.533433+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T04:00:33.890061+00:00 2021-04-03T04:00:35.684434+00:00 0:00:01.794373 12989 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T04:00:31.535223+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T03:00:00+00:00 PythonOperator 2021-04-03T04:00:09.779988+00:00 2021-04-03T04:00:12.515866+00:00 0:00:02.735878 12988 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T04:00:07.496188+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T02:00:00+00:00 EmrJobFlowSensor 2021-04-03T03:11:12.435062+00:00 2021-04-03T03:20:15.177045+00:00 0:09:02.741983 12986 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T03:11:09.965433+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T02:00:00+00:00 EmrJobFlowSensor 2021-04-03T03:11:08.327313+00:00 2021-04-03T03:20:11.107242+00:00 0:09:02.779929 12985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T03:11:05.958692+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T03:10:50.365279+00:00 2021-04-03T03:10:52.194806+00:00 0:00:01.829527 12984 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T03:10:47.943517+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T03:10:46.295644+00:00 2021-04-03T03:10:47.987385+00:00 0:00:01.691741 12983 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T03:10:43.959164+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T02:00:00+00:00 PythonOperator 2021-04-03T03:10:30.538309+00:00 2021-04-03T03:10:33.388093+00:00 0:00:02.849784 12982 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T03:10:27.878684+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T02:00:00+00:00 PythonOperator 2021-04-03T03:10:26.433862+00:00 2021-04-03T03:10:29.865342+00:00 0:00:03.431480 12981 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T03:10:23.839256+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T02:00:00+00:00 TriggerDagRunOperator 2021-04-03T03:10:14.336439+00:00 2021-04-03T03:10:14.748456+00:00 0:00:00.412017 12980 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T03:10:11.827147+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T02:00:00+00:00 TriggerDagRunOperator 2021-04-03T03:10:14.355502+00:00 2021-04-03T03:10:14.904565+00:00 0:00:00.549063 12979 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T03:10:11.827181+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T02:05:00+00:00 EmrJobFlowSensor 2021-04-03T03:06:07.646362+00:00 2021-04-03T03:15:10.262815+00:00 0:09:02.616453 12978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T03:06:05.531178+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T03:05:45.894483+00:00 2021-04-03T03:05:47.629805+00:00 0:00:01.735322 12977 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T03:05:43.512237+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T02:05:00+00:00 PythonOperator 2021-04-03T03:05:23.800893+00:00 2021-04-03T03:05:26.647536+00:00 0:00:02.846643 12976 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T03:05:21.548524+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T02:00:00+00:00 EmrJobFlowSensor 2021-04-03T03:00:57.206068+00:00 2021-04-03T03:09:59.924775+00:00 0:09:02.718707 12975 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T03:00:54.940877+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T03:00:35.382806+00:00 2021-04-03T03:00:37.203333+00:00 0:00:01.820527 12974 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T03:00:32.843832+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T02:00:00+00:00 PythonOperator 2021-04-03T03:00:12.983727+00:00 2021-04-03T03:00:15.707589+00:00 0:00:02.723862 12973 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T03:00:10.717276+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T01:00:00+00:00 EmrJobFlowSensor 2021-04-03T02:10:31.915235+00:00 2021-04-03T02:18:34.408618+00:00 0:08:02.493383 12971 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T02:10:29.121777+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T01:00:00+00:00 EmrJobFlowSensor 2021-04-03T02:10:29.545757+00:00 2021-04-03T02:20:32.657451+00:00 0:10:03.111694 12970 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T02:10:27.150426+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T02:10:09.563935+00:00 2021-04-03T02:10:11.367204+00:00 0:00:01.803269 12969 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T02:10:07.066935+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T02:10:09.353892+00:00 2021-04-03T02:10:11.122362+00:00 0:00:01.768470 12968 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T02:10:07.066988+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T01:00:00+00:00 PythonOperator 2021-04-03T02:09:43.236810+00:00 2021-04-03T02:09:45.968220+00:00 0:00:02.731410 12967 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T02:09:41.016062+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T01:00:00+00:00 PythonOperator 2021-04-03T02:09:41.517840+00:00 2021-04-03T02:09:44.552665+00:00 0:00:03.034825 12966 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T02:09:39.013822+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T01:00:00+00:00 TriggerDagRunOperator 2021-04-03T02:09:29.639441+00:00 2021-04-03T02:09:30.164098+00:00 0:00:00.524657 12965 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T02:09:27.006306+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T01:00:00+00:00 TriggerDagRunOperator 2021-04-03T02:09:29.407585+00:00 2021-04-03T02:09:29.871259+00:00 0:00:00.463674 12964 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T02:09:27.006276+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T01:05:00+00:00 EmrJobFlowSensor 2021-04-03T02:06:50.969133+00:00 2021-04-03T02:14:53.429351+00:00 0:08:02.460218 12963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T02:06:48.822937+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T02:05:34.994045+00:00 2021-04-03T02:05:36.761064+00:00 0:00:01.767019 12962 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T02:05:32.718738+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T01:05:00+00:00 PythonOperator 2021-04-03T02:05:12.873435+00:00 2021-04-03T02:05:15.551494+00:00 0:00:02.678059 12961 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T02:05:10.702027+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T01:00:00+00:00 EmrJobFlowSensor 2021-04-03T02:01:12.592586+00:00 2021-04-03T02:09:15.198978+00:00 0:08:02.606392 12960 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T02:01:10.287195+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T02:00:44.430249+00:00 2021-04-03T02:00:46.180949+00:00 0:00:01.750700 12959 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T02:00:42.222580+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T01:00:00+00:00 PythonOperator 2021-04-03T02:00:24.814119+00:00 2021-04-03T02:00:27.520809+00:00 0:00:02.706690 12958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T02:00:22.244771+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T00:00:00+00:00 EmrJobFlowSensor 2021-04-03T01:11:35.615045+00:00 2021-04-03T01:19:38.147459+00:00 0:08:02.532414 12956 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T01:11:33.251162+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T00:00:00+00:00 EmrJobFlowSensor 2021-04-03T01:11:17.517151+00:00 2021-04-03T01:21:20.272616+00:00 0:10:02.755465 12955 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T01:11:15.204893+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T01:11:13.751307+00:00 2021-04-03T01:11:15.555000+00:00 0:00:01.803693 12954 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T01:11:11.263813+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T01:10:55.397593+00:00 2021-04-03T01:10:57.287939+00:00 0:00:01.890346 12953 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T01:10:53.129483+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T00:00:00+00:00 PythonOperator 2021-04-03T01:10:51.299607+00:00 2021-04-03T01:10:54.057926+00:00 0:00:02.758319 12952 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T01:10:49.123953+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T00:00:00+00:00 PythonOperator 2021-04-03T01:10:35.437211+00:00 2021-04-03T01:10:38.443105+00:00 0:00:03.005894 12951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T01:10:33.114587+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T00:00:00+00:00 TriggerDagRunOperator 2021-04-03T01:10:27.441658+00:00 2021-04-03T01:10:28.125551+00:00 0:00:00.683893 12950 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T01:10:25.107104+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T00:00:00+00:00 TriggerDagRunOperator 2021-04-03T01:10:27.450930+00:00 2021-04-03T01:10:28.000622+00:00 0:00:00.549692 12949 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T01:10:25.107069+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T00:05:00+00:00 EmrJobFlowSensor 2021-04-03T01:05:46.956592+00:00 2021-04-03T01:14:49.446135+00:00 0:09:02.489543 12948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T01:05:44.718878+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T01:05:27.003217+00:00 2021-04-03T01:05:28.728851+00:00 0:00:01.725634 12947 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T01:05:24.706123+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T00:05:00+00:00 PythonOperator 2021-04-03T01:05:05.076200+00:00 2021-04-03T01:05:07.761694+00:00 0:00:02.685494 12946 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T01:05:02.786795+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T00:00:00+00:00 EmrJobFlowSensor 2021-04-03T01:01:14.736846+00:00 2021-04-03T01:10:17.574999+00:00 0:09:02.838153 12945 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T01:01:12.425874+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T01:00:46.664507+00:00 2021-04-03T01:00:48.472139+00:00 0:00:01.807632 12944 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T01:00:44.398816+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T00:00:00+00:00 PythonOperator 2021-04-03T01:00:22.688779+00:00 2021-04-03T01:00:25.482156+00:00 0:00:02.793377 12943 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T01:00:20.363246+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T23:00:00+00:00 EmrJobFlowSensor 2021-04-03T00:12:20.510069+00:00 2021-04-03T00:22:23.328259+00:00 0:10:02.818190 12941 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T00:12:18.226195+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T23:00:00+00:00 EmrJobFlowSensor 2021-04-03T00:12:08.583172+00:00 2021-04-03T00:21:11.308434+00:00 0:09:02.725262 12940 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T00:12:06.215087+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T00:11:58.781140+00:00 2021-04-03T00:12:00.600278+00:00 0:00:01.819138 12939 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T00:11:56.209424+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T00:11:46.454145+00:00 2021-04-03T00:11:48.331968+00:00 0:00:01.877823 12938 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T00:11:44.200057+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T23:00:00+00:00 PythonOperator 2021-04-03T00:11:36.703212+00:00 2021-04-03T00:11:39.650423+00:00 0:00:02.947211 12937 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T00:11:34.193659+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T23:00:00+00:00 PythonOperator 2021-04-03T00:11:24.683678+00:00 2021-04-03T00:11:27.394594+00:00 0:00:02.710916 12936 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T00:11:22.152210+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T23:00:00+00:00 TriggerDagRunOperator 2021-04-03T00:11:12.565227+00:00 2021-04-03T00:11:12.986042+00:00 0:00:00.420815 12935 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T00:11:10.128929+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T23:00:00+00:00 TriggerDagRunOperator 2021-04-03T00:11:12.416304+00:00 2021-04-03T00:11:12.982504+00:00 0:00:00.566200 12934 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T00:11:10.128893+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T23:05:00+00:00 EmrJobFlowSensor 2021-04-03T00:05:50.022225+00:00 2021-04-03T00:13:52.518200+00:00 0:08:02.495975 12933 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T00:05:47.659270+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T00:05:27.808539+00:00 2021-04-03T00:05:29.535417+00:00 0:00:01.726878 12932 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T00:05:25.550085+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T23:05:00+00:00 PythonOperator 2021-04-03T00:05:07.882281+00:00 2021-04-03T00:05:10.553165+00:00 0:00:02.670884 12931 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T00:05:05.531318+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T23:00:00+00:00 EmrJobFlowSensor 2021-04-03T00:00:53.523872+00:00 2021-04-03T00:10:56.494672+00:00 0:10:02.970800 12930 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T00:00:51.142776+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T00:00:29.715731+00:00 2021-04-03T00:00:31.535049+00:00 0:00:01.819318 12929 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T00:00:27.168383+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T23:00:00+00:00 PythonOperator 2021-04-03T00:00:07.871825+00:00 2021-04-03T00:00:10.749458+00:00 0:00:02.877633 12928 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T00:00:05.156050+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T22:00:00+00:00 EmrJobFlowSensor 2021-04-02T23:18:36.136163+00:00 2021-04-02T23:27:38.869096+00:00 0:09:02.732933 12926 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T23:18:33.856727+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T22:00:00+00:00 EmrJobFlowSensor 2021-04-02T23:18:20.237187+00:00 2021-04-02T23:28:23.149094+00:00 0:10:02.911907 12925 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T23:18:17.842039+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T23:18:12.041436+00:00 2021-04-02T23:18:13.769485+00:00 0:00:01.728049 12924 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T23:18:09.811570+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T23:17:58.334691+00:00 2021-04-02T23:18:00.204922+00:00 0:00:01.870231 12923 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T23:17:55.863774+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T22:00:00+00:00 PythonOperator 2021-04-02T23:17:51.998185+00:00 2021-04-02T23:17:54.704764+00:00 0:00:02.706579 12922 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T23:17:49.793123+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T22:00:00+00:00 PythonOperator 2021-04-02T23:17:38.212733+00:00 2021-04-02T23:17:41.216847+00:00 0:00:03.004114 12921 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T23:17:35.761869+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T22:00:00+00:00 TriggerDagRunOperator 2021-04-02T23:17:30.234485+00:00 2021-04-02T23:17:30.837058+00:00 0:00:00.602573 12920 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T23:17:27.678290+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T22:00:00+00:00 TriggerDagRunOperator 2021-04-02T23:17:29.977521+00:00 2021-04-02T23:17:30.443109+00:00 0:00:00.465588 12919 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T23:17:27.678257+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T22:05:00+00:00 EmrJobFlowSensor 2021-04-02T23:06:02.665155+00:00 2021-04-02T23:15:05.450652+00:00 0:09:02.785497 12918 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T23:06:00.414742+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T23:05:40.611398+00:00 2021-04-02T23:05:42.369361+00:00 0:00:01.757963 12917 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T23:05:38.390815+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T22:05:00+00:00 PythonOperator 2021-04-02T23:05:18.959560+00:00 2021-04-02T23:05:21.682872+00:00 0:00:02.723312 12916 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T23:05:16.386844+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T22:00:00+00:00 EmrJobFlowSensor 2021-04-02T23:01:04.807316+00:00 2021-04-02T23:17:08.566611+00:00 0:16:03.759295 12915 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T23:01:02.142996+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T23:00:28.181302+00:00 2021-04-02T23:00:29.928177+00:00 0:00:01.746875 12914 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T23:00:25.993474+00:00 2 default_pool