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 vc-asset-import_v002 create_emr_steps 2021-03-25T01:05:00+00:00 PythonOperator 2021-03-25T02:05:06.863827+00:00 2021-03-25T02:05:09.565183+00:00 0:00:02.701356 11444 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T02:05:04.684718+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T01:00:00+00:00 EmrJobFlowSensor 2021-03-25T02:00:48.344804+00:00 2021-03-25T02:09:50.950398+00:00 0:09:02.605594 11443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T02:00:46.195329+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T02:00:24.349423+00:00 2021-03-25T02:00:26.073633+00:00 0:00:01.724210 11442 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T02:00:22.134720+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T01:00:00+00:00 PythonOperator 2021-03-25T02:00:04.604306+00:00 2021-03-25T02:00:07.316375+00:00 0:00:02.712069 11441 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T02:00:02.117430+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-25T00:00:00+00:00 EmrJobFlowSensor 2021-03-25T01:12:15.501029+00:00 2021-03-25T01:21:18.131476+00:00 0:09:02.630447 11439 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T01:12:13.093505+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-25T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T01:11:55.227345+00:00 2021-03-25T01:11:57.036456+00:00 0:00:01.809111 11438 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T01:11:53.001277+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-25T00:00:00+00:00 PythonOperator 2021-03-25T01:11:33.318774+00:00 2021-03-25T01:11:36.182283+00:00 0:00:02.863509 11437 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T01:11:31.055688+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T00:00:00+00:00 EmrJobFlowSensor 2021-03-25T01:11:21.121271+00:00 2021-03-25T01:21:23.828533+00:00 0:10:02.707262 11436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T01:11:18.930085+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T01:10:59.139003+00:00 2021-03-25T01:11:00.850074+00:00 0:00:01.711071 11435 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T01:10:56.909406+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T00:00:00+00:00 PythonOperator 2021-03-25T01:10:35.282597+00:00 2021-03-25T01:10:38.246150+00:00 0:00:02.963553 11434 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T01:10:32.895754+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T00:00:00+00:00 TriggerDagRunOperator 2021-03-25T01:10:15.386982+00:00 2021-03-25T01:10:15.816539+00:00 0:00:00.429557 11433 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T01:10:12.858935+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T00:00:00+00:00 TriggerDagRunOperator 2021-03-25T01:10:15.196956+00:00 2021-03-25T01:10:15.737481+00:00 0:00:00.540525 11432 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T01:10:12.858889+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T00:05:00+00:00 EmrJobFlowSensor 2021-03-25T01:05:52.723180+00:00 2021-03-25T01:13:55.158989+00:00 0:08:02.435809 11431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T01:05:50.351855+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T00:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T01:05:30.873381+00:00 2021-03-25T01:05:32.500186+00:00 0:00:01.626805 11430 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T01:05:28.448862+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T00:05:00+00:00 PythonOperator 2021-03-25T01:05:10.433457+00:00 2021-03-25T01:05:13.121448+00:00 0:00:02.687991 11429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T01:05:08.259957+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T00:00:00+00:00 EmrJobFlowSensor 2021-03-25T01:00:56.070907+00:00 2021-03-25T01:09:58.659716+00:00 0:09:02.588809 11428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T01:00:53.864703+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T01:00:34.303996+00:00 2021-03-25T01:00:36.162970+00:00 0:00:01.858974 11427 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T01:00:31.843131+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T00:00:00+00:00 PythonOperator 2021-03-25T01:00:12.163893+00:00 2021-03-25T01:00:14.988834+00:00 0:00:02.824941 11426 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T01:00:09.795295+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T23:00:00+00:00 EmrJobFlowSensor 2021-03-25T00:12:30.855116+00:00 2021-03-25T00:22:33.650803+00:00 0:10:02.795687 11424 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T00:12:28.058800+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T23:00:00+00:00 EmrJobFlowSensor 2021-03-25T00:12:30.697080+00:00 2021-03-25T00:21:33.241177+00:00 0:09:02.544097 11423 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T00:12:28.058753+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T00:12:10.491485+00:00 2021-03-25T00:12:12.274540+00:00 0:00:01.783055 11422 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T00:12:07.962179+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T00:12:10.408849+00:00 2021-03-25T00:12:12.343325+00:00 0:00:01.934476 11421 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T00:12:07.962150+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T23:00:00+00:00 PythonOperator 2021-03-25T00:11:48.146743+00:00 2021-03-25T00:11:50.945560+00:00 0:00:02.798817 11420 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T00:11:45.839605+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T23:00:00+00:00 PythonOperator 2021-03-25T00:11:48.117577+00:00 2021-03-25T00:11:51.276165+00:00 0:00:03.158588 11419 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T00:11:45.839567+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T23:00:00+00:00 TriggerDagRunOperator 2021-03-25T00:11:26.111795+00:00 2021-03-25T00:11:26.699599+00:00 0:00:00.587804 11418 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T00:11:23.824104+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T23:00:00+00:00 TriggerDagRunOperator 2021-03-25T00:11:26.085015+00:00 2021-03-25T00:11:26.486247+00:00 0:00:00.401232 11417 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T00:11:23.824071+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T23:05:00+00:00 EmrJobFlowSensor 2021-03-25T00:06:03.617646+00:00 2021-03-25T00:14:06.117881+00:00 0:08:02.500235 11416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T00:06:01.482263+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T23:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T00:05:39.746090+00:00 2021-03-25T00:05:41.474922+00:00 0:00:01.728832 11415 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T00:05:37.543875+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T23:05:00+00:00 PythonOperator 2021-03-25T00:05:19.854542+00:00 2021-03-25T00:05:22.741240+00:00 0:00:02.886698 11414 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T00:05:17.463502+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T23:00:00+00:00 EmrJobFlowSensor 2021-03-25T00:01:03.408089+00:00 2021-03-25T00:11:06.208254+00:00 0:10:02.800165 11413 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T00:01:01.052387+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T00:00:43.118697+00:00 2021-03-25T00:00:44.774613+00:00 0:00:01.655916 11412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T00:00:40.923651+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T23:00:00+00:00 PythonOperator 2021-03-25T00:00:09.279598+00:00 2021-03-25T00:00:11.998759+00:00 0:00:02.719161 11411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T00:00:06.889307+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T22:00:00+00:00 EmrJobFlowSensor 2021-03-24T23:11:30.751398+00:00 2021-03-24T23:20:33.438151+00:00 0:09:02.686753 11409 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T23:11:28.173765+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T22:00:00+00:00 EmrJobFlowSensor 2021-03-24T23:11:12.280168+00:00 2021-03-24T23:21:15.069979+00:00 0:10:02.789811 11408 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T23:11:10.080088+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T23:11:10.312247+00:00 2021-03-24T23:11:12.135179+00:00 0:00:01.822932 11407 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T23:11:08.089851+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T23:10:48.596415+00:00 2021-03-24T23:10:50.313067+00:00 0:00:01.716652 11406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T23:10:46.005290+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T22:00:00+00:00 PythonOperator 2021-03-24T23:10:36.236618+00:00 2021-03-24T23:10:38.936466+00:00 0:00:02.699848 11405 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T23:10:33.997973+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T22:00:00+00:00 PythonOperator 2021-03-24T23:10:26.498789+00:00 2021-03-24T23:10:29.521766+00:00 0:00:03.022977 11404 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T23:10:23.995107+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T22:00:00+00:00 TriggerDagRunOperator 2021-03-24T23:10:14.285220+00:00 2021-03-24T23:10:14.689804+00:00 0:00:00.404584 11403 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T23:10:11.932336+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T22:00:00+00:00 TriggerDagRunOperator 2021-03-24T23:10:14.229113+00:00 2021-03-24T23:10:14.750653+00:00 0:00:00.521540 11402 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T23:10:11.932367+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T22:05:00+00:00 EmrJobFlowSensor 2021-03-24T23:05:50.055624+00:00 2021-03-24T23:14:52.649937+00:00 0:09:02.594313 11401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T23:05:47.668734+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T22:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T23:05:28.009862+00:00 2021-03-24T23:05:29.744375+00:00 0:00:01.734513 11400 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T23:05:25.665912+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T22:05:00+00:00 PythonOperator 2021-03-24T23:05:07.698408+00:00 2021-03-24T23:05:10.391635+00:00 0:00:02.693227 11399 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T23:05:05.527436+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T22:00:00+00:00 EmrJobFlowSensor 2021-03-24T23:00:49.314693+00:00 2021-03-24T23:09:51.978819+00:00 0:09:02.664126 11398 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T23:00:47.096737+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T23:00:27.206150+00:00 2021-03-24T23:00:28.886354+00:00 0:00:01.680204 11397 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T23:00:25.006650+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T22:00:00+00:00 PythonOperator 2021-03-24T23:00:05.505921+00:00 2021-03-24T23:00:08.254712+00:00 0:00:02.748791 11396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T23:00:03.060261+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T21:00:00+00:00 EmrJobFlowSensor 2021-03-24T22:11:26.687654+00:00 2021-03-24T22:20:29.303651+00:00 0:09:02.615997 11394 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T22:11:24.414850+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T21:00:00+00:00 EmrJobFlowSensor 2021-03-24T22:11:24.716492+00:00 2021-03-24T22:21:27.488215+00:00 0:10:02.771723 11393 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T22:11:22.432665+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T22:11:05.166582+00:00 2021-03-24T22:11:06.869358+00:00 0:00:01.702776 11392 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T22:11:02.387852+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T22:11:02.808085+00:00 2021-03-24T22:11:04.793613+00:00 0:00:01.985528 11391 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T22:11:00.395610+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T21:00:00+00:00 PythonOperator 2021-03-24T22:10:42.543632+00:00 2021-03-24T22:10:45.640719+00:00 0:00:03.097087 11390 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T22:10:40.314093+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T21:00:00+00:00 PythonOperator 2021-03-24T22:10:40.634643+00:00 2021-03-24T22:10:43.324239+00:00 0:00:02.689596 11389 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T22:10:38.376898+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T21:00:00+00:00 TriggerDagRunOperator 2021-03-24T22:10:20.886636+00:00 2021-03-24T22:10:21.296548+00:00 0:00:00.409912 11388 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T22:10:18.368051+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T21:00:00+00:00 TriggerDagRunOperator 2021-03-24T22:10:20.816356+00:00 2021-03-24T22:10:21.324718+00:00 0:00:00.508362 11387 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T22:10:18.368099+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T21:05:00+00:00 EmrJobFlowSensor 2021-03-24T22:06:06.433242+00:00 2021-03-24T22:14:08.866977+00:00 0:08:02.433735 11386 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T22:06:04.068948+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T21:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T22:05:44.090495+00:00 2021-03-24T22:05:45.796907+00:00 0:00:01.706412 11385 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T22:05:41.944219+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T21:05:00+00:00 PythonOperator 2021-03-24T22:05:24.245831+00:00 2021-03-24T22:05:26.966902+00:00 0:00:02.721071 11384 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T22:05:21.926334+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T21:00:00+00:00 EmrJobFlowSensor 2021-03-24T22:01:09.950075+00:00 2021-03-24T22:10:12.577972+00:00 0:09:02.627897 11383 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T22:01:07.551704+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T22:00:41.636671+00:00 2021-03-24T22:00:43.418542+00:00 0:00:01.781871 11382 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T22:00:39.416729+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T21:00:00+00:00 PythonOperator 2021-03-24T22:00:13.708923+00:00 2021-03-24T22:00:16.562397+00:00 0:00:02.853474 11381 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T22:00:11.395655+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T20:00:00+00:00 EmrJobFlowSensor 2021-03-24T21:11:21.029553+00:00 2021-03-24T21:20:23.665819+00:00 0:09:02.636266 11379 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T21:11:18.759524+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T20:00:00+00:00 EmrJobFlowSensor 2021-03-24T21:11:04.894776+00:00 2021-03-24T21:20:07.483143+00:00 0:09:02.588367 11378 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T21:11:02.687561+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T21:10:58.804262+00:00 2021-03-24T21:11:00.551221+00:00 0:00:01.746959 11377 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T21:10:56.635790+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T21:10:42.884571+00:00 2021-03-24T21:10:44.564535+00:00 0:00:01.679964 11376 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T21:10:40.615125+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T20:00:00+00:00 PythonOperator 2021-03-24T21:10:38.793504+00:00 2021-03-24T21:10:41.605799+00:00 0:00:02.812295 11375 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T21:10:36.622123+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T20:00:00+00:00 PythonOperator 2021-03-24T21:10:20.968537+00:00 2021-03-24T21:10:24.033024+00:00 0:00:03.064487 11374 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T21:10:18.666100+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T20:00:00+00:00 TriggerDagRunOperator 2021-03-24T21:10:12.850967+00:00 2021-03-24T21:10:13.363481+00:00 0:00:00.512514 11373 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T21:10:10.592498+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T20:00:00+00:00 TriggerDagRunOperator 2021-03-24T21:10:12.820437+00:00 2021-03-24T21:10:13.221884+00:00 0:00:00.401447 11372 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T21:10:10.592531+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T20:05:00+00:00 EmrJobFlowSensor 2021-03-24T21:05:48.320057+00:00 2021-03-24T21:14:50.861873+00:00 0:09:02.541816 11371 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T21:05:46.192761+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T20:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T21:05:28.443710+00:00 2021-03-24T21:05:30.168419+00:00 0:00:01.724709 11370 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T21:05:26.111070+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T20:05:00+00:00 PythonOperator 2021-03-24T21:05:06.282920+00:00 2021-03-24T21:05:09.038265+00:00 0:00:02.755345 11369 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T21:05:04.089206+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T20:00:00+00:00 EmrJobFlowSensor 2021-03-24T21:00:56.090302+00:00 2021-03-24T21:09:58.728606+00:00 0:09:02.638304 11368 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T21:00:53.706300+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T21:00:34.369206+00:00 2021-03-24T21:00:36.052449+00:00 0:00:01.683243 11367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T21:00:31.764783+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T20:00:00+00:00 PythonOperator 2021-03-24T21:00:11.900216+00:00 2021-03-24T21:00:14.619891+00:00 0:00:02.719675 11366 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T21:00:09.645173+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T19:00:00+00:00 EmrJobFlowSensor 2021-03-24T20:10:27.728699+00:00 2021-03-24T20:19:30.391717+00:00 0:09:02.663018 11364 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T20:10:25.070122+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T19:00:00+00:00 EmrJobFlowSensor 2021-03-24T20:10:27.641782+00:00 2021-03-24T20:19:30.276421+00:00 0:09:02.634639 11363 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T20:10:25.070157+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T20:10:05.297095+00:00 2021-03-24T20:10:07.023108+00:00 0:00:01.726013 11362 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T20:10:02.986307+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T20:10:05.217823+00:00 2021-03-24T20:10:07.066974+00:00 0:00:01.849151 11361 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T20:10:02.986272+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T19:00:00+00:00 PythonOperator 2021-03-24T20:09:43.213564+00:00 2021-03-24T20:09:46.256262+00:00 0:00:03.042698 11360 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T20:09:40.929845+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T19:00:00+00:00 PythonOperator 2021-03-24T20:09:43.163774+00:00 2021-03-24T20:09:45.905681+00:00 0:00:02.741907 11359 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T20:09:40.929807+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T19:00:00+00:00 TriggerDagRunOperator 2021-03-24T20:09:19.203662+00:00 2021-03-24T20:09:19.726226+00:00 0:00:00.522564 11358 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T20:09:16.909803+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T19:00:00+00:00 TriggerDagRunOperator 2021-03-24T20:09:19.139162+00:00 2021-03-24T20:09:19.557599+00:00 0:00:00.418437 11357 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T20:09:16.909840+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T19:05:00+00:00 EmrJobFlowSensor 2021-03-24T20:05:55.113838+00:00 2021-03-24T20:13:57.708139+00:00 0:08:02.594301 11356 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T20:05:52.671506+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T19:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T20:05:28.778408+00:00 2021-03-24T20:05:30.429760+00:00 0:00:01.651352 11355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T20:05:26.587453+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T19:05:00+00:00 PythonOperator 2021-03-24T20:05:06.692618+00:00 2021-03-24T20:05:09.381727+00:00 0:00:02.689109 11354 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T20:05:04.558317+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T19:00:00+00:00 EmrJobFlowSensor 2021-03-24T20:00:58.392753+00:00 2021-03-24T20:09:01.001740+00:00 0:08:02.608987 11353 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T20:00:56.158338+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-24T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T20:00:38.445623+00:00 2021-03-24T20:00:40.279510+00:00 0:00:01.833887 11352 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-24T20:00:36.140174+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-24T19:00:00+00:00 PythonOperator 2021-03-24T20:00:16.545493+00:00 2021-03-24T20:00:19.341155+00:00 0:00:02.795662 11351 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-24T20:00:14.124817+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T18:00:00+00:00 EmrJobFlowSensor 2021-03-24T19:11:21.399278+00:00 2021-03-24T19:21:24.164645+00:00 0:10:02.765367 11349 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T19:11:19.245434+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T18:00:00+00:00 EmrJobFlowSensor 2021-03-24T19:11:17.531186+00:00 2021-03-24T19:20:20.269879+00:00 0:09:02.738693 11348 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T19:11:15.241986+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T19:10:57.470358+00:00 2021-03-24T19:10:59.181872+00:00 0:00:01.711514 11347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T19:10:55.221722+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-24T19:10:49.404570+00:00 2021-03-24T19:10:51.174000+00:00 0:00:01.769430 11346 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T19:10:47.216818+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T18:00:00+00:00 PythonOperator 2021-03-24T19:10:29.657462+00:00 2021-03-24T19:10:32.580814+00:00 0:00:02.923352 11345 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T19:10:27.258556+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T18:00:00+00:00 PythonOperator 2021-03-24T19:10:27.393129+00:00 2021-03-24T19:10:30.265278+00:00 0:00:02.872149 11344 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T19:10:25.199184+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T18:00:00+00:00 TriggerDagRunOperator 2021-03-24T19:10:09.606514+00:00 2021-03-24T19:10:10.073493+00:00 0:00:00.466979 11343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T19:10:07.184639+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T18:00:00+00:00 TriggerDagRunOperator 2021-03-24T19:10:09.390987+00:00 2021-03-24T19:10:09.891460+00:00 0:00:00.500473 11342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T19:10:07.184602+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T18:05:00+00:00 EmrJobFlowSensor 2021-03-24T19:05:46.798461+00:00 2021-03-24T19:14:49.413358+00:00 0:09:02.614897 11341 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-24T19:05:44.651743+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-24T18:05:00+00:00 EmrCreateJobFlowOperator 2021-03-24T19:05:24.815323+00:00 2021-03-24T19:05:26.546524+00:00 0:00:01.731201 11340 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-24T19:05:22.630012+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-24T18:05:00+00:00 PythonOperator 2021-03-24T19:05:04.871504+00:00 2021-03-24T19:05:07.550217+00:00 0:00:02.678713 11339 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T19:05:02.614946+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-24T18:00:00+00:00 EmrJobFlowSensor 2021-03-24T19:00:54.623133+00:00 2021-03-24T19:09:57.273827+00:00 0:09:02.650694 11338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-24T19:00:52.213049+00:00 2 default_pool