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-06T09:00:00+00:00 PythonOperator 2021-05-06T10:00:08.381760+00:00 2021-05-06T10:00:11.459921+00:00 0:00:03.078161 25054 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T10:00:06.084308+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T08:00:00+00:00 TriggerDagRunOperator 2021-05-06T09:09:00.897102+00:00 2021-05-06T09:09:01.337069+00:00 0:00:00.439967 25046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T09:08:58.160766+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T08:00:00+00:00 TriggerDagRunOperator 2021-05-06T09:09:00.827298+00:00 2021-05-06T09:09:01.396415+00:00 0:00:00.569117 25045 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T09:08:58.160721+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T08:00:00+00:00 EmrJobFlowSensor 2021-05-06T09:00:51.438854+00:00 2021-05-06T09:08:53.880505+00:00 0:08:02.441651 25040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T09:00:49.305790+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T09:00:25.807460+00:00 2021-05-06T09:00:27.656082+00:00 0:00:01.848622 25039 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T09:00:23.280655+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T08:00:00+00:00 PythonOperator 2021-05-06T09:00:05.610958+00:00 2021-05-06T09:00:08.651454+00:00 0:00:03.040496 25038 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T09:00:03.265765+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T07:00:00+00:00 TriggerDagRunOperator 2021-05-06T08:09:05.639069+00:00 2021-05-06T08:09:06.049405+00:00 0:00:00.410336 25030 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T08:09:03.057358+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T07:00:00+00:00 TriggerDagRunOperator 2021-05-06T08:09:05.370482+00:00 2021-05-06T08:09:05.925743+00:00 0:00:00.555261 25029 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T08:09:03.057395+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T07:00:00+00:00 EmrJobFlowSensor 2021-05-06T08:00:54.507900+00:00 2021-05-06T08:08:57.018492+00:00 0:08:02.510592 25025 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T08:00:52.169794+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T08:00:32.346253+00:00 2021-05-06T08:00:34.048176+00:00 0:00:01.701923 25024 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T08:00:30.152469+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T07:00:00+00:00 PythonOperator 2021-05-06T08:00:10.531511+00:00 2021-05-06T08:00:13.585206+00:00 0:00:03.053695 25023 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T08:00:08.069722+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T06:00:00+00:00 TriggerDagRunOperator 2021-05-06T07:11:17.079817+00:00 2021-05-06T07:11:17.589853+00:00 0:00:00.510036 25015 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T07:11:14.775078+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T06:00:00+00:00 TriggerDagRunOperator 2021-05-06T07:11:16.945361+00:00 2021-05-06T07:11:17.362245+00:00 0:00:00.416884 25014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T07:11:14.775048+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T06:00:00+00:00 EmrJobFlowSensor 2021-05-06T07:00:57.876312+00:00 2021-05-06T07:11:00.590591+00:00 0:10:02.714279 25010 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T07:00:55.647308+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T07:00:37.779369+00:00 2021-05-06T07:00:39.493049+00:00 0:00:01.713680 25009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T07:00:35.561632+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T06:00:00+00:00 PythonOperator 2021-05-06T07:00:16.181651+00:00 2021-05-06T07:00:19.288190+00:00 0:00:03.106539 25008 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T07:00:13.471022+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T05:00:00+00:00 TriggerDagRunOperator 2021-05-06T06:09:01.203339+00:00 2021-05-06T06:09:01.749009+00:00 0:00:00.545670 25000 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T06:08:58.856405+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T05:00:00+00:00 TriggerDagRunOperator 2021-05-06T06:09:01.140645+00:00 2021-05-06T06:09:01.592718+00:00 0:00:00.452073 24999 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T06:08:58.856359+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T05:00:00+00:00 EmrJobFlowSensor 2021-05-06T06:00:48.184490+00:00 2021-05-06T06:08:50.619499+00:00 0:08:02.435009 24995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T06:00:45.850865+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T06:00:25.878753+00:00 2021-05-06T06:00:27.588472+00:00 0:00:01.709719 24994 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T06:00:23.738850+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T05:00:00+00:00 PythonOperator 2021-05-06T06:00:06.161132+00:00 2021-05-06T06:00:09.264965+00:00 0:00:03.103833 24993 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T06:00:03.726978+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T04:00:00+00:00 TriggerDagRunOperator 2021-05-06T05:11:32.434888+00:00 2021-05-06T05:11:33.049972+00:00 0:00:00.615084 24985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T05:11:29.366467+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T04:00:00+00:00 TriggerDagRunOperator 2021-05-06T05:11:32.374648+00:00 2021-05-06T05:11:32.761676+00:00 0:00:00.387028 24984 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T05:11:29.366413+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T04:00:00+00:00 EmrJobFlowSensor 2021-05-06T05:01:06.296426+00:00 2021-05-06T05:11:09.210550+00:00 0:10:02.914124 24980 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T05:01:03.975557+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T05:00:41.961503+00:00 2021-05-06T05:00:43.655243+00:00 0:00:01.693740 24979 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T05:00:39.892071+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T04:00:00+00:00 PythonOperator 2021-05-06T05:00:16.080978+00:00 2021-05-06T05:00:19.120840+00:00 0:00:03.039862 24978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T05:00:13.827423+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T03:00:00+00:00 TriggerDagRunOperator 2021-05-06T04:21:20.712241+00:00 2021-05-06T04:21:21.243719+00:00 0:00:00.531478 24970 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T04:21:18.491891+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T03:00:00+00:00 TriggerDagRunOperator 2021-05-06T04:21:20.629908+00:00 2021-05-06T04:21:21.022184+00:00 0:00:00.392276 24969 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T04:21:18.491864+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T03:00:00+00:00 EmrJobFlowSensor 2021-05-06T04:00:52.489360+00:00 2021-05-06T04:20:56.800477+00:00 0:20:04.311117 24965 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T04:00:49.956837+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T04:00:30.315976+00:00 2021-05-06T04:00:32.004628+00:00 0:00:01.688652 24964 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T04:00:27.858072+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T03:00:00+00:00 PythonOperator 2021-05-06T04:00:10.376260+00:00 2021-05-06T04:00:13.427734+00:00 0:00:03.051474 24963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T04:00:07.677690+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T02:00:00+00:00 TriggerDagRunOperator 2021-05-06T03:10:22.529541+00:00 2021-05-06T03:10:23.088868+00:00 0:00:00.559327 24955 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T03:10:20.269012+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T02:00:00+00:00 TriggerDagRunOperator 2021-05-06T03:10:22.451574+00:00 2021-05-06T03:10:22.841449+00:00 0:00:00.389875 24954 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T03:10:20.268978+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T02:00:00+00:00 EmrJobFlowSensor 2021-05-06T03:01:05.735859+00:00 2021-05-06T03:10:08.571495+00:00 0:09:02.835636 24950 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T03:01:03.153485+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T03:00:43.251695+00:00 2021-05-06T03:00:44.931573+00:00 0:00:01.679878 24949 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T03:00:41.024993+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T02:00:00+00:00 PythonOperator 2021-05-06T03:00:21.197883+00:00 2021-05-06T03:00:24.340443+00:00 0:00:03.142560 24948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T03:00:19.010061+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T01:00:00+00:00 TriggerDagRunOperator 2021-05-06T02:10:08.778267+00:00 2021-05-06T02:10:09.310343+00:00 0:00:00.532076 24940 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T02:10:06.400424+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T01:00:00+00:00 TriggerDagRunOperator 2021-05-06T02:10:08.478588+00:00 2021-05-06T02:10:08.928241+00:00 0:00:00.449653 24939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T02:10:06.400458+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T01:00:00+00:00 EmrJobFlowSensor 2021-05-06T02:00:51.026672+00:00 2021-05-06T02:09:53.768971+00:00 0:09:02.742299 24935 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T02:00:48.813567+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T02:00:29.244031+00:00 2021-05-06T02:00:31.069654+00:00 0:00:01.825623 24934 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T02:00:26.765704+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T01:00:00+00:00 PythonOperator 2021-05-06T02:00:07.399253+00:00 2021-05-06T02:00:10.493298+00:00 0:00:03.094045 24933 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T02:00:04.640938+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-06T00:00:00+00:00 TriggerDagRunOperator 2021-05-06T01:10:32.132666+00:00 2021-05-06T01:10:32.728342+00:00 0:00:00.595676 24925 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T01:10:29.449036+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-06T00:00:00+00:00 TriggerDagRunOperator 2021-05-06T01:10:32.014963+00:00 2021-05-06T01:10:32.426912+00:00 0:00:00.411949 24924 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T01:10:29.449084+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-06T00:00:00+00:00 EmrJobFlowSensor 2021-05-06T01:01:06.669608+00:00 2021-05-06T01:10:09.496726+00:00 0:09:02.827118 24920 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T01:01:04.255812+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-06T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T01:00:46.852095+00:00 2021-05-06T01:00:48.652907+00:00 0:00:01.800812 24919 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T01:00:44.369503+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-06T00:00:00+00:00 PythonOperator 2021-05-06T01:00:24.507386+00:00 2021-05-06T01:00:27.598317+00:00 0:00:03.090931 24918 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T01:00:21.976236+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T23:00:00+00:00 TriggerDagRunOperator 2021-05-06T00:11:25.488747+00:00 2021-05-06T00:11:25.980264+00:00 0:00:00.491517 24910 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T00:11:22.947572+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T23:00:00+00:00 TriggerDagRunOperator 2021-05-06T00:11:25.133085+00:00 2021-05-06T00:11:25.534742+00:00 0:00:00.401657 24909 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-06T00:11:22.947531+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T23:00:00+00:00 EmrJobFlowSensor 2021-05-06T00:01:04.131622+00:00 2021-05-06T00:11:06.966402+00:00 0:10:02.834780 24905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-06T00:01:01.746748+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-06T00:00:44.108639+00:00 2021-05-06T00:00:45.813626+00:00 0:00:01.704987 24904 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-06T00:00:41.792182+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T23:00:00+00:00 PythonOperator 2021-05-06T00:00:08.130699+00:00 2021-05-06T00:00:11.229817+00:00 0:00:03.099118 24903 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-06T00:00:05.647103+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T22:00:00+00:00 TriggerDagRunOperator 2021-05-05T23:10:08.118216+00:00 2021-05-05T23:10:08.735429+00:00 0:00:00.617213 24895 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T23:10:05.617893+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T22:00:00+00:00 TriggerDagRunOperator 2021-05-05T23:10:07.809376+00:00 2021-05-05T23:10:08.298749+00:00 0:00:00.489373 24894 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T23:10:05.617857+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T22:00:00+00:00 EmrJobFlowSensor 2021-05-05T23:00:58.983396+00:00 2021-05-05T23:10:01.835616+00:00 0:09:02.852220 24889 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T23:00:56.549699+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T23:00:31.231413+00:00 2021-05-05T23:00:33.031460+00:00 0:00:01.800047 24887 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T23:00:28.747980+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T22:00:00+00:00 PythonOperator 2021-05-05T23:00:09.367639+00:00 2021-05-05T23:00:12.453771+00:00 0:00:03.086132 24885 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T23:00:06.561740+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T21:00:00+00:00 TriggerDagRunOperator 2021-05-05T22:10:24.217726+00:00 2021-05-05T22:10:24.635118+00:00 0:00:00.417392 24877 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T22:10:21.803356+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T21:00:00+00:00 TriggerDagRunOperator 2021-05-05T22:10:24.037609+00:00 2021-05-05T22:10:24.567515+00:00 0:00:00.529906 24876 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T22:10:21.803390+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T21:00:00+00:00 EmrJobFlowSensor 2021-05-05T22:01:02.812572+00:00 2021-05-05T22:10:05.584942+00:00 0:09:02.772370 24872 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T22:01:00.362052+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T22:00:40.500487+00:00 2021-05-05T22:00:42.208033+00:00 0:00:01.707546 24871 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T22:00:38.296103+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T21:00:00+00:00 PythonOperator 2021-05-05T22:00:20.662006+00:00 2021-05-05T22:00:23.756906+00:00 0:00:03.094900 24870 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T22:00:18.240088+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T20:00:00+00:00 TriggerDagRunOperator 2021-05-05T21:12:58.957646+00:00 2021-05-05T21:12:59.356312+00:00 0:00:00.398666 24862 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T21:12:56.137887+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T20:00:00+00:00 TriggerDagRunOperator 2021-05-05T21:12:58.491849+00:00 2021-05-05T21:12:59.013742+00:00 0:00:00.521893 24861 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T21:12:56.137857+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T20:00:00+00:00 EmrJobFlowSensor 2021-05-05T21:00:50.793045+00:00 2021-05-05T21:12:53.872060+00:00 0:12:03.079015 24857 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T21:00:48.706320+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T21:00:29.129762+00:00 2021-05-05T21:00:30.807338+00:00 0:00:01.677576 24856 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T21:00:26.759824+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T20:00:00+00:00 PythonOperator 2021-05-05T21:00:07.454388+00:00 2021-05-05T21:00:10.530641+00:00 0:00:03.076253 24855 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T21:00:04.759493+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T19:00:00+00:00 TriggerDagRunOperator 2021-05-05T20:10:07.742556+00:00 2021-05-05T20:10:08.312105+00:00 0:00:00.569549 24847 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T20:10:05.268325+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T19:00:00+00:00 TriggerDagRunOperator 2021-05-05T20:10:07.560698+00:00 2021-05-05T20:10:07.973854+00:00 0:00:00.413156 24846 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T20:10:05.268281+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T19:00:00+00:00 EmrJobFlowSensor 2021-05-05T20:00:55.775002+00:00 2021-05-05T20:09:58.659165+00:00 0:09:02.884163 24842 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T20:00:53.652932+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T20:00:35.835289+00:00 2021-05-05T20:00:37.514192+00:00 0:00:01.678903 24841 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T20:00:33.607146+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T19:00:00+00:00 PythonOperator 2021-05-05T20:00:14.473035+00:00 2021-05-05T20:00:17.526575+00:00 0:00:03.053540 24840 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T20:00:11.680919+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T18:00:00+00:00 TriggerDagRunOperator 2021-05-05T19:09:03.187212+00:00 2021-05-05T19:09:03.781803+00:00 0:00:00.594591 24832 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T19:09:00.730805+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T18:00:00+00:00 TriggerDagRunOperator 2021-05-05T19:09:02.996193+00:00 2021-05-05T19:09:03.494547+00:00 0:00:00.498354 24831 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T19:09:00.730758+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T18:00:00+00:00 EmrJobFlowSensor 2021-05-05T19:00:49.901696+00:00 2021-05-05T19:08:52.441687+00:00 0:08:02.539991 24827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T19:00:47.591770+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T19:00:27.896693+00:00 2021-05-05T19:00:29.797716+00:00 0:00:01.901023 24826 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T19:00:25.516815+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T18:00:00+00:00 PythonOperator 2021-05-05T19:00:07.934793+00:00 2021-05-05T19:00:11.067767+00:00 0:00:03.132974 24825 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T19:00:05.491882+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T17:00:00+00:00 TriggerDagRunOperator 2021-05-05T18:09:12.207896+00:00 2021-05-05T18:09:12.736204+00:00 0:00:00.528308 24817 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T18:09:09.897723+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T17:00:00+00:00 TriggerDagRunOperator 2021-05-05T18:09:11.992157+00:00 2021-05-05T18:09:12.426412+00:00 0:00:00.434255 24816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T18:09:09.897759+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T17:00:00+00:00 EmrJobFlowSensor 2021-05-05T18:01:03.591327+00:00 2021-05-05T18:09:06.225074+00:00 0:08:02.633747 24812 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T18:01:01.121967+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T18:00:41.195757+00:00 2021-05-05T18:00:42.902503+00:00 0:00:01.706746 24811 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T18:00:39.100901+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T17:00:00+00:00 PythonOperator 2021-05-05T18:00:19.255668+00:00 2021-05-05T18:00:22.372628+00:00 0:00:03.116960 24810 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T18:00:17.088058+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T16:00:00+00:00 TriggerDagRunOperator 2021-05-05T17:16:10.438940+00:00 2021-05-05T17:16:10.937634+00:00 0:00:00.498694 24801 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T17:16:07.858450+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T16:00:00+00:00 TriggerDagRunOperator 2021-05-05T17:16:10.328679+00:00 2021-05-05T17:16:10.723419+00:00 0:00:00.394740 24800 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T17:16:07.858485+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T16:00:00+00:00 EmrJobFlowSensor 2021-05-05T17:01:09.171748+00:00 2021-05-05T17:09:11.819230+00:00 0:08:02.647482 24797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T17:01:06.962100+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T17:00:47.348196+00:00 2021-05-05T17:00:49.179545+00:00 0:00:01.831349 24796 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T17:00:44.919442+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T16:00:00+00:00 PythonOperator 2021-05-05T17:00:25.113306+00:00 2021-05-05T17:00:28.154862+00:00 0:00:03.041556 24795 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T17:00:22.951628+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T15:00:00+00:00 TriggerDagRunOperator 2021-05-05T16:13:08.456713+00:00 2021-05-05T16:13:08.999733+00:00 0:00:00.543020 24788 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T16:13:06.004877+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T15:00:00+00:00 TriggerDagRunOperator 2021-05-05T16:13:08.302699+00:00 2021-05-05T16:13:08.707889+00:00 0:00:00.405190 24787 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T16:13:06.004909+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T15:00:00+00:00 EmrJobFlowSensor 2021-05-05T16:03:59.730698+00:00 2021-05-05T16:13:02.517646+00:00 0:09:02.786948 24783 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T16:03:57.152924+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T16:03:39.251244+00:00 2021-05-05T16:03:41.015255+00:00 0:00:01.764011 24782 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T16:03:37.023420+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T15:00:00+00:00 PythonOperator 2021-05-05T16:03:07.297391+00:00 2021-05-05T16:03:10.391271+00:00 0:00:03.093880 24781 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T16:03:04.993193+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T14:00:00+00:00 TriggerDagRunOperator 2021-05-05T15:11:11.357564+00:00 2021-05-05T15:11:11.876483+00:00 0:00:00.518919 24773 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T15:11:08.860879+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T14:00:00+00:00 TriggerDagRunOperator 2021-05-05T15:11:11.171692+00:00 2021-05-05T15:11:11.616123+00:00 0:00:00.444431 24772 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T15:11:08.860922+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T14:00:00+00:00 EmrJobFlowSensor 2021-05-05T15:01:04.321579+00:00 2021-05-05T15:11:07.175035+00:00 0:10:02.853456 24768 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T15:01:01.947242+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T15:00:44.000351+00:00 2021-05-05T15:00:45.670781+00:00 0:00:01.670430 24767 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T15:00:41.835536+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T14:00:00+00:00 PythonOperator 2021-05-05T15:00:22.640930+00:00 2021-05-05T15:00:25.687594+00:00 0:00:03.046664 24766 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T15:00:19.843503+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T13:00:00+00:00 TriggerDagRunOperator 2021-05-05T14:11:02.557671+00:00 2021-05-05T14:11:03.160755+00:00 0:00:00.603084 24758 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T14:11:00.119350+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T13:00:00+00:00 TriggerDagRunOperator 2021-05-05T14:11:02.394211+00:00 2021-05-05T14:11:02.830288+00:00 0:00:00.436077 24757 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T14:11:00.119379+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T13:00:00+00:00 EmrJobFlowSensor 2021-05-05T14:00:55.320258+00:00 2021-05-05T14:10:58.148559+00:00 0:10:02.828301 24753 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T14:00:53.141122+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T14:00:33.480726+00:00 2021-05-05T14:00:35.352033+00:00 0:00:01.871307 24752 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T14:00:31.122277+00:00 2 default_pool