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-05-11T09:00:00+00:00 PythonOperator 2021-05-11T10:00:18.998947+00:00 2021-05-11T10:00:22.155489+00:00 0:00:03.156542 26867 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T10:00:16.688253+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T08:00:00+00:00 TriggerDagRunOperator 2021-05-11T09:10:14.662518+00:00 2021-05-11T09:10:15.167827+00:00 0:00:00.505309 26859 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T09:10:11.912240+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T08:00:00+00:00 TriggerDagRunOperator 2021-05-11T09:10:14.510919+00:00 2021-05-11T09:10:14.912181+00:00 0:00:00.401262 26858 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T09:10:11.912210+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T08:00:00+00:00 EmrJobFlowSensor 2021-05-11T09:00:59.771816+00:00 2021-05-11T09:10:02.655333+00:00 0:09:02.883517 26854 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T09:00:57.166598+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T09:00:37.347242+00:00 2021-05-11T09:00:39.069758+00:00 0:00:01.722516 26853 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T09:00:35.087988+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T08:00:00+00:00 PythonOperator 2021-05-11T09:00:17.476525+00:00 2021-05-11T09:00:20.610046+00:00 0:00:03.133521 26852 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T09:00:15.072132+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T07:00:00+00:00 TriggerDagRunOperator 2021-05-11T08:10:06.439274+00:00 2021-05-11T08:10:06.941558+00:00 0:00:00.502284 26844 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T08:10:03.807682+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T07:00:00+00:00 TriggerDagRunOperator 2021-05-11T08:10:06.022783+00:00 2021-05-11T08:10:06.440483+00:00 0:00:00.417700 26843 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T08:10:03.807650+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T07:00:00+00:00 EmrJobFlowSensor 2021-05-11T08:00:57.065970+00:00 2021-05-11T08:09:59.829554+00:00 0:09:02.763584 26839 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T08:00:54.834223+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T08:00:37.013103+00:00 2021-05-11T08:00:38.862969+00:00 0:00:01.849866 26838 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T08:00:34.809508+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T07:00:00+00:00 PythonOperator 2021-05-11T08:00:13.132836+00:00 2021-05-11T08:00:16.271518+00:00 0:00:03.138682 26837 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T08:00:10.785270+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T06:00:00+00:00 TriggerDagRunOperator 2021-05-11T07:27:10.850930+00:00 2021-05-11T07:27:11.395017+00:00 0:00:00.544087 26829 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T07:27:08.555663+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T06:00:00+00:00 TriggerDagRunOperator 2021-05-11T07:27:10.771802+00:00 2021-05-11T07:27:11.204081+00:00 0:00:00.432279 26828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T07:27:08.555695+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T06:00:00+00:00 EmrJobFlowSensor 2021-05-11T07:00:48.050652+00:00 2021-05-11T07:26:53.308343+00:00 0:26:05.257691 26824 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T07:00:45.749945+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T07:00:26.025973+00:00 2021-05-11T07:00:27.842293+00:00 0:00:01.816320 26823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T07:00:23.733506+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T06:00:00+00:00 PythonOperator 2021-05-11T07:00:04.277505+00:00 2021-05-11T07:00:07.472884+00:00 0:00:03.195379 26822 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T07:00:01.719491+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T05:00:00+00:00 TriggerDagRunOperator 2021-05-11T06:24:22.354402+00:00 2021-05-11T06:24:22.877269+00:00 0:00:00.522867 26814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T06:24:20.004218+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T05:00:00+00:00 TriggerDagRunOperator 2021-05-11T06:24:22.367239+00:00 2021-05-11T06:24:22.952501+00:00 0:00:00.585262 26813 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T06:24:20.004246+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T05:00:00+00:00 EmrJobFlowSensor 2021-05-11T06:00:53.777609+00:00 2021-05-11T06:23:58.500511+00:00 0:23:04.722902 26809 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T06:00:51.672394+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T06:00:30.341746+00:00 2021-05-11T06:00:32.143988+00:00 0:00:01.802242 26808 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T06:00:27.748467+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T05:00:00+00:00 PythonOperator 2021-05-11T06:00:07.864363+00:00 2021-05-11T06:00:11.106209+00:00 0:00:03.241846 26807 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T06:00:05.575298+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T04:00:00+00:00 TriggerDagRunOperator 2021-05-11T05:11:10.528426+00:00 2021-05-11T05:11:11.087285+00:00 0:00:00.558859 26799 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T05:11:07.973802+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T04:00:00+00:00 TriggerDagRunOperator 2021-05-11T05:11:10.402483+00:00 2021-05-11T05:11:10.798983+00:00 0:00:00.396500 26798 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T05:11:07.973767+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T04:00:00+00:00 EmrJobFlowSensor 2021-05-11T05:00:49.143474+00:00 2021-05-11T05:10:52.037822+00:00 0:10:02.894348 26794 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T05:00:46.607363+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T05:00:29.089489+00:00 2021-05-11T05:00:30.914590+00:00 0:00:01.825101 26793 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T05:00:26.593570+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T04:00:00+00:00 PythonOperator 2021-05-11T05:00:06.778936+00:00 2021-05-11T05:00:09.933427+00:00 0:00:03.154491 26792 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T05:00:04.544773+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T03:00:00+00:00 TriggerDagRunOperator 2021-05-11T04:11:12.610273+00:00 2021-05-11T04:11:13.120573+00:00 0:00:00.510300 26784 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T04:11:10.317892+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T03:00:00+00:00 TriggerDagRunOperator 2021-05-11T04:11:12.479129+00:00 2021-05-11T04:11:12.883102+00:00 0:00:00.403973 26783 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T04:11:10.317851+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T03:00:00+00:00 EmrJobFlowSensor 2021-05-11T04:00:57.524549+00:00 2021-05-11T04:11:00.365445+00:00 0:10:02.840896 26779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T04:00:55.402813+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T04:00:35.510867+00:00 2021-05-11T04:00:37.232014+00:00 0:00:01.721147 26778 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T04:00:33.390747+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T03:00:00+00:00 PythonOperator 2021-05-11T04:00:16.040345+00:00 2021-05-11T04:00:19.145663+00:00 0:00:03.105318 26777 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T04:00:13.119946+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T02:00:00+00:00 TriggerDagRunOperator 2021-05-11T03:10:11.824139+00:00 2021-05-11T03:10:12.344092+00:00 0:00:00.519953 26769 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T03:10:09.584483+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T02:00:00+00:00 TriggerDagRunOperator 2021-05-11T03:10:11.684333+00:00 2021-05-11T03:10:12.092801+00:00 0:00:00.408468 26768 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T03:10:09.584515+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T02:00:00+00:00 EmrJobFlowSensor 2021-05-11T03:00:48.798048+00:00 2021-05-11T03:09:51.457360+00:00 0:09:02.659312 26764 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T03:00:46.643916+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T03:00:29.055075+00:00 2021-05-11T03:00:30.870110+00:00 0:00:01.815035 26763 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T03:00:26.549163+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T02:00:00+00:00 PythonOperator 2021-05-11T03:00:06.800546+00:00 2021-05-11T03:00:09.947753+00:00 0:00:03.147207 26762 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T03:00:04.433644+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T01:00:00+00:00 TriggerDagRunOperator 2021-05-11T02:09:14.108562+00:00 2021-05-11T02:09:14.655140+00:00 0:00:00.546578 26754 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T02:09:11.555598+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T01:00:00+00:00 TriggerDagRunOperator 2021-05-11T02:09:13.938915+00:00 2021-05-11T02:09:14.441630+00:00 0:00:00.502715 26753 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T02:09:11.555629+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T01:00:00+00:00 EmrJobFlowSensor 2021-05-11T02:00:54.662864+00:00 2021-05-11T02:08:57.237411+00:00 0:08:02.574547 26749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T02:00:52.462608+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T02:00:30.692537+00:00 2021-05-11T02:00:32.397442+00:00 0:00:01.704905 26748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T02:00:28.463133+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T01:00:00+00:00 PythonOperator 2021-05-11T02:00:05.301265+00:00 2021-05-11T02:00:08.513170+00:00 0:00:03.211905 26747 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T02:00:02.469390+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-11T00:00:00+00:00 TriggerDagRunOperator 2021-05-11T01:09:58.802600+00:00 2021-05-11T01:09:59.313034+00:00 0:00:00.510434 26739 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T01:09:55.707638+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-11T00:00:00+00:00 TriggerDagRunOperator 2021-05-11T01:09:58.071919+00:00 2021-05-11T01:09:58.463924+00:00 0:00:00.392005 26738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T01:09:55.707588+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-11T00:00:00+00:00 EmrJobFlowSensor 2021-05-11T01:00:47.275756+00:00 2021-05-11T01:09:50.120591+00:00 0:09:02.844835 26734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T01:00:44.971222+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-11T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T01:00:25.435055+00:00 2021-05-11T01:00:27.286610+00:00 0:00:01.851555 26733 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T01:00:22.955821+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-11T00:00:00+00:00 PythonOperator 2021-05-11T01:00:03.646013+00:00 2021-05-11T01:00:06.829958+00:00 0:00:03.183945 26732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T01:00:00.963017+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T23:00:00+00:00 TriggerDagRunOperator 2021-05-11T00:10:33.409576+00:00 2021-05-11T00:10:33.952601+00:00 0:00:00.543025 26724 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T00:10:30.764111+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T23:00:00+00:00 TriggerDagRunOperator 2021-05-11T00:10:33.300601+00:00 2021-05-11T00:10:33.696299+00:00 0:00:00.395698 26723 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-11T00:10:30.764061+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T23:00:00+00:00 EmrJobFlowSensor 2021-05-11T00:01:09.581386+00:00 2021-05-11T00:10:12.340172+00:00 0:09:02.758786 26719 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-11T00:01:07.470134+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-11T00:00:39.654440+00:00 2021-05-11T00:00:41.374295+00:00 0:00:01.719855 26718 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-11T00:00:37.409701+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T23:00:00+00:00 PythonOperator 2021-05-11T00:00:17.603087+00:00 2021-05-11T00:00:20.711950+00:00 0:00:03.108863 26717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-11T00:00:15.389457+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T22:00:00+00:00 TriggerDagRunOperator 2021-05-10T23:11:56.935152+00:00 2021-05-10T23:11:57.472450+00:00 0:00:00.537298 26710 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T23:11:54.251242+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T22:00:00+00:00 TriggerDagRunOperator 2021-05-10T23:11:56.799982+00:00 2021-05-10T23:11:57.257740+00:00 0:00:00.457758 26709 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T23:11:54.251283+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T22:00:00+00:00 EmrJobFlowSensor 2021-05-10T23:01:08.716064+00:00 2021-05-10T23:10:11.680824+00:00 0:09:02.964760 26704 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T23:01:06.431006+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T23:00:44.652409+00:00 2021-05-10T23:00:46.428766+00:00 0:00:01.776357 26702 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T23:00:42.385345+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T22:00:00+00:00 PythonOperator 2021-05-10T23:00:14.533316+00:00 2021-05-10T23:00:17.656180+00:00 0:00:03.122864 26699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T23:00:12.360063+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T21:00:00+00:00 TriggerDagRunOperator 2021-05-10T22:09:08.302579+00:00 2021-05-10T22:09:08.848808+00:00 0:00:00.546229 26692 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T22:09:05.694361+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T21:00:00+00:00 TriggerDagRunOperator 2021-05-10T22:09:08.253539+00:00 2021-05-10T22:09:08.663356+00:00 0:00:00.409817 26691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T22:09:05.694401+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T21:00:00+00:00 EmrJobFlowSensor 2021-05-10T22:00:47.675474+00:00 2021-05-10T22:08:50.295930+00:00 0:08:02.620456 26686 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T22:00:45.320731+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T22:00:25.838668+00:00 2021-05-10T22:00:27.746770+00:00 0:00:01.908102 26685 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T22:00:23.369612+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T21:00:00+00:00 PythonOperator 2021-05-10T22:00:05.526383+00:00 2021-05-10T22:00:08.610571+00:00 0:00:03.084188 26684 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T22:00:03.288917+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T20:00:00+00:00 TriggerDagRunOperator 2021-05-10T21:10:08.869518+00:00 2021-05-10T21:10:09.318670+00:00 0:00:00.449152 26677 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T21:10:05.855197+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T20:00:00+00:00 TriggerDagRunOperator 2021-05-10T21:10:08.819039+00:00 2021-05-10T21:10:09.382525+00:00 0:00:00.563486 26676 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T21:10:05.855158+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T20:00:00+00:00 EmrJobFlowSensor 2021-05-10T21:00:58.971648+00:00 2021-05-10T21:10:01.671800+00:00 0:09:02.700152 26671 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T21:00:56.593695+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T21:00:36.977361+00:00 2021-05-10T21:00:38.801501+00:00 0:00:01.824140 26670 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T21:00:34.577946+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T20:00:00+00:00 PythonOperator 2021-05-10T21:00:15.068149+00:00 2021-05-10T21:00:18.194054+00:00 0:00:03.125905 26669 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T21:00:12.543999+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T19:00:00+00:00 TriggerDagRunOperator 2021-05-10T20:10:34.132349+00:00 2021-05-10T20:10:34.692267+00:00 0:00:00.559918 26662 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T20:10:31.444598+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T19:00:00+00:00 TriggerDagRunOperator 2021-05-10T20:10:33.869899+00:00 2021-05-10T20:10:34.322384+00:00 0:00:00.452485 26661 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T20:10:31.444551+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T19:00:00+00:00 EmrJobFlowSensor 2021-05-10T20:01:06.958752+00:00 2021-05-10T20:10:09.887627+00:00 0:09:02.928875 26656 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T20:01:04.651609+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T20:00:46.651798+00:00 2021-05-10T20:00:48.362799+00:00 0:00:01.711001 26655 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T20:00:44.522996+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T19:00:00+00:00 PythonOperator 2021-05-10T20:00:24.737697+00:00 2021-05-10T20:00:27.916606+00:00 0:00:03.178909 26654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T20:00:22.509029+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T18:00:00+00:00 TriggerDagRunOperator 2021-05-10T19:10:49.995963+00:00 2021-05-10T19:10:50.518960+00:00 0:00:00.522997 26647 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T19:10:47.626467+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T18:00:00+00:00 TriggerDagRunOperator 2021-05-10T19:10:49.765059+00:00 2021-05-10T19:10:50.182570+00:00 0:00:00.417511 26646 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T19:10:47.626435+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T18:00:00+00:00 EmrJobFlowSensor 2021-05-10T19:01:17.601480+00:00 2021-05-10T19:10:20.426826+00:00 0:09:02.825346 26641 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T19:01:15.512621+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T19:00:47.832394+00:00 2021-05-10T19:00:49.522440+00:00 0:00:01.690046 26640 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T19:00:45.490881+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T18:00:00+00:00 PythonOperator 2021-05-10T19:00:19.676189+00:00 2021-05-10T19:00:22.793685+00:00 0:00:03.117496 26639 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T19:00:17.419939+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T17:00:00+00:00 TriggerDagRunOperator 2021-05-10T18:11:28.399694+00:00 2021-05-10T18:11:28.917600+00:00 0:00:00.517906 26632 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T18:11:26.004118+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T17:00:00+00:00 TriggerDagRunOperator 2021-05-10T18:11:28.228802+00:00 2021-05-10T18:11:28.632407+00:00 0:00:00.403605 26631 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T18:11:26.004087+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T17:00:00+00:00 EmrJobFlowSensor 2021-05-10T18:01:07.677654+00:00 2021-05-10T18:11:10.635419+00:00 0:10:02.957765 26626 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T18:01:05.469377+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T18:00:41.630143+00:00 2021-05-10T18:00:43.436543+00:00 0:00:01.806400 26625 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T18:00:39.448509+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T17:00:00+00:00 PythonOperator 2021-05-10T18:00:19.803620+00:00 2021-05-10T18:00:23.019777+00:00 0:00:03.216157 26624 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T18:00:17.430238+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T16:00:00+00:00 TriggerDagRunOperator 2021-05-10T17:10:10.860845+00:00 2021-05-10T17:10:11.395288+00:00 0:00:00.534443 26617 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T17:10:08.589565+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T16:00:00+00:00 TriggerDagRunOperator 2021-05-10T17:10:10.787124+00:00 2021-05-10T17:10:11.202028+00:00 0:00:00.414904 26616 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T17:10:08.589539+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T16:00:00+00:00 EmrJobFlowSensor 2021-05-10T17:00:56.056562+00:00 2021-05-10T17:09:58.809684+00:00 0:09:02.753122 26611 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T17:00:53.579757+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T17:00:35.705955+00:00 2021-05-10T17:00:37.432747+00:00 0:00:01.726792 26610 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T17:00:33.520528+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T16:00:00+00:00 PythonOperator 2021-05-10T17:00:13.680992+00:00 2021-05-10T17:00:16.925015+00:00 0:00:03.244023 26609 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T17:00:11.498391+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T15:00:00+00:00 TriggerDagRunOperator 2021-05-10T16:11:08.076844+00:00 2021-05-10T16:11:08.635600+00:00 0:00:00.558756 26602 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T16:11:05.659238+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T15:00:00+00:00 TriggerDagRunOperator 2021-05-10T16:11:07.867326+00:00 2021-05-10T16:11:08.315090+00:00 0:00:00.447764 26601 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T16:11:05.659187+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T15:00:00+00:00 EmrJobFlowSensor 2021-05-10T16:02:01.073905+00:00 2021-05-10T16:11:03.874414+00:00 0:09:02.800509 26597 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T16:01:58.699144+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T16:01:36.868394+00:00 2021-05-10T16:01:38.549659+00:00 0:00:01.681265 26596 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T16:01:34.647724+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T15:00:00+00:00 PythonOperator 2021-05-10T16:00:21.417177+00:00 2021-05-10T16:00:24.525142+00:00 0:00:03.107965 26594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T16:00:19.306345+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T14:00:00+00:00 TriggerDagRunOperator 2021-05-10T15:11:38.311093+00:00 2021-05-10T15:11:38.773940+00:00 0:00:00.462847 26587 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T15:11:35.647100+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T14:00:00+00:00 TriggerDagRunOperator 2021-05-10T15:11:38.034762+00:00 2021-05-10T15:11:38.593775+00:00 0:00:00.559013 26586 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T15:11:35.647052+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T14:00:00+00:00 EmrJobFlowSensor 2021-05-10T15:01:22.618906+00:00 2021-05-10T15:11:25.585679+00:00 0:10:02.966773 26582 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T15:01:20.152819+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T15:01:00.940125+00:00 2021-05-10T15:01:02.764123+00:00 0:00:01.823998 26581 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T15:00:58.161720+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T14:00:00+00:00 PythonOperator 2021-05-10T15:00:40.352849+00:00 2021-05-10T15:00:43.471623+00:00 0:00:03.118774 26580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T15:00:37.998572+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T13:00:00+00:00 TriggerDagRunOperator 2021-05-10T14:11:08.934604+00:00 2021-05-10T14:11:09.444372+00:00 0:00:00.509768 26572 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T14:11:06.490075+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T13:00:00+00:00 TriggerDagRunOperator 2021-05-10T14:11:08.643790+00:00 2021-05-10T14:11:09.145199+00:00 0:00:00.501409 26571 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T14:11:06.490047+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T13:00:00+00:00 EmrJobFlowSensor 2021-05-10T14:00:47.508026+00:00 2021-05-10T14:10:50.555348+00:00 0:10:03.047322 26567 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T14:00:45.300918+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T14:00:27.306446+00:00 2021-05-10T14:00:29.001998+00:00 0:00:01.695552 26566 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T14:00:25.193794+00:00 2 default_pool