Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 create_emr_steps 2021-04-09T00:00:00+00:00 PythonOperator 2021-04-09T01:00:16.820113+00:00 2021-04-09T01:00:19.522336+00:00 0:00:02.702223 15106 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T01:00:13.762819+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T23:00:00+00:00 EmrJobFlowSensor 2021-04-09T00:10:10.008098+00:00 2021-04-09T00:20:12.794282+00:00 0:10:02.786184 15104 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T00:10:07.736436+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T23:00:00+00:00 EmrJobFlowSensor 2021-04-09T00:09:56.134760+00:00 2021-04-09T00:17:58.604496+00:00 0:08:02.469736 15103 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T00:09:53.855075+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T00:09:48.132329+00:00 2021-04-09T00:09:49.853986+00:00 0:00:01.721657 15102 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T00:09:45.779234+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T00:09:33.953129+00:00 2021-04-09T00:09:35.631614+00:00 0:00:01.678485 15101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T00:09:31.704883+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T23:00:00+00:00 PythonOperator 2021-04-09T00:09:28.121628+00:00 2021-04-09T00:09:31.036077+00:00 0:00:02.914449 15100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T00:09:25.713161+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T23:00:00+00:00 PythonOperator 2021-04-09T00:09:11.923246+00:00 2021-04-09T00:09:14.687707+00:00 0:00:02.764461 15099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T00:09:09.687631+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T23:00:00+00:00 TriggerDagRunOperator 2021-04-09T00:09:06.106899+00:00 2021-04-09T00:09:06.545387+00:00 0:00:00.438488 15098 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T00:09:03.678749+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T23:00:00+00:00 TriggerDagRunOperator 2021-04-09T00:09:05.976528+00:00 2021-04-09T00:09:06.614499+00:00 0:00:00.637971 15097 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T00:09:03.678782+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T23:05:00+00:00 EmrJobFlowSensor 2021-04-09T00:05:49.897909+00:00 2021-04-09T00:14:52.472016+00:00 0:09:02.574107 15096 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T00:05:47.366368+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-09T00:05:29.857806+00:00 2021-04-09T00:05:31.521946+00:00 0:00:01.664140 15095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-09T00:05:27.369361+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T23:05:00+00:00 PythonOperator 2021-04-09T00:05:05.665826+00:00 2021-04-09T00:05:08.344013+00:00 0:00:02.678187 15094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T00:05:03.284559+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T23:00:00+00:00 EmrJobFlowSensor 2021-04-09T00:00:47.081544+00:00 2021-04-09T00:08:49.701051+00:00 0:08:02.619507 15093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T00:00:44.799181+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T00:00:24.879056+00:00 2021-04-09T00:00:26.561157+00:00 0:00:01.682101 15092 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T00:00:22.708498+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T23:00:00+00:00 PythonOperator 2021-04-09T00:00:05.328628+00:00 2021-04-09T00:00:08.207131+00:00 0:00:02.878503 15091 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T00:00:02.698983+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T22:00:00+00:00 EmrJobFlowSensor 2021-04-08T23:11:11.604549+00:00 2021-04-08T23:21:14.460458+00:00 0:10:02.855909 15089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T23:11:09.043623+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T22:00:00+00:00 EmrJobFlowSensor 2021-04-08T23:11:11.538856+00:00 2021-04-08T23:21:14.527469+00:00 0:10:02.988613 15088 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T23:11:09.043658+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T23:10:51.586114+00:00 2021-04-08T23:10:53.278482+00:00 0:00:01.692368 15087 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T23:10:48.924528+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T23:10:49.350401+00:00 2021-04-08T23:10:51.333028+00:00 0:00:01.982627 15086 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T23:10:46.975089+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T22:00:00+00:00 PythonOperator 2021-04-08T23:10:29.482769+00:00 2021-04-08T23:10:32.693512+00:00 0:00:03.210743 15085 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T23:10:26.913510+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T22:00:00+00:00 PythonOperator 2021-04-08T23:10:29.199720+00:00 2021-04-08T23:10:32.042566+00:00 0:00:02.842846 15084 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T23:10:26.913554+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T22:00:00+00:00 TriggerDagRunOperator 2021-04-08T23:10:21.225197+00:00 2021-04-08T23:10:21.771423+00:00 0:00:00.546226 15083 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T23:10:18.901110+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T22:00:00+00:00 TriggerDagRunOperator 2021-04-08T23:10:21.101956+00:00 2021-04-08T23:10:21.576649+00:00 0:00:00.474693 15082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T23:10:18.901186+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T22:05:00+00:00 EmrJobFlowSensor 2021-04-08T23:05:56.684489+00:00 2021-04-08T23:13:59.063259+00:00 0:08:02.378770 15081 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T23:05:54.468606+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T23:05:34.641366+00:00 2021-04-08T23:05:36.411274+00:00 0:00:01.769908 15080 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T23:05:32.392381+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T22:05:00+00:00 PythonOperator 2021-04-08T23:05:12.567457+00:00 2021-04-08T23:05:15.332098+00:00 0:00:02.764641 15079 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T23:05:10.361903+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T22:00:00+00:00 EmrJobFlowSensor 2021-04-08T23:01:04.433438+00:00 2021-04-08T23:10:07.213894+00:00 0:09:02.780456 15078 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T23:01:02.050524+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T23:00:42.241972+00:00 2021-04-08T23:00:44.206201+00:00 0:00:01.964229 15077 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T23:00:39.962505+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T22:00:00+00:00 PythonOperator 2021-04-08T23:00:20.611094+00:00 2021-04-08T23:00:23.341029+00:00 0:00:02.729935 15076 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T23:00:17.942323+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T21:00:00+00:00 EmrJobFlowSensor 2021-04-08T22:11:34.569763+00:00 2021-04-08T22:21:37.359237+00:00 0:10:02.789474 15074 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T22:11:32.277793+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T21:00:00+00:00 EmrJobFlowSensor 2021-04-08T22:11:22.415613+00:00 2021-04-08T22:21:25.230729+00:00 0:10:02.815116 15073 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T22:11:20.208502+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T22:11:12.951108+00:00 2021-04-08T22:11:14.810807+00:00 0:00:01.859699 15072 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T22:11:10.199994+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T22:11:00.696258+00:00 2021-04-08T22:11:02.588801+00:00 0:00:01.892543 15071 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T22:10:58.248225+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T21:00:00+00:00 PythonOperator 2021-04-08T22:10:50.911213+00:00 2021-04-08T22:10:53.903538+00:00 0:00:02.992325 15070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T22:10:48.253934+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T21:00:00+00:00 PythonOperator 2021-04-08T22:10:38.527706+00:00 2021-04-08T22:10:41.355277+00:00 0:00:02.827571 15069 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T22:10:36.166155+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T21:00:00+00:00 TriggerDagRunOperator 2021-04-08T22:10:30.860219+00:00 2021-04-08T22:10:31.383983+00:00 0:00:00.523764 15068 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T22:10:28.169756+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T21:00:00+00:00 TriggerDagRunOperator 2021-04-08T22:10:30.762486+00:00 2021-04-08T22:10:31.178177+00:00 0:00:00.415691 15067 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T22:10:28.169791+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T21:05:00+00:00 EmrJobFlowSensor 2021-04-08T22:05:49.876358+00:00 2021-04-08T22:14:52.490790+00:00 0:09:02.614432 15066 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T22:05:47.696560+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T22:05:30.063133+00:00 2021-04-08T22:05:31.801680+00:00 0:00:01.738547 15065 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T22:05:27.666328+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T21:05:00+00:00 PythonOperator 2021-04-08T22:05:07.769733+00:00 2021-04-08T22:05:10.466130+00:00 0:00:02.696397 15064 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T22:05:05.607052+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T21:00:00+00:00 EmrJobFlowSensor 2021-04-08T22:01:05.439674+00:00 2021-04-08T22:10:08.238098+00:00 0:09:02.798424 15063 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T22:01:03.081785+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T22:00:43.329319+00:00 2021-04-08T22:00:45.114754+00:00 0:00:01.785435 15062 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T22:00:41.016586+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T21:00:00+00:00 PythonOperator 2021-04-08T22:00:23.817906+00:00 2021-04-08T22:00:26.638237+00:00 0:00:02.820331 15061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T22:00:21.003863+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T20:00:00+00:00 EmrJobFlowSensor 2021-04-08T21:12:11.809100+00:00 2021-04-08T21:21:14.575017+00:00 0:09:02.765917 15059 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T21:12:09.618641+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T20:00:00+00:00 EmrJobFlowSensor 2021-04-08T21:11:53.758172+00:00 2021-04-08T21:21:56.547697+00:00 0:10:02.789525 15058 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T21:11:51.602254+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T21:11:50.130057+00:00 2021-04-08T21:11:51.971894+00:00 0:00:01.841837 15057 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T21:11:47.599392+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T21:11:32.209190+00:00 2021-04-08T21:11:34.056984+00:00 0:00:01.847794 15056 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T21:11:29.644312+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T20:00:00+00:00 PythonOperator 2021-04-08T21:11:27.915041+00:00 2021-04-08T21:11:30.756546+00:00 0:00:02.841505 15055 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T21:11:25.558857+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T20:00:00+00:00 PythonOperator 2021-04-08T21:11:09.820616+00:00 2021-04-08T21:11:12.764748+00:00 0:00:02.944132 15054 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T21:11:07.523740+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T20:00:00+00:00 TriggerDagRunOperator 2021-04-08T21:11:03.869524+00:00 2021-04-08T21:11:04.413205+00:00 0:00:00.543681 15053 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T21:11:01.510754+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T20:00:00+00:00 TriggerDagRunOperator 2021-04-08T21:11:03.691553+00:00 2021-04-08T21:11:04.155429+00:00 0:00:00.463876 15052 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T21:11:01.510717+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T20:05:00+00:00 EmrJobFlowSensor 2021-04-08T21:05:57.392051+00:00 2021-04-08T21:14:59.984976+00:00 0:09:02.592925 15051 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T21:05:55.065331+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T21:05:37.203130+00:00 2021-04-08T21:05:38.957735+00:00 0:00:01.754605 15050 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T21:05:34.961483+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T20:05:00+00:00 PythonOperator 2021-04-08T21:05:15.169948+00:00 2021-04-08T21:05:17.942783+00:00 0:00:02.772835 15049 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T21:05:12.940774+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T20:00:00+00:00 EmrJobFlowSensor 2021-04-08T21:00:48.890561+00:00 2021-04-08T21:10:51.829047+00:00 0:10:02.938486 15048 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T21:00:46.510476+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T21:00:26.940330+00:00 2021-04-08T21:00:28.839687+00:00 0:00:01.899357 15047 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T21:00:24.433091+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T20:00:00+00:00 PythonOperator 2021-04-08T21:00:05.146768+00:00 2021-04-08T21:00:08.055582+00:00 0:00:02.908814 15046 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T21:00:02.426179+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T19:00:00+00:00 EmrJobFlowSensor 2021-04-08T20:11:31.992736+00:00 2021-04-08T20:30:36.059756+00:00 0:19:04.067020 15044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T20:11:29.547097+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T19:00:00+00:00 EmrJobFlowSensor 2021-04-08T20:11:15.715759+00:00 2021-04-08T20:20:18.405673+00:00 0:09:02.689914 15043 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T20:11:13.373015+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T20:11:09.699063+00:00 2021-04-08T20:11:11.441396+00:00 0:00:01.742333 15042 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T20:11:07.350260+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T20:10:53.630165+00:00 2021-04-08T20:10:55.526900+00:00 0:00:01.896735 15041 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T20:10:51.277678+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T19:00:00+00:00 PythonOperator 2021-04-08T20:10:47.513356+00:00 2021-04-08T20:10:50.226005+00:00 0:00:02.712649 15040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T20:10:45.273307+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T19:00:00+00:00 PythonOperator 2021-04-08T20:10:33.685766+00:00 2021-04-08T20:10:36.782822+00:00 0:00:03.097056 15039 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T20:10:31.260933+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T19:00:00+00:00 TriggerDagRunOperator 2021-04-08T20:10:23.817782+00:00 2021-04-08T20:10:24.480121+00:00 0:00:00.662339 15038 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T20:10:21.252854+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T19:00:00+00:00 TriggerDagRunOperator 2021-04-08T20:10:23.682369+00:00 2021-04-08T20:10:24.269471+00:00 0:00:00.587102 15037 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T20:10:21.252823+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T19:05:00+00:00 EmrJobFlowSensor 2021-04-08T20:05:54.980248+00:00 2021-04-08T20:14:57.614189+00:00 0:09:02.633941 15036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T20:05:52.766384+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T20:05:34.888056+00:00 2021-04-08T20:05:36.519157+00:00 0:00:01.631101 15035 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T20:05:32.691417+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T19:05:00+00:00 PythonOperator 2021-04-08T20:05:12.992943+00:00 2021-04-08T20:05:15.692890+00:00 0:00:02.699947 15034 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T20:05:10.618467+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T19:00:00+00:00 EmrJobFlowSensor 2021-04-08T20:00:56.302565+00:00 2021-04-08T20:09:59.043447+00:00 0:09:02.740882 15033 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T20:00:54.121402+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T20:00:34.467576+00:00 2021-04-08T20:00:36.370249+00:00 0:00:01.902673 15032 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T20:00:32.083650+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T19:00:00+00:00 PythonOperator 2021-04-08T20:00:12.309512+00:00 2021-04-08T20:00:15.068804+00:00 0:00:02.759292 15031 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T20:00:10.024343+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T18:00:00+00:00 EmrJobFlowSensor 2021-04-08T19:10:12.202465+00:00 2021-04-08T19:19:14.952598+00:00 0:09:02.750133 15029 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T19:10:09.960287+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T18:00:00+00:00 EmrJobFlowSensor 2021-04-08T19:10:04.383144+00:00 2021-04-08T19:19:07.149488+00:00 0:09:02.766344 15028 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T19:10:01.909487+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T19:09:50.295050+00:00 2021-04-08T19:09:51.959922+00:00 0:00:01.664872 15027 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T19:09:47.954136+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T19:09:42.102027+00:00 2021-04-08T19:09:43.935599+00:00 0:00:01.833572 15026 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T19:09:39.893769+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T18:00:00+00:00 PythonOperator 2021-04-08T19:09:30.696845+00:00 2021-04-08T19:09:33.642399+00:00 0:00:02.945554 15025 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T19:09:28.053220+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T18:00:00+00:00 PythonOperator 2021-04-08T19:09:22.049957+00:00 2021-04-08T19:09:24.767069+00:00 0:00:02.717112 15024 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T19:09:19.853457+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T18:00:00+00:00 TriggerDagRunOperator 2021-04-08T19:09:08.409654+00:00 2021-04-08T19:09:08.901200+00:00 0:00:00.491546 15023 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T19:09:05.843306+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T18:00:00+00:00 TriggerDagRunOperator 2021-04-08T19:09:08.120125+00:00 2021-04-08T19:09:08.671897+00:00 0:00:00.551772 15022 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T19:09:05.843338+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T18:05:00+00:00 EmrJobFlowSensor 2021-04-08T19:05:54.160633+00:00 2021-04-08T19:13:56.729680+00:00 0:08:02.569047 15021 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T19:05:51.668012+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T19:05:31.873412+00:00 2021-04-08T19:05:33.594120+00:00 0:00:01.720708 15020 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T19:05:29.587593+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T18:05:00+00:00 PythonOperator 2021-04-08T19:05:09.670072+00:00 2021-04-08T19:05:12.421316+00:00 0:00:02.751244 15019 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T19:05:07.524589+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T18:00:00+00:00 EmrJobFlowSensor 2021-04-08T19:00:55.273406+00:00 2021-04-08T19:08:57.684991+00:00 0:08:02.411585 15018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T19:00:53.102241+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T19:00:35.240886+00:00 2021-04-08T19:00:36.953161+00:00 0:00:01.712275 15017 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T19:00:33.084873+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T18:00:00+00:00 PythonOperator 2021-04-08T19:00:11.710050+00:00 2021-04-08T19:00:14.458367+00:00 0:00:02.748317 15016 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T19:00:09.074647+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T17:00:00+00:00 EmrJobFlowSensor 2021-04-08T18:11:30.611689+00:00 2021-04-08T18:21:33.557566+00:00 0:10:02.945877 15014 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T18:11:28.060474+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T17:00:00+00:00 EmrJobFlowSensor 2021-04-08T18:11:16.210004+00:00 2021-04-08T18:21:19.070637+00:00 0:10:02.860633 15013 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T18:11:13.943973+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T18:11:06.207443+00:00 2021-04-08T18:11:08.066644+00:00 0:00:01.859201 15012 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T18:11:03.906868+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T18:10:52.191829+00:00 2021-04-08T18:10:54.108023+00:00 0:00:01.916194 15011 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T18:10:49.893220+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T17:00:00+00:00 PythonOperator 2021-04-08T18:10:44.289974+00:00 2021-04-08T18:10:47.314179+00:00 0:00:03.024205 15010 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T18:10:41.885575+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T17:00:00+00:00 PythonOperator 2021-04-08T18:10:28.071468+00:00 2021-04-08T18:10:30.826938+00:00 0:00:02.755470 15009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T18:10:25.855615+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T17:00:00+00:00 TriggerDagRunOperator 2021-04-08T18:10:20.340514+00:00 2021-04-08T18:10:20.909886+00:00 0:00:00.569372 15008 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T18:10:17.847625+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T17:00:00+00:00 TriggerDagRunOperator 2021-04-08T18:10:20.197331+00:00 2021-04-08T18:10:20.646413+00:00 0:00:00.449082 15007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T18:10:17.847661+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T17:05:00+00:00 EmrJobFlowSensor 2021-04-08T18:05:59.674594+00:00 2021-04-08T18:15:02.494910+00:00 0:09:02.820316 15006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T18:05:57.460426+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T18:05:37.801110+00:00 2021-04-08T18:05:39.649060+00:00 0:00:01.847950 15005 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T18:05:35.441963+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T17:05:00+00:00 PythonOperator 2021-04-08T18:05:15.695784+00:00 2021-04-08T18:05:18.358613+00:00 0:00:02.662829 15004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T18:05:13.362933+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T17:00:00+00:00 EmrJobFlowSensor 2021-04-08T18:00:55.158755+00:00 2021-04-08T18:09:57.764573+00:00 0:09:02.605818 15003 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T18:00:52.790752+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T18:00:35.259976+00:00 2021-04-08T18:00:37.144305+00:00 0:00:01.884329 15002 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T18:00:32.770793+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T17:00:00+00:00 PythonOperator 2021-04-08T18:00:13.047039+00:00 2021-04-08T18:00:15.925923+00:00 0:00:02.878884 15001 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T18:00:10.690980+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T16:00:00+00:00 EmrJobFlowSensor 2021-04-08T17:13:52.236158+00:00 2021-04-08T17:21:54.897184+00:00 0:08:02.661026 15000 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T17:13:49.963001+00:00 2 default_pool