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 trigger_dagrun_campaign-history-job_v002 2023-04-04T15:00:00+00:00 TriggerDagRunOperator 2023-04-04T16:21:18.406395+00:00 2023-04-04T16:21:18.843195+00:00 0:00:00.436800 363998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T16:21:15.717515+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-04T15:00:00+00:00 EmrJobFlowSensor 2023-04-04T16:03:08.607123+00:00 2023-04-04T16:13:10.447241+00:00 0:10:01.840118 363991 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-04T16:03:06.247902+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-04T15:00:00+00:00 EmrCreateJobFlowOperator 2023-04-04T16:02:46.584420+00:00 2023-04-04T16:02:47.463415+00:00 0:00:00.878995 363989 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-04T16:02:44.187342+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-04T15:00:00+00:00 PythonOperator 2023-04-04T16:02:24.788595+00:00 2023-04-04T16:02:28.305970+00:00 0:00:03.517375 363987 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-04T16:02:22.166672+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-04T14:00:00+00:00 TriggerDagRunOperator 2023-04-04T15:48:59.451123+00:00 2023-04-04T15:48:59.974750+00:00 0:00:00.523627 363982 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T15:48:56.685271+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-04T14:00:00+00:00 TriggerDagRunOperator 2023-04-04T15:48:59.213761+00:00 2023-04-04T15:48:59.661905+00:00 0:00:00.448144 363981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T15:48:56.685299+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-04T14:00:00+00:00 EmrJobFlowSensor 2023-04-04T15:17:45.752216+00:00 2023-04-04T15:27:47.603231+00:00 0:10:01.851015 363977 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-04T15:17:42.551944+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-04T14:00:00+00:00 EmrCreateJobFlowOperator 2023-04-04T15:17:24.496043+00:00 2023-04-04T15:17:25.815343+00:00 0:00:01.319300 363973 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-04T15:17:20.534089+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-04T14:00:00+00:00 PythonOperator 2023-04-04T15:17:02.850210+00:00 2023-04-04T15:17:06.964536+00:00 0:00:04.114326 363969 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-04T15:16:58.506081+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-04T13:00:00+00:00 TriggerDagRunOperator 2023-04-04T15:17:02.702990+00:00 2023-04-04T15:17:03.233624+00:00 0:00:00.530634 363968 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T15:16:58.506067+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-04T13:00:00+00:00 TriggerDagRunOperator 2023-04-04T15:17:00.831064+00:00 2023-04-04T15:17:01.622974+00:00 0:00:00.791910 363967 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T15:16:58.506032+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-04T13:00:00+00:00 EmrJobFlowSensor 2023-04-04T14:00:48.553142+00:00 2023-04-04T14:10:50.327283+00:00 0:10:01.774141 363961 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-04T14:00:46.241491+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-04T13:00:00+00:00 EmrCreateJobFlowOperator 2023-04-04T14:00:28.623788+00:00 2023-04-04T14:00:29.583233+00:00 0:00:00.959445 363959 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-04T14:00:26.203526+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-04T13:00:00+00:00 PythonOperator 2023-04-04T14:00:06.671910+00:00 2023-04-04T14:00:10.007510+00:00 0:00:03.335600 363957 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-04T14:00:04.177076+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-04T12:00:00+00:00 TriggerDagRunOperator 2023-04-04T13:35:10.989704+00:00 2023-04-04T13:35:11.578300+00:00 0:00:00.588596 363947 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T13:35:07.997789+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-04T12:00:00+00:00 TriggerDagRunOperator 2023-04-04T13:35:10.617438+00:00 2023-04-04T13:35:11.218193+00:00 0:00:00.600755 363946 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T13:35:07.997829+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-04T12:00:00+00:00 EmrJobFlowSensor 2023-04-04T13:01:04.740825+00:00 2023-04-04T13:11:06.574119+00:00 0:10:01.833294 363943 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-04T13:01:02.263218+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-04T12:00:00+00:00 EmrCreateJobFlowOperator 2023-04-04T13:00:42.428212+00:00 2023-04-04T13:00:43.294154+00:00 0:00:00.865942 363941 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-04T13:00:40.245670+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-04T12:00:00+00:00 PythonOperator 2023-04-04T13:00:18.874260+00:00 2023-04-04T13:00:22.163918+00:00 0:00:03.289658 363939 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-04T13:00:16.299378+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-04T11:00:00+00:00 TriggerDagRunOperator 2023-04-04T12:11:01.051440+00:00 2023-04-04T12:11:01.544749+00:00 0:00:00.493309 363930 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T12:10:58.388788+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-04T11:00:00+00:00 TriggerDagRunOperator 2023-04-04T12:11:00.615791+00:00 2023-04-04T12:11:01.133384+00:00 0:00:00.517593 363929 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T12:10:58.388751+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-04T11:00:00+00:00 EmrJobFlowSensor 2023-04-04T12:00:50.892097+00:00 2023-04-04T12:10:52.728222+00:00 0:10:01.836125 363923 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-04T12:00:48.407349+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-04T11:00:00+00:00 EmrCreateJobFlowOperator 2023-04-04T12:00:28.556420+00:00 2023-04-04T12:00:29.389170+00:00 0:00:00.832750 363920 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-04T12:00:26.337993+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-04T11:00:00+00:00 PythonOperator 2023-04-04T12:00:06.902905+00:00 2023-04-04T12:00:10.435191+00:00 0:00:03.532286 363919 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-04T12:00:04.264007+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-04T10:00:00+00:00 TriggerDagRunOperator 2023-04-04T11:51:31.205827+00:00 2023-04-04T11:51:31.728892+00:00 0:00:00.523065 363913 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T11:51:28.457990+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-04T10:00:00+00:00 TriggerDagRunOperator 2023-04-04T11:51:31.140780+00:00 2023-04-04T11:51:31.620622+00:00 0:00:00.479842 363912 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T11:51:28.458019+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-04T10:00:00+00:00 EmrJobFlowSensor 2023-04-04T11:10:28.646466+00:00 2023-04-04T11:20:30.423803+00:00 0:10:01.777337 363909 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-04T11:10:26.240665+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-04T10:00:00+00:00 EmrCreateJobFlowOperator 2023-04-04T11:10:06.382254+00:00 2023-04-04T11:10:07.171417+00:00 0:00:00.789163 363906 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-04T11:10:04.219470+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-04T10:00:00+00:00 PythonOperator 2023-04-04T11:09:44.363367+00:00 2023-04-04T11:09:47.630925+00:00 0:00:03.267558 363903 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-04T11:09:42.197490+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-04T09:00:00+00:00 TriggerDagRunOperator 2023-04-04T10:14:56.973540+00:00 2023-04-04T10:14:57.453647+00:00 0:00:00.480107 363892 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T10:14:54.641986+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-04T09:00:00+00:00 TriggerDagRunOperator 2023-04-04T10:14:56.917773+00:00 2023-04-04T10:14:57.374834+00:00 0:00:00.457061 363891 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T10:14:54.641958+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-04T09:00:00+00:00 EmrJobFlowSensor 2023-04-04T10:00:49.009984+00:00 2023-04-04T10:10:51.280072+00:00 0:10:02.270088 363884 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-04T10:00:46.116527+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-04T09:00:00+00:00 EmrCreateJobFlowOperator 2023-04-04T10:00:26.417456+00:00 2023-04-04T10:00:27.228155+00:00 0:00:00.810699 363882 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-04T10:00:24.033486+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-04T09:00:00+00:00 PythonOperator 2023-04-04T10:00:07.011993+00:00 2023-04-04T10:00:10.511390+00:00 0:00:03.499397 363880 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-04T10:00:03.929270+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-04T08:00:00+00:00 TriggerDagRunOperator 2023-04-04T09:12:59.147477+00:00 2023-04-04T09:12:59.661896+00:00 0:00:00.514419 363870 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T09:12:56.745372+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-04T08:00:00+00:00 TriggerDagRunOperator 2023-04-04T09:12:59.103578+00:00 2023-04-04T09:12:59.550542+00:00 0:00:00.446964 363869 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T09:12:56.745343+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-04T08:00:00+00:00 EmrJobFlowSensor 2023-04-04T09:02:40.212931+00:00 2023-04-04T09:12:42.003870+00:00 0:10:01.790939 363862 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-04T09:02:37.790505+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-04T08:00:00+00:00 EmrCreateJobFlowOperator 2023-04-04T09:02:18.116945+00:00 2023-04-04T09:02:18.989285+00:00 0:00:00.872340 363860 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-04T09:02:15.770366+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-04T08:00:00+00:00 PythonOperator 2023-04-04T09:01:58.711302+00:00 2023-04-04T09:02:02.290403+00:00 0:00:03.579101 363858 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-04T09:01:55.814372+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-04T07:00:00+00:00 TriggerDagRunOperator 2023-04-04T08:12:29.292243+00:00 2023-04-04T08:12:29.800060+00:00 0:00:00.507817 363848 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T08:12:26.933683+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-04T07:00:00+00:00 TriggerDagRunOperator 2023-04-04T08:12:29.144477+00:00 2023-04-04T08:12:29.600423+00:00 0:00:00.455946 363847 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T08:12:26.933650+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-04T07:00:00+00:00 EmrJobFlowSensor 2023-04-04T08:01:00.419490+00:00 2023-04-04T08:11:02.381824+00:00 0:10:01.962334 363842 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-04T08:00:57.720288+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-04T07:00:00+00:00 EmrCreateJobFlowOperator 2023-04-04T08:00:38.100060+00:00 2023-04-04T08:00:38.977602+00:00 0:00:00.877542 363839 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-04T08:00:35.712677+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-04T07:00:00+00:00 PythonOperator 2023-04-04T08:00:18.381234+00:00 2023-04-04T08:00:21.749567+00:00 0:00:03.368333 363838 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-04T08:00:15.693221+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-04T06:00:00+00:00 TriggerDagRunOperator 2023-04-04T07:12:27.017857+00:00 2023-04-04T07:12:27.519903+00:00 0:00:00.502046 363827 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T07:12:24.300022+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-04T06:00:00+00:00 TriggerDagRunOperator 2023-04-04T07:12:26.776732+00:00 2023-04-04T07:12:27.247076+00:00 0:00:00.470344 363826 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T07:12:24.299991+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-04T06:00:00+00:00 EmrJobFlowSensor 2023-04-04T07:02:20.415762+00:00 2023-04-04T07:12:22.174954+00:00 0:10:01.759192 363820 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-04T07:02:18.242510+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-04T06:00:00+00:00 EmrCreateJobFlowOperator 2023-04-04T07:01:58.576476+00:00 2023-04-04T07:01:59.530468+00:00 0:00:00.953992 363818 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-04T07:01:56.225554+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-04T06:00:00+00:00 PythonOperator 2023-04-04T07:01:38.429574+00:00 2023-04-04T07:01:42.422943+00:00 0:00:03.993369 363816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-04T07:01:36.203313+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-04T05:00:00+00:00 TriggerDagRunOperator 2023-04-04T06:18:43.055570+00:00 2023-04-04T06:18:43.532429+00:00 0:00:00.476859 363807 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T06:18:40.373620+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-04T05:00:00+00:00 TriggerDagRunOperator 2023-04-04T06:18:42.902889+00:00 2023-04-04T06:18:43.349917+00:00 0:00:00.447028 363806 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T06:18:40.373648+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-04T05:00:00+00:00 EmrJobFlowSensor 2023-04-04T06:06:22.145235+00:00 2023-04-04T06:16:24.065724+00:00 0:10:01.920489 363803 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-04T06:06:17.482508+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-04T05:00:00+00:00 EmrCreateJobFlowOperator 2023-04-04T06:05:58.065181+00:00 2023-04-04T06:05:59.233251+00:00 0:00:01.168070 363799 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-04T06:05:55.463967+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-04T05:00:00+00:00 PythonOperator 2023-04-04T06:05:41.013503+00:00 2023-04-04T06:05:47.447890+00:00 0:00:06.434387 363796 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-04T06:05:35.330463+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-04T04:00:00+00:00 TriggerDagRunOperator 2023-04-04T05:21:14.999133+00:00 2023-04-04T05:21:15.562036+00:00 0:00:00.562903 363789 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T05:21:11.908600+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-04T04:00:00+00:00 TriggerDagRunOperator 2023-04-04T05:21:14.592969+00:00 2023-04-04T05:21:15.082891+00:00 0:00:00.489922 363788 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T05:21:11.908640+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-04T04:00:00+00:00 EmrJobFlowSensor 2023-04-04T05:01:48.949550+00:00 2023-04-04T05:11:50.755356+00:00 0:10:01.805806 363781 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-04T05:01:46.745065+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-04T04:00:00+00:00 EmrCreateJobFlowOperator 2023-04-04T05:01:27.292791+00:00 2023-04-04T05:01:28.181844+00:00 0:00:00.889053 363779 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-04T05:01:24.722755+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-04T04:00:00+00:00 PythonOperator 2023-04-04T05:01:07.238049+00:00 2023-04-04T05:01:11.308894+00:00 0:00:04.070845 363777 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-04T05:01:04.704736+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-04T03:00:00+00:00 TriggerDagRunOperator 2023-04-04T04:11:25.843550+00:00 2023-04-04T04:11:26.513887+00:00 0:00:00.670337 363767 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T04:11:23.165042+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-04T03:00:00+00:00 TriggerDagRunOperator 2023-04-04T04:11:25.741957+00:00 2023-04-04T04:11:26.403083+00:00 0:00:00.661126 363766 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T04:11:23.165014+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-04T03:00:00+00:00 EmrJobFlowSensor 2023-04-04T04:01:03.039187+00:00 2023-04-04T04:11:05.000119+00:00 0:10:01.960932 363759 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-04T04:01:00.435341+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-04T03:00:00+00:00 EmrCreateJobFlowOperator 2023-04-04T04:00:40.532059+00:00 2023-04-04T04:00:41.439519+00:00 0:00:00.907460 363757 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-04T04:00:38.402462+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-04T03:00:00+00:00 PythonOperator 2023-04-04T04:00:18.700348+00:00 2023-04-04T04:00:21.961765+00:00 0:00:03.261417 363755 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-04T04:00:16.382730+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-04T02:00:00+00:00 TriggerDagRunOperator 2023-04-04T03:15:35.992364+00:00 2023-04-04T03:15:36.503951+00:00 0:00:00.511587 363746 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T03:15:32.922794+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-04T02:00:00+00:00 TriggerDagRunOperator 2023-04-04T03:15:35.691787+00:00 2023-04-04T03:15:36.184255+00:00 0:00:00.492468 363745 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T03:15:32.922765+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-04T02:00:00+00:00 EmrJobFlowSensor 2023-04-04T03:02:27.939231+00:00 2023-04-04T03:10:29.478004+00:00 0:08:01.538773 363738 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-04T03:02:25.422071+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-04T02:00:00+00:00 EmrCreateJobFlowOperator 2023-04-04T03:00:27.437527+00:00 2023-04-04T03:00:28.364727+00:00 0:00:00.927200 363735 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-04T03:00:25.153654+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-04T02:00:00+00:00 PythonOperator 2023-04-04T03:00:05.810164+00:00 2023-04-04T03:00:09.982114+00:00 0:00:04.171950 363733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-04T03:00:03.196112+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-04T01:00:00+00:00 TriggerDagRunOperator 2023-04-04T02:20:56.258276+00:00 2023-04-04T02:20:56.757700+00:00 0:00:00.499424 363727 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T02:20:53.418253+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-04T01:00:00+00:00 TriggerDagRunOperator 2023-04-04T02:20:56.140761+00:00 2023-04-04T02:20:56.617269+00:00 0:00:00.476508 363726 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T02:20:53.418297+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-04T01:00:00+00:00 EmrJobFlowSensor 2023-04-04T02:07:56.164351+00:00 2023-04-04T02:17:57.985537+00:00 0:10:01.821186 363723 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-04T02:07:53.589825+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-04T01:00:00+00:00 EmrCreateJobFlowOperator 2023-04-04T02:07:37.106105+00:00 2023-04-04T02:07:37.969850+00:00 0:00:00.863745 363720 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-04T02:07:33.566279+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-04T01:00:00+00:00 PythonOperator 2023-04-04T02:07:14.935228+00:00 2023-04-04T02:07:19.028746+00:00 0:00:04.093518 363717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-04T02:07:11.505345+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-04T00:00:00+00:00 TriggerDagRunOperator 2023-04-04T01:12:35.546670+00:00 2023-04-04T01:12:36.098679+00:00 0:00:00.552009 363701 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T01:12:32.939958+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-04T00:00:00+00:00 TriggerDagRunOperator 2023-04-04T01:12:35.312308+00:00 2023-04-04T01:12:35.751601+00:00 0:00:00.439293 363700 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T01:12:32.939994+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-04T00:00:00+00:00 EmrJobFlowSensor 2023-04-04T01:02:12.240067+00:00 2023-04-04T01:12:13.974657+00:00 0:10:01.734590 363694 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-04T01:02:09.973766+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-04T00:00:00+00:00 EmrCreateJobFlowOperator 2023-04-04T01:01:50.212712+00:00 2023-04-04T01:01:51.155089+00:00 0:00:00.942377 363692 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-04T01:01:47.956294+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-04T00:00:00+00:00 PythonOperator 2023-04-04T01:01:30.507148+00:00 2023-04-04T01:01:34.414271+00:00 0:00:03.907123 363690 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-04T01:01:27.935808+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-03T23:00:00+00:00 TriggerDagRunOperator 2023-04-04T00:12:11.693820+00:00 2023-04-04T00:12:12.190173+00:00 0:00:00.496353 363679 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T00:12:08.630078+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-03T23:00:00+00:00 TriggerDagRunOperator 2023-04-04T00:12:11.517273+00:00 2023-04-04T00:12:11.965068+00:00 0:00:00.447795 363678 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T00:12:08.630113+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-03T23:00:00+00:00 EmrJobFlowSensor 2023-04-04T00:00:53.668598+00:00 2023-04-04T00:10:55.334526+00:00 0:10:01.665928 363672 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-04T00:00:51.274748+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-03T23:00:00+00:00 EmrCreateJobFlowOperator 2023-04-04T00:00:33.651343+00:00 2023-04-04T00:00:34.504407+00:00 0:00:00.853064 363670 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-04T00:00:31.292417+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-03T23:00:00+00:00 PythonOperator 2023-04-04T00:00:12.090939+00:00 2023-04-04T00:00:15.427877+00:00 0:00:03.336938 363668 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-04T00:00:09.308292+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-03T22:00:00+00:00 TriggerDagRunOperator 2023-04-03T23:16:13.383062+00:00 2023-04-03T23:16:13.862725+00:00 0:00:00.479663 363658 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T23:16:10.792086+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-03T22:00:00+00:00 TriggerDagRunOperator 2023-04-03T23:16:13.236006+00:00 2023-04-03T23:16:13.679054+00:00 0:00:00.443048 363657 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T23:16:10.792128+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-03T22:00:00+00:00 EmrJobFlowSensor 2023-04-03T23:03:22.711536+00:00 2023-04-03T23:13:24.535732+00:00 0:10:01.824196 363649 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-03T23:03:20.475559+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-03T22:00:00+00:00 EmrCreateJobFlowOperator 2023-04-03T23:03:00.890093+00:00 2023-04-03T23:03:01.949222+00:00 0:00:01.059129 363646 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-03T23:02:58.455769+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-03T22:00:00+00:00 PythonOperator 2023-04-03T23:02:41.200423+00:00 2023-04-03T23:02:44.663654+00:00 0:00:03.463231 363643 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-03T23:02:38.442689+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-03T21:00:00+00:00 TriggerDagRunOperator 2023-04-03T22:10:56.778359+00:00 2023-04-03T22:10:57.261874+00:00 0:00:00.483515 363632 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T22:10:54.311003+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-03T21:00:00+00:00 TriggerDagRunOperator 2023-04-03T22:10:56.681035+00:00 2023-04-03T22:10:57.118422+00:00 0:00:00.437387 363631 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T22:10:54.311039+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-03T21:00:00+00:00 EmrJobFlowSensor 2023-04-03T22:00:48.418160+00:00 2023-04-03T22:10:50.573853+00:00 0:10:02.155693 363624 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-03T22:00:45.969524+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-03T21:00:00+00:00 EmrCreateJobFlowOperator 2023-04-03T22:00:26.186604+00:00 2023-04-03T22:00:27.424190+00:00 0:00:01.237586 363622 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-03T22:00:23.949254+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-03T21:00:00+00:00 PythonOperator 2023-04-03T22:00:06.529479+00:00 2023-04-03T22:00:12.815409+00:00 0:00:06.285930 363620 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-03T22:00:03.904904+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-03T20:00:00+00:00 TriggerDagRunOperator 2023-04-03T21:11:25.993014+00:00 2023-04-03T21:11:26.670456+00:00 0:00:00.677442 363609 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T21:11:23.459075+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-03T20:00:00+00:00 TriggerDagRunOperator 2023-04-03T21:11:25.762355+00:00 2023-04-03T21:11:26.454211+00:00 0:00:00.691856 363608 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T21:11:23.459109+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-03T20:00:00+00:00 EmrJobFlowSensor 2023-04-03T21:01:01.657675+00:00 2023-04-03T21:11:03.359308+00:00 0:10:01.701633 363602 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-03T21:00:58.878542+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-03T20:00:00+00:00 EmrCreateJobFlowOperator 2023-04-03T21:00:39.106101+00:00 2023-04-03T21:00:40.015016+00:00 0:00:00.908915 363600 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-03T21:00:36.849592+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-03T20:00:00+00:00 PythonOperator 2023-04-03T21:00:19.107472+00:00 2023-04-03T21:00:22.517455+00:00 0:00:03.409983 363598 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-03T21:00:16.833140+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-03T19:00:00+00:00 TriggerDagRunOperator 2023-04-03T20:11:11.473617+00:00 2023-04-03T20:11:12.014173+00:00 0:00:00.540556 363586 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T20:11:09.258781+00:00 2 default_pool