Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success vc-asset-import_v002 check_cluster_status 2021-03-23T06:05:00+00:00 EmrJobFlowSensor 2021-03-23T07:05:58.495462+00:00 2021-03-23T07:16:01.192580+00:00 0:10:02.697118 10803 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T07:05:56.306354+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T06:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T07:05:36.684544+00:00 2021-03-23T07:05:38.346131+00:00 0:00:01.661587 10802 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T07:05:34.360012+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T06:05:00+00:00 PythonOperator 2021-03-23T07:05:14.635839+00:00 2021-03-23T07:05:17.325809+00:00 0:00:02.689970 10801 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T07:05:12.350039+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T06:00:00+00:00 EmrJobFlowSensor 2021-03-23T07:00:50.028392+00:00 2021-03-23T07:09:52.772611+00:00 0:09:02.744219 10800 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T07:00:47.722505+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T07:00:28.347051+00:00 2021-03-23T07:00:30.069536+00:00 0:00:01.722485 10799 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T07:00:25.757958+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T06:00:00+00:00 PythonOperator 2021-03-23T07:00:06.012441+00:00 2021-03-23T07:00:08.840317+00:00 0:00:02.827876 10798 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T07:00:03.704508+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-22T23:00:00+00:00 EmrJobFlowSensor 2021-03-23T06:44:26.586371+00:00 2021-03-23T07:19:32.632694+00:00 0:35:06.046323 10797 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T06:44:24.270552+00:00 3 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-22T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T06:44:04.663347+00:00 2021-03-23T06:44:06.444463+00:00 0:00:01.781116 10796 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T06:44:02.264813+00:00 3 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-23T03:00:00+00:00 PythonOperator 2021-03-23T06:44:04.629289+00:00 2021-03-23T06:44:07.688156+00:00 0:00:03.058867 10795 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T06:44:02.264784+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T23:00:00+00:00 PythonOperator 2021-03-23T06:43:42.539031+00:00 2021-03-23T06:43:45.647579+00:00 0:00:03.108548 10794 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T06:43:40.192749+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T05:00:00+00:00 EmrJobFlowSensor 2021-03-23T06:12:55.551298+00:00 2021-03-23T06:20:58.044095+00:00 0:08:02.492797 10792 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T06:12:53.253518+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T06:12:31.656802+00:00 2021-03-23T06:12:33.446867+00:00 0:00:01.790065 10791 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T06:12:29.289747+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T05:00:00+00:00 PythonOperator 2021-03-23T06:12:09.449376+00:00 2021-03-23T06:12:12.285957+00:00 0:00:02.836581 10790 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T06:12:07.211949+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T05:00:00+00:00 TriggerDagRunOperator 2021-03-23T06:12:04.153308+00:00 2021-03-23T06:12:04.529261+00:00 0:00:00.375953 10789 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T06:12:01.266521+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T05:00:00+00:00 TriggerDagRunOperator 2021-03-23T06:12:03.771301+00:00 2021-03-23T06:12:04.319144+00:00 0:00:00.547843 10788 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T06:12:01.266557+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T05:05:00+00:00 EmrJobFlowSensor 2021-03-23T06:05:50.846636+00:00 2021-03-23T06:16:53.814608+00:00 0:11:02.967972 10787 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T06:05:48.582265+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T05:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T06:05:28.662315+00:00 2021-03-23T06:05:30.304388+00:00 0:00:01.642073 10786 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T06:05:26.507950+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T05:05:00+00:00 PythonOperator 2021-03-23T06:05:06.755755+00:00 2021-03-23T06:05:09.468766+00:00 0:00:02.713011 10785 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T06:05:04.559024+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T05:00:00+00:00 EmrJobFlowSensor 2021-03-23T06:01:50.582112+00:00 2021-03-23T06:11:53.327189+00:00 0:10:02.745077 10784 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T06:01:48.240326+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T06:01:22.364785+00:00 2021-03-23T06:01:24.327936+00:00 0:00:01.963151 10783 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T06:01:20.101053+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T05:00:00+00:00 PythonOperator 2021-03-23T06:00:04.316586+00:00 2021-03-23T06:00:07.037810+00:00 0:00:02.721224 10782 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T06:00:01.996634+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T04:00:00+00:00 EmrJobFlowSensor 2021-03-23T05:13:12.531506+00:00 2021-03-23T05:21:15.212428+00:00 0:08:02.680922 10780 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T05:13:10.354710+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T05:12:50.500553+00:00 2021-03-23T05:12:52.153785+00:00 0:00:01.653232 10779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T05:12:48.336230+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T04:00:00+00:00 PythonOperator 2021-03-23T05:12:30.911283+00:00 2021-03-23T05:12:33.670744+00:00 0:00:02.759461 10778 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T05:12:28.366101+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T04:00:00+00:00 TriggerDagRunOperator 2021-03-23T05:12:23.070421+00:00 2021-03-23T05:12:23.751624+00:00 0:00:00.681203 10777 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T05:12:20.370362+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T04:00:00+00:00 TriggerDagRunOperator 2021-03-23T05:12:22.930586+00:00 2021-03-23T05:12:23.329876+00:00 0:00:00.399290 10776 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T05:12:20.370331+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T04:05:00+00:00 EmrJobFlowSensor 2021-03-23T05:06:00.307889+00:00 2021-03-23T05:16:03.112099+00:00 0:10:02.804210 10775 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T05:05:57.965012+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T04:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T05:05:38.030371+00:00 2021-03-23T05:05:39.806961+00:00 0:00:01.776590 10774 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T05:05:35.811945+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T04:05:00+00:00 PythonOperator 2021-03-23T05:05:15.978429+00:00 2021-03-23T05:05:18.673014+00:00 0:00:02.694585 10773 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T05:05:13.791719+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T04:00:00+00:00 EmrJobFlowSensor 2021-03-23T05:01:03.705731+00:00 2021-03-23T05:12:06.737324+00:00 0:11:03.031593 10772 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T05:01:01.335389+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T05:00:41.600413+00:00 2021-03-23T05:00:43.400695+00:00 0:00:01.800282 10771 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T05:00:39.231996+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T04:00:00+00:00 PythonOperator 2021-03-23T05:00:19.751760+00:00 2021-03-23T05:00:22.627792+00:00 0:00:02.876032 10770 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T05:00:17.213966+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T03:00:00+00:00 EmrJobFlowSensor 2021-03-23T04:11:26.013437+00:00 2021-03-23T04:21:28.761252+00:00 0:10:02.747815 10768 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T04:11:23.796599+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T03:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T04:11:04.097876+00:00 2021-03-23T04:11:05.778094+00:00 0:00:01.680218 10767 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T04:11:01.775621+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T03:00:00+00:00 PythonOperator 2021-03-23T04:10:42.015682+00:00 2021-03-23T04:10:44.737328+00:00 0:00:02.721646 10766 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T04:10:39.755657+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T03:00:00+00:00 TriggerDagRunOperator 2021-03-23T04:10:24.330420+00:00 2021-03-23T04:10:24.760048+00:00 0:00:00.429628 10765 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T04:10:21.687787+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T03:00:00+00:00 TriggerDagRunOperator 2021-03-23T04:10:24.067713+00:00 2021-03-23T04:10:24.671149+00:00 0:00:00.603436 10764 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T04:10:21.687754+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T03:05:00+00:00 EmrJobFlowSensor 2021-03-23T04:05:57.456616+00:00 2021-03-23T04:15:00.232640+00:00 0:09:02.776024 10763 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T04:05:55.265259+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T03:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T04:05:33.401151+00:00 2021-03-23T04:05:35.151338+00:00 0:00:01.750187 10762 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T04:05:31.236000+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T03:05:00+00:00 PythonOperator 2021-03-23T04:05:11.323465+00:00 2021-03-23T04:05:14.062074+00:00 0:00:02.738609 10761 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T04:05:09.191056+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T03:00:00+00:00 EmrJobFlowSensor 2021-03-23T04:01:14.888044+00:00 2021-03-23T04:10:17.561146+00:00 0:09:02.673102 10760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T04:01:12.717049+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T03:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T04:00:54.905277+00:00 2021-03-23T04:00:56.656716+00:00 0:00:01.751439 10759 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T04:00:52.706173+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T03:00:00+00:00 PythonOperator 2021-03-23T04:00:33.103305+00:00 2021-03-23T04:00:35.879847+00:00 0:00:02.776542 10758 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T04:00:30.740769+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T02:00:00+00:00 EmrJobFlowSensor 2021-03-23T03:13:20.272622+00:00 2021-03-23T03:22:22.794847+00:00 0:09:02.522225 10757 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T03:13:17.954596+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T02:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T03:12:57.976564+00:00 2021-03-23T03:12:59.669657+00:00 0:00:01.693093 10756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T03:12:55.835997+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T02:00:00+00:00 PythonOperator 2021-03-23T03:12:38.061030+00:00 2021-03-23T03:12:40.800783+00:00 0:00:02.739753 10755 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T03:12:35.818318+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T02:00:00+00:00 TriggerDagRunOperator 2021-03-23T03:12:12.519579+00:00 2021-03-23T03:12:13.009634+00:00 0:00:00.490055 10754 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T03:12:09.601261+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T02:00:00+00:00 TriggerDagRunOperator 2021-03-23T03:12:12.424785+00:00 2021-03-23T03:12:12.898437+00:00 0:00:00.473652 10753 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T03:12:09.601298+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T02:05:00+00:00 EmrJobFlowSensor 2021-03-23T03:05:52.271689+00:00 2021-03-23T03:15:54.943087+00:00 0:10:02.671398 10751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T03:05:50.104477+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T02:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T03:05:30.703185+00:00 2021-03-23T03:05:32.365782+00:00 0:00:01.662597 10750 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T03:05:28.169016+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T02:05:00+00:00 PythonOperator 2021-03-23T03:05:08.145748+00:00 2021-03-23T03:05:10.816616+00:00 0:00:02.670868 10749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T03:05:05.990821+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T02:00:00+00:00 EmrJobFlowSensor 2021-03-23T03:01:06.122331+00:00 2021-03-23T03:10:08.654490+00:00 0:09:02.532159 10748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T03:01:03.663515+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T02:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T03:00:46.128957+00:00 2021-03-23T03:00:47.898393+00:00 0:00:01.769436 10747 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T03:00:43.655329+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T02:00:00+00:00 PythonOperator 2021-03-23T03:00:23.923214+00:00 2021-03-23T03:00:26.717575+00:00 0:00:02.794361 10746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T03:00:21.550491+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T01:00:00+00:00 EmrJobFlowSensor 2021-03-23T02:12:17.127159+00:00 2021-03-23T02:22:20.033678+00:00 0:10:02.906519 10745 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T02:12:14.948520+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T02:11:55.276397+00:00 2021-03-23T02:11:57.006403+00:00 0:00:01.730006 10744 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T02:11:52.878013+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T01:00:00+00:00 PythonOperator 2021-03-23T02:11:29.213376+00:00 2021-03-23T02:11:31.975266+00:00 0:00:02.761890 10743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T02:11:26.866482+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T01:00:00+00:00 TriggerDagRunOperator 2021-03-23T02:11:06.023957+00:00 2021-03-23T02:11:06.428076+00:00 0:00:00.404119 10742 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T02:11:02.857603+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T01:00:00+00:00 TriggerDagRunOperator 2021-03-23T02:11:05.676324+00:00 2021-03-23T02:11:06.201968+00:00 0:00:00.525644 10741 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T02:11:02.857649+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T01:05:00+00:00 EmrJobFlowSensor 2021-03-23T02:06:00.718285+00:00 2021-03-23T02:18:03.807677+00:00 0:12:03.089392 10739 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T02:05:58.371869+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T01:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T02:05:36.408499+00:00 2021-03-23T02:05:38.098830+00:00 0:00:01.690331 10738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T02:05:34.290804+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T01:05:00+00:00 PythonOperator 2021-03-23T02:05:10.786971+00:00 2021-03-23T02:05:13.494490+00:00 0:00:02.707519 10737 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T02:05:08.341009+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T01:00:00+00:00 EmrJobFlowSensor 2021-03-23T02:00:56.075399+00:00 2021-03-23T02:10:58.738518+00:00 0:10:02.663119 10736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T02:00:53.782584+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T02:00:34.195638+00:00 2021-03-23T02:00:36.059901+00:00 0:00:01.864263 10735 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T02:00:31.768467+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T01:00:00+00:00 PythonOperator 2021-03-23T02:00:09.890411+00:00 2021-03-23T02:00:12.606895+00:00 0:00:02.716484 10734 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T02:00:07.688727+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T00:00:00+00:00 EmrJobFlowSensor 2021-03-23T01:11:21.273512+00:00 2021-03-23T01:21:24.126049+00:00 0:10:02.852537 10733 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T01:11:19.028127+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T01:10:59.375369+00:00 2021-03-23T01:11:01.082371+00:00 0:00:01.707002 10732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T01:10:57.073829+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-23T00:00:00+00:00 PythonOperator 2021-03-23T01:10:39.933779+00:00 2021-03-23T01:10:43.000395+00:00 0:00:03.066616 10731 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T01:10:37.046784+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T00:00:00+00:00 PythonOperator 2021-03-23T01:10:39.702457+00:00 2021-03-23T01:10:42.471323+00:00 0:00:02.768866 10730 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T01:10:37.046820+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T00:00:00+00:00 TriggerDagRunOperator 2021-03-23T01:10:27.557648+00:00 2021-03-23T01:10:28.056453+00:00 0:00:00.498805 10729 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T01:10:24.965425+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T00:00:00+00:00 TriggerDagRunOperator 2021-03-23T01:10:27.267650+00:00 2021-03-23T01:10:27.674605+00:00 0:00:00.406955 10728 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T01:10:24.965453+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T00:05:00+00:00 EmrJobFlowSensor 2021-03-23T01:06:07.269981+00:00 2021-03-23T01:17:10.182675+00:00 0:11:02.912694 10726 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T01:06:05.040740+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T00:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T01:05:45.015857+00:00 2021-03-23T01:05:46.668119+00:00 0:00:01.652262 10725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T01:05:42.894462+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T00:05:00+00:00 PythonOperator 2021-03-23T01:05:25.329672+00:00 2021-03-23T01:05:28.003214+00:00 0:00:02.673542 10724 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T01:05:22.855268+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T00:00:00+00:00 EmrJobFlowSensor 2021-03-23T01:01:04.689181+00:00 2021-03-23T01:10:07.292877+00:00 0:09:02.603696 10723 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T01:01:02.397583+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T01:00:40.731916+00:00 2021-03-23T01:00:42.438198+00:00 0:00:01.706282 10722 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T01:00:38.342086+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T00:00:00+00:00 PythonOperator 2021-03-23T01:00:20.403405+00:00 2021-03-23T01:00:23.162864+00:00 0:00:02.759459 10721 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T01:00:18.208036+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T23:00:00+00:00 EmrJobFlowSensor 2021-03-23T00:11:03.987292+00:00 2021-03-23T00:19:06.540004+00:00 0:08:02.552712 10718 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T00:11:01.561559+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T00:10:43.984438+00:00 2021-03-23T00:10:45.804399+00:00 0:00:01.819961 10717 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T00:10:41.558058+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T23:00:00+00:00 PythonOperator 2021-03-23T00:10:21.809425+00:00 2021-03-23T00:10:24.519018+00:00 0:00:02.709593 10715 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T00:10:19.455147+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T23:00:00+00:00 TriggerDagRunOperator 2021-03-23T00:10:14.565118+00:00 2021-03-23T00:10:14.985896+00:00 0:00:00.420778 10714 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T00:10:11.157454+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T23:00:00+00:00 TriggerDagRunOperator 2021-03-23T00:10:14.328788+00:00 2021-03-23T00:10:14.891148+00:00 0:00:00.562360 10713 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T00:10:11.157497+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-22T23:05:00+00:00 EmrJobFlowSensor 2021-03-23T00:06:03.729572+00:00 2021-03-23T00:16:06.509098+00:00 0:10:02.779526 10711 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T00:06:01.500622+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-22T23:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T00:05:41.499116+00:00 2021-03-23T00:05:43.154398+00:00 0:00:01.655282 10710 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T00:05:39.388600+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-22T23:05:00+00:00 PythonOperator 2021-03-23T00:05:19.568710+00:00 2021-03-23T00:05:22.310387+00:00 0:00:02.741677 10709 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T00:05:17.333574+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T23:00:00+00:00 EmrJobFlowSensor 2021-03-23T00:00:59.120710+00:00 2021-03-23T00:10:01.843548+00:00 0:09:02.722838 10708 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T00:00:56.866976+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T00:00:39.180741+00:00 2021-03-23T00:00:40.877668+00:00 0:00:01.696927 10707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T00:00:36.856316+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T23:00:00+00:00 PythonOperator 2021-03-23T00:00:17.209412+00:00 2021-03-23T00:00:20.034138+00:00 0:00:02.824726 10706 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T00:00:14.852644+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T22:00:00+00:00 EmrJobFlowSensor 2021-03-22T23:12:09.148612+00:00 2021-03-22T23:22:11.798739+00:00 0:10:02.650127 10705 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T23:12:06.410318+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-22T22:00:00+00:00 EmrJobFlowSensor 2021-03-22T23:12:06.938941+00:00 2021-03-23T00:11:16.374849+00:00 0:59:09.435908 10704 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T23:12:04.476236+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T23:11:46.552891+00:00 2021-03-22T23:11:48.261819+00:00 0:00:01.708928 10703 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T23:11:44.397672+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-22T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T23:11:44.632606+00:00 2021-03-22T23:11:46.504916+00:00 0:00:01.872310 10702 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T23:11:42.385339+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T22:00:00+00:00 PythonOperator 2021-03-22T23:11:25.453656+00:00 2021-03-22T23:11:28.245675+00:00 0:00:02.792019 10701 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T23:11:22.324206+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T22:00:00+00:00 PythonOperator 2021-03-22T23:11:22.922227+00:00 2021-03-22T23:11:26.705380+00:00 0:00:03.783153 10700 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T23:11:20.362559+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T22:00:00+00:00 TriggerDagRunOperator 2021-03-22T23:11:13.190763+00:00 2021-03-22T23:11:13.707774+00:00 0:00:00.517011 10699 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T23:11:10.358143+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T22:00:00+00:00 TriggerDagRunOperator 2021-03-22T23:11:13.124626+00:00 2021-03-22T23:11:13.546017+00:00 0:00:00.421391 10698 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T23:11:10.358172+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-22T22:05:00+00:00 EmrJobFlowSensor 2021-03-22T23:05:50.358325+00:00 2021-03-22T23:15:53.018320+00:00 0:10:02.659995 10696 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T23:05:48.130043+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-22T22:05:00+00:00 EmrCreateJobFlowOperator 2021-03-22T23:05:28.256002+00:00 2021-03-22T23:05:29.906641+00:00 0:00:01.650639 10695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T23:05:26.105951+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-22T22:05:00+00:00 PythonOperator 2021-03-22T23:05:08.286697+00:00 2021-03-22T23:05:11.109551+00:00 0:00:02.822854 10694 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T23:05:06.090075+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T22:00:00+00:00 EmrJobFlowSensor 2021-03-22T23:00:49.985191+00:00 2021-03-22T23:10:52.856588+00:00 0:10:02.871397 10693 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T23:00:47.656140+00:00 2 default_pool