Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 create_emr_steps 2021-03-23T10:00:00+00:00 PythonOperator 2021-03-23T11:00:21.093093+00:00 2021-03-23T11:00:23.833502+00:00 0:00:02.740409 10858 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T11:00:18.773965+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T09:00:00+00:00 TriggerDagRunOperator 2021-03-23T10:11:33.376158+00:00 2021-03-23T10:11:33.813840+00:00 0:00:00.437682 10850 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T10:11:31.006043+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T09:00:00+00:00 TriggerDagRunOperator 2021-03-23T10:11:33.273176+00:00 2021-03-23T10:11:33.802328+00:00 0:00:00.529152 10849 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T10:11:31.006092+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T09:00:00+00:00 EmrJobFlowSensor 2021-03-23T10:01:08.251383+00:00 2021-03-23T10:11:11.060165+00:00 0:10:02.808782 10845 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T10:01:05.924815+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T10:00:46.332833+00:00 2021-03-23T10:00:48.043296+00:00 0:00:01.710463 10844 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T10:00:43.957183+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T09:00:00+00:00 PythonOperator 2021-03-23T10:00:24.334470+00:00 2021-03-23T10:00:27.036828+00:00 0:00:02.702358 10843 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T10:00:21.886301+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T08:00:00+00:00 TriggerDagRunOperator 2021-03-23T09:11:07.898754+00:00 2021-03-23T09:11:08.392546+00:00 0:00:00.493792 10835 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T09:11:05.493438+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T08:00:00+00:00 TriggerDagRunOperator 2021-03-23T09:11:07.725597+00:00 2021-03-23T09:11:08.142252+00:00 0:00:00.416655 10834 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T09:11:05.493477+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T08:00:00+00:00 EmrJobFlowSensor 2021-03-23T09:01:01.021181+00:00 2021-03-23T09:11:04.019425+00:00 0:10:02.998244 10830 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T09:00:58.650300+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T09:00:38.999344+00:00 2021-03-23T09:00:40.688084+00:00 0:00:01.688740 10829 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T09:00:36.559007+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T08:00:00+00:00 PythonOperator 2021-03-23T09:00:18.719131+00:00 2021-03-23T09:00:21.467466+00:00 0:00:02.748335 10828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T09:00:16.398654+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T07:00:00+00:00 TriggerDagRunOperator 2021-03-23T08:11:24.237820+00:00 2021-03-23T08:11:24.680289+00:00 0:00:00.442469 10820 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T08:11:21.735040+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T07:00:00+00:00 TriggerDagRunOperator 2021-03-23T08:11:24.037876+00:00 2021-03-23T08:11:24.662164+00:00 0:00:00.624288 10819 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T08:11:21.735005+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T07:00:00+00:00 EmrJobFlowSensor 2021-03-23T08:00:57.004460+00:00 2021-03-23T08:10:59.877060+00:00 0:10:02.872600 10815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T08:00:54.653219+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T08:00:36.843434+00:00 2021-03-23T08:00:38.635579+00:00 0:00:01.792145 10814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T08:00:34.591846+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T07:00:00+00:00 PythonOperator 2021-03-23T08:00:15.147308+00:00 2021-03-23T08:00:17.926896+00:00 0:00:02.779588 10813 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T08:00:12.561327+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T06:00:00+00:00 TriggerDagRunOperator 2021-03-23T07:10:08.930914+00:00 2021-03-23T07:10:09.432390+00:00 0:00:00.501476 10805 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T07:10:06.585550+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T06:00:00+00:00 TriggerDagRunOperator 2021-03-23T07:10:08.833089+00:00 2021-03-23T07:10:09.286959+00:00 0:00:00.453870 10804 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T07:10:06.585582+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 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 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-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 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-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 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-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 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-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 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-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 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-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 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-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 campaign-flow-job_v002 check_cluster_status 2021-03-22T22:00:00+00:00 EmrJobFlowSensor 2021-03-22T23:00:49.985191+00:00 2021-03-22T23:10:52.856588+00:00 0:10:02.871397 10693 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T23:00:47.656140+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T23:00:30.226024+00:00 2021-03-22T23:00:32.046560+00:00 0:00:01.820536 10692 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T23:00:27.655519+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T22:00:00+00:00 PythonOperator 2021-03-22T23:00:07.665790+00:00 2021-03-22T23:00:10.398358+00:00 0:00:02.732568 10691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T23:00:05.498187+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T21:00:00+00:00 TriggerDagRunOperator 2021-03-22T22:10:08.672274+00:00 2021-03-22T22:10:09.181908+00:00 0:00:00.509634 10684 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T22:10:06.144334+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T21:00:00+00:00 TriggerDagRunOperator 2021-03-22T22:10:08.635718+00:00 2021-03-22T22:10:09.093193+00:00 0:00:00.457475 10683 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T22:10:06.144370+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T21:00:00+00:00 EmrJobFlowSensor 2021-03-22T22:00:57.620216+00:00 2021-03-22T22:10:00.258439+00:00 0:09:02.638223 10678 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T22:00:55.343359+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T22:00:37.568237+00:00 2021-03-22T22:00:39.358296+00:00 0:00:01.790059 10677 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T22:00:35.276760+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T21:00:00+00:00 PythonOperator 2021-03-22T22:00:15.323201+00:00 2021-03-22T22:00:18.033273+00:00 0:00:02.710072 10676 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T22:00:13.169575+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T20:00:00+00:00 TriggerDagRunOperator 2021-03-22T21:11:06.424868+00:00 2021-03-22T21:11:06.928144+00:00 0:00:00.503276 10669 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T21:11:03.948563+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T20:00:00+00:00 TriggerDagRunOperator 2021-03-22T21:11:06.418397+00:00 2021-03-22T21:11:06.949668+00:00 0:00:00.531271 10668 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T21:11:03.948534+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T20:00:00+00:00 EmrJobFlowSensor 2021-03-22T21:00:56.078670+00:00 2021-03-22T21:10:58.825368+00:00 0:10:02.746698 10663 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T21:00:53.731703+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T21:00:34.098527+00:00 2021-03-22T21:00:35.752328+00:00 0:00:01.653801 10662 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T21:00:31.749986+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T20:00:00+00:00 PythonOperator 2021-03-22T21:00:12.170487+00:00 2021-03-22T21:00:14.909496+00:00 0:00:02.739009 10661 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T21:00:09.690460+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T19:00:00+00:00 TriggerDagRunOperator 2021-03-22T20:09:15.219289+00:00 2021-03-22T20:09:15.853035+00:00 0:00:00.633746 10654 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T20:09:12.640782+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T19:00:00+00:00 TriggerDagRunOperator 2021-03-22T20:09:15.200741+00:00 2021-03-22T20:09:15.645280+00:00 0:00:00.444539 10653 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T20:09:12.640752+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T19:00:00+00:00 EmrJobFlowSensor 2021-03-22T20:00:50.900528+00:00 2021-03-22T20:08:53.375676+00:00 0:08:02.475148 10648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T20:00:48.683932+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T20:00:28.864242+00:00 2021-03-22T20:00:30.678651+00:00 0:00:01.814409 10647 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T20:00:26.602325+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T19:00:00+00:00 PythonOperator 2021-03-22T20:00:07.067625+00:00 2021-03-22T20:00:09.882093+00:00 0:00:02.814468 10646 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T20:00:04.649563+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T18:00:00+00:00 TriggerDagRunOperator 2021-03-22T19:11:48.566918+00:00 2021-03-22T19:11:49.051932+00:00 0:00:00.485014 10639 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T19:11:45.963681+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T18:00:00+00:00 TriggerDagRunOperator 2021-03-22T19:11:48.398421+00:00 2021-03-22T19:11:48.824872+00:00 0:00:00.426451 10638 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T19:11:45.963720+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T18:00:00+00:00 EmrJobFlowSensor 2021-03-22T19:02:25.650921+00:00 2021-03-22T19:11:28.391538+00:00 0:09:02.740617 10633 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T19:02:23.330571+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T19:01:55.523315+00:00 2021-03-22T19:01:57.236701+00:00 0:00:01.713386 10632 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T19:01:53.302605+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T18:00:00+00:00 PythonOperator 2021-03-22T19:01:29.914920+00:00 2021-03-22T19:01:32.758836+00:00 0:00:02.843916 10631 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T19:01:27.265317+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T17:00:00+00:00 TriggerDagRunOperator 2021-03-22T18:11:12.574615+00:00 2021-03-22T18:11:13.076502+00:00 0:00:00.501887 10624 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T18:11:10.245882+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T17:00:00+00:00 TriggerDagRunOperator 2021-03-22T18:11:12.497023+00:00 2021-03-22T18:11:12.887488+00:00 0:00:00.390465 10623 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T18:11:10.245924+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T17:00:00+00:00 EmrJobFlowSensor 2021-03-22T18:00:51.609316+00:00 2021-03-22T18:10:54.519562+00:00 0:10:02.910246 10618 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T18:00:49.256413+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T18:00:29.615746+00:00 2021-03-22T18:00:31.329707+00:00 0:00:01.713961 10617 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T18:00:27.243213+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T17:00:00+00:00 PythonOperator 2021-03-22T18:00:07.681297+00:00 2021-03-22T18:00:10.578416+00:00 0:00:02.897119 10616 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T18:00:05.240824+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T16:00:00+00:00 TriggerDagRunOperator 2021-03-22T17:15:16.681182+00:00 2021-03-22T17:15:17.177303+00:00 0:00:00.496121 10609 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T17:15:14.244500+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T16:00:00+00:00 TriggerDagRunOperator 2021-03-22T17:15:16.617304+00:00 2021-03-22T17:15:17.037541+00:00 0:00:00.420237 10608 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T17:15:14.244449+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T16:00:00+00:00 EmrJobFlowSensor 2021-03-22T17:05:49.693534+00:00 2021-03-22T17:14:52.425273+00:00 0:09:02.731739 10606 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T17:05:47.444365+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T17:05:27.636519+00:00 2021-03-22T17:05:29.484812+00:00 0:00:01.848293 10604 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T17:05:25.421290+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T16:00:00+00:00 PythonOperator 2021-03-22T17:00:17.000027+00:00 2021-03-22T17:00:19.758395+00:00 0:00:02.758368 10601 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T17:00:14.656198+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T15:00:00+00:00 TriggerDagRunOperator 2021-03-22T16:10:44.138312+00:00 2021-03-22T16:10:44.548474+00:00 0:00:00.410162 10594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T16:10:41.721497+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T15:00:00+00:00 TriggerDagRunOperator 2021-03-22T16:10:43.932985+00:00 2021-03-22T16:10:44.444482+00:00 0:00:00.511497 10593 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T16:10:41.721545+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T15:00:00+00:00 EmrJobFlowSensor 2021-03-22T16:01:19.299123+00:00 2021-03-22T16:10:21.953417+00:00 0:09:02.654294 10589 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T16:01:17.055807+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T16:00:59.207235+00:00 2021-03-22T16:01:00.982374+00:00 0:00:01.775139 10588 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T16:00:56.949977+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T15:00:00+00:00 PythonOperator 2021-03-22T16:00:37.742429+00:00 2021-03-22T16:00:40.545175+00:00 0:00:02.802746 10587 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T16:00:35.016374+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T14:00:00+00:00 TriggerDagRunOperator 2021-03-22T15:10:12.088810+00:00 2021-03-22T15:10:12.626399+00:00 0:00:00.537589 10579 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T15:10:09.791566+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T14:00:00+00:00 TriggerDagRunOperator 2021-03-22T15:10:12.054796+00:00 2021-03-22T15:10:12.437866+00:00 0:00:00.383070 10578 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T15:10:09.791601+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T14:00:00+00:00 EmrJobFlowSensor 2021-03-22T15:01:05.442543+00:00 2021-03-22T15:10:08.176205+00:00 0:09:02.733662 10574 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T15:01:03.049192+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T15:00:43.093915+00:00 2021-03-22T15:00:44.775905+00:00 0:00:01.681990 10573 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T15:00:40.987301+00:00 2 default_pool