Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T02:00:00+00:00 TriggerDagRunOperator 2021-04-04T03:10:18.752011+00:00 2021-04-04T03:10:19.145163+00:00 0:00:00.393152 13341 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T03:10:16.389301+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T02:05:00+00:00 EmrJobFlowSensor 2021-04-04T03:05:48.275819+00:00 2021-04-04T03:14:50.870977+00:00 0:09:02.595158 13340 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T03:05:45.753283+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T03:05:25.965883+00:00 2021-04-04T03:05:27.713359+00:00 0:00:01.747476 13339 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T03:05:23.760436+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T02:05:00+00:00 PythonOperator 2021-04-04T03:05:06.071379+00:00 2021-04-04T03:05:08.852737+00:00 0:00:02.781358 13338 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T03:05:03.648540+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T02:00:00+00:00 EmrJobFlowSensor 2021-04-04T03:01:03.812856+00:00 2021-04-04T03:10:06.654895+00:00 0:09:02.842039 13337 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T03:01:01.185782+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T03:00:41.212827+00:00 2021-04-04T03:00:42.899247+00:00 0:00:01.686420 13336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T03:00:39.083173+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T02:00:00+00:00 PythonOperator 2021-04-04T03:00:21.352793+00:00 2021-04-04T03:00:24.107913+00:00 0:00:02.755120 13335 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T03:00:19.064324+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T01:00:00+00:00 EmrJobFlowSensor 2021-04-04T02:12:07.461412+00:00 2021-04-04T02:21:10.101225+00:00 0:09:02.639813 13333 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T02:12:05.191700+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T01:00:00+00:00 EmrJobFlowSensor 2021-04-04T02:11:47.690947+00:00 2021-04-04T02:21:50.605077+00:00 0:10:02.914130 13332 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T02:11:45.189616+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T02:11:43.617811+00:00 2021-04-04T02:11:45.317224+00:00 0:00:01.699413 13331 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T02:11:41.177127+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T02:11:27.913932+00:00 2021-04-04T02:11:29.608619+00:00 0:00:01.694687 13330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T02:11:25.171129+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T01:00:00+00:00 PythonOperator 2021-04-04T02:11:23.314774+00:00 2021-04-04T02:11:26.707246+00:00 0:00:03.392472 13329 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T02:11:21.100804+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T01:00:00+00:00 PythonOperator 2021-04-04T02:11:05.417255+00:00 2021-04-04T02:11:08.294881+00:00 0:00:02.877626 13328 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T02:11:03.090201+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T01:00:00+00:00 TriggerDagRunOperator 2021-04-04T02:11:00.035903+00:00 2021-04-04T02:11:00.569718+00:00 0:00:00.533815 13327 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T02:10:57.101454+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T01:00:00+00:00 TriggerDagRunOperator 2021-04-04T02:10:59.386851+00:00 2021-04-04T02:10:59.776462+00:00 0:00:00.389611 13326 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T02:10:57.101489+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T01:05:00+00:00 EmrJobFlowSensor 2021-04-04T02:06:04.660232+00:00 2021-04-04T02:14:07.142520+00:00 0:08:02.482288 13325 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T02:06:02.500235+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T02:05:42.847669+00:00 2021-04-04T02:05:44.591052+00:00 0:00:01.743383 13324 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T02:05:40.475980+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T01:05:00+00:00 PythonOperator 2021-04-04T02:05:12.597564+00:00 2021-04-04T02:05:15.272964+00:00 0:00:02.675400 13323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T02:05:10.440025+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T01:00:00+00:00 EmrJobFlowSensor 2021-04-04T02:00:50.663076+00:00 2021-04-04T02:10:53.588493+00:00 0:10:02.925417 13322 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T02:00:48.157711+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T02:00:28.288037+00:00 2021-04-04T02:00:30.013492+00:00 0:00:01.725455 13321 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T02:00:26.061341+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T01:00:00+00:00 PythonOperator 2021-04-04T02:00:08.429844+00:00 2021-04-04T02:00:11.224463+00:00 0:00:02.794619 13320 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T02:00:06.044387+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T00:00:00+00:00 EmrJobFlowSensor 2021-04-04T01:12:41.746374+00:00 2021-04-04T01:21:44.474093+00:00 0:09:02.727719 13318 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T01:12:39.348708+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T00:00:00+00:00 EmrJobFlowSensor 2021-04-04T01:12:39.736538+00:00 2021-04-04T01:24:42.738101+00:00 0:12:03.001563 13317 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T01:12:37.352672+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T01:12:21.421373+00:00 2021-04-04T01:12:23.140912+00:00 0:00:01.719539 13316 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T01:12:19.254480+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T01:12:17.429126+00:00 2021-04-04T01:12:19.178378+00:00 0:00:01.749252 13315 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T01:12:15.250573+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T00:00:00+00:00 PythonOperator 2021-04-04T01:11:59.874135+00:00 2021-04-04T01:12:02.598629+00:00 0:00:02.724494 13314 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T01:11:57.233494+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T00:00:00+00:00 PythonOperator 2021-04-04T01:11:57.565405+00:00 2021-04-04T01:12:00.820841+00:00 0:00:03.255436 13313 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T01:11:55.232404+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T00:00:00+00:00 TriggerDagRunOperator 2021-04-04T01:11:37.866582+00:00 2021-04-04T01:11:38.474602+00:00 0:00:00.608020 13312 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T01:11:35.278439+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T00:00:00+00:00 TriggerDagRunOperator 2021-04-04T01:11:37.689484+00:00 2021-04-04T01:11:38.092538+00:00 0:00:00.403054 13311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T01:11:35.278390+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T00:05:00+00:00 EmrJobFlowSensor 2021-04-04T01:05:52.882816+00:00 2021-04-04T01:14:55.287903+00:00 0:09:02.405087 13310 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T01:05:50.603975+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T01:05:31.215164+00:00 2021-04-04T01:05:32.944289+00:00 0:00:01.729125 13309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T01:05:28.463849+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T00:05:00+00:00 PythonOperator 2021-04-04T01:05:10.630151+00:00 2021-04-04T01:05:13.282572+00:00 0:00:02.652421 13308 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T01:05:08.307739+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T00:00:00+00:00 EmrJobFlowSensor 2021-04-04T01:01:10.214990+00:00 2021-04-04T01:11:13.112473+00:00 0:10:02.897483 13307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T01:01:07.843602+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T01:00:48.150022+00:00 2021-04-04T01:00:49.834454+00:00 0:00:01.684432 13306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T01:00:45.821714+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T00:00:00+00:00 PythonOperator 2021-04-04T01:00:16.078641+00:00 2021-04-04T01:00:18.786758+00:00 0:00:02.708117 13305 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T01:00:13.794797+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T23:00:00+00:00 EmrJobFlowSensor 2021-04-04T00:12:22.427886+00:00 2021-04-04T00:22:25.226022+00:00 0:10:02.798136 13303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T00:12:20.300849+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T23:00:00+00:00 EmrJobFlowSensor 2021-04-04T00:12:02.559811+00:00 2021-04-04T00:20:05.188278+00:00 0:08:02.628467 13302 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T00:12:00.283092+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T00:12:00.687681+00:00 2021-04-04T00:12:02.492047+00:00 0:00:01.804366 13301 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T00:11:58.354479+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T00:11:38.682278+00:00 2021-04-04T00:11:40.393922+00:00 0:00:01.711644 13300 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T00:11:36.255581+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T23:00:00+00:00 PythonOperator 2021-04-04T00:11:32.554889+00:00 2021-04-04T00:11:35.514770+00:00 0:00:02.959881 13299 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T00:11:30.257451+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T23:00:00+00:00 PythonOperator 2021-04-04T00:11:16.510480+00:00 2021-04-04T00:11:19.349691+00:00 0:00:02.839211 13298 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T00:11:14.235384+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T23:00:00+00:00 TriggerDagRunOperator 2021-04-04T00:11:08.587733+00:00 2021-04-04T00:11:09.147866+00:00 0:00:00.560133 13297 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T00:11:06.231875+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T23:00:00+00:00 TriggerDagRunOperator 2021-04-04T00:11:08.552405+00:00 2021-04-04T00:11:09.007849+00:00 0:00:00.455444 13296 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T00:11:06.231841+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T23:05:00+00:00 EmrJobFlowSensor 2021-04-04T00:05:56.073074+00:00 2021-04-04T00:14:58.609729+00:00 0:09:02.536655 13295 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T00:05:53.846237+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T00:05:36.041697+00:00 2021-04-04T00:05:37.680845+00:00 0:00:01.639148 13294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T00:05:33.833861+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T23:05:00+00:00 PythonOperator 2021-04-04T00:05:12.185038+00:00 2021-04-04T00:05:14.995832+00:00 0:00:02.810794 13293 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T00:05:09.864175+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T23:00:00+00:00 EmrJobFlowSensor 2021-04-04T00:00:51.666535+00:00 2021-04-04T00:10:54.650394+00:00 0:10:02.983859 13292 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T00:00:49.325077+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T00:00:32.023269+00:00 2021-04-04T00:00:33.738175+00:00 0:00:01.714906 13291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T00:00:29.468143+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T23:00:00+00:00 PythonOperator 2021-04-04T00:00:09.646081+00:00 2021-04-04T00:00:12.474727+00:00 0:00:02.828646 13290 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T00:00:07.290141+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T22:00:00+00:00 EmrJobFlowSensor 2021-04-03T23:24:13.231780+00:00 2021-04-03T23:24:14.721450+00:00 0:00:01.489670 13288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T23:24:10.876204+00:00 3 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T22:00:00+00:00 EmrJobFlowSensor 2021-04-03T23:24:07.099662+00:00 2021-04-03T23:24:08.590069+00:00 0:00:01.490407 13287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T23:24:04.870930+00:00 3 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T23:11:01.744987+00:00 2021-04-03T23:11:03.656666+00:00 0:00:01.911679 13284 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T23:10:59.433276+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T23:10:55.761759+00:00 2021-04-03T23:10:57.562924+00:00 0:00:01.801165 13283 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T23:10:53.426177+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T22:00:00+00:00 PythonOperator 2021-04-03T23:10:38.249167+00:00 2021-04-03T23:10:41.151849+00:00 0:00:02.902682 13282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T23:10:35.404644+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T22:00:00+00:00 PythonOperator 2021-04-03T23:10:33.605543+00:00 2021-04-03T23:10:37.199766+00:00 0:00:03.594223 13281 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T23:10:31.401886+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T22:00:00+00:00 TriggerDagRunOperator 2021-04-03T23:10:27.680621+00:00 2021-04-03T23:10:28.215389+00:00 0:00:00.534768 13280 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T23:10:25.396543+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T22:00:00+00:00 TriggerDagRunOperator 2021-04-03T23:10:27.645688+00:00 2021-04-03T23:10:28.064570+00:00 0:00:00.418882 13279 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T23:10:25.396578+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T22:05:00+00:00 EmrJobFlowSensor 2021-04-03T23:06:01.156610+00:00 2021-04-03T23:15:03.749483+00:00 0:09:02.592873 13278 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T23:05:58.944865+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T23:05:39.186895+00:00 2021-04-03T23:05:40.841245+00:00 0:00:01.654350 13277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T23:05:36.855554+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T22:05:00+00:00 PythonOperator 2021-04-03T23:05:16.865800+00:00 2021-04-03T23:05:19.530460+00:00 0:00:02.664660 13276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T23:05:14.728703+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T22:00:00+00:00 EmrJobFlowSensor 2021-04-03T23:01:02.855353+00:00 2021-04-03T23:10:05.564487+00:00 0:09:02.709134 13275 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T23:01:00.455921+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T23:00:40.605344+00:00 2021-04-03T23:00:42.302893+00:00 0:00:01.697549 13274 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T23:00:38.344625+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T22:00:00+00:00 PythonOperator 2021-04-03T23:00:19.205981+00:00 2021-04-03T23:00:22.039622+00:00 0:00:02.833641 13273 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T23:00:16.372674+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T21:00:00+00:00 EmrJobFlowSensor 2021-04-03T22:11:12.888940+00:00 2021-04-03T22:20:15.567145+00:00 0:09:02.678205 13271 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T22:11:10.604671+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T21:00:00+00:00 EmrJobFlowSensor 2021-04-03T22:10:57.511601+00:00 2021-04-03T22:20:00.148006+00:00 0:09:02.636405 13270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T22:10:54.662509+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T22:10:50.744861+00:00 2021-04-03T22:10:52.441310+00:00 0:00:01.696449 13269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T22:10:48.588376+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T22:10:34.933003+00:00 2021-04-03T22:10:36.622177+00:00 0:00:01.689174 13268 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T22:10:32.572708+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T21:00:00+00:00 PythonOperator 2021-04-03T22:10:28.783265+00:00 2021-04-03T22:10:31.667355+00:00 0:00:02.884090 13267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T22:10:26.512632+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T21:00:00+00:00 PythonOperator 2021-04-03T22:10:12.948713+00:00 2021-04-03T22:10:15.812756+00:00 0:00:02.864043 13266 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T22:10:10.497160+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T21:00:00+00:00 TriggerDagRunOperator 2021-04-03T22:10:06.911508+00:00 2021-04-03T22:10:07.429894+00:00 0:00:00.518386 13265 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T22:10:04.501280+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T21:00:00+00:00 TriggerDagRunOperator 2021-04-03T22:10:06.764652+00:00 2021-04-03T22:10:07.170392+00:00 0:00:00.405740 13264 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T22:10:04.501234+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T21:05:00+00:00 EmrJobFlowSensor 2021-04-03T22:05:46.368975+00:00 2021-04-03T22:14:49.113854+00:00 0:09:02.744879 13263 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T22:05:44.115900+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T22:05:26.621796+00:00 2021-04-03T22:05:28.324384+00:00 0:00:01.702588 13262 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T22:05:24.162802+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T21:05:00+00:00 PythonOperator 2021-04-03T22:05:04.274346+00:00 2021-04-03T22:05:06.995178+00:00 0:00:02.720832 13261 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T22:05:02.042187+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T21:00:00+00:00 EmrJobFlowSensor 2021-04-03T22:00:49.825943+00:00 2021-04-03T22:09:52.586429+00:00 0:09:02.760486 13260 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T22:00:47.656276+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T22:00:28.097205+00:00 2021-04-03T22:00:29.938067+00:00 0:00:01.840862 13259 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T22:00:25.637854+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T21:00:00+00:00 PythonOperator 2021-04-03T22:00:08.349493+00:00 2021-04-03T22:00:11.106201+00:00 0:00:02.756708 13258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T22:00:05.621360+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T20:00:00+00:00 EmrJobFlowSensor 2021-04-03T21:21:26.076316+00:00 2021-04-03T21:31:28.954656+00:00 0:10:02.878340 13256 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T21:21:23.827025+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T20:00:00+00:00 EmrJobFlowSensor 2021-04-03T21:21:22.062817+00:00 2021-04-03T21:31:25.048731+00:00 0:10:02.985914 13255 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T21:21:19.822906+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T21:21:04.034842+00:00 2021-04-03T21:21:05.747460+00:00 0:00:01.712618 13254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T21:21:01.809523+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T21:21:00.419978+00:00 2021-04-03T21:21:02.177448+00:00 0:00:01.757470 13253 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T21:20:57.870944+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T20:00:00+00:00 PythonOperator 2021-04-03T21:20:42.420815+00:00 2021-04-03T21:20:45.212663+00:00 0:00:02.791848 13252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T21:20:39.847573+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T20:00:00+00:00 PythonOperator 2021-04-03T21:20:38.039753+00:00 2021-04-03T21:20:41.293287+00:00 0:00:03.253534 13251 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T21:20:35.790101+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T20:00:00+00:00 TriggerDagRunOperator 2021-04-03T21:20:18.290719+00:00 2021-04-03T21:20:18.806878+00:00 0:00:00.516159 13250 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T21:20:15.735328+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T20:00:00+00:00 TriggerDagRunOperator 2021-04-03T21:20:17.903870+00:00 2021-04-03T21:20:18.306565+00:00 0:00:00.402695 13249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T21:20:15.735363+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T20:05:00+00:00 EmrJobFlowSensor 2021-04-03T21:06:02.727197+00:00 2021-04-03T21:15:05.347290+00:00 0:09:02.620093 13248 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T21:06:00.291064+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-03T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-03T21:05:42.546410+00:00 2021-04-03T21:05:44.287584+00:00 0:00:01.741174 13247 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T21:05:40.255485+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-03T20:05:00+00:00 PythonOperator 2021-04-03T21:05:20.275455+00:00 2021-04-03T21:05:22.973019+00:00 0:00:02.697564 13246 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T21:05:18.129358+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-03T20:00:00+00:00 EmrJobFlowSensor 2021-04-03T21:01:00.290843+00:00 2021-04-03T21:20:04.403914+00:00 0:19:04.113071 13245 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T21:00:57.810605+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-03T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T21:00:38.016905+00:00 2021-04-03T21:00:39.700219+00:00 0:00:01.683314 13244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-03T21:00:35.788474+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-03T20:00:00+00:00 PythonOperator 2021-04-03T21:00:16.348911+00:00 2021-04-03T21:00:19.233348+00:00 0:00:02.884437 13243 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-03T21:00:13.765567+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-03T19:00:00+00:00 EmrJobFlowSensor 2021-04-03T20:11:19.051029+00:00 2021-04-03T20:21:21.830916+00:00 0:10:02.779887 13241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T20:11:16.855386+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-03T19:00:00+00:00 EmrJobFlowSensor 2021-04-03T20:11:11.085701+00:00 2021-04-03T20:21:14.019250+00:00 0:10:02.933549 13240 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T20:11:08.841323+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-03T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T20:10:47.081492+00:00 2021-04-03T20:10:48.772298+00:00 0:00:01.690806 13239 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T20:10:44.822028+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-03T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-03T20:10:43.104072+00:00 2021-04-03T20:10:44.766368+00:00 0:00:01.662296 13238 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-03T20:10:40.821463+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-03T19:00:00+00:00 PythonOperator 2021-04-03T20:10:25.320008+00:00 2021-04-03T20:10:28.192047+00:00 0:00:02.872039 13237 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T20:10:22.803313+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-03T19:00:00+00:00 PythonOperator 2021-04-03T20:10:21.271679+00:00 2021-04-03T20:10:24.246219+00:00 0:00:02.974540 13236 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-03T20:10:18.857174+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-03T19:00:00+00:00 TriggerDagRunOperator 2021-04-03T20:10:13.217521+00:00 2021-04-03T20:10:13.735485+00:00 0:00:00.517964 13235 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T20:10:10.793946+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-03T19:00:00+00:00 TriggerDagRunOperator 2021-04-03T20:10:13.001688+00:00 2021-04-03T20:10:13.403277+00:00 0:00:00.401589 13234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T20:10:10.793982+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-03T19:05:00+00:00 EmrJobFlowSensor 2021-04-03T20:06:04.661826+00:00 2021-04-03T20:15:07.141241+00:00 0:09:02.479415 13233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-03T20:06:02.342656+00:00 2 default_pool