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_cluster_and_add_emr_steps 2021-07-09T14:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T15:00:42.469462+00:00 2021-07-09T15:00:44.421599+00:00 0:00:01.952137 51898 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-09T15:00:39.982847+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-09T14:00:00+00:00 PythonOperator 2021-07-09T15:00:20.482751+00:00 2021-07-09T15:00:24.206428+00:00 0:00:03.723677 51897 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-09T15:00:17.955435+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-09T13:00:00+00:00 EmrJobFlowSensor 2021-07-09T14:13:10.609773+00:00 2021-07-09T14:24:13.711782+00:00 0:11:03.102009 51895 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T14:13:08.329306+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-09T13:00:00+00:00 EmrJobFlowSensor 2021-07-09T14:12:58.797276+00:00 2021-07-09T14:23:02.064414+00:00 0:10:03.267138 51894 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T14:12:56.359298+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-09T13:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T14:12:48.529722+00:00 2021-07-09T14:12:50.273422+00:00 0:00:01.743700 51893 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T14:12:46.344691+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-09T13:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T14:12:38.727743+00:00 2021-07-09T14:12:40.521139+00:00 0:00:01.793396 51892 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T14:12:36.309755+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-09T13:00:00+00:00 PythonOperator 2021-07-09T14:12:25.023161+00:00 2021-07-09T14:12:28.807219+00:00 0:00:03.784058 51891 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T14:12:22.346385+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-09T13:00:00+00:00 PythonOperator 2021-07-09T14:12:16.778272+00:00 2021-07-09T14:12:20.606497+00:00 0:00:03.828225 51890 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T14:12:14.377971+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-09T13:00:00+00:00 TriggerDagRunOperator 2021-07-09T14:12:10.815321+00:00 2021-07-09T14:12:11.250155+00:00 0:00:00.434834 51889 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T14:12:08.344518+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-09T13:00:00+00:00 TriggerDagRunOperator 2021-07-09T14:12:10.816904+00:00 2021-07-09T14:12:11.341566+00:00 0:00:00.524662 51888 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T14:12:08.344466+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-09T13:05:00+00:00 EmrJobFlowSensor 2021-07-09T14:06:00.266134+00:00 2021-07-09T14:15:02.991650+00:00 0:09:02.725516 51887 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T14:05:57.756805+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-09T13:05:00+00:00 EmrCreateJobFlowOperator 2021-07-09T14:05:40.079156+00:00 2021-07-09T14:05:41.800904+00:00 0:00:01.721748 51886 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T14:05:37.654267+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-09T13:05:00+00:00 PythonOperator 2021-07-09T14:05:17.916810+00:00 2021-07-09T14:05:21.602486+00:00 0:00:03.685676 51885 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T14:05:15.558665+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-09T13:00:00+00:00 EmrJobFlowSensor 2021-07-09T14:00:57.232303+00:00 2021-07-09T14:12:00.533169+00:00 0:11:03.300866 51884 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T14:00:54.981132+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-09T13:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T14:00:37.107830+00:00 2021-07-09T14:00:38.855344+00:00 0:00:01.747514 51883 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-09T14:00:34.960775+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-09T13:00:00+00:00 PythonOperator 2021-07-09T14:00:15.322758+00:00 2021-07-09T14:00:19.175514+00:00 0:00:03.852756 51882 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-09T14:00:12.909030+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-09T12:00:00+00:00 EmrJobFlowSensor 2021-07-09T13:11:16.357013+00:00 2021-07-09T13:23:19.629443+00:00 0:12:03.272430 51880 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T13:11:13.520564+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-09T12:00:00+00:00 EmrJobFlowSensor 2021-07-09T13:11:13.954121+00:00 2021-07-09T13:21:17.379131+00:00 0:10:03.425010 51879 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T13:11:11.508559+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-09T12:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T13:10:51.840563+00:00 2021-07-09T13:10:53.678670+00:00 0:00:01.838107 51878 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T13:10:49.488810+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-09T12:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T13:10:51.710901+00:00 2021-07-09T13:10:53.494203+00:00 0:00:01.783302 51877 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T13:10:49.488777+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-09T12:00:00+00:00 PythonOperator 2021-07-09T13:10:32.367620+00:00 2021-07-09T13:10:36.237771+00:00 0:00:03.870151 51876 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T13:10:29.540695+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-09T12:00:00+00:00 PythonOperator 2021-07-09T13:10:29.930440+00:00 2021-07-09T13:10:34.357965+00:00 0:00:04.427525 51875 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T13:10:27.582174+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-09T12:00:00+00:00 TriggerDagRunOperator 2021-07-09T13:10:15.940640+00:00 2021-07-09T13:10:16.467354+00:00 0:00:00.526714 51874 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T13:10:13.420314+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-09T12:00:00+00:00 TriggerDagRunOperator 2021-07-09T13:10:15.797700+00:00 2021-07-09T13:10:16.223050+00:00 0:00:00.425350 51873 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T13:10:13.420280+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-09T12:05:00+00:00 EmrJobFlowSensor 2021-07-09T13:05:59.273593+00:00 2021-07-09T13:15:02.094807+00:00 0:09:02.821214 51872 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T13:05:56.905878+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-09T12:05:00+00:00 EmrCreateJobFlowOperator 2021-07-09T13:05:37.232421+00:00 2021-07-09T13:05:38.991402+00:00 0:00:01.758981 51871 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T13:05:34.947923+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-09T12:05:00+00:00 PythonOperator 2021-07-09T13:05:13.087763+00:00 2021-07-09T13:05:16.533836+00:00 0:00:03.446073 51870 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T13:05:10.861740+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-09T12:00:00+00:00 EmrJobFlowSensor 2021-07-09T13:01:00.897712+00:00 2021-07-09T13:10:03.778803+00:00 0:09:02.881091 51869 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T13:00:58.447841+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-09T12:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T13:00:40.519563+00:00 2021-07-09T13:00:42.230578+00:00 0:00:01.711015 51868 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-09T13:00:38.287316+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-09T12:00:00+00:00 PythonOperator 2021-07-09T13:00:18.498708+00:00 2021-07-09T13:00:22.275979+00:00 0:00:03.777271 51867 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-09T13:00:16.253620+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-09T11:00:00+00:00 EmrJobFlowSensor 2021-07-09T12:11:43.077581+00:00 2021-07-09T12:21:46.089316+00:00 0:10:03.011735 51865 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T12:11:40.812472+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-09T11:00:00+00:00 EmrJobFlowSensor 2021-07-09T12:11:31.455318+00:00 2021-07-09T12:21:34.339959+00:00 0:10:02.884641 51864 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T12:11:28.844044+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-09T11:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T12:11:21.016755+00:00 2021-07-09T12:11:22.782148+00:00 0:00:01.765393 51863 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T12:11:18.797516+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-09T11:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T12:11:09.150879+00:00 2021-07-09T12:11:10.880686+00:00 0:00:01.729807 51862 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T12:11:06.847778+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-09T11:00:00+00:00 PythonOperator 2021-07-09T12:10:59.252383+00:00 2021-07-09T12:11:03.034406+00:00 0:00:03.782023 51861 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T12:10:56.766890+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-09T11:00:00+00:00 PythonOperator 2021-07-09T12:10:47.423516+00:00 2021-07-09T12:10:51.396055+00:00 0:00:03.972539 51860 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T12:10:44.701204+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-09T11:00:00+00:00 TriggerDagRunOperator 2021-07-09T12:10:39.279099+00:00 2021-07-09T12:10:39.788074+00:00 0:00:00.508975 51859 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T12:10:36.761817+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-09T11:00:00+00:00 TriggerDagRunOperator 2021-07-09T12:10:39.150937+00:00 2021-07-09T12:10:39.525408+00:00 0:00:00.374471 51858 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T12:10:36.761771+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-09T11:05:00+00:00 EmrJobFlowSensor 2021-07-09T12:06:08.374715+00:00 2021-07-09T12:15:11.175149+00:00 0:09:02.800434 51857 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T12:06:06.203566+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-09T11:05:00+00:00 EmrCreateJobFlowOperator 2021-07-09T12:05:46.541209+00:00 2021-07-09T12:05:48.302463+00:00 0:00:01.761254 51856 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T12:05:44.149411+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-09T11:05:00+00:00 PythonOperator 2021-07-09T12:05:18.569330+00:00 2021-07-09T12:05:22.004262+00:00 0:00:03.434932 51855 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T12:05:16.118109+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-09T11:00:00+00:00 EmrJobFlowSensor 2021-07-09T12:01:16.298485+00:00 2021-07-09T12:10:19.173855+00:00 0:09:02.875370 51854 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T12:01:13.789061+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-09T11:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T12:00:44.271433+00:00 2021-07-09T12:00:46.196143+00:00 0:00:01.924710 51853 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-09T12:00:41.760454+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-09T11:00:00+00:00 PythonOperator 2021-07-09T12:00:16.113025+00:00 2021-07-09T12:00:19.876802+00:00 0:00:03.763777 51852 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-09T12:00:13.666945+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-09T10:00:00+00:00 EmrJobFlowSensor 2021-07-09T11:11:17.058441+00:00 2021-07-09T11:23:20.443066+00:00 0:12:03.384625 51850 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T11:11:14.903941+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-09T10:00:00+00:00 EmrJobFlowSensor 2021-07-09T11:11:13.277990+00:00 2021-07-09T11:21:16.296243+00:00 0:10:03.018253 51849 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T11:11:10.960054+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-09T10:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T11:10:53.331987+00:00 2021-07-09T11:10:55.145508+00:00 0:00:01.813521 51848 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T11:10:50.878184+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-09T10:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T11:10:49.455054+00:00 2021-07-09T11:10:51.170909+00:00 0:00:01.715855 51847 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T11:10:46.879466+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-09T10:00:00+00:00 PythonOperator 2021-07-09T11:10:31.026776+00:00 2021-07-09T11:10:35.012593+00:00 0:00:03.985817 51846 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T11:10:28.801416+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-09T10:00:00+00:00 PythonOperator 2021-07-09T11:10:27.206640+00:00 2021-07-09T11:10:30.624316+00:00 0:00:03.417676 51845 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T11:10:24.858549+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-09T10:00:00+00:00 TriggerDagRunOperator 2021-07-09T11:10:17.574389+00:00 2021-07-09T11:10:18.025505+00:00 0:00:00.451116 51844 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T11:10:14.854045+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-09T10:00:00+00:00 TriggerDagRunOperator 2021-07-09T11:10:17.276365+00:00 2021-07-09T11:10:17.836035+00:00 0:00:00.559670 51843 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T11:10:14.853996+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-09T10:05:00+00:00 EmrJobFlowSensor 2021-07-09T11:05:48.357682+00:00 2021-07-09T11:14:50.895740+00:00 0:09:02.538058 51842 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T11:05:46.233899+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-09T10:05:00+00:00 EmrCreateJobFlowOperator 2021-07-09T11:05:26.364936+00:00 2021-07-09T11:05:28.014334+00:00 0:00:01.649398 51841 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T11:05:24.227827+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-09T10:05:00+00:00 PythonOperator 2021-07-09T11:05:06.545112+00:00 2021-07-09T11:05:10.310394+00:00 0:00:03.765282 51840 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T11:05:04.211375+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-09T10:00:00+00:00 EmrJobFlowSensor 2021-07-09T11:01:06.004587+00:00 2021-07-09T11:10:08.878209+00:00 0:09:02.873622 51839 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T11:01:03.820676+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-09T10:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T11:00:44.487347+00:00 2021-07-09T11:00:46.347469+00:00 0:00:01.860122 51838 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-09T11:00:41.869748+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-09T10:00:00+00:00 PythonOperator 2021-07-09T11:00:20.093693+00:00 2021-07-09T11:00:23.854161+00:00 0:00:03.760468 51837 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-09T11:00:17.852221+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-09T09:00:00+00:00 EmrJobFlowSensor 2021-07-09T10:12:51.308028+00:00 2021-07-09T10:22:54.358736+00:00 0:10:03.050708 51836 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T10:12:48.937263+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-09T09:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T10:12:29.365891+00:00 2021-07-09T10:12:31.228623+00:00 0:00:01.862732 51835 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T10:12:26.923083+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-09T09:00:00+00:00 EmrJobFlowSensor 2021-07-09T10:12:21.597475+00:00 2021-07-09T10:21:24.298755+00:00 0:09:02.701280 51834 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T10:12:18.918811+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-09T09:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T10:11:45.179691+00:00 2021-07-09T10:11:46.868668+00:00 0:00:01.688977 51832 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T10:11:42.821427+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-09T09:00:00+00:00 PythonOperator 2021-07-09T10:11:29.357844+00:00 2021-07-09T10:11:33.252230+00:00 0:00:03.894386 51831 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T10:11:26.787348+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-09T09:00:00+00:00 PythonOperator 2021-07-09T10:11:23.531630+00:00 2021-07-09T10:11:27.120403+00:00 0:00:03.588773 51830 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T10:11:20.854017+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-09T09:00:00+00:00 TriggerDagRunOperator 2021-07-09T10:11:06.985551+00:00 2021-07-09T10:11:07.468228+00:00 0:00:00.482677 51829 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T10:11:04.707464+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-09T09:00:00+00:00 TriggerDagRunOperator 2021-07-09T10:11:06.826535+00:00 2021-07-09T10:11:07.240458+00:00 0:00:00.413923 51828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T10:11:04.707431+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-09T09:05:00+00:00 EmrJobFlowSensor 2021-07-09T10:06:06.378358+00:00 2021-07-09T10:15:08.951525+00:00 0:09:02.573167 51827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T10:06:04.272508+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-09T09:05:00+00:00 EmrCreateJobFlowOperator 2021-07-09T10:05:44.783821+00:00 2021-07-09T10:05:46.617320+00:00 0:00:01.833499 51826 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T10:05:42.259156+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-09T09:05:00+00:00 PythonOperator 2021-07-09T10:05:22.630209+00:00 2021-07-09T10:05:26.373220+00:00 0:00:03.743011 51825 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T10:05:20.484260+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-09T09:00:00+00:00 EmrJobFlowSensor 2021-07-09T10:00:48.160349+00:00 2021-07-09T10:10:50.933811+00:00 0:10:02.773462 51824 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T10:00:45.871020+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-09T09:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T10:00:26.289443+00:00 2021-07-09T10:00:27.965099+00:00 0:00:01.675656 51823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-09T10:00:23.941539+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-09T09:00:00+00:00 PythonOperator 2021-07-09T10:00:04.325108+00:00 2021-07-09T10:00:07.841843+00:00 0:00:03.516735 51822 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-09T10:00:01.857262+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-09T08:00:00+00:00 EmrJobFlowSensor 2021-07-09T09:12:26.558470+00:00 2021-07-09T09:22:29.588887+00:00 0:10:03.030417 51821 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T09:12:24.380528+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-09T08:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T09:12:04.749825+00:00 2021-07-09T09:12:06.642540+00:00 0:00:01.892715 51820 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T09:12:02.325326+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-09T08:00:00+00:00 EmrJobFlowSensor 2021-07-09T09:11:55.568166+00:00 2021-07-09T09:21:58.537107+00:00 0:10:02.968941 51819 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T09:11:52.266144+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-09T08:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T09:10:59.578096+00:00 2021-07-09T09:11:01.275693+00:00 0:00:01.697597 51817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T09:10:56.905557+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-09T08:00:00+00:00 PythonOperator 2021-07-09T09:10:51.122854+00:00 2021-07-09T09:10:54.798360+00:00 0:00:03.675506 51816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T09:10:48.910506+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-09T08:00:00+00:00 PythonOperator 2021-07-09T09:10:37.591464+00:00 2021-07-09T09:10:41.786029+00:00 0:00:04.194565 51815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T09:10:34.948745+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-09T08:00:00+00:00 TriggerDagRunOperator 2021-07-09T09:10:29.403438+00:00 2021-07-09T09:10:29.918886+00:00 0:00:00.515448 51814 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T09:10:26.859319+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-09T08:00:00+00:00 TriggerDagRunOperator 2021-07-09T09:10:29.180493+00:00 2021-07-09T09:10:29.585948+00:00 0:00:00.405455 51813 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T09:10:26.859289+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-09T08:05:00+00:00 EmrJobFlowSensor 2021-07-09T09:05:52.536749+00:00 2021-07-09T09:14:55.305122+00:00 0:09:02.768373 51812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T09:05:50.327235+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-09T08:05:00+00:00 EmrCreateJobFlowOperator 2021-07-09T09:05:32.467214+00:00 2021-07-09T09:05:34.171209+00:00 0:00:01.703995 51811 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T09:05:30.310930+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-09T08:05:00+00:00 PythonOperator 2021-07-09T09:05:10.539351+00:00 2021-07-09T09:05:14.318844+00:00 0:00:03.779493 51810 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T09:05:08.290093+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-09T08:00:00+00:00 EmrJobFlowSensor 2021-07-09T09:01:02.557295+00:00 2021-07-09T09:10:05.342943+00:00 0:09:02.785648 51809 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T09:00:59.971336+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-09T08:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T09:00:40.114031+00:00 2021-07-09T09:00:41.854691+00:00 0:00:01.740660 51808 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-09T09:00:37.845624+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-09T08:00:00+00:00 PythonOperator 2021-07-09T09:00:17.894078+00:00 2021-07-09T09:00:21.680644+00:00 0:00:03.786566 51807 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-09T09:00:15.715425+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-07-09T07:00:00+00:00 EmrJobFlowSensor 2021-07-09T08:12:19.365808+00:00 2021-07-09T08:22:22.296051+00:00 0:10:02.930243 51806 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T08:12:16.994678+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-07-09T07:00:00+00:00 EmrJobFlowSensor 2021-07-09T08:12:07.154884+00:00 2021-07-09T08:22:10.247896+00:00 0:10:03.093012 51805 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T08:12:04.949510+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-07-09T07:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T08:11:57.361357+00:00 2021-07-09T08:11:59.172194+00:00 0:00:01.810837 51804 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T08:11:54.943299+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-07-09T07:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T08:11:47.184472+00:00 2021-07-09T08:11:49.071908+00:00 0:00:01.887436 51803 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T08:11:44.935860+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-07-09T07:00:00+00:00 PythonOperator 2021-07-09T08:11:35.091890+00:00 2021-07-09T08:11:39.307428+00:00 0:00:04.215538 51802 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T08:11:32.927075+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-07-09T07:00:00+00:00 PythonOperator 2021-07-09T08:11:25.138337+00:00 2021-07-09T08:11:28.661852+00:00 0:00:03.523515 51801 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T08:11:22.902313+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-07-09T07:00:00+00:00 TriggerDagRunOperator 2021-07-09T08:11:11.599076+00:00 2021-07-09T08:11:12.213391+00:00 0:00:00.614315 51800 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T08:11:08.775678+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-07-09T07:00:00+00:00 TriggerDagRunOperator 2021-07-09T08:11:11.481520+00:00 2021-07-09T08:11:11.875309+00:00 0:00:00.393789 51799 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T08:11:08.775711+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-07-09T07:05:00+00:00 EmrJobFlowSensor 2021-07-09T08:06:06.467283+00:00 2021-07-09T08:15:09.096645+00:00 0:09:02.629362 51797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T08:06:04.392356+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-07-09T07:05:00+00:00 EmrCreateJobFlowOperator 2021-07-09T08:05:44.590314+00:00 2021-07-09T08:05:46.253111+00:00 0:00:01.662797 51796 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T08:05:42.330807+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-07-09T07:05:00+00:00 PythonOperator 2021-07-09T08:05:22.721947+00:00 2021-07-09T08:05:26.367520+00:00 0:00:03.645573 51795 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T08:05:20.357451+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-07-09T07:00:00+00:00 EmrJobFlowSensor 2021-07-09T08:00:52.142273+00:00 2021-07-09T08:10:54.989228+00:00 0:10:02.846955 51794 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T08:00:49.956767+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-07-09T07:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T08:00:30.340052+00:00 2021-07-09T08:00:32.081831+00:00 0:00:01.741779 51793 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-07-09T08:00:27.950814+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-07-09T07:00:00+00:00 PythonOperator 2021-07-09T08:00:08.101791+00:00 2021-07-09T08:00:12.025553+00:00 0:00:03.923762 51792 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-07-09T08:00:05.787341+00:00 2 default_pool