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_cluster_and_add_emr_steps 2021-03-23T01:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T02:05:36.408499+00:00 2021-03-23T02:05:38.098830+00:00 0:00:01.690331 10738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T02:05:34.290804+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T01:05:00+00:00 PythonOperator 2021-03-23T02:05:10.786971+00:00 2021-03-23T02:05:13.494490+00:00 0:00:02.707519 10737 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T02:05:08.341009+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T01:00:00+00:00 EmrJobFlowSensor 2021-03-23T02:00:56.075399+00:00 2021-03-23T02:10:58.738518+00:00 0:10:02.663119 10736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T02:00:53.782584+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T02:00:34.195638+00:00 2021-03-23T02:00:36.059901+00:00 0:00:01.864263 10735 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T02:00:31.768467+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T01:00:00+00:00 PythonOperator 2021-03-23T02:00:09.890411+00:00 2021-03-23T02:00:12.606895+00:00 0:00:02.716484 10734 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T02:00:07.688727+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T00:00:00+00:00 EmrJobFlowSensor 2021-03-23T01:11:21.273512+00:00 2021-03-23T01:21:24.126049+00:00 0:10:02.852537 10733 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T01:11:19.028127+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T01:10:59.375369+00:00 2021-03-23T01:11:01.082371+00:00 0:00:01.707002 10732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T01:10:57.073829+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-23T00:00:00+00:00 PythonOperator 2021-03-23T01:10:39.933779+00:00 2021-03-23T01:10:43.000395+00:00 0:00:03.066616 10731 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T01:10:37.046784+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T00:00:00+00:00 PythonOperator 2021-03-23T01:10:39.702457+00:00 2021-03-23T01:10:42.471323+00:00 0:00:02.768866 10730 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T01:10:37.046820+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T00:00:00+00:00 TriggerDagRunOperator 2021-03-23T01:10:27.557648+00:00 2021-03-23T01:10:28.056453+00:00 0:00:00.498805 10729 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T01:10:24.965425+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T00:00:00+00:00 TriggerDagRunOperator 2021-03-23T01:10:27.267650+00:00 2021-03-23T01:10:27.674605+00:00 0:00:00.406955 10728 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T01:10:24.965453+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T00:05:00+00:00 EmrJobFlowSensor 2021-03-23T01:06:07.269981+00:00 2021-03-23T01:17:10.182675+00:00 0:11:02.912694 10726 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T01:06:05.040740+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T00:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T01:05:45.015857+00:00 2021-03-23T01:05:46.668119+00:00 0:00:01.652262 10725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T01:05:42.894462+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T00:05:00+00:00 PythonOperator 2021-03-23T01:05:25.329672+00:00 2021-03-23T01:05:28.003214+00:00 0:00:02.673542 10724 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T01:05:22.855268+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T00:00:00+00:00 EmrJobFlowSensor 2021-03-23T01:01:04.689181+00:00 2021-03-23T01:10:07.292877+00:00 0:09:02.603696 10723 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T01:01:02.397583+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T01:00:40.731916+00:00 2021-03-23T01:00:42.438198+00:00 0:00:01.706282 10722 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T01:00:38.342086+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T00:00:00+00:00 PythonOperator 2021-03-23T01:00:20.403405+00:00 2021-03-23T01:00:23.162864+00:00 0:00:02.759459 10721 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T01:00:18.208036+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T23:00:00+00:00 EmrJobFlowSensor 2021-03-23T00:11:03.987292+00:00 2021-03-23T00:19:06.540004+00:00 0:08:02.552712 10718 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T00:11:01.561559+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T00:10:43.984438+00:00 2021-03-23T00:10:45.804399+00:00 0:00:01.819961 10717 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T00:10:41.558058+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T23:00:00+00:00 PythonOperator 2021-03-23T00:10:21.809425+00:00 2021-03-23T00:10:24.519018+00:00 0:00:02.709593 10715 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T00:10:19.455147+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T23:00:00+00:00 TriggerDagRunOperator 2021-03-23T00:10:14.565118+00:00 2021-03-23T00:10:14.985896+00:00 0:00:00.420778 10714 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T00:10:11.157454+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T23:00:00+00:00 TriggerDagRunOperator 2021-03-23T00:10:14.328788+00:00 2021-03-23T00:10:14.891148+00:00 0:00:00.562360 10713 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T00:10:11.157497+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-22T23:05:00+00:00 EmrJobFlowSensor 2021-03-23T00:06:03.729572+00:00 2021-03-23T00:16:06.509098+00:00 0:10:02.779526 10711 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T00:06:01.500622+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-22T23:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T00:05:41.499116+00:00 2021-03-23T00:05:43.154398+00:00 0:00:01.655282 10710 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T00:05:39.388600+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-22T23:05:00+00:00 PythonOperator 2021-03-23T00:05:19.568710+00:00 2021-03-23T00:05:22.310387+00:00 0:00:02.741677 10709 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T00:05:17.333574+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T23:00:00+00:00 EmrJobFlowSensor 2021-03-23T00:00:59.120710+00:00 2021-03-23T00:10:01.843548+00:00 0:09:02.722838 10708 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T00:00:56.866976+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T00:00:39.180741+00:00 2021-03-23T00:00:40.877668+00:00 0:00:01.696927 10707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T00:00:36.856316+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T23:00:00+00:00 PythonOperator 2021-03-23T00:00:17.209412+00:00 2021-03-23T00:00:20.034138+00:00 0:00:02.824726 10706 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T00:00:14.852644+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T22:00:00+00:00 EmrJobFlowSensor 2021-03-22T23:12:09.148612+00:00 2021-03-22T23:22:11.798739+00:00 0:10:02.650127 10705 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T23:12:06.410318+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-22T22:00:00+00:00 EmrJobFlowSensor 2021-03-22T23:12:06.938941+00:00 2021-03-23T00:11:16.374849+00:00 0:59:09.435908 10704 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T23:12:04.476236+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T23:11:46.552891+00:00 2021-03-22T23:11:48.261819+00:00 0:00:01.708928 10703 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T23:11:44.397672+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-22T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T23:11:44.632606+00:00 2021-03-22T23:11:46.504916+00:00 0:00:01.872310 10702 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T23:11:42.385339+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T22:00:00+00:00 PythonOperator 2021-03-22T23:11:25.453656+00:00 2021-03-22T23:11:28.245675+00:00 0:00:02.792019 10701 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T23:11:22.324206+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T22:00:00+00:00 PythonOperator 2021-03-22T23:11:22.922227+00:00 2021-03-22T23:11:26.705380+00:00 0:00:03.783153 10700 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T23:11:20.362559+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T22:00:00+00:00 TriggerDagRunOperator 2021-03-22T23:11:13.190763+00:00 2021-03-22T23:11:13.707774+00:00 0:00:00.517011 10699 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T23:11:10.358143+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T22:00:00+00:00 TriggerDagRunOperator 2021-03-22T23:11:13.124626+00:00 2021-03-22T23:11:13.546017+00:00 0:00:00.421391 10698 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T23:11:10.358172+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-22T22:05:00+00:00 EmrJobFlowSensor 2021-03-22T23:05:50.358325+00:00 2021-03-22T23:15:53.018320+00:00 0:10:02.659995 10696 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T23:05:48.130043+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-22T22:05:00+00:00 EmrCreateJobFlowOperator 2021-03-22T23:05:28.256002+00:00 2021-03-22T23:05:29.906641+00:00 0:00:01.650639 10695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T23:05:26.105951+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-22T22:05:00+00:00 PythonOperator 2021-03-22T23:05:08.286697+00:00 2021-03-22T23:05:11.109551+00:00 0:00:02.822854 10694 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T23:05:06.090075+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T22:00:00+00:00 EmrJobFlowSensor 2021-03-22T23:00:49.985191+00:00 2021-03-22T23:10:52.856588+00:00 0:10:02.871397 10693 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T23:00:47.656140+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T23:00:30.226024+00:00 2021-03-22T23:00:32.046560+00:00 0:00:01.820536 10692 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T23:00:27.655519+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T22:00:00+00:00 PythonOperator 2021-03-22T23:00:07.665790+00:00 2021-03-22T23:00:10.398358+00:00 0:00:02.732568 10691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T23:00:05.498187+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T21:00:00+00:00 EmrJobFlowSensor 2021-03-22T22:11:16.427734+00:00 2021-03-22T22:20:19.210670+00:00 0:09:02.782936 10690 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T22:11:14.123766+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-22T21:00:00+00:00 EmrJobFlowSensor 2021-03-22T22:11:10.364007+00:00 2021-03-22T22:44:16.278137+00:00 0:33:05.914130 10689 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T22:11:08.118345+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T22:10:54.403157+00:00 2021-03-22T22:10:56.058896+00:00 0:00:01.655739 10688 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T22:10:52.101573+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-22T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T22:10:48.511533+00:00 2021-03-22T22:10:50.323817+00:00 0:00:01.812284 10687 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T22:10:46.156123+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T21:00:00+00:00 PythonOperator 2021-03-22T22:10:32.537116+00:00 2021-03-22T22:10:35.212109+00:00 0:00:02.674993 10686 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T22:10:30.160132+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T21:00:00+00:00 PythonOperator 2021-03-22T22:10:28.507492+00:00 2021-03-22T22:10:31.547292+00:00 0:00:03.039800 10685 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T22:10:26.150395+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T21:00:00+00:00 TriggerDagRunOperator 2021-03-22T22:10:08.672274+00:00 2021-03-22T22:10:09.181908+00:00 0:00:00.509634 10684 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T22:10:06.144334+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T21:00:00+00:00 TriggerDagRunOperator 2021-03-22T22:10:08.635718+00:00 2021-03-22T22:10:09.093193+00:00 0:00:00.457475 10683 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T22:10:06.144370+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-22T21:05:00+00:00 EmrJobFlowSensor 2021-03-22T22:05:52.252881+00:00 2021-03-22T22:15:54.994271+00:00 0:10:02.741390 10681 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T22:05:49.945498+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-22T21:05:00+00:00 EmrCreateJobFlowOperator 2021-03-22T22:05:30.623372+00:00 2021-03-22T22:05:32.356701+00:00 0:00:01.733329 10680 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T22:05:28.050701+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-22T21:05:00+00:00 PythonOperator 2021-03-22T22:05:10.157334+00:00 2021-03-22T22:05:12.821401+00:00 0:00:02.664067 10679 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T22:05:07.793687+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T21:00:00+00:00 EmrJobFlowSensor 2021-03-22T22:00:57.620216+00:00 2021-03-22T22:10:00.258439+00:00 0:09:02.638223 10678 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T22:00:55.343359+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T22:00:37.568237+00:00 2021-03-22T22:00:39.358296+00:00 0:00:01.790059 10677 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T22:00:35.276760+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T21:00:00+00:00 PythonOperator 2021-03-22T22:00:15.323201+00:00 2021-03-22T22:00:18.033273+00:00 0:00:02.710072 10676 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T22:00:13.169575+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T20:00:00+00:00 EmrJobFlowSensor 2021-03-22T21:12:14.293053+00:00 2021-03-22T21:20:16.929794+00:00 0:08:02.636741 10675 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T21:12:12.037600+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-22T20:00:00+00:00 EmrJobFlowSensor 2021-03-22T21:12:10.177614+00:00 2021-03-22T21:46:16.319279+00:00 0:34:06.141665 10674 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T21:12:08.049128+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T21:11:52.281567+00:00 2021-03-22T21:11:53.971988+00:00 0:00:01.690421 10673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T21:11:50.015714+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-22T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T21:11:48.353025+00:00 2021-03-22T21:11:50.175073+00:00 0:00:01.822048 10672 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T21:11:46.011885+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T20:00:00+00:00 PythonOperator 2021-03-22T21:11:30.707028+00:00 2021-03-22T21:11:33.410720+00:00 0:00:02.703692 10671 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T21:11:27.997300+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T20:00:00+00:00 PythonOperator 2021-03-22T21:11:26.570958+00:00 2021-03-22T21:11:29.993279+00:00 0:00:03.422321 10670 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T21:11:24.061537+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T20:00:00+00:00 TriggerDagRunOperator 2021-03-22T21:11:06.424868+00:00 2021-03-22T21:11:06.928144+00:00 0:00:00.503276 10669 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T21:11:03.948563+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T20:00:00+00:00 TriggerDagRunOperator 2021-03-22T21:11:06.418397+00:00 2021-03-22T21:11:06.949668+00:00 0:00:00.531271 10668 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T21:11:03.948534+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-22T20:05:00+00:00 EmrJobFlowSensor 2021-03-22T21:05:56.453080+00:00 2021-03-22T21:15:59.123765+00:00 0:10:02.670685 10666 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T21:05:54.164704+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-22T20:05:00+00:00 EmrCreateJobFlowOperator 2021-03-22T21:05:34.372581+00:00 2021-03-22T21:05:36.069502+00:00 0:00:01.696921 10665 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T21:05:32.147997+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-22T20:05:00+00:00 PythonOperator 2021-03-22T21:05:12.242654+00:00 2021-03-22T21:05:15.037465+00:00 0:00:02.794811 10664 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T21:05:10.050653+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T20:00:00+00:00 EmrJobFlowSensor 2021-03-22T21:00:56.078670+00:00 2021-03-22T21:10:58.825368+00:00 0:10:02.746698 10663 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T21:00:53.731703+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T21:00:34.098527+00:00 2021-03-22T21:00:35.752328+00:00 0:00:01.653801 10662 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T21:00:31.749986+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T20:00:00+00:00 PythonOperator 2021-03-22T21:00:12.170487+00:00 2021-03-22T21:00:14.909496+00:00 0:00:02.739009 10661 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T21:00:09.690460+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-22T19:00:00+00:00 EmrJobFlowSensor 2021-03-22T20:10:18.849604+00:00 2021-03-22T20:44:24.805419+00:00 0:34:05.955815 10660 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T20:10:16.619853+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T19:00:00+00:00 EmrJobFlowSensor 2021-03-22T20:10:10.827308+00:00 2021-03-22T20:18:13.278447+00:00 0:08:02.451139 10659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T20:10:08.612212+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-22T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T20:09:57.097922+00:00 2021-03-22T20:09:58.778106+00:00 0:00:01.680184 10658 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T20:09:54.658981+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T20:09:49.490072+00:00 2021-03-22T20:09:51.285725+00:00 0:00:01.795653 10657 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T20:09:46.665909+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T19:00:00+00:00 PythonOperator 2021-03-22T20:09:36.984064+00:00 2021-03-22T20:09:40.039586+00:00 0:00:03.055522 10656 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T20:09:34.584154+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T19:00:00+00:00 PythonOperator 2021-03-22T20:09:27.190076+00:00 2021-03-22T20:09:29.944819+00:00 0:00:02.754743 10655 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T20:09:24.524634+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T19:00:00+00:00 TriggerDagRunOperator 2021-03-22T20:09:15.219289+00:00 2021-03-22T20:09:15.853035+00:00 0:00:00.633746 10654 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T20:09:12.640782+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T19:00:00+00:00 TriggerDagRunOperator 2021-03-22T20:09:15.200741+00:00 2021-03-22T20:09:15.645280+00:00 0:00:00.444539 10653 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T20:09:12.640752+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-22T19:05:00+00:00 EmrJobFlowSensor 2021-03-22T20:05:51.253503+00:00 2021-03-22T20:15:54.018588+00:00 0:10:02.765085 10651 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T20:05:49.095270+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-22T19:05:00+00:00 EmrCreateJobFlowOperator 2021-03-22T20:05:29.167166+00:00 2021-03-22T20:05:30.825329+00:00 0:00:01.658163 10650 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T20:05:27.076890+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-22T19:05:00+00:00 PythonOperator 2021-03-22T20:05:07.391229+00:00 2021-03-22T20:05:10.140144+00:00 0:00:02.748915 10649 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T20:05:05.056337+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T19:00:00+00:00 EmrJobFlowSensor 2021-03-22T20:00:50.900528+00:00 2021-03-22T20:08:53.375676+00:00 0:08:02.475148 10648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T20:00:48.683932+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T20:00:28.864242+00:00 2021-03-22T20:00:30.678651+00:00 0:00:01.814409 10647 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T20:00:26.602325+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T19:00:00+00:00 PythonOperator 2021-03-22T20:00:07.067625+00:00 2021-03-22T20:00:09.882093+00:00 0:00:02.814468 10646 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T20:00:04.649563+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T18:00:00+00:00 EmrJobFlowSensor 2021-03-22T19:12:54.742663+00:00 2021-03-22T19:22:57.492612+00:00 0:10:02.749949 10645 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T19:12:52.122567+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-22T18:00:00+00:00 EmrJobFlowSensor 2021-03-22T19:12:52.344735+00:00 2021-03-22T19:45:58.627311+00:00 0:33:06.282576 10644 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T19:12:50.119369+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T19:12:32.555813+00:00 2021-03-22T19:12:34.244080+00:00 0:00:01.688267 10643 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T19:12:30.243764+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-22T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T19:12:30.712947+00:00 2021-03-22T19:12:32.515140+00:00 0:00:01.802193 10642 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T19:12:28.162611+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T18:00:00+00:00 PythonOperator 2021-03-22T19:12:10.548943+00:00 2021-03-22T19:12:13.266674+00:00 0:00:02.717731 10641 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T19:12:08.054470+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T18:00:00+00:00 PythonOperator 2021-03-22T19:12:10.529058+00:00 2021-03-22T19:12:13.599253+00:00 0:00:03.070195 10640 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T19:12:08.054522+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T18:00:00+00:00 TriggerDagRunOperator 2021-03-22T19:11:48.566918+00:00 2021-03-22T19:11:49.051932+00:00 0:00:00.485014 10639 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T19:11:45.963681+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T18:00:00+00:00 TriggerDagRunOperator 2021-03-22T19:11:48.398421+00:00 2021-03-22T19:11:48.824872+00:00 0:00:00.426451 10638 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T19:11:45.963720+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-22T18:05:00+00:00 EmrJobFlowSensor 2021-03-22T19:06:40.012059+00:00 2021-03-22T19:15:42.507212+00:00 0:09:02.495153 10637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T19:06:37.497364+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-22T18:05:00+00:00 EmrCreateJobFlowOperator 2021-03-22T19:05:40.065716+00:00 2021-03-22T19:05:41.722237+00:00 0:00:01.656521 10635 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T19:05:37.872695+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-22T18:05:00+00:00 PythonOperator 2021-03-22T19:05:17.855740+00:00 2021-03-22T19:05:20.613772+00:00 0:00:02.758032 10634 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T19:05:15.533397+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T18:00:00+00:00 EmrJobFlowSensor 2021-03-22T19:02:25.650921+00:00 2021-03-22T19:11:28.391538+00:00 0:09:02.740617 10633 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T19:02:23.330571+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T19:01:55.523315+00:00 2021-03-22T19:01:57.236701+00:00 0:00:01.713386 10632 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T19:01:53.302605+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T18:00:00+00:00 PythonOperator 2021-03-22T19:01:29.914920+00:00 2021-03-22T19:01:32.758836+00:00 0:00:02.843916 10631 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T19:01:27.265317+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-22T17:00:00+00:00 EmrJobFlowSensor 2021-03-22T18:12:30.942804+00:00 2021-03-22T18:45:36.691085+00:00 0:33:05.748281 10630 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T18:12:28.465123+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T17:00:00+00:00 EmrJobFlowSensor 2021-03-22T18:12:24.663392+00:00 2021-03-22T18:21:27.230426+00:00 0:09:02.567034 10629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T18:12:22.349087+00:00 2 default_pool