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-history-job_v002 create_emr_steps 2021-04-19T02:00:00+00:00 PythonOperator 2021-04-19T03:11:10.713100+00:00 2021-04-19T03:11:14.078920+00:00 0:00:03.365820 18764 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T03:11:08.258344+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T02:00:00+00:00 TriggerDagRunOperator 2021-04-19T03:11:04.857092+00:00 2021-04-19T03:11:05.530592+00:00 0:00:00.673500 18763 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T03:11:02.250797+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T02:00:00+00:00 TriggerDagRunOperator 2021-04-19T03:11:04.436574+00:00 2021-04-19T03:11:05.000214+00:00 0:00:00.563640 18762 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T03:11:02.250765+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T02:05:00+00:00 EmrJobFlowSensor 2021-04-19T03:05:52.053388+00:00 2021-04-19T03:14:54.647296+00:00 0:09:02.593908 18761 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T03:05:49.894041+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T03:05:30.229818+00:00 2021-04-19T03:05:31.883959+00:00 0:00:01.654141 18760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T03:05:27.885228+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T02:05:00+00:00 PythonOperator 2021-04-19T03:05:10.020151+00:00 2021-04-19T03:05:14.110455+00:00 0:00:04.090304 18759 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T03:05:07.832520+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T02:00:00+00:00 EmrJobFlowSensor 2021-04-19T03:00:53.839494+00:00 2021-04-19T03:10:56.668713+00:00 0:10:02.829219 18758 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T03:00:51.367575+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T03:00:33.682843+00:00 2021-04-19T03:00:35.728053+00:00 0:00:02.045210 18757 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T03:00:31.288675+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T02:00:00+00:00 PythonOperator 2021-04-19T03:00:11.530623+00:00 2021-04-19T03:00:14.500233+00:00 0:00:02.969610 18756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T03:00:09.248075+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T01:00:00+00:00 EmrJobFlowSensor 2021-04-19T02:12:35.313768+00:00 2021-04-19T02:21:38.020482+00:00 0:09:02.706714 18754 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T02:12:32.773119+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T01:00:00+00:00 EmrJobFlowSensor 2021-04-19T02:12:29.066685+00:00 2021-04-19T02:24:32.027889+00:00 0:12:02.961204 18753 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T02:12:26.611519+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T02:12:12.705702+00:00 2021-04-19T02:12:14.431347+00:00 0:00:01.725645 18752 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T02:12:10.583798+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T02:12:09.282651+00:00 2021-04-19T02:12:11.094587+00:00 0:00:01.811936 18751 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T02:12:06.643687+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T01:00:00+00:00 PythonOperator 2021-04-19T02:11:52.852687+00:00 2021-04-19T02:11:56.017117+00:00 0:00:03.164430 18750 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T02:11:50.526281+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T01:00:00+00:00 PythonOperator 2021-04-19T02:11:46.781662+00:00 2021-04-19T02:11:49.902919+00:00 0:00:03.121257 18749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T02:11:44.522462+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T01:00:00+00:00 TriggerDagRunOperator 2021-04-19T02:11:28.936044+00:00 2021-04-19T02:11:29.456726+00:00 0:00:00.520682 18748 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T02:11:26.506613+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T01:00:00+00:00 TriggerDagRunOperator 2021-04-19T02:11:28.818375+00:00 2021-04-19T02:11:29.215156+00:00 0:00:00.396781 18747 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T02:11:26.506577+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T01:05:00+00:00 EmrJobFlowSensor 2021-04-19T02:06:04.137713+00:00 2021-04-19T02:14:06.533190+00:00 0:08:02.395477 18746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T02:06:02.000624+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T02:05:42.191975+00:00 2021-04-19T02:05:43.986143+00:00 0:00:01.794168 18745 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T02:05:39.980458+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T01:05:00+00:00 PythonOperator 2021-04-19T02:05:20.347387+00:00 2021-04-19T02:05:23.272570+00:00 0:00:02.925183 18744 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T02:05:17.959988+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T01:00:00+00:00 EmrJobFlowSensor 2021-04-19T02:01:03.901514+00:00 2021-04-19T02:11:06.745917+00:00 0:10:02.844403 18743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T02:01:01.539678+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T02:00:39.863853+00:00 2021-04-19T02:00:41.566632+00:00 0:00:01.702779 18742 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T02:00:37.581246+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T01:00:00+00:00 PythonOperator 2021-04-19T02:00:19.835182+00:00 2021-04-19T02:00:22.778183+00:00 0:00:02.943001 18741 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T02:00:17.508756+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T00:00:00+00:00 EmrJobFlowSensor 2021-04-19T01:10:07.186041+00:00 2021-04-19T01:20:10.118716+00:00 0:10:02.932675 18739 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T01:10:04.800014+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T00:00:00+00:00 EmrJobFlowSensor 2021-04-19T01:09:49.541181+00:00 2021-04-19T01:18:52.036894+00:00 0:09:02.495713 18738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T01:09:46.755580+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T01:09:47.002657+00:00 2021-04-19T01:09:49.106765+00:00 0:00:02.104108 18737 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T01:09:44.750050+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T01:09:27.586578+00:00 2021-04-19T01:09:29.258485+00:00 0:00:01.671907 18736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T01:09:24.777604+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T00:00:00+00:00 PythonOperator 2021-04-19T01:09:25.139315+00:00 2021-04-19T01:09:28.803505+00:00 0:00:03.664190 18735 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T01:09:22.770230+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T00:00:00+00:00 PythonOperator 2021-04-19T01:09:06.964625+00:00 2021-04-19T01:09:09.854023+00:00 0:00:02.889398 18734 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T01:09:04.750942+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T00:00:00+00:00 TriggerDagRunOperator 2021-04-19T01:09:01.745049+00:00 2021-04-19T01:09:02.147637+00:00 0:00:00.402588 18733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T01:08:58.857186+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T00:00:00+00:00 TriggerDagRunOperator 2021-04-19T01:09:01.412939+00:00 2021-04-19T01:09:01.964547+00:00 0:00:00.551608 18732 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T01:08:58.857238+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T00:05:00+00:00 EmrJobFlowSensor 2021-04-19T01:05:48.464045+00:00 2021-04-19T01:14:51.045336+00:00 0:09:02.581291 18731 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T01:05:46.295174+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T01:05:28.364777+00:00 2021-04-19T01:05:30.075087+00:00 0:00:01.710310 18730 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T01:05:26.240262+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T00:05:00+00:00 PythonOperator 2021-04-19T01:05:06.552888+00:00 2021-04-19T01:05:09.437501+00:00 0:00:02.884613 18729 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T01:05:04.276066+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T00:00:00+00:00 EmrJobFlowSensor 2021-04-19T01:00:48.655202+00:00 2021-04-19T01:08:51.185190+00:00 0:08:02.529988 18728 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T01:00:45.843908+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T01:00:26.096602+00:00 2021-04-19T01:00:27.790425+00:00 0:00:01.693823 18727 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T01:00:23.860012+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T00:00:00+00:00 PythonOperator 2021-04-19T01:00:06.085231+00:00 2021-04-19T01:00:09.205788+00:00 0:00:03.120557 18726 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T01:00:03.753517+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-18T23:00:00+00:00 EmrJobFlowSensor 2021-04-19T00:12:28.598365+00:00 2021-04-19T00:21:31.275522+00:00 0:09:02.677157 18724 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T00:12:26.120122+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-18T23:00:00+00:00 EmrJobFlowSensor 2021-04-19T00:12:18.687512+00:00 2021-04-19T00:22:21.382258+00:00 0:10:02.694746 18723 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T00:12:16.111804+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-18T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T00:12:06.306916+00:00 2021-04-19T00:12:08.163406+00:00 0:00:01.856490 18722 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T00:12:04.103923+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-18T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T00:11:56.548611+00:00 2021-04-19T00:11:58.402929+00:00 0:00:01.854318 18721 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T00:11:54.169514+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-18T23:00:00+00:00 PythonOperator 2021-04-19T00:11:44.713091+00:00 2021-04-19T00:11:47.845055+00:00 0:00:03.131964 18720 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T00:11:42.082958+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-18T23:00:00+00:00 PythonOperator 2021-04-19T00:11:36.502065+00:00 2021-04-19T00:11:39.860658+00:00 0:00:03.358593 18719 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T00:11:34.154025+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T23:00:00+00:00 TriggerDagRunOperator 2021-04-19T00:11:26.367267+00:00 2021-04-19T00:11:26.961941+00:00 0:00:00.594674 18718 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T00:11:24.044073+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T23:00:00+00:00 TriggerDagRunOperator 2021-04-19T00:11:26.236366+00:00 2021-04-19T00:11:26.697221+00:00 0:00:00.460855 18717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T00:11:24.044104+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-18T23:05:00+00:00 EmrJobFlowSensor 2021-04-19T00:05:59.756721+00:00 2021-04-19T00:14:02.308068+00:00 0:08:02.551347 18716 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T00:05:57.441024+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-18T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T00:05:37.512324+00:00 2021-04-19T00:05:39.263759+00:00 0:00:01.751435 18715 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T00:05:35.291279+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-18T23:05:00+00:00 PythonOperator 2021-04-19T00:05:17.712200+00:00 2021-04-19T00:05:20.581820+00:00 0:00:02.869620 18714 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T00:05:15.248737+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T23:00:00+00:00 EmrJobFlowSensor 2021-04-19T00:01:03.834098+00:00 2021-04-19T00:11:06.671491+00:00 0:10:02.837393 18713 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T00:01:00.952397+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T00:00:41.249317+00:00 2021-04-19T00:00:43.082845+00:00 0:00:01.833528 18712 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T00:00:38.860469+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T23:00:00+00:00 PythonOperator 2021-04-19T00:00:20.982567+00:00 2021-04-19T00:00:24.278468+00:00 0:00:03.295901 18711 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T00:00:18.735538+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-18T22:00:00+00:00 EmrJobFlowSensor 2021-04-18T23:12:49.401139+00:00 2021-04-18T23:21:52.058461+00:00 0:09:02.657322 18709 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T23:12:47.183197+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-18T22:00:00+00:00 EmrJobFlowSensor 2021-04-18T23:12:31.612941+00:00 2021-04-18T23:22:34.462975+00:00 0:10:02.850034 18708 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T23:12:29.249538+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-18T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T23:12:19.366496+00:00 2021-04-18T23:12:21.085918+00:00 0:00:01.719422 18707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T23:12:17.126703+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-18T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T23:12:11.781882+00:00 2021-04-18T23:12:13.642286+00:00 0:00:01.860404 18706 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T23:12:09.157312+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-18T22:00:00+00:00 PythonOperator 2021-04-18T23:11:59.841729+00:00 2021-04-18T23:12:02.796700+00:00 0:00:02.954971 18705 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T23:11:57.125090+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-18T22:00:00+00:00 PythonOperator 2021-04-18T23:11:49.565258+00:00 2021-04-18T23:11:52.696220+00:00 0:00:03.130962 18704 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T23:11:47.164665+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T22:00:00+00:00 TriggerDagRunOperator 2021-04-18T23:11:39.446951+00:00 2021-04-18T23:11:40.371123+00:00 0:00:00.924172 18703 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T23:11:37.089466+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T22:00:00+00:00 TriggerDagRunOperator 2021-04-18T23:11:39.385636+00:00 2021-04-18T23:11:39.799686+00:00 0:00:00.414050 18702 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T23:11:37.089498+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-18T22:05:00+00:00 EmrJobFlowSensor 2021-04-18T23:05:50.746235+00:00 2021-04-18T23:13:53.271729+00:00 0:08:02.525494 18701 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T23:05:48.465090+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-18T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-18T23:05:30.758275+00:00 2021-04-18T23:05:32.435638+00:00 0:00:01.677363 18700 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T23:05:28.463397+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-18T22:05:00+00:00 PythonOperator 2021-04-18T23:05:08.458682+00:00 2021-04-18T23:05:11.573045+00:00 0:00:03.114363 18699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T23:05:06.313634+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T22:00:00+00:00 EmrJobFlowSensor 2021-04-18T23:01:04.758166+00:00 2021-04-18T23:11:07.643041+00:00 0:10:02.884875 18698 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T23:01:02.008365+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T23:00:44.303118+00:00 2021-04-18T23:00:46.017660+00:00 0:00:01.714542 18697 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T23:00:41.988859+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T22:00:00+00:00 PythonOperator 2021-04-18T23:00:22.695720+00:00 2021-04-18T23:00:25.854423+00:00 0:00:03.158703 18696 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T23:00:19.968293+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-18T21:00:00+00:00 EmrJobFlowSensor 2021-04-18T22:10:16.102521+00:00 2021-04-18T22:21:19.146079+00:00 0:11:03.043558 18694 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T22:10:13.833620+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-18T21:00:00+00:00 EmrJobFlowSensor 2021-04-18T22:10:04.160651+00:00 2021-04-18T22:20:06.901900+00:00 0:10:02.741249 18693 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T22:10:01.823409+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-18T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T22:09:56.484505+00:00 2021-04-18T22:09:58.165209+00:00 0:00:01.680704 18692 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T22:09:53.852997+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-18T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T22:09:44.304889+00:00 2021-04-18T22:09:46.062882+00:00 0:00:01.757993 18691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T22:09:41.861004+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-18T21:00:00+00:00 PythonOperator 2021-04-18T22:09:34.366173+00:00 2021-04-18T22:09:37.688333+00:00 0:00:03.322160 18690 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T22:09:31.783499+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-18T21:00:00+00:00 PythonOperator 2021-04-18T22:09:21.941354+00:00 2021-04-18T22:09:24.818682+00:00 0:00:02.877328 18689 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T22:09:19.747857+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T21:00:00+00:00 TriggerDagRunOperator 2021-04-18T22:09:12.238186+00:00 2021-04-18T22:09:12.667213+00:00 0:00:00.429027 18688 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T22:09:09.741111+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T21:00:00+00:00 TriggerDagRunOperator 2021-04-18T22:09:11.991304+00:00 2021-04-18T22:09:12.564221+00:00 0:00:00.572917 18687 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T22:09:09.741145+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-18T21:05:00+00:00 EmrJobFlowSensor 2021-04-18T22:06:02.349432+00:00 2021-04-18T22:14:04.848846+00:00 0:08:02.499414 18686 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T22:05:59.462744+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-18T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-18T22:05:39.578124+00:00 2021-04-18T22:05:41.237058+00:00 0:00:01.658934 18685 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T22:05:37.401044+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-18T21:05:00+00:00 PythonOperator 2021-04-18T22:05:17.913691+00:00 2021-04-18T22:05:20.794207+00:00 0:00:02.880516 18684 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T22:05:15.357450+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T21:00:00+00:00 EmrJobFlowSensor 2021-04-18T22:01:01.572711+00:00 2021-04-18T22:09:04.189569+00:00 0:08:02.616858 18683 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T22:00:58.853493+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T22:00:39.212581+00:00 2021-04-18T22:00:41.002621+00:00 0:00:01.790040 18682 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T22:00:36.775260+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T21:00:00+00:00 PythonOperator 2021-04-18T22:00:18.955300+00:00 2021-04-18T22:00:21.926397+00:00 0:00:02.971097 18681 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T22:00:16.635064+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-18T20:00:00+00:00 EmrJobFlowSensor 2021-04-18T21:10:12.304532+00:00 2021-04-18T21:19:14.928845+00:00 0:09:02.624313 18679 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T21:10:10.085463+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-18T20:00:00+00:00 EmrJobFlowSensor 2021-04-18T21:09:58.309043+00:00 2021-04-18T21:20:01.150736+00:00 0:10:02.841693 18678 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T21:09:56.029676+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-18T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T21:09:50.913466+00:00 2021-04-18T21:09:52.590128+00:00 0:00:01.676662 18677 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T21:09:48.085677+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-18T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T21:09:38.703405+00:00 2021-04-18T21:09:40.377478+00:00 0:00:01.674073 18676 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T21:09:36.015716+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-18T20:00:00+00:00 PythonOperator 2021-04-18T21:09:28.364376+00:00 2021-04-18T21:09:31.344032+00:00 0:00:02.979656 18675 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T21:09:26.005114+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-18T20:00:00+00:00 PythonOperator 2021-04-18T21:09:16.492791+00:00 2021-04-18T21:09:19.759580+00:00 0:00:03.266789 18674 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T21:09:13.999306+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T20:00:00+00:00 TriggerDagRunOperator 2021-04-18T21:09:08.542366+00:00 2021-04-18T21:09:09.103353+00:00 0:00:00.560987 18673 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T21:09:05.989947+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T20:00:00+00:00 TriggerDagRunOperator 2021-04-18T21:09:08.510913+00:00 2021-04-18T21:09:08.967208+00:00 0:00:00.456295 18672 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T21:09:05.989916+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-18T20:05:00+00:00 EmrJobFlowSensor 2021-04-18T21:06:02.004639+00:00 2021-04-18T21:15:04.724587+00:00 0:09:02.719948 18671 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T21:05:59.755598+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-18T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-18T21:05:41.887117+00:00 2021-04-18T21:05:43.645190+00:00 0:00:01.758073 18670 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T21:05:39.738790+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-18T20:05:00+00:00 PythonOperator 2021-04-18T21:05:20.061241+00:00 2021-04-18T21:05:23.211435+00:00 0:00:03.150194 18669 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T21:05:17.721789+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T20:00:00+00:00 EmrJobFlowSensor 2021-04-18T21:00:53.667687+00:00 2021-04-18T21:08:56.221792+00:00 0:08:02.554105 18668 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T21:00:51.414417+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T21:00:27.626766+00:00 2021-04-18T21:00:29.466663+00:00 0:00:01.839897 18667 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T21:00:25.392035+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T20:00:00+00:00 PythonOperator 2021-04-18T21:00:05.641548+00:00 2021-04-18T21:00:08.544935+00:00 0:00:02.903387 18666 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T21:00:03.363111+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-18T19:00:00+00:00 EmrJobFlowSensor 2021-04-18T20:12:21.912824+00:00 2021-04-18T20:22:24.712560+00:00 0:10:02.799736 18664 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T20:12:19.596505+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-18T19:00:00+00:00 EmrJobFlowSensor 2021-04-18T20:12:18.031071+00:00 2021-04-18T20:20:20.453392+00:00 0:08:02.422321 18663 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T20:12:15.602160+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-18T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T20:12:00.673544+00:00 2021-04-18T20:12:02.382557+00:00 0:00:01.709013 18662 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T20:11:57.655845+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-18T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T20:11:55.869973+00:00 2021-04-18T20:11:57.696542+00:00 0:00:01.826569 18661 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T20:11:53.530450+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-18T19:00:00+00:00 PythonOperator 2021-04-18T20:11:38.321535+00:00 2021-04-18T20:11:41.473499+00:00 0:00:03.151964 18660 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T20:11:35.571103+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-18T19:00:00+00:00 PythonOperator 2021-04-18T20:11:33.923248+00:00 2021-04-18T20:11:37.107512+00:00 0:00:03.184264 18659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T20:11:31.509866+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T19:00:00+00:00 TriggerDagRunOperator 2021-04-18T20:11:15.866206+00:00 2021-04-18T20:11:16.392301+00:00 0:00:00.526095 18658 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T20:11:13.495319+00:00 2 default_pool