Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 create_emr_steps 2021-04-05T13:00:00+00:00 PythonOperator 2021-04-05T14:00:07.391890+00:00 2021-04-05T14:00:10.234542+00:00 0:00:02.842652 13860 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T14:00:04.792205+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T12:00:00+00:00 EmrJobFlowSensor 2021-04-05T13:11:14.802290+00:00 2021-04-05T13:20:17.582802+00:00 0:09:02.780512 13858 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T13:11:12.422352+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T12:00:00+00:00 EmrJobFlowSensor 2021-04-05T13:11:10.887175+00:00 2021-04-05T13:19:13.448142+00:00 0:08:02.560967 13857 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T13:11:08.480287+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T13:10:54.778063+00:00 2021-04-05T13:10:56.513922+00:00 0:00:01.735859 13856 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T13:10:52.405811+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T13:10:50.871799+00:00 2021-04-05T13:10:52.603789+00:00 0:00:01.731990 13855 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T13:10:48.453898+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T12:00:00+00:00 PythonOperator 2021-04-05T13:10:32.957607+00:00 2021-04-05T13:10:35.853188+00:00 0:00:02.895581 13854 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T13:10:30.387587+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T12:00:00+00:00 PythonOperator 2021-04-05T13:10:28.806357+00:00 2021-04-05T13:10:31.621634+00:00 0:00:02.815277 13853 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T13:10:26.320887+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T12:00:00+00:00 TriggerDagRunOperator 2021-04-05T13:10:20.567904+00:00 2021-04-05T13:10:21.112002+00:00 0:00:00.544098 13852 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T13:10:18.312216+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T12:00:00+00:00 TriggerDagRunOperator 2021-04-05T13:10:20.538372+00:00 2021-04-05T13:10:20.955247+00:00 0:00:00.416875 13851 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T13:10:18.312247+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T12:05:00+00:00 EmrJobFlowSensor 2021-04-05T13:05:50.171786+00:00 2021-04-05T13:14:52.862365+00:00 0:09:02.690579 13850 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T13:05:47.791998+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T13:05:28.002111+00:00 2021-04-05T13:05:29.770653+00:00 0:00:01.768542 13849 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T13:05:25.733996+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T12:05:00+00:00 PythonOperator 2021-04-05T13:05:06.182070+00:00 2021-04-05T13:05:09.034696+00:00 0:00:02.852626 13848 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T13:05:03.777469+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T12:00:00+00:00 EmrJobFlowSensor 2021-04-05T13:00:55.399876+00:00 2021-04-05T13:09:58.169244+00:00 0:09:02.769368 13847 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T13:00:53.208059+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T13:00:33.350588+00:00 2021-04-05T13:00:35.089817+00:00 0:00:01.739229 13846 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T13:00:31.189795+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T12:00:00+00:00 PythonOperator 2021-04-05T13:00:11.654775+00:00 2021-04-05T13:00:14.494799+00:00 0:00:02.840024 13845 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T13:00:09.162792+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T11:00:00+00:00 EmrJobFlowSensor 2021-04-05T12:12:12.400918+00:00 2021-04-05T12:21:15.146141+00:00 0:09:02.745223 13843 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T12:12:10.117179+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T11:00:00+00:00 EmrJobFlowSensor 2021-04-05T12:12:12.372363+00:00 2021-04-05T12:22:15.309688+00:00 0:10:02.937325 13842 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T12:12:10.117143+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T12:11:50.666827+00:00 2021-04-05T12:11:52.399438+00:00 0:00:01.732611 13841 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T12:11:48.164039+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T12:11:50.710537+00:00 2021-04-05T12:11:52.532817+00:00 0:00:01.822280 13840 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T12:11:48.164000+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T11:00:00+00:00 PythonOperator 2021-04-05T12:11:31.451050+00:00 2021-04-05T12:11:34.435813+00:00 0:00:02.984763 13839 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T12:11:28.166067+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T11:00:00+00:00 PythonOperator 2021-04-05T12:11:29.316511+00:00 2021-04-05T12:11:32.409212+00:00 0:00:03.092701 13838 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T12:11:26.152855+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T11:00:00+00:00 TriggerDagRunOperator 2021-04-05T12:11:16.451353+00:00 2021-04-05T12:11:16.985381+00:00 0:00:00.534028 13837 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T12:11:14.052984+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T11:00:00+00:00 TriggerDagRunOperator 2021-04-05T12:11:16.382883+00:00 2021-04-05T12:11:16.787495+00:00 0:00:00.404612 13836 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T12:11:14.053032+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T11:05:00+00:00 EmrJobFlowSensor 2021-04-05T12:06:04.098386+00:00 2021-04-05T12:15:06.706973+00:00 0:09:02.608587 13835 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T12:06:01.690764+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T12:05:44.033383+00:00 2021-04-05T12:05:45.715694+00:00 0:00:01.682311 13834 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T12:05:41.666011+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T11:05:00+00:00 PythonOperator 2021-04-05T12:05:21.843554+00:00 2021-04-05T12:05:24.609494+00:00 0:00:02.765940 13833 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T12:05:19.578001+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T11:00:00+00:00 EmrJobFlowSensor 2021-04-05T12:01:03.518529+00:00 2021-04-05T12:11:06.246990+00:00 0:10:02.728461 13832 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T12:01:01.144790+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T12:00:41.405586+00:00 2021-04-05T12:00:43.215362+00:00 0:00:01.809776 13831 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T12:00:39.059964+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T11:00:00+00:00 PythonOperator 2021-04-05T12:00:21.464033+00:00 2021-04-05T12:00:24.286776+00:00 0:00:02.822743 13830 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T12:00:18.994208+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T10:00:00+00:00 EmrJobFlowSensor 2021-04-05T11:23:05.127439+00:00 2021-04-05T11:23:06.608352+00:00 0:00:01.480913 13828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T11:23:02.789488+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T10:00:00+00:00 EmrJobFlowSensor 2021-04-05T11:11:25.952497+00:00 2021-04-05T11:20:28.801943+00:00 0:09:02.849446 13827 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T11:11:23.654337+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T11:11:04.089902+00:00 2021-04-05T11:11:05.932689+00:00 0:00:01.842787 13825 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T11:11:01.615053+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T11:11:02.049290+00:00 2021-04-05T11:11:03.816698+00:00 0:00:01.767408 13824 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T11:10:59.676387+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T10:00:00+00:00 PythonOperator 2021-04-05T11:10:41.779079+00:00 2021-04-05T11:10:44.494468+00:00 0:00:02.715389 13823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T11:10:39.593323+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T10:00:00+00:00 PythonOperator 2021-04-05T11:10:39.929217+00:00 2021-04-05T11:10:42.923104+00:00 0:00:02.993887 13822 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T11:10:37.596182+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T10:00:00+00:00 TriggerDagRunOperator 2021-04-05T11:10:23.988565+00:00 2021-04-05T11:10:24.607314+00:00 0:00:00.618749 13821 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T11:10:21.552034+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T10:00:00+00:00 TriggerDagRunOperator 2021-04-05T11:10:23.810941+00:00 2021-04-05T11:10:24.405972+00:00 0:00:00.595031 13820 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T11:10:21.552067+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T10:05:00+00:00 EmrJobFlowSensor 2021-04-05T11:05:55.604099+00:00 2021-04-05T11:14:58.236260+00:00 0:09:02.632161 13819 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T11:05:53.082477+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T11:05:33.371120+00:00 2021-04-05T11:05:35.010852+00:00 0:00:01.639732 13818 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T11:05:31.066731+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T10:05:00+00:00 PythonOperator 2021-04-05T11:05:11.374441+00:00 2021-04-05T11:05:14.096151+00:00 0:00:02.721710 13817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T11:05:09.051003+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T10:00:00+00:00 EmrJobFlowSensor 2021-04-05T11:01:04.957947+00:00 2021-04-05T11:10:07.645716+00:00 0:09:02.687769 13816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T11:01:02.592811+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T11:00:42.753081+00:00 2021-04-05T11:00:44.478787+00:00 0:00:01.725706 13815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T11:00:40.510042+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T10:00:00+00:00 PythonOperator 2021-04-05T11:00:20.831281+00:00 2021-04-05T11:00:23.785324+00:00 0:00:02.954043 13814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T11:00:18.492295+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T09:00:00+00:00 EmrJobFlowSensor 2021-04-05T10:11:10.676911+00:00 2021-04-05T10:21:13.576133+00:00 0:10:02.899222 13812 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T10:11:08.400838+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T09:00:00+00:00 EmrJobFlowSensor 2021-04-05T10:11:08.634279+00:00 2021-04-05T10:20:11.246782+00:00 0:09:02.612503 13811 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T10:11:06.389784+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T10:10:49.090747+00:00 2021-04-05T10:10:50.757179+00:00 0:00:01.666432 13810 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T10:10:46.305844+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T10:10:46.608064+00:00 2021-04-05T10:10:48.684958+00:00 0:00:02.076894 13809 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T10:10:44.348477+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T09:00:00+00:00 PythonOperator 2021-04-05T10:10:26.950029+00:00 2021-04-05T10:10:29.741967+00:00 0:00:02.791938 13808 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T10:10:24.293361+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T09:00:00+00:00 PythonOperator 2021-04-05T10:10:26.943766+00:00 2021-04-05T10:10:29.984927+00:00 0:00:03.041161 13807 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T10:10:24.293329+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T09:00:00+00:00 TriggerDagRunOperator 2021-04-05T10:10:14.632809+00:00 2021-04-05T10:10:15.310436+00:00 0:00:00.677627 13806 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T10:10:12.280643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T09:00:00+00:00 TriggerDagRunOperator 2021-04-05T10:10:14.608530+00:00 2021-04-05T10:10:15.149565+00:00 0:00:00.541035 13805 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T10:10:12.280593+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T09:05:00+00:00 EmrJobFlowSensor 2021-04-05T10:06:06.170923+00:00 2021-04-05T10:15:08.923635+00:00 0:09:02.752712 13804 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T10:06:03.938359+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T10:05:44.503785+00:00 2021-04-05T10:05:46.214148+00:00 0:00:01.710363 13803 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T10:05:41.923193+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T09:05:00+00:00 PythonOperator 2021-04-05T10:05:22.076616+00:00 2021-04-05T10:05:24.777261+00:00 0:00:02.700645 13802 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T10:05:19.900353+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T09:00:00+00:00 EmrJobFlowSensor 2021-04-05T10:01:01.525558+00:00 2021-04-05T10:10:04.243208+00:00 0:09:02.717650 13801 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T10:00:59.313347+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T10:00:31.710072+00:00 2021-04-05T10:00:33.524513+00:00 0:00:01.814441 13800 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T10:00:29.359895+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T09:00:00+00:00 PythonOperator 2021-04-05T10:00:09.722520+00:00 2021-04-05T10:00:12.593262+00:00 0:00:02.870742 13799 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T10:00:07.273108+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T08:00:00+00:00 EmrJobFlowSensor 2021-04-05T09:12:10.108590+00:00 2021-04-05T09:22:12.736131+00:00 0:10:02.627541 13797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T09:12:07.937494+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T08:00:00+00:00 EmrJobFlowSensor 2021-04-05T09:12:08.303295+00:00 2021-04-05T09:29:12.242586+00:00 0:17:03.939291 13796 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T09:12:05.935395+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T09:11:50.228023+00:00 2021-04-05T09:11:51.909770+00:00 0:00:01.681747 13795 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T09:11:47.919301+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T09:11:46.429573+00:00 2021-04-05T09:11:48.245354+00:00 0:00:01.815781 13794 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T09:11:44.044154+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T08:00:00+00:00 PythonOperator 2021-04-05T09:11:28.118032+00:00 2021-04-05T09:11:31.092472+00:00 0:00:02.974440 13793 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T09:11:25.902188+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T08:00:00+00:00 PythonOperator 2021-04-05T09:11:26.581568+00:00 2021-04-05T09:11:29.555677+00:00 0:00:02.974109 13792 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T09:11:23.916496+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T08:00:00+00:00 TriggerDagRunOperator 2021-04-05T09:11:14.281572+00:00 2021-04-05T09:11:14.817394+00:00 0:00:00.535822 13791 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T09:11:11.886977+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T08:00:00+00:00 TriggerDagRunOperator 2021-04-05T09:11:14.005228+00:00 2021-04-05T09:11:14.410464+00:00 0:00:00.405236 13790 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T09:11:11.887008+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T08:05:00+00:00 EmrJobFlowSensor 2021-04-05T09:05:55.705651+00:00 2021-04-05T09:14:58.436800+00:00 0:09:02.731149 13789 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T09:05:53.265022+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T09:05:33.313499+00:00 2021-04-05T09:05:34.947820+00:00 0:00:01.634321 13788 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T09:05:31.182355+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T08:05:00+00:00 PythonOperator 2021-04-05T09:05:11.371181+00:00 2021-04-05T09:05:14.159442+00:00 0:00:02.788261 13787 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T09:05:09.152666+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T08:00:00+00:00 EmrJobFlowSensor 2021-04-05T09:00:59.092826+00:00 2021-04-05T09:11:01.937940+00:00 0:10:02.845114 13786 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T09:00:56.698779+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T09:00:39.122355+00:00 2021-04-05T09:00:40.810370+00:00 0:00:01.688015 13785 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T09:00:36.683801+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T08:00:00+00:00 PythonOperator 2021-04-05T09:00:16.925392+00:00 2021-04-05T09:00:19.808316+00:00 0:00:02.882924 13784 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T09:00:14.621266+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T07:00:00+00:00 EmrJobFlowSensor 2021-04-05T08:15:20.628218+00:00 2021-04-05T08:25:23.618722+00:00 0:10:02.990504 13783 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T08:15:18.255521+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T07:00:00+00:00 EmrJobFlowSensor 2021-04-05T08:15:14.578977+00:00 2021-04-05T08:25:17.403811+00:00 0:10:02.824834 13782 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T08:15:12.243299+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T08:14:58.691111+00:00 2021-04-05T08:15:00.482820+00:00 0:00:01.791709 13781 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T08:14:56.280455+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T08:14:54.598044+00:00 2021-04-05T08:14:56.385563+00:00 0:00:01.787519 13780 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T08:14:52.274004+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T07:00:00+00:00 PythonOperator 2021-04-05T08:14:36.970579+00:00 2021-04-05T08:14:39.883060+00:00 0:00:02.912481 13779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T08:14:34.213593+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T07:00:00+00:00 PythonOperator 2021-04-05T08:14:32.611618+00:00 2021-04-05T08:14:35.514884+00:00 0:00:02.903266 13778 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T08:14:30.268185+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T07:00:00+00:00 TriggerDagRunOperator 2021-04-05T08:14:11.078125+00:00 2021-04-05T08:14:11.633171+00:00 0:00:00.555046 13777 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T08:14:08.186431+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T07:00:00+00:00 TriggerDagRunOperator 2021-04-05T08:14:10.682326+00:00 2021-04-05T08:14:11.146432+00:00 0:00:00.464106 13776 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T08:14:08.186462+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T07:05:00+00:00 EmrJobFlowSensor 2021-04-05T08:06:00.776016+00:00 2021-04-05T08:14:03.276722+00:00 0:08:02.500706 13774 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T08:05:58.557609+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T08:05:31.010598+00:00 2021-04-05T08:05:32.732428+00:00 0:00:01.721830 13773 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T08:05:28.568198+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T07:05:00+00:00 PythonOperator 2021-04-05T08:05:08.988005+00:00 2021-04-05T08:05:11.658182+00:00 0:00:02.670177 13772 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T08:05:06.456169+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T07:00:00+00:00 EmrJobFlowSensor 2021-04-05T08:00:54.550590+00:00 2021-04-05T08:10:57.486957+00:00 0:10:02.936367 13771 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T08:00:51.991524+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T08:00:32.220289+00:00 2021-04-05T08:00:33.983065+00:00 0:00:01.762776 13770 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T08:00:29.964244+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T07:00:00+00:00 PythonOperator 2021-04-05T08:00:10.152538+00:00 2021-04-05T08:00:12.907409+00:00 0:00:02.754871 13769 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T08:00:07.888570+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T06:00:00+00:00 EmrJobFlowSensor 2021-04-05T07:10:40.895257+00:00 2021-04-05T07:20:43.812157+00:00 0:10:02.916900 13768 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T07:10:38.545698+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-05T06:00:00+00:00 EmrJobFlowSensor 2021-04-05T07:10:23.078336+00:00 2021-04-05T07:19:25.962338+00:00 0:09:02.884002 13767 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T07:10:20.468647+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-05T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T07:10:18.729120+00:00 2021-04-05T07:10:20.443555+00:00 0:00:01.714435 13766 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T07:10:16.468124+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-05T06:05:00+00:00 EmrJobFlowSensor 2021-04-05T07:10:14.803441+00:00 2021-04-05T07:19:17.476169+00:00 0:09:02.672728 13765 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T07:10:12.397260+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-05T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T07:10:01.324679+00:00 2021-04-05T07:10:03.066963+00:00 0:00:01.742284 13764 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T07:09:58.465639+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-05T06:00:00+00:00 PythonOperator 2021-04-05T07:09:56.525360+00:00 2021-04-05T07:09:59.722156+00:00 0:00:03.196796 13763 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T07:09:54.361720+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-05T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-05T07:09:52.514337+00:00 2021-04-05T07:09:54.185188+00:00 0:00:01.670851 13762 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-05T07:09:50.360589+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-05T06:00:00+00:00 PythonOperator 2021-04-05T07:09:40.659420+00:00 2021-04-05T07:09:43.516090+00:00 0:00:02.856670 13761 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T07:09:38.347242+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-05T06:00:00+00:00 TriggerDagRunOperator 2021-04-05T07:09:35.589836+00:00 2021-04-05T07:09:35.974113+00:00 0:00:00.384277 13760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T07:09:32.344567+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-05T06:00:00+00:00 TriggerDagRunOperator 2021-04-05T07:09:34.632942+00:00 2021-04-05T07:09:35.147976+00:00 0:00:00.515034 13759 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T07:09:32.344597+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-05T06:05:00+00:00 PythonOperator 2021-04-05T07:09:33.538394+00:00 2021-04-05T07:09:36.552922+00:00 0:00:03.014528 13758 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T07:09:30.396000+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-05T06:00:00+00:00 EmrJobFlowSensor 2021-04-05T07:00:57.789193+00:00 2021-04-05T07:09:00.352950+00:00 0:08:02.563757 13756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-05T07:00:55.530792+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-05T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-05T07:00:27.821461+00:00 2021-04-05T07:00:29.706067+00:00 0:00:01.884606 13755 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-05T07:00:25.503218+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-05T06:00:00+00:00 PythonOperator 2021-04-05T07:00:05.836415+00:00 2021-04-05T07:00:08.593209+00:00 0:00:02.756794 13754 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-05T07:00:03.490147+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-05T05:00:00+00:00 EmrJobFlowSensor 2021-04-05T06:10:02.846859+00:00 2021-04-05T06:20:05.812606+00:00 0:10:02.965747 13753 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-05T06:10:00.487195+00:00 2 default_pool