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 missing-dr-check-job_v002 create_cluster_and_add_emr_steps 2020-10-28T07:30:00+00:00 EmrCreateJobFlowOperator 2020-10-29T07:30:20.049498+00:00 2020-10-29T07:30:21.768027+00:00 0:00:01.718529 4830 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-29T07:30:17.969102+00:00 2 default_pool
success daily-import-job_v002 create_cluster_and_add_emr_steps 2020-10-28T07:30:00+00:00 EmrCreateJobFlowOperator 2020-10-29T07:30:15.774893+00:00 2020-10-29T07:30:17.469080+00:00 0:00:01.694187 4829 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-29T07:30:13.984836+00:00 2 default_pool
success missing-dr-check-job_v002 create_emr_steps 2020-10-28T07:30:00+00:00 PythonOperator 2020-10-29T07:30:09.965390+00:00 2020-10-29T07:30:12.630683+00:00 0:00:02.665293 4828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-29T07:30:07.961246+00:00 2 default_pool
success daily-import-job_v002 create_emr_steps 2020-10-28T07:30:00+00:00 PythonOperator 2020-10-29T07:30:05.700353+00:00 2020-10-29T07:30:08.551754+00:00 0:00:02.851401 4827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-29T07:30:03.966712+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-29T06:00:00+00:00 EmrJobFlowSensor 2020-10-29T07:00:50.429957+00:00 2020-10-29T07:12:53.408458+00:00 0:12:02.978501 4826 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-29T07:00:48.305771+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-29T06:00:00+00:00 EmrCreateJobFlowOperator 2020-10-29T07:00:30.377833+00:00 2020-10-29T07:00:32.107123+00:00 0:00:01.729290 4825 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-29T07:00:28.289434+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-29T06:00:00+00:00 PythonOperator 2020-10-29T07:00:12.158290+00:00 2020-10-29T07:00:14.968082+00:00 0:00:02.809792 4824 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-29T07:00:10.271311+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2020-10-29T05:00:00+00:00 EmrJobFlowSensor 2020-10-29T06:46:43.277800+00:00 2020-10-29T06:58:46.288171+00:00 0:12:03.010371 4822 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-29T06:46:41.424312+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2020-10-29T05:00:00+00:00 EmrCreateJobFlowOperator 2020-10-29T06:46:33.394773+00:00 2020-10-29T06:46:35.192203+00:00 0:00:01.797430 4821 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-29T06:46:31.418259+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2020-10-29T05:00:00+00:00 PythonOperator 2020-10-29T06:46:25.165495+00:00 2020-10-29T06:46:27.958495+00:00 0:00:02.793000 4820 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-29T06:46:23.409900+00:00 2 default_pool
success pop-quality-check_v002 check_cluster_status 2020-10-29T05:47:13.908679+00:00 EmrJobFlowSensor 2020-10-29T05:47:51.857813+00:00 2020-10-29T05:57:54.563640+00:00 0:10:02.705827 4819 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-29T05:47:50.087165+00:00 2 default_pool
success pop-quality-check_v002 create_cluster_and_add_emr_steps 2020-10-29T05:47:13.908679+00:00 EmrCreateJobFlowOperator 2020-10-29T05:47:44.031332+00:00 2020-10-29T05:47:45.635110+00:00 0:00:01.603778 4818 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-29T05:47:42.097936+00:00 2 default_pool
success pop-quality-check_v002 create_emr_steps 2020-10-29T05:47:13.908679+00:00 PythonOperator 2020-10-29T05:47:33.847180+00:00 2020-10-29T05:47:36.509720+00:00 0:00:02.662540 4817 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-29T05:47:32.090638+00:00 2 default_pool
success missing-dr-check-job_v002 check_cluster_status 2020-10-29T05:37:49.991290+00:00 EmrJobFlowSensor 2020-10-29T05:38:21.863776+00:00 2020-10-29T05:47:24.477702+00:00 0:09:02.613926 4815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-29T05:38:20.149059+00:00 2 default_pool
success missing-dr-check-job_v002 create_cluster_and_add_emr_steps 2020-10-29T05:37:49.991290+00:00 EmrCreateJobFlowOperator 2020-10-29T05:38:11.805844+00:00 2020-10-29T05:38:13.457281+00:00 0:00:01.651437 4814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-29T05:38:10.117977+00:00 2 default_pool
success missing-dr-check-job_v002 create_emr_steps 2020-10-29T05:37:49.991290+00:00 PythonOperator 2020-10-29T05:38:03.878345+00:00 2020-10-29T05:38:06.552598+00:00 0:00:02.674253 4813 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-29T05:38:02.109467+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-10-27T23:00:00+00:00 EmrJobFlowSensor 2020-10-28T23:00:31.864178+00:00 2020-10-28T23:10:34.620961+00:00 0:10:02.756783 4803 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-28T23:00:30.072958+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-10-27T23:00:00+00:00 EmrCreateJobFlowOperator 2020-10-28T23:00:21.755394+00:00 2020-10-28T23:00:23.443007+00:00 0:00:01.687613 4802 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-28T23:00:20.068179+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-10-27T23:00:00+00:00 PythonOperator 2020-10-28T23:00:12.106323+00:00 2020-10-28T23:00:14.944953+00:00 0:00:02.838630 4801 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-28T23:00:10.058337+00:00 2 default_pool
success 24hrPOP-Aggregator-ModelTransform_v002 check_cluster_status 2020-10-28T14:52:21.186140+00:00 EmrJobFlowSensor 2020-10-28T14:52:52.809302+00:00 2020-10-28T15:14:57.137454+00:00 0:22:04.328152 4792 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-28T14:52:50.998759+00:00 2 default_pool
success 24hrPOP-Aggregator-ModelTransform_v002 create_cluster_and_add_emr_steps 2020-10-28T14:52:21.186140+00:00 EmrCreateJobFlowOperator 2020-10-28T14:52:42.727225+00:00 2020-10-28T14:52:44.438404+00:00 0:00:01.711179 4791 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-28T14:52:40.978015+00:00 2 default_pool
success 24hrPOP-Aggregator-ModelTransform_v002 create_emr_steps 2020-10-28T14:52:21.186140+00:00 PythonOperator 2020-10-28T14:52:32.703268+00:00 2020-10-28T14:52:35.386795+00:00 0:00:02.683527 4790 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-28T14:52:30.983201+00:00 2 default_pool
success 24hrPOP-Aggregator-ModelTransform_v002 check_cluster_status 2020-10-28T12:21:59.155676+00:00 EmrJobFlowSensor 2020-10-28T12:22:24.240339+00:00 2020-10-28T12:44:28.630710+00:00 0:22:04.390371 4786 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-28T12:22:22.486027+00:00 2 default_pool
success 24hrPOP-Aggregator-ModelTransform_v002 create_cluster_and_add_emr_steps 2020-10-28T12:21:59.155676+00:00 EmrCreateJobFlowOperator 2020-10-28T12:22:14.600107+00:00 2020-10-28T12:22:16.363150+00:00 0:00:01.763043 4785 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-28T12:22:12.449979+00:00 2 default_pool
success 24hrPOP-Aggregator-ModelTransform_v002 create_emr_steps 2020-10-28T12:21:59.155676+00:00 PythonOperator 2020-10-28T12:22:04.653926+00:00 2020-10-28T12:22:07.189453+00:00 0:00:02.535527 4784 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-28T12:22:02.440667+00:00 2 default_pool
success 24hrPOP-Aggregator-ModelTransform_v002 check_cluster_status 2020-10-28T12:06:44.200219+00:00 EmrJobFlowSensor 2020-10-28T12:07:11.250151+00:00 2020-10-28T12:17:14.171836+00:00 0:10:02.921685 4783 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-28T12:07:09.355284+00:00 2 default_pool
success 24hrPOP-Aggregator-ModelTransform_v002 create_cluster_and_add_emr_steps 2020-10-28T12:06:44.200219+00:00 EmrCreateJobFlowOperator 2020-10-28T12:07:01.102493+00:00 2020-10-28T12:07:02.836493+00:00 0:00:01.734000 4782 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-28T12:06:59.356194+00:00 2 default_pool
success 24hrPOP-Aggregator-ModelTransform_v002 create_emr_steps 2020-10-28T12:06:44.200219+00:00 PythonOperator 2020-10-28T12:06:51.195231+00:00 2020-10-28T12:06:53.712576+00:00 0:00:02.517345 4781 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-28T12:06:49.443524+00:00 2 default_pool
failed 24hrPOP-Aggregator-ModelTransform_v002 check_cluster_status 2020-10-28T11:57:19.054035+00:00 EmrJobFlowSensor 2020-10-28T11:57:50.721583+00:00 2020-10-28T12:07:53.503529+00:00 0:10:02.781946 4780 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-28T11:57:48.759406+00:00 2 default_pool
success 24hrPOP-Aggregator-ModelTransform_v002 create_cluster_and_add_emr_steps 2020-10-28T11:57:19.054035+00:00 EmrCreateJobFlowOperator 2020-10-28T11:57:40.438560+00:00 2020-10-28T11:57:42.105417+00:00 0:00:01.666857 4779 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-28T11:57:38.725848+00:00 2 default_pool
success 24hrPOP-Aggregator-ModelTransform_v002 create_emr_steps 2020-10-28T11:57:19.054035+00:00 PythonOperator 2020-10-28T11:57:30.958182+00:00 2020-10-28T11:57:33.535343+00:00 0:00:02.577161 4778 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-28T11:57:28.720214+00:00 2 default_pool
success drm-migration-job_v002 check_cluster_status 2020-10-28T10:20:00+00:00 EmrJobFlowSensor 2020-10-28T11:20:32.088179+00:00 2020-10-28T11:30:34.963416+00:00 0:10:02.875237 4776 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-28T11:20:29.970553+00:00 2 default_pool
success drm-migration-job_v002 create_cluster_and_add_emr_steps 2020-10-28T10:20:00+00:00 EmrCreateJobFlowOperator 2020-10-28T11:20:21.881505+00:00 2020-10-28T11:20:23.555208+00:00 0:00:01.673703 4775 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-28T11:20:19.952404+00:00 2 default_pool
success drm-migration-job_v002 create_emr_steps 2020-10-28T10:20:00+00:00 PythonOperator 2020-10-28T11:20:11.714754+00:00 2020-10-28T11:20:14.358418+00:00 0:00:02.643664 4774 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-28T11:20:09.974188+00:00 2 default_pool
success drm-migration-job_v002 check_cluster_status 2020-10-28T09:20:00+00:00 EmrJobFlowSensor 2020-10-28T10:20:45.643350+00:00 2020-10-28T10:29:48.311257+00:00 0:09:02.667907 4772 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-28T10:20:43.466749+00:00 2 default_pool
success drm-migration-job_v002 create_cluster_and_add_emr_steps 2020-10-28T09:20:00+00:00 EmrCreateJobFlowOperator 2020-10-28T10:20:27.083346+00:00 2020-10-28T10:20:28.708636+00:00 0:00:01.625290 4771 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-28T10:20:25.379577+00:00 2 default_pool
success drm-migration-job_v002 create_emr_steps 2020-10-28T09:20:00+00:00 PythonOperator 2020-10-28T10:20:07.997373+00:00 2020-10-28T10:20:11.044934+00:00 0:00:03.047561 4770 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-28T10:20:05.349992+00:00 2 default_pool
success drm-migration-job_v002 check_cluster_status 2020-10-28T08:20:00+00:00 EmrJobFlowSensor 2020-10-28T09:20:23.396564+00:00 2020-10-28T09:30:26.169567+00:00 0:10:02.773003 4768 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-28T09:20:21.690444+00:00 2 default_pool
success drm-migration-job_v002 create_cluster_and_add_emr_steps 2020-10-28T08:20:00+00:00 EmrCreateJobFlowOperator 2020-10-28T09:20:15.423770+00:00 2020-10-28T09:20:17.084254+00:00 0:00:01.660484 4767 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-28T09:20:13.688135+00:00 2 default_pool
success drm-migration-job_v002 create_emr_steps 2020-10-28T08:20:00+00:00 PythonOperator 2020-10-28T09:20:05.491316+00:00 2020-10-28T09:20:08.155721+00:00 0:00:02.664405 4766 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-28T09:20:03.691730+00:00 2 default_pool
success drm-migration-job_v002 check_cluster_status 2020-10-28T07:20:00+00:00 EmrJobFlowSensor 2020-10-28T08:20:26.969564+00:00 2020-10-28T08:29:29.567743+00:00 0:09:02.598179 4764 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-28T08:20:25.009528+00:00 2 default_pool
success drm-migration-job_v002 create_cluster_and_add_emr_steps 2020-10-28T07:20:00+00:00 EmrCreateJobFlowOperator 2020-10-28T08:20:16.641737+00:00 2020-10-28T08:20:18.298831+00:00 0:00:01.657094 4763 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-28T08:20:15.003250+00:00 2 default_pool
success drm-migration-job_v002 create_emr_steps 2020-10-28T07:20:00+00:00 PythonOperator 2020-10-28T08:20:08.755766+00:00 2020-10-28T08:20:11.380792+00:00 0:00:02.625026 4762 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-28T08:20:06.993420+00:00 2 default_pool
success daily-import-job_v002 check_cluster_status 2020-10-27T07:30:00+00:00 EmrJobFlowSensor 2020-10-28T07:30:30.591750+00:00 2020-10-28T07:40:33.350001+00:00 0:10:02.758251 4760 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-28T07:30:28.663615+00:00 2 default_pool
success daily-import-job_v002 create_cluster_and_add_emr_steps 2020-10-27T07:30:00+00:00 EmrCreateJobFlowOperator 2020-10-28T07:30:20.458080+00:00 2020-10-28T07:30:22.127936+00:00 0:00:01.669856 4759 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-28T07:30:18.657697+00:00 2 default_pool
success daily-import-job_v002 create_emr_steps 2020-10-27T07:30:00+00:00 PythonOperator 2020-10-28T07:30:12.328229+00:00 2020-10-28T07:30:14.942972+00:00 0:00:02.614743 4758 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-28T07:30:10.631413+00:00 2 default_pool
success drm-migration-job_v002 check_cluster_status 2020-10-28T06:20:00+00:00 EmrJobFlowSensor 2020-10-28T07:20:31.828210+00:00 2020-10-28T07:29:34.504330+00:00 0:09:02.676120 4757 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-28T07:20:30.094563+00:00 2 default_pool
success drm-migration-job_v002 create_cluster_and_add_emr_steps 2020-10-28T06:20:00+00:00 EmrCreateJobFlowOperator 2020-10-28T07:20:21.726413+00:00 2020-10-28T07:20:23.408499+00:00 0:00:01.682086 4756 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-28T07:20:20.081215+00:00 2 default_pool
success drm-migration-job_v002 create_emr_steps 2020-10-28T06:20:00+00:00 PythonOperator 2020-10-28T07:20:13.810111+00:00 2020-10-28T07:20:16.445813+00:00 0:00:02.635702 4755 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-28T07:20:12.077794+00:00 2 default_pool
success drm-migration-job_v002 check_cluster_status 2020-10-28T05:20:00+00:00 EmrJobFlowSensor 2020-10-28T06:20:24.795615+00:00 2020-10-28T06:30:27.491384+00:00 0:10:02.695769 4753 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-28T06:20:23.077360+00:00 2 default_pool
success drm-migration-job_v002 create_cluster_and_add_emr_steps 2020-10-28T05:20:00+00:00 EmrCreateJobFlowOperator 2020-10-28T06:20:16.838565+00:00 2020-10-28T06:20:18.476362+00:00 0:00:01.637797 4752 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-28T06:20:15.055059+00:00 2 default_pool
success drm-migration-job_v002 create_emr_steps 2020-10-28T05:20:00+00:00 PythonOperator 2020-10-28T06:20:06.810988+00:00 2020-10-28T06:20:09.500439+00:00 0:00:02.689451 4751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-28T06:20:05.041609+00:00 2 default_pool
success drm-migration-job_v002 check_cluster_status 2020-10-28T06:16:29.002217+00:00 EmrJobFlowSensor 2020-10-28T06:16:56.503377+00:00 2020-10-28T06:25:59.083382+00:00 0:09:02.580005 4750 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-28T06:16:54.862734+00:00 2 default_pool
success drm-migration-job_v002 create_cluster_and_add_emr_steps 2020-10-28T06:16:29.002217+00:00 EmrCreateJobFlowOperator 2020-10-28T06:16:46.521196+00:00 2020-10-28T06:16:48.230915+00:00 0:00:01.709719 4749 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-28T06:16:44.851927+00:00 2 default_pool
success drm-migration-job_v002 create_emr_steps 2020-10-28T06:16:29.002217+00:00 PythonOperator 2020-10-28T06:16:36.674023+00:00 2020-10-28T06:16:39.435498+00:00 0:00:02.761475 4748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-28T06:16:34.844663+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2020-10-28T05:53:08.161941+00:00 EmrJobFlowSensor 2020-10-28T05:53:33.183854+00:00 2020-10-28T06:03:35.852089+00:00 0:10:02.668235 4747 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-28T05:53:31.567302+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2020-10-28T05:53:08.161941+00:00 EmrCreateJobFlowOperator 2020-10-28T05:53:23.440565+00:00 2020-10-28T05:53:25.083576+00:00 0:00:01.643011 4746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-28T05:53:21.559233+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2020-10-28T05:53:08.161941+00:00 PythonOperator 2020-10-28T05:53:13.224286+00:00 2020-10-28T05:53:16.029749+00:00 0:00:02.805463 4745 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-28T05:53:11.547974+00:00 2 default_pool
success drm-migration-job_v002 check_cluster_status 2020-10-28T05:40:53.461294+00:00 EmrJobFlowSensor 2020-10-28T05:41:20.636507+00:00 2020-10-28T05:50:23.187956+00:00 0:09:02.551449 4744 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-28T05:41:18.880013+00:00 2 default_pool
success drm-migration-job_v002 create_cluster_and_add_emr_steps 2020-10-28T05:40:53.461294+00:00 EmrCreateJobFlowOperator 2020-10-28T05:41:12.562756+00:00 2020-10-28T05:41:14.417432+00:00 0:00:01.854676 4743 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-28T05:41:10.918603+00:00 2 default_pool
success drm-migration-job_v002 check_cluster_status 2020-10-28T04:20:00+00:00 EmrJobFlowSensor 2020-10-28T05:41:02.681056+00:00 2020-10-28T05:43:04.390655+00:00 0:02:01.709599 4742 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-28T05:41:00.855663+00:00 2 default_pool
success drm-migration-job_v002 create_emr_steps 2020-10-28T05:40:53.461294+00:00 PythonOperator 2020-10-28T05:41:02.633069+00:00 2020-10-28T05:41:05.339952+00:00 0:00:02.706883 4741 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-28T05:41:00.855693+00:00 2 default_pool
success drm-migration-job_v002 create_cluster_and_add_emr_steps 2020-10-28T04:20:00+00:00 EmrCreateJobFlowOperator 2020-10-28T05:40:52.654064+00:00 2020-10-28T05:40:54.317084+00:00 0:00:01.663020 4740 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-28T05:40:50.847873+00:00 2 default_pool
success drm-migration-job_v002 create_emr_steps 2020-10-28T04:20:00+00:00 PythonOperator 2020-10-28T05:40:42.582205+00:00 2020-10-28T05:40:45.291242+00:00 0:00:02.709037 4739 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-28T05:40:40.837368+00:00 2 default_pool
success daily-import-job_v002 check_cluster_status 2020-10-28T05:24:34.309963+00:00 EmrJobFlowSensor 2020-10-28T05:25:04.368161+00:00 2020-10-28T05:35:07.064554+00:00 0:10:02.696393 4737 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-28T05:25:02.557570+00:00 2 default_pool
success daily-import-job_v002 create_cluster_and_add_emr_steps 2020-10-28T05:24:34.309963+00:00 EmrCreateJobFlowOperator 2020-10-28T05:24:54.562672+00:00 2020-10-28T05:24:56.280003+00:00 0:00:01.717331 4736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-28T05:24:52.544891+00:00 2 default_pool
success daily-import-job_v002 create_emr_steps 2020-10-28T05:24:34.309963+00:00 PythonOperator 2020-10-28T05:24:44.243174+00:00 2020-10-28T05:24:46.881590+00:00 0:00:02.638416 4735 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-28T05:24:42.543748+00:00 2 default_pool
success campaign-delta-job_v002 check_cluster_status 2020-10-28T05:21:44.098825+00:00 EmrJobFlowSensor 2020-10-28T05:22:08.188472+00:00 2020-10-28T05:34:11.200217+00:00 0:12:03.011745 4734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-28T05:22:06.404859+00:00 2 default_pool
success campaign-delta-job_v002 create_cluster_and_add_emr_steps 2020-10-28T05:21:44.098825+00:00 EmrCreateJobFlowOperator 2020-10-28T05:21:58.134364+00:00 2020-10-28T05:21:59.814481+00:00 0:00:01.680117 4733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-28T05:21:56.372764+00:00 2 default_pool
success campaign-delta-job_v002 create_emr_steps 2020-10-28T05:21:44.098825+00:00 PythonOperator 2020-10-28T05:21:47.988993+00:00 2020-10-28T05:21:50.717798+00:00 0:00:02.728805 4732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-28T05:21:46.380263+00:00 2 default_pool
success campaign-delta-job_v002 check_cluster_status 2020-10-28T05:07:27.403339+00:00 EmrJobFlowSensor 2020-10-28T05:07:53.203517+00:00 2020-10-28T05:17:55.903725+00:00 0:10:02.700208 4731 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-28T05:07:51.569100+00:00 2 default_pool
success campaign-delta-job_v002 create_cluster_and_add_emr_steps 2020-10-28T05:07:27.403339+00:00 EmrCreateJobFlowOperator 2020-10-28T05:07:45.327106+00:00 2020-10-28T05:07:46.934757+00:00 0:00:01.607651 4730 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-28T05:07:43.564083+00:00 2 default_pool
success campaign-delta-job_v002 create_emr_steps 2020-10-28T05:07:27.403339+00:00 PythonOperator 2020-10-28T05:07:35.226559+00:00 2020-10-28T05:07:37.944592+00:00 0:00:02.718033 4729 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-28T05:07:33.551815+00:00 2 default_pool
success campaign-delta-job_v002 check_cluster_status 2020-10-28T04:50:27.624008+00:00 EmrJobFlowSensor 2020-10-28T04:50:58.387993+00:00 2020-10-28T05:02:01.317869+00:00 0:11:02.929876 4728 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-28T04:50:56.636198+00:00 2 default_pool
success campaign-delta-job_v002 create_cluster_and_add_emr_steps 2020-10-28T04:50:27.624008+00:00 EmrCreateJobFlowOperator 2020-10-28T04:50:48.462858+00:00 2020-10-28T04:50:50.146126+00:00 0:00:01.683268 4727 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-28T04:50:46.634552+00:00 2 default_pool
success campaign-delta-job_v002 create_emr_steps 2020-10-28T04:50:27.624008+00:00 PythonOperator 2020-10-28T04:50:40.304693+00:00 2020-10-28T04:50:43.026196+00:00 0:00:02.721503 4726 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-28T04:50:38.625351+00:00 2 default_pool
success campaign-delta-job_v002 check_cluster_status 2020-10-28T04:42:29.678537+00:00 EmrJobFlowSensor 2020-10-28T04:42:54.091701+00:00 2020-10-28T04:51:56.584718+00:00 0:09:02.493017 4725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-28T04:42:52.216585+00:00 2 default_pool
success campaign-delta-job_v002 create_cluster_and_add_emr_steps 2020-10-28T04:42:29.678537+00:00 EmrCreateJobFlowOperator 2020-10-28T04:42:43.957240+00:00 2020-10-28T04:42:45.636597+00:00 0:00:01.679357 4724 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-28T04:42:42.195053+00:00 2 default_pool
success campaign-delta-job_v002 create_emr_steps 2020-10-28T04:42:29.678537+00:00 PythonOperator 2020-10-28T04:42:35.919286+00:00 2020-10-28T04:42:38.627052+00:00 0:00:02.707766 4723 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-28T04:42:34.190648+00:00 2 default_pool
success campaign-delta-job_v002 check_cluster_status 2020-10-28T04:12:39.241180+00:00 EmrJobFlowSensor 2020-10-28T04:13:04.984617+00:00 2020-10-28T04:25:07.841097+00:00 0:12:02.856480 4721 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-28T04:13:03.154420+00:00 2 default_pool
success campaign-delta-job_v002 create_cluster_and_add_emr_steps 2020-10-28T04:12:39.241180+00:00 EmrCreateJobFlowOperator 2020-10-28T04:12:55.106446+00:00 2020-10-28T04:12:56.717089+00:00 0:00:01.610643 4720 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-28T04:12:53.157982+00:00 2 default_pool
success campaign-delta-job_v002 create_emr_steps 2020-10-28T04:12:39.241180+00:00 PythonOperator 2020-10-28T04:12:44.942947+00:00 2020-10-28T04:12:47.724820+00:00 0:00:02.781873 4719 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-28T04:12:43.155777+00:00 2 default_pool
success daily-import-job_v002 check_cluster_status 2020-10-27T04:30:04.247874+00:00 EmrJobFlowSensor 2020-10-27T10:52:50.711061+00:00 2020-10-27T11:09:54.376410+00:00 0:17:03.665349 4701 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-27T10:52:48.856616+00:00 5 default_pool
success daily-import-job_v002 create_cluster_and_add_emr_steps 2020-10-27T04:30:04.247874+00:00 EmrCreateJobFlowOperator 2020-10-27T10:52:42.531910+00:00 2020-10-27T10:52:44.213929+00:00 0:00:01.682019 4700 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-27T10:52:40.847090+00:00 5 default_pool
success daily-import-job_v002 create_emr_steps 2020-10-27T04:30:04.247874+00:00 PythonOperator 2020-10-27T10:52:32.659476+00:00 2020-10-27T10:52:35.428744+00:00 0:00:02.769268 4699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-27T10:52:30.846140+00:00 5 default_pool
success campaign-versioning-job_v002 check_cluster_status 2020-10-26T12:00:24.579041+00:00 EmrJobFlowSensor 2020-10-27T10:38:21.702888+00:00 2020-10-27T10:48:24.420654+00:00 0:10:02.717766 4698 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-27T10:38:20.043738+00:00 4 default_pool
success campaign-versioning-job_v002 create_cluster_and_add_emr_steps 2020-10-26T12:00:24.579041+00:00 EmrCreateJobFlowOperator 2020-10-27T10:38:14.133387+00:00 2020-10-27T10:38:15.810797+00:00 0:00:01.677410 4697 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-27T10:38:12.033525+00:00 4 default_pool
success campaign-versioning-job_v002 create_emr_steps 2020-10-26T12:00:24.579041+00:00 PythonOperator 2020-10-27T10:38:03.964862+00:00 2020-10-27T10:38:06.489631+00:00 0:00:02.524769 4696 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-27T10:38:02.021225+00:00 4 default_pool
success campaign-delta-job_v002 check_cluster_status 2020-10-27T08:51:16.826478+00:00 EmrJobFlowSensor 2020-10-27T08:51:45.256385+00:00 2020-10-27T09:01:48.043268+00:00 0:10:02.786883 4690 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-27T08:51:43.308421+00:00 2 default_pool
success campaign-delta-job_v002 create_cluster_and_add_emr_steps 2020-10-27T08:51:16.826478+00:00 EmrCreateJobFlowOperator 2020-10-27T08:51:35.625958+00:00 2020-10-27T08:51:37.323274+00:00 0:00:01.697316 4689 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-27T08:51:33.287447+00:00 2 default_pool
success campaign-delta-job_v002 create_emr_steps 2020-10-27T08:51:16.826478+00:00 PythonOperator 2020-10-27T08:51:25.280911+00:00 2020-10-27T08:51:28.022577+00:00 0:00:02.741666 4688 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-27T08:51:23.369400+00:00 2 default_pool
success campaign-delta-job_v002 check_cluster_status 2020-10-27T08:21:37.361079+00:00 EmrJobFlowSensor 2020-10-27T08:22:09.449308+00:00 2020-10-27T08:31:12.096020+00:00 0:09:02.646712 4686 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-27T08:22:07.680425+00:00 2 default_pool
success campaign-delta-job_v002 create_cluster_and_add_emr_steps 2020-10-27T08:21:37.361079+00:00 EmrCreateJobFlowOperator 2020-10-27T08:21:59.575016+00:00 2020-10-27T08:22:01.282514+00:00 0:00:01.707498 4685 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-27T08:21:57.662570+00:00 2 default_pool
success campaign-delta-job_v002 create_emr_steps 2020-10-27T08:21:37.361079+00:00 PythonOperator 2020-10-27T08:21:49.521128+00:00 2020-10-27T08:21:52.292720+00:00 0:00:02.771592 4684 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-27T08:21:47.657079+00:00 2 default_pool
success campaign-delta-job_v002 check_cluster_status 2020-10-27T08:09:18.813936+00:00 EmrJobFlowSensor 2020-10-27T08:09:46.668385+00:00 2020-10-27T08:19:49.579216+00:00 0:10:02.910831 4683 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-27T08:09:44.820823+00:00 2 default_pool
success campaign-delta-job_v002 create_cluster_and_add_emr_steps 2020-10-27T08:09:18.813936+00:00 EmrCreateJobFlowOperator 2020-10-27T08:09:36.530189+00:00 2020-10-27T08:09:38.164754+00:00 0:00:01.634565 4682 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-27T08:09:34.803665+00:00 2 default_pool
success campaign-delta-job_v002 create_emr_steps 2020-10-27T08:09:18.813936+00:00 PythonOperator 2020-10-27T08:09:28.776262+00:00 2020-10-27T08:09:31.578634+00:00 0:00:02.802372 4681 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-27T08:09:26.790414+00:00 2 default_pool
success daily-import-job_v002 check_cluster_status 2020-10-26T07:30:00+00:00 EmrJobFlowSensor 2020-10-27T07:30:28.238102+00:00 2020-10-27T07:48:32.067743+00:00 0:18:03.829641 4679 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2020-10-27T07:30:26.534343+00:00 2 default_pool
success daily-import-job_v002 create_cluster_and_add_emr_steps 2020-10-26T07:30:00+00:00 EmrCreateJobFlowOperator 2020-10-27T07:30:20.728027+00:00 2020-10-27T07:30:22.391439+00:00 0:00:01.663412 4678 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2020-10-27T07:30:18.520094+00:00 2 default_pool
success daily-import-job_v002 create_emr_steps 2020-10-26T07:30:00+00:00 PythonOperator 2020-10-27T07:30:10.648137+00:00 2020-10-27T07:30:13.455875+00:00 0:00:02.807738 4677 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2020-10-27T07:30:08.508573+00:00 2 default_pool