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_cluster_and_add_emr_steps 2023-06-04T18:00:00+00:00 EmrCreateJobFlowOperator 2023-06-04T19:00:28.303366+00:00 2023-06-04T19:00:29.167596+00:00 0:00:00.864230 391088 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-04T19:00:26.325304+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-04T18:00:00+00:00 PythonOperator 2023-06-04T19:00:06.396690+00:00 2023-06-04T19:00:07.320180+00:00 0:00:00.923490 391086 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-04T19:00:04.305973+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-04T17:00:00+00:00 TriggerDagRunOperator 2023-06-04T18:10:55.627335+00:00 2023-06-04T18:10:56.093566+00:00 0:00:00.466231 391073 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T18:10:53.429460+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-04T17:00:00+00:00 TriggerDagRunOperator 2023-06-04T18:10:55.397076+00:00 2023-06-04T18:10:55.814275+00:00 0:00:00.417199 391072 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T18:10:53.429425+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-04T17:00:00+00:00 EmrJobFlowSensor 2023-06-04T18:00:50.002334+00:00 2023-06-04T18:10:51.930300+00:00 0:10:01.927966 391065 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-04T18:00:47.930244+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-04T17:00:00+00:00 EmrCreateJobFlowOperator 2023-06-04T18:00:27.976104+00:00 2023-06-04T18:00:28.869921+00:00 0:00:00.893817 391064 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-04T18:00:25.866224+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-04T17:00:00+00:00 PythonOperator 2023-06-04T18:00:08.030602+00:00 2023-06-04T18:00:08.931227+00:00 0:00:00.900625 391063 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-04T18:00:05.851114+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-04T16:00:00+00:00 TriggerDagRunOperator 2023-06-04T17:11:14.287853+00:00 2023-06-04T17:11:14.721601+00:00 0:00:00.433748 391051 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T17:11:12.121146+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-04T16:00:00+00:00 TriggerDagRunOperator 2023-06-04T17:11:14.264893+00:00 2023-06-04T17:11:14.680878+00:00 0:00:00.415985 391050 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T17:11:12.121119+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-04T16:00:00+00:00 EmrJobFlowSensor 2023-06-04T17:00:59.134814+00:00 2023-06-04T17:11:00.931828+00:00 0:10:01.797014 391043 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-04T17:00:57.101971+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-04T16:00:00+00:00 EmrCreateJobFlowOperator 2023-06-04T17:00:37.139448+00:00 2023-06-04T17:00:38.065720+00:00 0:00:00.926272 391041 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-04T17:00:35.087518+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-04T16:00:00+00:00 PythonOperator 2023-06-04T17:00:17.137445+00:00 2023-06-04T17:00:18.091721+00:00 0:00:00.954276 391039 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-04T17:00:15.026697+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-04T15:00:00+00:00 TriggerDagRunOperator 2023-06-04T16:20:38.790159+00:00 2023-06-04T16:20:39.223950+00:00 0:00:00.433791 391030 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T16:20:36.441485+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-04T15:00:00+00:00 TriggerDagRunOperator 2023-06-04T16:20:38.710042+00:00 2023-06-04T16:20:39.123988+00:00 0:00:00.413946 391029 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T16:20:36.441458+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-04T15:00:00+00:00 EmrJobFlowSensor 2023-06-04T16:10:14.751027+00:00 2023-06-04T16:20:16.504743+00:00 0:10:01.753716 391024 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-04T16:10:12.646747+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-04T15:00:00+00:00 EmrCreateJobFlowOperator 2023-06-04T16:09:54.657334+00:00 2023-06-04T16:09:55.877516+00:00 0:00:01.220182 391022 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-04T16:09:52.616576+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-04T15:00:00+00:00 PythonOperator 2023-06-04T16:09:32.951058+00:00 2023-06-04T16:09:33.861140+00:00 0:00:00.910082 391018 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-04T16:09:30.598541+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-04T14:00:00+00:00 TriggerDagRunOperator 2023-06-04T15:14:01.167923+00:00 2023-06-04T15:14:01.601364+00:00 0:00:00.433441 391010 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T15:13:58.721088+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-04T14:00:00+00:00 TriggerDagRunOperator 2023-06-04T15:14:01.051746+00:00 2023-06-04T15:14:01.451079+00:00 0:00:00.399333 391009 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T15:13:58.721061+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-04T14:00:00+00:00 EmrJobFlowSensor 2023-06-04T15:03:35.972792+00:00 2023-06-04T15:13:38.038158+00:00 0:10:02.065366 391002 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-04T15:03:33.878407+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-04T14:00:00+00:00 EmrCreateJobFlowOperator 2023-06-04T15:03:16.004979+00:00 2023-06-04T15:03:17.016234+00:00 0:00:01.011255 391001 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-04T15:03:13.858072+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-04T14:00:00+00:00 PythonOperator 2023-06-04T15:02:53.896332+00:00 2023-06-04T15:02:55.284996+00:00 0:00:01.388664 390998 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-04T15:02:51.836739+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-04T13:00:00+00:00 TriggerDagRunOperator 2023-06-04T14:29:36.375517+00:00 2023-06-04T14:29:36.830868+00:00 0:00:00.455351 390991 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T14:29:34.061671+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-04T13:00:00+00:00 TriggerDagRunOperator 2023-06-04T14:29:36.293028+00:00 2023-06-04T14:29:36.696265+00:00 0:00:00.403237 390990 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T14:29:34.061697+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-04T13:00:00+00:00 EmrJobFlowSensor 2023-06-04T14:01:06.919734+00:00 2023-06-04T14:11:08.563681+00:00 0:10:01.643947 390983 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-04T14:01:04.915418+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-04T13:00:00+00:00 EmrCreateJobFlowOperator 2023-06-04T14:00:45.082154+00:00 2023-06-04T14:00:46.034762+00:00 0:00:00.952608 390981 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-04T14:00:42.891666+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-04T13:00:00+00:00 PythonOperator 2023-06-04T14:00:23.053643+00:00 2023-06-04T14:00:23.980020+00:00 0:00:00.926377 390979 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-04T14:00:20.908145+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-04T12:00:00+00:00 TriggerDagRunOperator 2023-06-04T13:11:53.645736+00:00 2023-06-04T13:11:54.092707+00:00 0:00:00.446971 390970 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T13:11:51.398669+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-04T12:00:00+00:00 TriggerDagRunOperator 2023-06-04T13:11:53.497301+00:00 2023-06-04T13:11:53.917852+00:00 0:00:00.420551 390969 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T13:11:51.398698+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-04T12:00:00+00:00 EmrJobFlowSensor 2023-06-04T13:01:40.600515+00:00 2023-06-04T13:11:42.400440+00:00 0:10:01.799925 390963 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-04T13:01:38.540636+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-04T12:00:00+00:00 EmrCreateJobFlowOperator 2023-06-04T13:01:20.574178+00:00 2023-06-04T13:01:21.559095+00:00 0:00:00.984917 390961 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-04T13:01:18.522378+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-04T12:00:00+00:00 PythonOperator 2023-06-04T13:00:18.212258+00:00 2023-06-04T13:00:19.119884+00:00 0:00:00.907626 390957 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-04T13:00:16.056463+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-04T11:00:00+00:00 TriggerDagRunOperator 2023-06-04T12:11:01.101066+00:00 2023-06-04T12:11:01.526009+00:00 0:00:00.424943 390948 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T12:10:58.973485+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-04T11:00:00+00:00 TriggerDagRunOperator 2023-06-04T12:11:00.930952+00:00 2023-06-04T12:11:01.412662+00:00 0:00:00.481710 390947 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T12:10:58.973453+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-04T11:00:00+00:00 EmrJobFlowSensor 2023-06-04T12:00:51.279926+00:00 2023-06-04T12:10:53.072332+00:00 0:10:01.792406 390940 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-04T12:00:49.257472+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-04T11:00:00+00:00 EmrCreateJobFlowOperator 2023-06-04T12:00:29.196045+00:00 2023-06-04T12:00:30.188103+00:00 0:00:00.992058 390938 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-04T12:00:27.236739+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-04T11:00:00+00:00 PythonOperator 2023-06-04T12:00:09.430507+00:00 2023-06-04T12:00:10.381497+00:00 0:00:00.950990 390936 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-04T12:00:07.215478+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-04T10:00:00+00:00 TriggerDagRunOperator 2023-06-04T11:11:15.099909+00:00 2023-06-04T11:11:15.543617+00:00 0:00:00.443708 390925 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T11:11:12.970252+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-04T10:00:00+00:00 TriggerDagRunOperator 2023-06-04T11:11:14.890269+00:00 2023-06-04T11:11:15.345219+00:00 0:00:00.454950 390924 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T11:11:12.970220+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-04T10:00:00+00:00 EmrJobFlowSensor 2023-06-04T11:01:07.204978+00:00 2023-06-04T11:11:08.948772+00:00 0:10:01.743794 390918 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-04T11:01:05.200977+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-04T10:00:00+00:00 EmrCreateJobFlowOperator 2023-06-04T11:00:45.614448+00:00 2023-06-04T11:00:46.563798+00:00 0:00:00.949350 390916 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-04T11:00:43.197819+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-04T10:00:00+00:00 PythonOperator 2023-06-04T11:00:23.794870+00:00 2023-06-04T11:00:24.786807+00:00 0:00:00.991937 390914 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-04T11:00:21.205542+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-04T09:00:00+00:00 TriggerDagRunOperator 2023-06-04T10:45:21.506816+00:00 2023-06-04T10:45:21.946260+00:00 0:00:00.439444 390908 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T10:45:19.143894+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-04T09:00:00+00:00 TriggerDagRunOperator 2023-06-04T10:45:21.501602+00:00 2023-06-04T10:45:21.961580+00:00 0:00:00.459978 390907 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T10:45:19.143858+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-04T09:00:00+00:00 EmrJobFlowSensor 2023-06-04T10:26:51.315936+00:00 2023-06-04T10:36:53.077831+00:00 0:10:01.761895 390903 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-04T10:26:49.124996+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-04T09:00:00+00:00 EmrCreateJobFlowOperator 2023-06-04T10:26:29.748410+00:00 2023-06-04T10:26:30.654965+00:00 0:00:00.906555 390900 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-04T10:26:27.066551+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-04T09:00:00+00:00 PythonOperator 2023-06-04T10:26:09.441208+00:00 2023-06-04T10:26:10.396601+00:00 0:00:00.955393 390897 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-04T10:26:07.049247+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-04T08:00:00+00:00 TriggerDagRunOperator 2023-06-04T09:20:37.629713+00:00 2023-06-04T09:20:38.034955+00:00 0:00:00.405242 390888 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T09:20:35.426989+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-04T08:00:00+00:00 TriggerDagRunOperator 2023-06-04T09:20:37.630344+00:00 2023-06-04T09:20:38.070637+00:00 0:00:00.440293 390887 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T09:20:35.426961+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-04T08:00:00+00:00 EmrJobFlowSensor 2023-06-04T09:02:22.752967+00:00 2023-06-04T09:12:24.470526+00:00 0:10:01.717559 390880 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-04T09:02:20.739161+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-04T08:00:00+00:00 EmrCreateJobFlowOperator 2023-06-04T09:02:00.696010+00:00 2023-06-04T09:02:01.749931+00:00 0:00:01.053921 390878 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-04T09:01:58.719073+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-04T08:00:00+00:00 PythonOperator 2023-06-04T09:01:40.835081+00:00 2023-06-04T09:01:42.334008+00:00 0:00:01.498927 390876 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-04T09:01:38.700186+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-04T07:00:00+00:00 TriggerDagRunOperator 2023-06-04T08:13:55.805946+00:00 2023-06-04T08:13:56.237067+00:00 0:00:00.431121 390868 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T08:13:53.028242+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-04T07:00:00+00:00 TriggerDagRunOperator 2023-06-04T08:13:55.419571+00:00 2023-06-04T08:13:55.855242+00:00 0:00:00.435671 390867 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T08:13:53.028205+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-04T07:00:00+00:00 EmrJobFlowSensor 2023-06-04T08:01:22.068681+00:00 2023-06-04T08:11:23.835848+00:00 0:10:01.767167 390860 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-04T08:01:20.028470+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-04T07:00:00+00:00 EmrCreateJobFlowOperator 2023-06-04T08:01:02.111121+00:00 2023-06-04T08:01:03.093861+00:00 0:00:00.982740 390858 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-04T08:01:00.061117+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-04T07:00:00+00:00 PythonOperator 2023-06-04T08:00:40.408783+00:00 2023-06-04T08:00:41.419215+00:00 0:00:01.010432 390856 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-04T08:00:37.991136+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-04T06:00:00+00:00 TriggerDagRunOperator 2023-06-04T07:11:42.618342+00:00 2023-06-04T07:11:43.147059+00:00 0:00:00.528717 390845 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T07:11:40.326935+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-04T06:00:00+00:00 TriggerDagRunOperator 2023-06-04T07:11:42.545280+00:00 2023-06-04T07:11:43.059547+00:00 0:00:00.514267 390844 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T07:11:40.326962+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-04T06:00:00+00:00 EmrJobFlowSensor 2023-06-04T07:00:47.669325+00:00 2023-06-04T07:10:49.464891+00:00 0:10:01.795566 390839 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-04T07:00:45.669125+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-04T06:00:00+00:00 EmrCreateJobFlowOperator 2023-06-04T07:00:25.623404+00:00 2023-06-04T07:00:26.620553+00:00 0:00:00.997149 390837 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-04T07:00:23.649456+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-04T06:00:00+00:00 PythonOperator 2023-06-04T07:00:03.764554+00:00 2023-06-04T07:00:04.713429+00:00 0:00:00.948875 390835 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-04T07:00:01.628087+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-04T05:00:00+00:00 TriggerDagRunOperator 2023-06-04T06:11:15.648747+00:00 2023-06-04T06:11:16.116725+00:00 0:00:00.467978 390826 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T06:11:13.395702+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-04T05:00:00+00:00 TriggerDagRunOperator 2023-06-04T06:11:15.605512+00:00 2023-06-04T06:11:16.085542+00:00 0:00:00.480030 390825 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T06:11:13.395670+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-04T05:00:00+00:00 EmrJobFlowSensor 2023-06-04T06:01:05.629276+00:00 2023-06-04T06:11:07.498055+00:00 0:10:01.868779 390819 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-04T06:01:03.549788+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-04T05:00:00+00:00 EmrCreateJobFlowOperator 2023-06-04T06:00:41.700145+00:00 2023-06-04T06:00:42.661508+00:00 0:00:00.961363 390817 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-04T06:00:39.526262+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-04T05:00:00+00:00 PythonOperator 2023-06-04T06:00:19.630915+00:00 2023-06-04T06:00:20.540928+00:00 0:00:00.910013 390815 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-04T06:00:17.504682+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-04T04:00:00+00:00 TriggerDagRunOperator 2023-06-04T05:16:26.545861+00:00 2023-06-04T05:16:27.011228+00:00 0:00:00.465367 390805 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T05:16:24.462584+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-04T04:00:00+00:00 TriggerDagRunOperator 2023-06-04T05:16:26.438360+00:00 2023-06-04T05:16:26.832099+00:00 0:00:00.393739 390804 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T05:16:24.462554+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-04T04:00:00+00:00 EmrJobFlowSensor 2023-06-04T05:00:51.353451+00:00 2023-06-04T05:10:53.355399+00:00 0:10:02.001948 390799 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-04T05:00:49.184347+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-04T04:00:00+00:00 EmrCreateJobFlowOperator 2023-06-04T05:00:31.277521+00:00 2023-06-04T05:00:32.176589+00:00 0:00:00.899068 390797 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-04T05:00:29.112744+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-04T04:00:00+00:00 PythonOperator 2023-06-04T05:00:09.381823+00:00 2023-06-04T05:00:10.319661+00:00 0:00:00.937838 390796 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-04T05:00:07.103171+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-04T03:00:00+00:00 TriggerDagRunOperator 2023-06-04T04:11:23.040702+00:00 2023-06-04T04:11:23.480668+00:00 0:00:00.439966 390785 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T04:11:20.822834+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-04T03:00:00+00:00 TriggerDagRunOperator 2023-06-04T04:11:23.001571+00:00 2023-06-04T04:11:23.431131+00:00 0:00:00.429560 390784 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T04:11:20.822863+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-04T03:00:00+00:00 EmrJobFlowSensor 2023-06-04T04:01:00.346270+00:00 2023-06-04T04:11:02.136102+00:00 0:10:01.789832 390778 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-04T04:00:58.189538+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-04T03:00:00+00:00 EmrCreateJobFlowOperator 2023-06-04T04:00:38.196996+00:00 2023-06-04T04:00:39.064422+00:00 0:00:00.867426 390776 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-04T04:00:36.191071+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-04T03:00:00+00:00 PythonOperator 2023-06-04T04:00:18.167388+00:00 2023-06-04T04:00:19.146322+00:00 0:00:00.978934 390774 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-04T04:00:16.121970+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-04T02:00:00+00:00 TriggerDagRunOperator 2023-06-04T03:20:36.564289+00:00 2023-06-04T03:20:37.041575+00:00 0:00:00.477286 390767 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T03:20:34.012526+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-04T02:00:00+00:00 TriggerDagRunOperator 2023-06-04T03:20:36.512882+00:00 2023-06-04T03:20:36.921642+00:00 0:00:00.408760 390766 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T03:20:34.012554+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-04T02:00:00+00:00 EmrJobFlowSensor 2023-06-04T03:07:44.900036+00:00 2023-06-04T03:17:46.959914+00:00 0:10:02.059878 390761 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-04T03:07:42.814672+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-04T02:00:00+00:00 EmrCreateJobFlowOperator 2023-06-04T03:07:24.891190+00:00 2023-06-04T03:07:25.806476+00:00 0:00:00.915286 390758 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-04T03:07:22.793317+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-04T02:00:00+00:00 PythonOperator 2023-06-04T03:07:03.148051+00:00 2023-06-04T03:07:04.101887+00:00 0:00:00.953836 390755 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-04T03:07:00.783508+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-04T01:00:00+00:00 TriggerDagRunOperator 2023-06-04T02:33:11.775122+00:00 2023-06-04T02:33:12.226118+00:00 0:00:00.450996 390748 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T02:33:09.478058+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-04T01:00:00+00:00 TriggerDagRunOperator 2023-06-04T02:33:11.753872+00:00 2023-06-04T02:33:12.170483+00:00 0:00:00.416611 390747 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T02:33:09.478030+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-04T01:00:00+00:00 EmrJobFlowSensor 2023-06-04T02:03:05.330508+00:00 2023-06-04T02:13:07.170893+00:00 0:10:01.840385 390740 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-04T02:03:03.321655+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-04T01:00:00+00:00 EmrCreateJobFlowOperator 2023-06-04T02:02:45.326365+00:00 2023-06-04T02:02:46.165260+00:00 0:00:00.838895 390738 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-04T02:02:43.305103+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-04T01:00:00+00:00 PythonOperator 2023-06-04T02:02:23.605613+00:00 2023-06-04T02:02:24.510345+00:00 0:00:00.904732 390736 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-04T02:02:21.293606+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-04T00:00:00+00:00 TriggerDagRunOperator 2023-06-04T01:14:42.044136+00:00 2023-06-04T01:14:42.659520+00:00 0:00:00.615384 390717 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T01:14:39.475803+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-04T00:00:00+00:00 TriggerDagRunOperator 2023-06-04T01:14:41.905131+00:00 2023-06-04T01:14:42.565123+00:00 0:00:00.659992 390716 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T01:14:39.475765+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-04T00:00:00+00:00 EmrJobFlowSensor 2023-06-04T01:01:40.192056+00:00 2023-06-04T01:11:42.165294+00:00 0:10:01.973238 390710 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-04T01:01:38.168203+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-04T00:00:00+00:00 EmrCreateJobFlowOperator 2023-06-04T01:01:20.132015+00:00 2023-06-04T01:01:21.071787+00:00 0:00:00.939772 390708 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-04T01:01:18.150379+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-04T00:00:00+00:00 PythonOperator 2023-06-04T01:00:58.165889+00:00 2023-06-04T01:00:59.111919+00:00 0:00:00.946030 390706 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-04T01:00:56.128694+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-03T23:00:00+00:00 TriggerDagRunOperator 2023-06-04T00:12:15.440583+00:00 2023-06-04T00:12:15.848174+00:00 0:00:00.407591 390694 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T00:12:13.221217+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-03T23:00:00+00:00 TriggerDagRunOperator 2023-06-04T00:12:15.443039+00:00 2023-06-04T00:12:15.882335+00:00 0:00:00.439296 390693 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-04T00:12:13.221248+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-03T23:00:00+00:00 EmrJobFlowSensor 2023-06-04T00:02:02.920650+00:00 2023-06-04T00:12:04.700774+00:00 0:10:01.780124 390686 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-04T00:02:00.936614+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-03T23:00:00+00:00 EmrCreateJobFlowOperator 2023-06-04T00:01:42.879554+00:00 2023-06-04T00:01:43.980830+00:00 0:00:01.101276 390684 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-04T00:01:40.895377+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-03T23:00:00+00:00 PythonOperator 2023-06-04T00:01:20.964456+00:00 2023-06-04T00:01:22.032264+00:00 0:00:01.067808 390682 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-04T00:01:18.873443+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-03T22:00:00+00:00 TriggerDagRunOperator 2023-06-03T23:11:42.952515+00:00 2023-06-03T23:11:43.435473+00:00 0:00:00.482958 390671 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T23:11:40.758671+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-03T22:00:00+00:00 TriggerDagRunOperator 2023-06-03T23:11:42.916388+00:00 2023-06-03T23:11:43.386688+00:00 0:00:00.470300 390670 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-03T23:11:40.758643+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-03T22:00:00+00:00 EmrJobFlowSensor 2023-06-03T23:01:17.872483+00:00 2023-06-03T23:11:19.623302+00:00 0:10:01.750819 390662 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-03T23:01:15.859445+00:00 2 default_pool