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-04-11T09:00:00+00:00 PythonOperator 2021-04-11T10:00:23.424758+00:00 2021-04-11T10:00:26.451578+00:00 0:00:03.026820 15961 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T10:00:20.945152+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T08:00:00+00:00 TriggerDagRunOperator 2021-04-11T09:10:05.581900+00:00 2021-04-11T09:10:05.967062+00:00 0:00:00.385162 15953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T09:10:02.764668+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T08:00:00+00:00 TriggerDagRunOperator 2021-04-11T09:10:05.247533+00:00 2021-04-11T09:10:05.776746+00:00 0:00:00.529213 15952 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T09:10:02.764634+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T08:00:00+00:00 EmrJobFlowSensor 2021-04-11T09:00:53.803943+00:00 2021-04-11T09:09:56.429828+00:00 0:09:02.625885 15948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T09:00:51.646549+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T09:00:34.427552+00:00 2021-04-11T09:00:36.117819+00:00 0:00:01.690267 15947 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T09:00:31.631611+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T08:00:00+00:00 PythonOperator 2021-04-11T09:00:12.325445+00:00 2021-04-11T09:00:15.053697+00:00 0:00:02.728252 15946 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T09:00:09.617004+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T07:00:00+00:00 TriggerDagRunOperator 2021-04-11T08:10:30.460203+00:00 2021-04-11T08:10:30.894709+00:00 0:00:00.434506 15938 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T08:10:27.954163+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T07:00:00+00:00 TriggerDagRunOperator 2021-04-11T08:10:30.417277+00:00 2021-04-11T08:10:31.014381+00:00 0:00:00.597104 15937 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T08:10:27.954199+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T07:00:00+00:00 EmrJobFlowSensor 2021-04-11T08:01:09.655120+00:00 2021-04-11T08:10:12.416856+00:00 0:09:02.761736 15933 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T08:01:07.123129+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T08:00:39.653621+00:00 2021-04-11T08:00:41.397531+00:00 0:00:01.743910 15932 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T08:00:37.096943+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T07:00:00+00:00 PythonOperator 2021-04-11T08:00:19.663431+00:00 2021-04-11T08:00:23.034553+00:00 0:00:03.371122 15931 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T08:00:17.083593+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T06:00:00+00:00 TriggerDagRunOperator 2021-04-11T07:10:29.840475+00:00 2021-04-11T07:10:30.373003+00:00 0:00:00.532528 15923 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T07:10:27.333196+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T06:00:00+00:00 TriggerDagRunOperator 2021-04-11T07:10:29.620711+00:00 2021-04-11T07:10:30.061784+00:00 0:00:00.441073 15922 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T07:10:27.333154+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T06:00:00+00:00 EmrJobFlowSensor 2021-04-11T07:01:04.887310+00:00 2021-04-11T07:10:07.531856+00:00 0:09:02.644546 15918 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T07:01:02.487065+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T07:00:42.985194+00:00 2021-04-11T07:00:44.792911+00:00 0:00:01.807717 15917 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T07:00:40.446894+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T06:00:00+00:00 PythonOperator 2021-04-11T07:00:21.329711+00:00 2021-04-11T07:00:24.277388+00:00 0:00:02.947677 15916 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T07:00:18.468375+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T05:00:00+00:00 TriggerDagRunOperator 2021-04-11T06:09:16.489744+00:00 2021-04-11T06:09:16.971327+00:00 0:00:00.481583 15908 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T06:09:13.781497+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T05:00:00+00:00 TriggerDagRunOperator 2021-04-11T06:09:16.209583+00:00 2021-04-11T06:09:16.771574+00:00 0:00:00.561991 15907 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T06:09:13.781452+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T05:00:00+00:00 EmrJobFlowSensor 2021-04-11T06:01:03.123715+00:00 2021-04-11T06:09:06.134832+00:00 0:08:03.011117 15903 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T06:01:00.803622+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T06:00:40.904605+00:00 2021-04-11T06:00:42.619688+00:00 0:00:01.715083 15902 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T06:00:38.782333+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T05:00:00+00:00 PythonOperator 2021-04-11T06:00:19.710959+00:00 2021-04-11T06:00:22.845896+00:00 0:00:03.134937 15901 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T06:00:16.685338+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T04:00:00+00:00 TriggerDagRunOperator 2021-04-11T05:19:05.937964+00:00 2021-04-11T05:19:06.457662+00:00 0:00:00.519698 15893 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T05:19:03.498673+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T04:00:00+00:00 TriggerDagRunOperator 2021-04-11T05:19:05.775622+00:00 2021-04-11T05:19:06.176819+00:00 0:00:00.401197 15892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T05:19:03.498639+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T04:00:00+00:00 EmrJobFlowSensor 2021-04-11T05:00:50.228507+00:00 2021-04-11T05:18:54.240654+00:00 0:18:04.012147 15888 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T05:00:47.607704+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T05:00:29.889587+00:00 2021-04-11T05:00:31.555949+00:00 0:00:01.666362 15887 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T05:00:27.588790+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T04:00:00+00:00 PythonOperator 2021-04-11T05:00:07.949978+00:00 2021-04-11T05:00:10.949202+00:00 0:00:02.999224 15886 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T05:00:05.557448+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T03:00:00+00:00 TriggerDagRunOperator 2021-04-11T04:10:10.551659+00:00 2021-04-11T04:10:11.110152+00:00 0:00:00.558493 15878 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T04:10:08.226161+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T03:00:00+00:00 TriggerDagRunOperator 2021-04-11T04:10:10.466452+00:00 2021-04-11T04:10:10.872740+00:00 0:00:00.406288 15877 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T04:10:08.226193+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T03:00:00+00:00 EmrJobFlowSensor 2021-04-11T04:00:55.539679+00:00 2021-04-11T04:09:58.446268+00:00 0:09:02.906589 15873 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T04:00:53.175871+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T04:00:35.651427+00:00 2021-04-11T04:00:37.324609+00:00 0:00:01.673182 15872 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T04:00:33.161081+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T03:00:00+00:00 PythonOperator 2021-04-11T04:00:13.820033+00:00 2021-04-11T04:00:16.637963+00:00 0:00:02.817930 15871 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T04:00:11.176734+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T02:00:00+00:00 TriggerDagRunOperator 2021-04-11T03:09:16.061384+00:00 2021-04-11T03:09:16.625558+00:00 0:00:00.564174 15863 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T03:09:13.470450+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T02:00:00+00:00 TriggerDagRunOperator 2021-04-11T03:09:16.037478+00:00 2021-04-11T03:09:16.430618+00:00 0:00:00.393140 15862 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T03:09:13.470499+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T02:00:00+00:00 EmrJobFlowSensor 2021-04-11T03:00:56.703310+00:00 2021-04-11T03:08:59.161763+00:00 0:08:02.458453 15858 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T03:00:54.574322+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T03:00:36.760813+00:00 2021-04-11T03:00:38.475313+00:00 0:00:01.714500 15857 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T03:00:34.557722+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T02:00:00+00:00 PythonOperator 2021-04-11T03:00:15.509322+00:00 2021-04-11T03:00:18.308391+00:00 0:00:02.799069 15856 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T03:00:12.568159+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T01:00:00+00:00 TriggerDagRunOperator 2021-04-11T02:11:18.616728+00:00 2021-04-11T02:11:19.117913+00:00 0:00:00.501185 15848 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T02:11:16.215005+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T01:00:00+00:00 TriggerDagRunOperator 2021-04-11T02:11:18.529814+00:00 2021-04-11T02:11:18.956261+00:00 0:00:00.426447 15847 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T02:11:16.214958+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T01:00:00+00:00 EmrJobFlowSensor 2021-04-11T02:01:00.198740+00:00 2021-04-11T02:11:03.155901+00:00 0:10:02.957161 15843 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T02:00:57.472728+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T02:00:37.684071+00:00 2021-04-11T02:00:39.396827+00:00 0:00:01.712756 15842 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T02:00:35.455031+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T01:00:00+00:00 PythonOperator 2021-04-11T02:00:17.715488+00:00 2021-04-11T02:00:20.760334+00:00 0:00:03.044846 15841 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T02:00:15.341548+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-11T00:00:00+00:00 TriggerDagRunOperator 2021-04-11T01:10:11.244742+00:00 2021-04-11T01:10:11.779115+00:00 0:00:00.534373 15833 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T01:10:08.691005+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-11T00:00:00+00:00 TriggerDagRunOperator 2021-04-11T01:10:11.214571+00:00 2021-04-11T01:10:11.654659+00:00 0:00:00.440088 15832 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T01:10:08.690978+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-11T00:00:00+00:00 EmrJobFlowSensor 2021-04-11T01:00:54.176770+00:00 2021-04-11T01:09:56.924696+00:00 0:09:02.747926 15828 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T01:00:51.678723+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-11T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T01:00:33.839856+00:00 2021-04-11T01:00:35.560607+00:00 0:00:01.720751 15827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T01:00:31.608062+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-11T00:00:00+00:00 PythonOperator 2021-04-11T01:00:12.013877+00:00 2021-04-11T01:00:14.716460+00:00 0:00:02.702583 15826 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T01:00:09.589734+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T23:00:00+00:00 TriggerDagRunOperator 2021-04-11T00:10:16.051605+00:00 2021-04-11T00:10:16.591724+00:00 0:00:00.540119 15818 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T00:10:13.699023+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T23:00:00+00:00 TriggerDagRunOperator 2021-04-11T00:10:15.926279+00:00 2021-04-11T00:10:16.335725+00:00 0:00:00.409446 15817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-11T00:10:13.698987+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T23:00:00+00:00 EmrJobFlowSensor 2021-04-11T00:00:51.161308+00:00 2021-04-11T00:09:53.989871+00:00 0:09:02.828563 15813 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-11T00:00:48.667133+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-11T00:00:28.827940+00:00 2021-04-11T00:00:30.532200+00:00 0:00:01.704260 15812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-11T00:00:26.608180+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T23:00:00+00:00 PythonOperator 2021-04-11T00:00:09.082594+00:00 2021-04-11T00:00:12.033753+00:00 0:00:02.951159 15811 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-11T00:00:06.589686+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T22:00:00+00:00 TriggerDagRunOperator 2021-04-10T23:10:09.421960+00:00 2021-04-10T23:10:09.895828+00:00 0:00:00.473868 15803 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T23:10:06.662217+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T22:00:00+00:00 TriggerDagRunOperator 2021-04-10T23:10:09.312245+00:00 2021-04-10T23:10:09.858732+00:00 0:00:00.546487 15802 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T23:10:06.662263+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T22:00:00+00:00 EmrJobFlowSensor 2021-04-10T23:00:58.023954+00:00 2021-04-10T23:10:00.638291+00:00 0:09:02.614337 15798 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T23:00:55.787276+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T23:00:36.497768+00:00 2021-04-10T23:00:38.232486+00:00 0:00:01.734718 15797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T23:00:33.761992+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T22:00:00+00:00 PythonOperator 2021-04-10T23:00:16.118967+00:00 2021-04-10T23:00:19.086491+00:00 0:00:02.967524 15796 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T23:00:13.638220+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T21:00:00+00:00 TriggerDagRunOperator 2021-04-10T22:09:06.349584+00:00 2021-04-10T22:09:06.813614+00:00 0:00:00.464030 15788 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T22:09:03.830603+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T21:00:00+00:00 TriggerDagRunOperator 2021-04-10T22:09:06.229977+00:00 2021-04-10T22:09:06.801403+00:00 0:00:00.571426 15787 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T22:09:03.830568+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T21:00:00+00:00 EmrJobFlowSensor 2021-04-10T22:00:55.414548+00:00 2021-04-10T22:08:57.975644+00:00 0:08:02.561096 15783 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T22:00:53.060365+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T22:00:33.457722+00:00 2021-04-10T22:00:35.195246+00:00 0:00:01.737524 15782 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T22:00:31.045937+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T21:00:00+00:00 PythonOperator 2021-04-10T22:00:11.327703+00:00 2021-04-10T22:00:14.075137+00:00 0:00:02.747434 15781 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T22:00:09.021267+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T20:00:00+00:00 TriggerDagRunOperator 2021-04-10T21:10:59.650675+00:00 2021-04-10T21:11:00.164312+00:00 0:00:00.513637 15773 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T21:10:56.991755+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T20:00:00+00:00 TriggerDagRunOperator 2021-04-10T21:10:59.443438+00:00 2021-04-10T21:10:59.879253+00:00 0:00:00.435815 15772 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T21:10:56.991711+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T20:00:00+00:00 EmrJobFlowSensor 2021-04-10T21:00:52.213311+00:00 2021-04-10T21:10:55.114059+00:00 0:10:02.900748 15768 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T21:00:49.938168+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T21:00:30.761381+00:00 2021-04-10T21:00:32.502851+00:00 0:00:01.741470 15767 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T21:00:28.059484+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T20:00:00+00:00 PythonOperator 2021-04-10T21:00:08.378676+00:00 2021-04-10T21:00:11.299079+00:00 0:00:02.920403 15766 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T21:00:05.892266+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T19:00:00+00:00 TriggerDagRunOperator 2021-04-10T20:10:40.040008+00:00 2021-04-10T20:10:40.586446+00:00 0:00:00.546438 15758 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T20:10:37.547651+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T19:00:00+00:00 TriggerDagRunOperator 2021-04-10T20:10:39.776322+00:00 2021-04-10T20:10:40.218976+00:00 0:00:00.442654 15757 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T20:10:37.547620+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T19:00:00+00:00 EmrJobFlowSensor 2021-04-10T20:00:53.034307+00:00 2021-04-10T20:09:55.620004+00:00 0:09:02.585697 15753 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T20:00:50.582452+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T20:00:30.920618+00:00 2021-04-10T20:00:32.637704+00:00 0:00:01.717086 15752 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T20:00:28.564723+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T19:00:00+00:00 PythonOperator 2021-04-10T20:00:10.702459+00:00 2021-04-10T20:00:13.639588+00:00 0:00:02.937129 15751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T20:00:08.445655+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T18:00:00+00:00 TriggerDagRunOperator 2021-04-10T19:10:29.334216+00:00 2021-04-10T19:10:29.885170+00:00 0:00:00.550954 15743 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T19:10:27.002352+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T18:00:00+00:00 TriggerDagRunOperator 2021-04-10T19:10:29.213565+00:00 2021-04-10T19:10:29.674239+00:00 0:00:00.460674 15742 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T19:10:27.002320+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T18:00:00+00:00 EmrJobFlowSensor 2021-04-10T19:01:10.356918+00:00 2021-04-10T19:10:13.056766+00:00 0:09:02.699848 15738 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T19:01:07.770245+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T19:00:47.843457+00:00 2021-04-10T19:00:49.531868+00:00 0:00:01.688411 15737 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T19:00:45.702308+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T18:00:00+00:00 PythonOperator 2021-04-10T19:00:20.028506+00:00 2021-04-10T19:00:22.728018+00:00 0:00:02.699512 15736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T19:00:17.677956+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T17:00:00+00:00 TriggerDagRunOperator 2021-04-10T18:11:16.098775+00:00 2021-04-10T18:11:16.544913+00:00 0:00:00.446138 15728 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T18:11:13.647989+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T17:00:00+00:00 TriggerDagRunOperator 2021-04-10T18:11:16.059945+00:00 2021-04-10T18:11:16.640575+00:00 0:00:00.580630 15727 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T18:11:13.648022+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T17:00:00+00:00 EmrJobFlowSensor 2021-04-10T18:00:59.026390+00:00 2021-04-10T18:11:01.835964+00:00 0:10:02.809574 15723 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T18:00:56.717339+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T18:00:37.027662+00:00 2021-04-10T18:00:38.793723+00:00 0:00:01.766061 15722 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T18:00:34.747328+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T17:00:00+00:00 PythonOperator 2021-04-10T18:00:17.289501+00:00 2021-04-10T18:00:20.103527+00:00 0:00:02.814026 15721 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T18:00:14.686877+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T16:00:00+00:00 TriggerDagRunOperator 2021-04-10T17:13:14.853194+00:00 2021-04-10T17:13:15.361525+00:00 0:00:00.508331 15714 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T17:13:12.005688+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T16:00:00+00:00 TriggerDagRunOperator 2021-04-10T17:13:14.618183+00:00 2021-04-10T17:13:15.060498+00:00 0:00:00.442315 15713 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T17:13:12.005658+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T16:00:00+00:00 EmrJobFlowSensor 2021-04-10T17:00:48.748518+00:00 2021-04-10T17:10:51.491597+00:00 0:10:02.743079 15708 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T17:00:46.503100+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T17:00:26.928107+00:00 2021-04-10T17:00:28.599832+00:00 0:00:01.671725 15707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T17:00:24.556319+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T16:00:00+00:00 PythonOperator 2021-04-10T17:00:04.643517+00:00 2021-04-10T17:00:07.347628+00:00 0:00:02.704111 15706 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T17:00:02.455321+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T15:00:00+00:00 TriggerDagRunOperator 2021-04-10T16:11:08.225174+00:00 2021-04-10T16:11:08.767249+00:00 0:00:00.542075 15699 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T16:11:05.313336+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T15:00:00+00:00 TriggerDagRunOperator 2021-04-10T16:11:07.740188+00:00 2021-04-10T16:11:08.189195+00:00 0:00:00.449007 15698 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T16:11:05.313287+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T15:00:00+00:00 EmrJobFlowSensor 2021-04-10T16:00:53.549043+00:00 2021-04-10T16:10:56.870021+00:00 0:10:03.320978 15693 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T16:00:51.099628+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T16:00:31.651412+00:00 2021-04-10T16:00:33.375290+00:00 0:00:01.723878 15692 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T16:00:29.242502+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T15:00:00+00:00 PythonOperator 2021-04-10T16:00:11.164200+00:00 2021-04-10T16:00:13.946956+00:00 0:00:02.782756 15691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T16:00:08.970745+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T14:00:00+00:00 TriggerDagRunOperator 2021-04-10T15:21:07.774786+00:00 2021-04-10T15:21:08.582422+00:00 0:00:00.807636 15684 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T15:21:05.341938+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T14:00:00+00:00 TriggerDagRunOperator 2021-04-10T15:21:07.597298+00:00 2021-04-10T15:21:07.998273+00:00 0:00:00.400975 15683 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T15:21:05.341972+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T14:00:00+00:00 EmrJobFlowSensor 2021-04-10T15:00:56.134882+00:00 2021-04-10T15:21:00.301778+00:00 0:20:04.166896 15678 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T15:00:53.622001+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T15:00:34.104440+00:00 2021-04-10T15:00:35.977618+00:00 0:00:01.873178 15677 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T15:00:31.672151+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T14:00:00+00:00 PythonOperator 2021-04-10T15:00:11.856400+00:00 2021-04-10T15:00:14.588193+00:00 0:00:02.731793 15676 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T15:00:09.592707+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T13:00:00+00:00 TriggerDagRunOperator 2021-04-10T14:11:16.813621+00:00 2021-04-10T14:11:17.207227+00:00 0:00:00.393606 15669 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T14:11:14.195419+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T13:00:00+00:00 TriggerDagRunOperator 2021-04-10T14:11:16.481383+00:00 2021-04-10T14:11:17.005036+00:00 0:00:00.523653 15668 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T14:11:14.195384+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T13:00:00+00:00 EmrJobFlowSensor 2021-04-10T14:00:55.232116+00:00 2021-04-10T14:10:57.969957+00:00 0:10:02.737841 15663 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T14:00:52.827363+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T14:00:33.210760+00:00 2021-04-10T14:00:35.424645+00:00 0:00:02.213885 15662 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T14:00:30.810052+00:00 2 default_pool