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 check_cluster_status 2023-03-03T21:00:00+00:00 EmrJobFlowSensor 2023-03-03T22:01:07.869582+00:00 2023-03-03T22:11:09.668506+00:00 0:10:01.798924 348050 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-03T22:01:04.791339+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-03T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-03T22:00:45.353776+00:00 2023-03-03T22:00:46.264799+00:00 0:00:00.911023 348048 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-03T22:00:42.658262+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-03T21:00:00+00:00 PythonOperator 2023-03-03T22:00:22.826409+00:00 2023-03-03T22:00:26.784147+00:00 0:00:03.957738 348046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-03T22:00:20.637576+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-03T20:00:00+00:00 TriggerDagRunOperator 2023-03-03T21:12:03.549030+00:00 2023-03-03T21:12:04.074489+00:00 0:00:00.525459 348035 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T21:12:01.033672+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-03T20:00:00+00:00 TriggerDagRunOperator 2023-03-03T21:12:03.426430+00:00 2023-03-03T21:12:03.892664+00:00 0:00:00.466234 348034 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T21:12:01.033644+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-03T20:00:00+00:00 EmrJobFlowSensor 2023-03-03T21:01:42.718291+00:00 2023-03-03T21:11:44.572044+00:00 0:10:01.853753 348027 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-03T21:01:40.353554+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-03T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-03T21:01:22.707298+00:00 2023-03-03T21:01:23.627708+00:00 0:00:00.920410 348025 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-03T21:01:20.337109+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-03T20:00:00+00:00 PythonOperator 2023-03-03T21:01:01.162091+00:00 2023-03-03T21:01:07.633053+00:00 0:00:06.470962 348023 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-03T21:00:58.306840+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-03T19:00:00+00:00 TriggerDagRunOperator 2023-03-03T20:38:21.181825+00:00 2023-03-03T20:38:21.673877+00:00 0:00:00.492052 348016 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T20:38:18.065144+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-03T19:00:00+00:00 TriggerDagRunOperator 2023-03-03T20:38:21.086954+00:00 2023-03-03T20:38:21.546337+00:00 0:00:00.459383 348015 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T20:38:18.065109+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-03T19:00:00+00:00 EmrJobFlowSensor 2023-03-03T20:13:15.409624+00:00 2023-03-03T20:23:17.220101+00:00 0:10:01.810477 348011 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-03T20:13:13.181318+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-03T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-03T20:12:54.420851+00:00 2023-03-03T20:12:55.303180+00:00 0:00:00.882329 348009 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-03T20:12:51.161885+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-03T19:00:00+00:00 PythonOperator 2023-03-03T20:12:31.898928+00:00 2023-03-03T20:12:35.796652+00:00 0:00:03.897724 348006 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-03T20:12:29.209273+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-03T18:00:00+00:00 TriggerDagRunOperator 2023-03-03T19:16:53.855097+00:00 2023-03-03T19:16:54.453019+00:00 0:00:00.597922 347995 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T19:16:51.340104+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-03T18:00:00+00:00 TriggerDagRunOperator 2023-03-03T19:16:53.833970+00:00 2023-03-03T19:16:54.385846+00:00 0:00:00.551876 347994 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T19:16:51.340076+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-03T18:00:00+00:00 EmrJobFlowSensor 2023-03-03T19:06:42.863911+00:00 2023-03-03T19:16:44.993874+00:00 0:10:02.129963 347990 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-03T19:06:40.550526+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-03T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-03T19:06:20.752028+00:00 2023-03-03T19:06:21.601245+00:00 0:00:00.849217 347987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-03T19:06:18.527475+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-03T18:00:00+00:00 PythonOperator 2023-03-03T19:06:02.425341+00:00 2023-03-03T19:06:05.780427+00:00 0:00:03.355086 347984 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-03T19:05:58.528694+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-03T17:00:00+00:00 TriggerDagRunOperator 2023-03-03T18:31:38.336111+00:00 2023-03-03T18:31:38.844161+00:00 0:00:00.508050 347976 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T18:31:35.737371+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-03T17:00:00+00:00 TriggerDagRunOperator 2023-03-03T18:31:38.320909+00:00 2023-03-03T18:31:38.795523+00:00 0:00:00.474614 347975 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T18:31:35.737344+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-03T17:00:00+00:00 EmrJobFlowSensor 2023-03-03T18:07:56.568553+00:00 2023-03-03T18:17:58.369070+00:00 0:10:01.800517 347970 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-03T18:07:54.376341+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-03T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-03T18:07:34.545033+00:00 2023-03-03T18:07:35.396804+00:00 0:00:00.851771 347967 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-03T18:07:32.361260+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-03T17:00:00+00:00 PythonOperator 2023-03-03T18:07:15.401035+00:00 2023-03-03T18:07:19.112055+00:00 0:00:03.711020 347964 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-03T18:07:12.340629+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-03T16:00:00+00:00 TriggerDagRunOperator 2023-03-03T17:22:00.345116+00:00 2023-03-03T17:22:00.898008+00:00 0:00:00.552892 347957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T17:21:57.492008+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-03T16:00:00+00:00 TriggerDagRunOperator 2023-03-03T17:22:00.262543+00:00 2023-03-03T17:22:00.824473+00:00 0:00:00.561930 347956 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T17:21:57.492038+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-03T16:00:00+00:00 EmrJobFlowSensor 2023-03-03T17:10:34.344364+00:00 2023-03-03T17:20:36.151560+00:00 0:10:01.807196 347952 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-03T17:10:31.915980+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-03T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-03T17:10:12.252305+00:00 2023-03-03T17:10:13.029153+00:00 0:00:00.776848 347949 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-03T17:10:09.887198+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-03T16:00:00+00:00 PythonOperator 2023-03-03T17:09:50.109470+00:00 2023-03-03T17:09:56.156910+00:00 0:00:06.047440 347946 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-03T17:09:47.865037+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-03T15:00:00+00:00 TriggerDagRunOperator 2023-03-03T16:11:30.334665+00:00 2023-03-03T16:11:30.802548+00:00 0:00:00.467883 347939 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T16:11:27.690232+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-03T15:00:00+00:00 TriggerDagRunOperator 2023-03-03T16:11:30.176979+00:00 2023-03-03T16:11:30.656777+00:00 0:00:00.479798 347938 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T16:11:27.690195+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-03T15:00:00+00:00 EmrJobFlowSensor 2023-03-03T16:01:07.661173+00:00 2023-03-03T16:11:09.522794+00:00 0:10:01.861621 347932 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-03T16:01:04.493972+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-03T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-03T16:00:45.408194+00:00 2023-03-03T16:00:46.514367+00:00 0:00:01.106173 347930 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-03T16:00:40.347743+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-03T15:00:00+00:00 PythonOperator 2023-03-03T16:00:21.982646+00:00 2023-03-03T16:00:25.620657+00:00 0:00:03.638011 347928 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-03T16:00:18.338351+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-03T14:00:00+00:00 TriggerDagRunOperator 2023-03-03T15:18:13.481268+00:00 2023-03-03T15:18:14.084434+00:00 0:00:00.603166 347919 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T15:18:10.961814+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-03T14:00:00+00:00 TriggerDagRunOperator 2023-03-03T15:18:13.317993+00:00 2023-03-03T15:18:13.803454+00:00 0:00:00.485461 347918 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T15:18:10.961784+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-03T14:00:00+00:00 EmrJobFlowSensor 2023-03-03T15:08:03.199456+00:00 2023-03-03T15:18:05.231053+00:00 0:10:02.031597 347913 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-03T15:08:00.828818+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-03T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-03T15:07:41.239497+00:00 2023-03-03T15:07:42.736784+00:00 0:00:01.497287 347910 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-03T15:07:38.795244+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-03T14:00:00+00:00 PythonOperator 2023-03-03T15:07:21.676918+00:00 2023-03-03T15:07:25.606278+00:00 0:00:03.929360 347907 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-03T15:07:18.814247+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-03T13:00:00+00:00 TriggerDagRunOperator 2023-03-03T14:11:18.805617+00:00 2023-03-03T14:11:19.318532+00:00 0:00:00.512915 347899 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T14:11:16.530446+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-03T13:00:00+00:00 TriggerDagRunOperator 2023-03-03T14:11:18.734568+00:00 2023-03-03T14:11:19.374951+00:00 0:00:00.640383 347898 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T14:11:16.530479+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-03T13:00:00+00:00 EmrJobFlowSensor 2023-03-03T14:01:04.980558+00:00 2023-03-03T14:11:06.777202+00:00 0:10:01.796644 347892 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-03T14:01:02.642146+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-03T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-03T14:00:45.144194+00:00 2023-03-03T14:00:46.026099+00:00 0:00:00.881905 347890 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-03T14:00:40.597865+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-03T13:00:00+00:00 PythonOperator 2023-03-03T14:00:20.787238+00:00 2023-03-03T14:00:24.707375+00:00 0:00:03.920137 347888 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-03T14:00:18.577461+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-03T12:00:00+00:00 TriggerDagRunOperator 2023-03-03T13:30:24.712647+00:00 2023-03-03T13:30:25.320198+00:00 0:00:00.607551 347882 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T13:30:21.497188+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-03T12:00:00+00:00 TriggerDagRunOperator 2023-03-03T13:30:24.393323+00:00 2023-03-03T13:30:24.855709+00:00 0:00:00.462386 347881 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T13:30:21.497221+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-03T12:00:00+00:00 EmrJobFlowSensor 2023-03-03T13:13:34.203122+00:00 2023-03-03T13:23:36.065707+00:00 0:10:01.862585 347878 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-03T13:13:30.896799+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-03T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-03T13:13:13.708301+00:00 2023-03-03T13:13:14.622267+00:00 0:00:00.913966 347875 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-03T13:13:10.860413+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-03T12:00:00+00:00 PythonOperator 2023-03-03T13:12:52.039211+00:00 2023-03-03T13:12:55.111845+00:00 0:00:03.072634 347872 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-03T13:12:48.890812+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-03T11:00:00+00:00 TriggerDagRunOperator 2023-03-03T12:24:27.349841+00:00 2023-03-03T12:24:27.859997+00:00 0:00:00.510156 347862 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T12:24:22.369513+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-03T11:00:00+00:00 TriggerDagRunOperator 2023-03-03T12:24:24.604226+00:00 2023-03-03T12:24:25.048218+00:00 0:00:00.443992 347861 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T12:24:22.369466+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-03T11:00:00+00:00 EmrJobFlowSensor 2023-03-03T12:01:07.890241+00:00 2023-03-03T12:11:09.726854+00:00 0:10:01.836613 347857 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-03T12:01:05.323456+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-03T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-03T12:00:47.196188+00:00 2023-03-03T12:00:48.677814+00:00 0:00:01.481626 347855 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-03T12:00:43.320895+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-03T11:00:00+00:00 PythonOperator 2023-03-03T12:00:23.724796+00:00 2023-03-03T12:00:27.704968+00:00 0:00:03.980172 347852 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-03T12:00:21.209277+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-03T10:00:00+00:00 TriggerDagRunOperator 2023-03-03T11:23:18.367142+00:00 2023-03-03T11:23:18.993842+00:00 0:00:00.626700 347844 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T11:23:15.402686+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-03T10:00:00+00:00 TriggerDagRunOperator 2023-03-03T11:23:18.207445+00:00 2023-03-03T11:23:18.679989+00:00 0:00:00.472544 347843 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T11:23:15.402715+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-03T10:00:00+00:00 EmrJobFlowSensor 2023-03-03T11:04:23.636242+00:00 2023-03-03T11:14:25.331933+00:00 0:10:01.695691 347836 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-03T11:04:21.326321+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-03T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-03T11:04:03.454120+00:00 2023-03-03T11:04:04.243563+00:00 0:00:00.789443 347834 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-03T11:04:01.294182+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-03T10:00:00+00:00 PythonOperator 2023-03-03T11:03:41.799508+00:00 2023-03-03T11:03:45.719445+00:00 0:00:03.919937 347832 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-03T11:03:39.255017+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-03T09:00:00+00:00 TriggerDagRunOperator 2023-03-03T10:15:36.168740+00:00 2023-03-03T10:15:36.720358+00:00 0:00:00.551618 347825 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T10:15:33.296731+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-03T09:00:00+00:00 TriggerDagRunOperator 2023-03-03T10:15:36.068908+00:00 2023-03-03T10:15:36.604850+00:00 0:00:00.535942 347824 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T10:15:33.296775+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-03T09:00:00+00:00 EmrJobFlowSensor 2023-03-03T10:05:15.512978+00:00 2023-03-03T10:15:17.791758+00:00 0:10:02.278780 347817 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-03T10:05:12.591482+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-03T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-03T10:04:55.008738+00:00 2023-03-03T10:04:55.989788+00:00 0:00:00.981050 347816 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-03T10:04:52.537348+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-03T09:00:00+00:00 PythonOperator 2023-03-03T10:04:33.077771+00:00 2023-03-03T10:04:37.395582+00:00 0:00:04.317811 347813 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-03T10:04:30.554519+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-03T08:00:00+00:00 TriggerDagRunOperator 2023-03-03T09:29:40.865972+00:00 2023-03-03T09:29:41.443293+00:00 0:00:00.577321 347806 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T09:29:37.968505+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-03T08:00:00+00:00 TriggerDagRunOperator 2023-03-03T09:29:40.880231+00:00 2023-03-03T09:29:41.511261+00:00 0:00:00.631030 347805 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T09:29:37.968538+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-03T08:00:00+00:00 EmrJobFlowSensor 2023-03-03T09:11:16.518507+00:00 2023-03-03T09:21:18.350923+00:00 0:10:01.832416 347801 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-03T09:11:14.130553+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-03T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-03T09:10:54.494030+00:00 2023-03-03T09:10:55.401668+00:00 0:00:00.907638 347798 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-03T09:10:52.106586+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-03T08:00:00+00:00 PythonOperator 2023-03-03T09:10:32.480009+00:00 2023-03-03T09:10:36.639346+00:00 0:00:04.159337 347795 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-03T09:10:30.107994+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-03T07:00:00+00:00 TriggerDagRunOperator 2023-03-03T08:11:22.009549+00:00 2023-03-03T08:11:22.560697+00:00 0:00:00.551148 347787 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T08:11:19.119114+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-03T07:00:00+00:00 TriggerDagRunOperator 2023-03-03T08:11:21.956109+00:00 2023-03-03T08:11:22.442144+00:00 0:00:00.486035 347786 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T08:11:19.119146+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-03T07:00:00+00:00 EmrJobFlowSensor 2023-03-03T08:01:08.912863+00:00 2023-03-03T08:10:10.633098+00:00 0:09:01.720235 347779 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-03T08:01:06.451582+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-03T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-03T08:00:44.952783+00:00 2023-03-03T08:00:46.001137+00:00 0:00:01.048354 347777 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-03T08:00:42.499381+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-03T07:00:00+00:00 PythonOperator 2023-03-03T08:00:22.966247+00:00 2023-03-03T08:00:25.981950+00:00 0:00:03.015703 347775 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-03T08:00:20.359911+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-03T06:00:00+00:00 TriggerDagRunOperator 2023-03-03T07:32:22.226053+00:00 2023-03-03T07:32:22.726598+00:00 0:00:00.500545 347767 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T07:32:19.325704+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-03T06:00:00+00:00 TriggerDagRunOperator 2023-03-03T07:32:22.152766+00:00 2023-03-03T07:32:22.700013+00:00 0:00:00.547247 347766 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T07:32:19.325675+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-03T06:00:00+00:00 EmrJobFlowSensor 2023-03-03T07:21:57.474854+00:00 2023-03-03T07:31:59.338593+00:00 0:10:01.863739 347763 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-03T07:21:54.942630+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-03T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-03T07:21:35.084366+00:00 2023-03-03T07:21:35.878445+00:00 0:00:00.794079 347760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-03T07:21:32.863502+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-03T06:00:00+00:00 PythonOperator 2023-03-03T07:21:13.165398+00:00 2023-03-03T07:21:16.208822+00:00 0:00:03.043424 347757 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-03T07:21:10.841028+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-03T05:00:00+00:00 TriggerDagRunOperator 2023-03-03T06:11:12.666650+00:00 2023-03-03T06:11:13.198144+00:00 0:00:00.531494 347748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T06:11:10.040734+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-03T05:00:00+00:00 TriggerDagRunOperator 2023-03-03T06:11:12.670503+00:00 2023-03-03T06:11:13.242208+00:00 0:00:00.571705 347747 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T06:11:10.040695+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-03T05:00:00+00:00 EmrJobFlowSensor 2023-03-03T06:03:50.449341+00:00 2023-03-03T06:10:51.853400+00:00 0:07:01.404059 347740 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-03T06:03:47.910261+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-03T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-03T06:00:29.402477+00:00 2023-03-03T06:00:30.245303+00:00 0:00:00.842826 347737 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-03T06:00:27.074417+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-03T05:00:00+00:00 PythonOperator 2023-03-03T06:00:09.433062+00:00 2023-03-03T06:00:12.525959+00:00 0:00:03.092897 347735 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-03T06:00:07.057309+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-03T04:00:00+00:00 TriggerDagRunOperator 2023-03-03T05:11:50.769462+00:00 2023-03-03T05:11:51.308660+00:00 0:00:00.539198 347725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T05:11:48.298887+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-03T04:00:00+00:00 TriggerDagRunOperator 2023-03-03T05:11:50.764320+00:00 2023-03-03T05:11:51.295678+00:00 0:00:00.531358 347724 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T05:11:48.298914+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-03T04:00:00+00:00 EmrJobFlowSensor 2023-03-03T05:00:54.963042+00:00 2023-03-03T05:09:56.755202+00:00 0:09:01.792160 347716 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-03T05:00:52.603816+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-03T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-03T05:00:33.222466+00:00 2023-03-03T05:00:34.155747+00:00 0:00:00.933281 347714 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-03T05:00:30.607138+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-03T04:00:00+00:00 PythonOperator 2023-03-03T05:00:10.915415+00:00 2023-03-03T05:00:16.323951+00:00 0:00:05.408536 347712 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-03T05:00:08.430501+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-03T03:00:00+00:00 TriggerDagRunOperator 2023-03-03T04:17:39.468737+00:00 2023-03-03T04:17:39.980467+00:00 0:00:00.511730 347704 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T04:17:36.546597+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-03T03:00:00+00:00 TriggerDagRunOperator 2023-03-03T04:17:39.393908+00:00 2023-03-03T04:17:39.881865+00:00 0:00:00.487957 347703 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T04:17:36.546625+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-03T03:00:00+00:00 EmrJobFlowSensor 2023-03-03T04:07:23.138674+00:00 2023-03-03T04:17:24.849191+00:00 0:10:01.710517 347698 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-03T04:07:20.904556+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-03T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-03T04:07:01.234746+00:00 2023-03-03T04:07:02.110240+00:00 0:00:00.875494 347695 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-03T04:06:58.883247+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-03T03:00:00+00:00 PythonOperator 2023-03-03T04:06:41.793734+00:00 2023-03-03T04:06:45.263446+00:00 0:00:03.469712 347693 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-03T04:06:38.843887+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-03T02:00:00+00:00 TriggerDagRunOperator 2023-03-03T03:28:00.112519+00:00 2023-03-03T03:28:00.629562+00:00 0:00:00.517043 347685 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T03:27:56.874433+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-03T02:00:00+00:00 TriggerDagRunOperator 2023-03-03T03:27:59.790602+00:00 2023-03-03T03:28:00.345913+00:00 0:00:00.555311 347684 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T03:27:56.874472+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-03T02:00:00+00:00 EmrJobFlowSensor 2023-03-03T03:17:31.752532+00:00 2023-03-03T03:27:33.517982+00:00 0:10:01.765450 347680 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-03T03:17:29.389074+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-03T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-03T03:17:09.754011+00:00 2023-03-03T03:17:10.633172+00:00 0:00:00.879161 347677 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-03T03:17:07.364626+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-03T02:00:00+00:00 PythonOperator 2023-03-03T03:16:49.697641+00:00 2023-03-03T03:16:52.915156+00:00 0:00:03.217515 347674 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-03T03:16:47.348550+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-03T01:00:00+00:00 TriggerDagRunOperator 2023-03-03T02:29:50.432455+00:00 2023-03-03T02:29:51.108731+00:00 0:00:00.676276 347668 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T02:29:47.646338+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-03T01:00:00+00:00 TriggerDagRunOperator 2023-03-03T02:29:50.346906+00:00 2023-03-03T02:29:50.831215+00:00 0:00:00.484309 347667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T02:29:47.646311+00:00 2 default_pool