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-04-19T04:05:00+00:00 PythonOperator 2021-04-19T05:05:19.671273+00:00 2021-04-19T05:05:22.795354+00:00 0:00:03.124081 18789 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T05:05:17.144502+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T04:00:00+00:00 EmrJobFlowSensor 2021-04-19T05:03:23.076662+00:00 2021-04-19T05:12:25.697844+00:00 0:09:02.621182 18788 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T05:03:20.727796+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T05:03:01.211088+00:00 2021-04-19T05:03:03.036150+00:00 0:00:01.825062 18787 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T05:02:58.768702+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T04:00:00+00:00 PythonOperator 2021-04-19T05:02:41.765851+00:00 2021-04-19T05:02:44.763126+00:00 0:00:02.997275 18786 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T05:02:38.703508+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T03:00:00+00:00 EmrJobFlowSensor 2021-04-19T04:11:42.980380+00:00 2021-04-19T04:21:45.843220+00:00 0:10:02.862840 18784 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T04:11:40.591154+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T03:00:00+00:00 EmrJobFlowSensor 2021-04-19T04:11:42.803913+00:00 2021-04-19T04:21:45.593137+00:00 0:10:02.789224 18783 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T04:11:40.591188+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T04:11:23.285025+00:00 2021-04-19T04:11:24.963938+00:00 0:00:01.678913 18782 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T04:11:20.576493+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T04:11:20.824448+00:00 2021-04-19T04:11:22.907987+00:00 0:00:02.083539 18781 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T04:11:18.580128+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T03:00:00+00:00 PythonOperator 2021-04-19T04:11:01.030941+00:00 2021-04-19T04:11:03.964972+00:00 0:00:02.934031 18780 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T04:10:58.654052+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T03:00:00+00:00 PythonOperator 2021-04-19T04:10:58.923988+00:00 2021-04-19T04:11:02.280045+00:00 0:00:03.356057 18779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T04:10:56.575200+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T03:00:00+00:00 TriggerDagRunOperator 2021-04-19T04:10:42.840436+00:00 2021-04-19T04:10:43.384746+00:00 0:00:00.544310 18778 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T04:10:40.492324+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T03:00:00+00:00 TriggerDagRunOperator 2021-04-19T04:10:42.683284+00:00 2021-04-19T04:10:43.110648+00:00 0:00:00.427364 18777 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T04:10:40.492358+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T03:05:00+00:00 EmrJobFlowSensor 2021-04-19T04:06:52.215700+00:00 2021-04-19T04:14:54.663926+00:00 0:08:02.448226 18776 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T04:06:50.056743+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T04:05:38.376883+00:00 2021-04-19T04:05:40.059425+00:00 0:00:01.682542 18775 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T04:05:35.991820+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T03:05:00+00:00 PythonOperator 2021-04-19T04:05:18.135202+00:00 2021-04-19T04:05:21.285307+00:00 0:00:03.150105 18774 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T04:05:15.924141+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T03:00:00+00:00 EmrJobFlowSensor 2021-04-19T04:01:17.822488+00:00 2021-04-19T04:10:20.445231+00:00 0:09:02.622743 18773 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T04:01:15.658600+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T04:00:55.809268+00:00 2021-04-19T04:00:58.161168+00:00 0:00:02.351900 18772 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T04:00:53.631041+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T03:00:00+00:00 PythonOperator 2021-04-19T04:00:26.027756+00:00 2021-04-19T04:00:28.959890+00:00 0:00:02.932134 18771 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T04:00:23.610719+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T02:00:00+00:00 EmrJobFlowSensor 2021-04-19T03:11:56.483330+00:00 2021-04-19T03:23:59.458279+00:00 0:12:02.974949 18769 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T03:11:54.316003+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T02:00:00+00:00 EmrJobFlowSensor 2021-04-19T03:11:54.587337+00:00 2021-04-19T03:20:57.445800+00:00 0:09:02.858463 18768 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T03:11:52.316990+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T03:11:36.489203+00:00 2021-04-19T03:11:38.186244+00:00 0:00:01.697041 18767 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T03:11:34.299526+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T03:11:32.886163+00:00 2021-04-19T03:11:34.545466+00:00 0:00:01.659303 18766 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T03:11:30.366061+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T02:00:00+00:00 PythonOperator 2021-04-19T03:11:13.156477+00:00 2021-04-19T03:11:16.546585+00:00 0:00:03.390108 18765 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T03:11:10.253377+00:00 2 default_pool
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