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_booking-processing-job_v002 2023-03-31T11:00:00+00:00 TriggerDagRunOperator 2023-03-31T12:19:29.219084+00:00 2023-03-31T12:19:29.669318+00:00 0:00:00.450234 361943 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T12:19:26.806459+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-31T11:00:00+00:00 EmrJobFlowSensor 2023-03-31T12:09:05.669169+00:00 2023-03-31T12:19:07.516656+00:00 0:10:01.847487 361940 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-31T12:09:03.232479+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-31T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-31T12:08:45.433619+00:00 2023-03-31T12:08:46.243587+00:00 0:00:00.809968 361937 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-31T12:08:43.163132+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-31T11:00:00+00:00 PythonOperator 2023-03-31T12:08:23.338109+00:00 2023-03-31T12:08:27.526410+00:00 0:00:04.188301 361934 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-31T12:08:21.138760+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-31T10:00:00+00:00 TriggerDagRunOperator 2023-03-31T11:12:29.226016+00:00 2023-03-31T11:12:29.758492+00:00 0:00:00.532476 361924 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T11:12:26.726027+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-31T10:00:00+00:00 TriggerDagRunOperator 2023-03-31T11:12:29.128230+00:00 2023-03-31T11:12:29.573442+00:00 0:00:00.445212 361923 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T11:12:26.725998+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-31T10:00:00+00:00 EmrJobFlowSensor 2023-03-31T11:02:07.322390+00:00 2023-03-31T11:12:09.350198+00:00 0:10:02.027808 361916 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-31T11:02:05.029115+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-31T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-31T11:01:47.264386+00:00 2023-03-31T11:01:48.330531+00:00 0:00:01.066145 361915 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-31T11:01:44.997704+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-31T10:00:00+00:00 PythonOperator 2023-03-31T11:01:26.096580+00:00 2023-03-31T11:01:31.872628+00:00 0:00:05.776048 361912 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-31T11:01:22.976025+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-31T09:00:00+00:00 TriggerDagRunOperator 2023-03-31T10:13:46.289282+00:00 2023-03-31T10:13:46.779354+00:00 0:00:00.490072 361905 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T10:13:43.245402+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-31T09:00:00+00:00 TriggerDagRunOperator 2023-03-31T10:13:46.146806+00:00 2023-03-31T10:13:46.631366+00:00 0:00:00.484560 361904 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T10:13:43.245366+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-31T09:00:00+00:00 EmrJobFlowSensor 2023-03-31T10:01:02.512254+00:00 2023-03-31T10:11:04.373359+00:00 0:10:01.861105 361897 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-31T10:01:00.243603+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-31T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-31T10:00:40.572664+00:00 2023-03-31T10:00:41.459226+00:00 0:00:00.886562 361895 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-31T10:00:38.221000+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-31T09:00:00+00:00 PythonOperator 2023-03-31T10:00:21.131733+00:00 2023-03-31T10:00:24.634087+00:00 0:00:03.502354 361893 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-31T10:00:18.207723+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-31T08:00:00+00:00 TriggerDagRunOperator 2023-03-31T09:11:11.476617+00:00 2023-03-31T09:11:11.991389+00:00 0:00:00.514772 361882 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T09:11:09.157949+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-31T08:00:00+00:00 TriggerDagRunOperator 2023-03-31T09:11:11.451794+00:00 2023-03-31T09:11:11.943304+00:00 0:00:00.491510 361881 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T09:11:09.157993+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-31T08:00:00+00:00 EmrJobFlowSensor 2023-03-31T09:01:01.079515+00:00 2023-03-31T09:11:03.087323+00:00 0:10:02.007808 361875 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-31T09:00:58.397508+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-31T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-31T09:00:38.961374+00:00 2023-03-31T09:00:39.847181+00:00 0:00:00.885807 361873 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-31T09:00:36.329205+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-31T08:00:00+00:00 PythonOperator 2023-03-31T09:00:16.731267+00:00 2023-03-31T09:00:20.771636+00:00 0:00:04.040369 361871 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-31T09:00:14.327134+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-31T07:00:00+00:00 TriggerDagRunOperator 2023-03-31T08:29:13.941257+00:00 2023-03-31T08:29:14.442127+00:00 0:00:00.500870 361864 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T08:29:10.948391+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-31T07:00:00+00:00 TriggerDagRunOperator 2023-03-31T08:29:13.823390+00:00 2023-03-31T08:29:14.303810+00:00 0:00:00.480420 361863 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T08:29:10.948363+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-31T07:00:00+00:00 EmrJobFlowSensor 2023-03-31T08:18:51.310458+00:00 2023-03-31T08:28:53.159569+00:00 0:10:01.849111 361858 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-31T08:18:49.049840+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-31T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-31T08:18:31.408285+00:00 2023-03-31T08:18:32.294015+00:00 0:00:00.885730 361855 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-31T08:18:29.027091+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-31T07:00:00+00:00 PythonOperator 2023-03-31T08:18:09.980856+00:00 2023-03-31T08:18:14.435827+00:00 0:00:04.454971 361852 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-31T08:18:07.009219+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-31T06:00:00+00:00 TriggerDagRunOperator 2023-03-31T07:11:16.225882+00:00 2023-03-31T07:11:16.743636+00:00 0:00:00.517754 361841 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T07:11:13.604286+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-31T06:00:00+00:00 TriggerDagRunOperator 2023-03-31T07:11:16.067097+00:00 2023-03-31T07:11:16.541945+00:00 0:00:00.474848 361840 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T07:11:13.604242+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-31T06:00:00+00:00 EmrJobFlowSensor 2023-03-31T07:01:06.423504+00:00 2023-03-31T07:11:08.231527+00:00 0:10:01.808023 361834 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-31T07:01:04.008672+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-31T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-31T07:00:44.440909+00:00 2023-03-31T07:00:45.320553+00:00 0:00:00.879644 361832 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-31T07:00:42.004396+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-31T06:00:00+00:00 PythonOperator 2023-03-31T07:00:22.232242+00:00 2023-03-31T07:00:26.303883+00:00 0:00:04.071641 361830 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-31T07:00:19.905638+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-31T05:00:00+00:00 TriggerDagRunOperator 2023-03-31T06:17:16.436430+00:00 2023-03-31T06:17:16.988365+00:00 0:00:00.551935 361822 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T06:17:13.194020+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-31T05:00:00+00:00 TriggerDagRunOperator 2023-03-31T06:17:16.026678+00:00 2023-03-31T06:17:16.492151+00:00 0:00:00.465473 361821 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T06:17:13.194061+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-31T05:00:00+00:00 EmrJobFlowSensor 2023-03-31T06:07:03.188126+00:00 2023-03-31T06:17:04.920170+00:00 0:10:01.732044 361816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-31T06:07:00.960103+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-31T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-31T06:06:43.211017+00:00 2023-03-31T06:06:44.098689+00:00 0:00:00.887672 361813 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-31T06:06:40.944551+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-31T05:00:00+00:00 PythonOperator 2023-03-31T06:06:21.815291+00:00 2023-03-31T06:06:25.960143+00:00 0:00:04.144852 361810 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-31T06:06:18.927506+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-31T04:00:00+00:00 TriggerDagRunOperator 2023-03-31T05:24:35.540837+00:00 2023-03-31T05:24:36.075506+00:00 0:00:00.534669 361803 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T05:24:32.775698+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-31T04:00:00+00:00 TriggerDagRunOperator 2023-03-31T05:24:35.344691+00:00 2023-03-31T05:24:35.818165+00:00 0:00:00.473474 361802 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T05:24:32.775726+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-31T04:00:00+00:00 EmrJobFlowSensor 2023-03-31T05:14:26.332437+00:00 2023-03-31T05:24:28.026291+00:00 0:10:01.693854 361799 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-31T05:14:23.631123+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-31T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-31T05:14:03.886226+00:00 2023-03-31T05:14:04.681427+00:00 0:00:00.795201 361795 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-31T05:14:01.561506+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-31T04:00:00+00:00 PythonOperator 2023-03-31T05:13:41.757830+00:00 2023-03-31T05:13:45.157114+00:00 0:00:03.399284 361792 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-31T05:13:39.539590+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-31T03:00:00+00:00 TriggerDagRunOperator 2023-03-31T04:12:19.323222+00:00 2023-03-31T04:12:19.829915+00:00 0:00:00.506693 361782 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T04:12:16.214941+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-31T03:00:00+00:00 TriggerDagRunOperator 2023-03-31T04:12:19.093177+00:00 2023-03-31T04:12:19.546445+00:00 0:00:00.453268 361781 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T04:12:16.214903+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-31T03:00:00+00:00 EmrJobFlowSensor 2023-03-31T04:00:54.172029+00:00 2023-03-31T04:10:55.995549+00:00 0:10:01.823520 361774 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-31T04:00:51.718118+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-31T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-31T04:00:32.057531+00:00 2023-03-31T04:00:32.993636+00:00 0:00:00.936105 361772 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-31T04:00:29.690194+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-31T03:00:00+00:00 PythonOperator 2023-03-31T04:00:11.812374+00:00 2023-03-31T04:00:15.678100+00:00 0:00:03.865726 361770 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-31T04:00:09.607572+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-31T02:00:00+00:00 TriggerDagRunOperator 2023-03-31T03:11:18.985281+00:00 2023-03-31T03:11:19.449297+00:00 0:00:00.464016 361761 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T03:11:16.495380+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-31T02:00:00+00:00 TriggerDagRunOperator 2023-03-31T03:11:18.797316+00:00 2023-03-31T03:11:19.261096+00:00 0:00:00.463780 361760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T03:11:16.495409+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-31T02:00:00+00:00 EmrJobFlowSensor 2023-03-31T03:01:02.019640+00:00 2023-03-31T03:11:03.955181+00:00 0:10:01.935541 361753 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-31T03:00:59.549978+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-31T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-31T03:00:39.852915+00:00 2023-03-31T03:00:40.782764+00:00 0:00:00.929849 361750 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-31T03:00:37.533605+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-31T02:00:00+00:00 PythonOperator 2023-03-31T03:00:18.178262+00:00 2023-03-31T03:00:21.599239+00:00 0:00:03.420977 361749 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-31T03:00:15.465051+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-31T01:00:00+00:00 TriggerDagRunOperator 2023-03-31T02:11:12.320075+00:00 2023-03-31T02:11:12.800300+00:00 0:00:00.480225 361740 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T02:11:10.042076+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-31T01:00:00+00:00 TriggerDagRunOperator 2023-03-31T02:11:12.214671+00:00 2023-03-31T02:11:12.703977+00:00 0:00:00.489306 361739 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T02:11:10.042106+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-31T01:00:00+00:00 EmrJobFlowSensor 2023-03-31T02:01:00.390241+00:00 2023-03-31T02:11:02.214537+00:00 0:10:01.824296 361733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-31T02:00:58.184485+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-31T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-31T02:00:40.363600+00:00 2023-03-31T02:00:41.283861+00:00 0:00:00.920261 361731 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-31T02:00:38.168078+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-31T01:00:00+00:00 PythonOperator 2023-03-31T02:00:18.423884+00:00 2023-03-31T02:00:22.494801+00:00 0:00:04.070917 361729 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-31T02:00:16.145775+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-31T00:00:00+00:00 TriggerDagRunOperator 2023-03-31T01:20:46.112180+00:00 2023-03-31T01:20:46.624503+00:00 0:00:00.512323 361716 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T01:20:43.243052+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-31T00:00:00+00:00 TriggerDagRunOperator 2023-03-31T01:20:45.734433+00:00 2023-03-31T01:20:46.324537+00:00 0:00:00.590104 361715 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T01:20:43.243081+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-31T00:00:00+00:00 EmrJobFlowSensor 2023-03-31T01:08:49.549450+00:00 2023-03-31T01:18:51.284528+00:00 0:10:01.735078 361710 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-31T01:08:47.125899+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-31T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-31T01:08:27.362279+00:00 2023-03-31T01:08:28.375337+00:00 0:00:01.013058 361707 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-31T01:08:25.072834+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-31T00:00:00+00:00 PythonOperator 2023-03-31T01:08:06.172596+00:00 2023-03-31T01:08:09.845440+00:00 0:00:03.672844 361704 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-31T01:08:03.056506+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-30T23:00:00+00:00 TriggerDagRunOperator 2023-03-31T00:27:07.913110+00:00 2023-03-31T00:27:08.457808+00:00 0:00:00.544698 361697 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T00:27:05.444392+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-30T23:00:00+00:00 TriggerDagRunOperator 2023-03-31T00:27:07.891477+00:00 2023-03-31T00:27:08.391866+00:00 0:00:00.500389 361696 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-31T00:27:05.444362+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-30T23:00:00+00:00 EmrJobFlowSensor 2023-03-31T00:00:51.544324+00:00 2023-03-31T00:10:53.279196+00:00 0:10:01.734872 361689 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-31T00:00:49.352015+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-30T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-31T00:00:31.615836+00:00 2023-03-31T00:00:32.429247+00:00 0:00:00.813411 361687 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-31T00:00:29.335874+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-30T23:00:00+00:00 PythonOperator 2023-03-31T00:00:09.996094+00:00 2023-03-31T00:00:13.204264+00:00 0:00:03.208170 361685 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-31T00:00:07.321469+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-30T22:00:00+00:00 TriggerDagRunOperator 2023-03-30T23:11:23.327304+00:00 2023-03-30T23:11:23.803068+00:00 0:00:00.475764 361674 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T23:11:20.836816+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-30T22:00:00+00:00 TriggerDagRunOperator 2023-03-30T23:11:23.258153+00:00 2023-03-30T23:11:23.713071+00:00 0:00:00.454918 361673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T23:11:20.836785+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-30T22:00:00+00:00 EmrJobFlowSensor 2023-03-30T23:01:07.642210+00:00 2023-03-30T23:11:09.419966+00:00 0:10:01.777756 361667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-30T23:01:05.457000+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-30T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-30T23:00:49.242736+00:00 2023-03-30T23:00:50.061323+00:00 0:00:00.818587 361664 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-30T23:00:45.511506+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-30T22:00:00+00:00 PythonOperator 2023-03-30T23:00:25.820264+00:00 2023-03-30T23:00:30.052666+00:00 0:00:04.232402 361661 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-30T23:00:23.490254+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-30T21:00:00+00:00 TriggerDagRunOperator 2023-03-30T22:11:21.372030+00:00 2023-03-30T22:11:21.846151+00:00 0:00:00.474121 361647 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T22:11:18.521873+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-30T21:00:00+00:00 TriggerDagRunOperator 2023-03-30T22:11:21.331565+00:00 2023-03-30T22:11:21.851142+00:00 0:00:00.519577 361646 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T22:11:18.521917+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-30T21:00:00+00:00 EmrJobFlowSensor 2023-03-30T22:01:04.592315+00:00 2023-03-30T22:11:06.450650+00:00 0:10:01.858335 361640 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-30T22:01:02.369131+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-30T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-30T22:00:44.045081+00:00 2023-03-30T22:00:45.342527+00:00 0:00:01.297446 361638 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-30T22:00:40.345848+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-30T21:00:00+00:00 PythonOperator 2023-03-30T22:00:20.595380+00:00 2023-03-30T22:00:24.617412+00:00 0:00:04.022032 361636 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-30T22:00:18.334148+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-30T20:00:00+00:00 TriggerDagRunOperator 2023-03-30T21:11:07.779036+00:00 2023-03-30T21:11:08.283115+00:00 0:00:00.504079 361624 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T21:11:05.114519+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-30T20:00:00+00:00 TriggerDagRunOperator 2023-03-30T21:11:07.766872+00:00 2023-03-30T21:11:08.283533+00:00 0:00:00.516661 361623 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T21:11:05.114468+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-30T20:00:00+00:00 EmrJobFlowSensor 2023-03-30T21:01:00.969244+00:00 2023-03-30T21:11:02.745721+00:00 0:10:01.776477 361616 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-30T21:00:58.755118+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-30T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-30T21:00:40.965256+00:00 2023-03-30T21:00:41.797321+00:00 0:00:00.832065 361614 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-30T21:00:38.721508+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-30T20:00:00+00:00 PythonOperator 2023-03-30T21:00:19.149321+00:00 2023-03-30T21:00:22.774066+00:00 0:00:03.624745 361612 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-30T21:00:16.668804+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-30T19:00:00+00:00 TriggerDagRunOperator 2023-03-30T20:11:14.416238+00:00 2023-03-30T20:11:14.902946+00:00 0:00:00.486708 361602 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T20:11:11.733321+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-30T19:00:00+00:00 TriggerDagRunOperator 2023-03-30T20:11:14.281685+00:00 2023-03-30T20:11:14.771677+00:00 0:00:00.489992 361601 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T20:11:11.733350+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-30T19:00:00+00:00 EmrJobFlowSensor 2023-03-30T20:00:54.887588+00:00 2023-03-30T20:10:56.837899+00:00 0:10:01.950311 361594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-30T20:00:52.729745+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-30T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-30T20:00:34.932948+00:00 2023-03-30T20:00:35.767757+00:00 0:00:00.834809 361592 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-30T20:00:32.710907+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-30T19:00:00+00:00 PythonOperator 2023-03-30T20:00:12.830237+00:00 2023-03-30T20:00:16.774468+00:00 0:00:03.944231 361590 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-30T20:00:10.691671+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-30T18:00:00+00:00 TriggerDagRunOperator 2023-03-30T19:16:56.366070+00:00 2023-03-30T19:16:56.902448+00:00 0:00:00.536378 361580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T19:16:53.840042+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-30T18:00:00+00:00 TriggerDagRunOperator 2023-03-30T19:16:56.357891+00:00 2023-03-30T19:16:56.905146+00:00 0:00:00.547255 361579 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T19:16:53.840072+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-30T18:00:00+00:00 EmrJobFlowSensor 2023-03-30T19:03:57.478989+00:00 2023-03-30T19:13:59.224385+00:00 0:10:01.745396 361572 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-30T19:03:55.306902+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-30T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-30T19:03:37.539604+00:00 2023-03-30T19:03:38.532695+00:00 0:00:00.993091 361570 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-30T19:03:35.282659+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-30T18:00:00+00:00 PythonOperator 2023-03-30T19:03:16.141488+00:00 2023-03-30T19:03:19.519171+00:00 0:00:03.377683 361568 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-30T19:03:13.315321+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-30T17:00:00+00:00 TriggerDagRunOperator 2023-03-30T18:21:58.036820+00:00 2023-03-30T18:21:58.511505+00:00 0:00:00.474685 361561 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T18:21:55.466309+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-30T17:00:00+00:00 TriggerDagRunOperator 2023-03-30T18:21:58.017807+00:00 2023-03-30T18:21:58.492937+00:00 0:00:00.475130 361560 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T18:21:55.466275+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-30T17:00:00+00:00 EmrJobFlowSensor 2023-03-30T18:08:58.951487+00:00 2023-03-30T18:19:00.703260+00:00 0:10:01.751773 361556 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-30T18:08:56.788277+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-30T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-30T18:08:39.015642+00:00 2023-03-30T18:08:40.079247+00:00 0:00:01.063605 361553 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-30T18:08:34.768096+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-30T17:00:00+00:00 PythonOperator 2023-03-30T18:00:24.318816+00:00 2023-03-30T18:00:28.144096+00:00 0:00:03.825280 361549 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-30T18:00:22.067857+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-30T16:00:00+00:00 TriggerDagRunOperator 2023-03-30T17:26:15.374190+00:00 2023-03-30T17:26:15.924443+00:00 0:00:00.550253 361541 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T17:26:12.327155+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-30T16:00:00+00:00 TriggerDagRunOperator 2023-03-30T17:26:14.901738+00:00 2023-03-30T17:26:15.360954+00:00 0:00:00.459216 361540 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T17:26:12.327185+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-30T16:00:00+00:00 EmrJobFlowSensor 2023-03-30T17:14:29.996344+00:00 2023-03-30T17:24:31.885738+00:00 0:10:01.889394 361535 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-30T17:14:27.628589+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-30T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-30T17:14:08.001365+00:00 2023-03-30T17:14:08.845024+00:00 0:00:00.843659 361532 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-30T17:14:05.556612+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-30T16:00:00+00:00 PythonOperator 2023-03-30T17:13:46.322254+00:00 2023-03-30T17:13:50.155995+00:00 0:00:03.833741 361529 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-30T17:13:43.539648+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-30T15:00:00+00:00 TriggerDagRunOperator 2023-03-30T16:23:17.839522+00:00 2023-03-30T16:23:18.319223+00:00 0:00:00.479701 361521 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T16:23:15.327710+00:00 2 default_pool