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-03-30T15:00:00+00:00 TriggerDagRunOperator 2023-03-30T16:23:17.782717+00:00 2023-03-30T16:23:18.245305+00:00 0:00:00.462588 361520 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T16:23:15.327738+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-30T15:00:00+00:00 EmrJobFlowSensor 2023-03-30T16:12:56.233488+00:00 2023-03-30T16:22:58.381470+00:00 0:10:02.147982 361516 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-30T16:12:54.016530+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-30T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-30T16:12:34.236981+00:00 2023-03-30T16:12:35.172913+00:00 0:00:00.935932 361513 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-30T16:12:31.999138+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-30T15:00:00+00:00 PythonOperator 2023-03-30T16:12:14.282902+00:00 2023-03-30T16:12:17.434325+00:00 0:00:03.151423 361511 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-30T16:12:11.982335+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-30T14:00:00+00:00 TriggerDagRunOperator 2023-03-30T15:26:30.459157+00:00 2023-03-30T15:26:30.952046+00:00 0:00:00.492889 361502 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T15:26:27.542865+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-30T14:00:00+00:00 TriggerDagRunOperator 2023-03-30T15:26:30.281385+00:00 2023-03-30T15:26:30.799625+00:00 0:00:00.518240 361501 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T15:26:27.542834+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-30T14:00:00+00:00 EmrJobFlowSensor 2023-03-30T15:02:10.460546+00:00 2023-03-30T15:12:12.144928+00:00 0:10:01.684382 361494 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-30T15:02:08.284925+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-30T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-30T15:01:48.538545+00:00 2023-03-30T15:01:49.466462+00:00 0:00:00.927917 361492 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-30T15:01:46.262761+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-30T14:00:00+00:00 PythonOperator 2023-03-30T15:01:29.106409+00:00 2023-03-30T15:01:36.051419+00:00 0:00:06.945010 361490 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-30T15:01:26.271172+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-30T13:00:00+00:00 TriggerDagRunOperator 2023-03-30T14:19:17.869139+00:00 2023-03-30T14:19:18.377114+00:00 0:00:00.507975 361484 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T14:19:14.796627+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-30T13:00:00+00:00 TriggerDagRunOperator 2023-03-30T14:19:17.672971+00:00 2023-03-30T14:19:18.124269+00:00 0:00:00.451298 361483 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T14:19:14.796598+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-30T13:00:00+00:00 EmrJobFlowSensor 2023-03-30T14:08:59.765944+00:00 2023-03-30T14:19:01.703492+00:00 0:10:01.937548 361480 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-30T14:08:57.525475+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-30T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-30T14:08:38.912591+00:00 2023-03-30T14:08:40.198174+00:00 0:00:01.285583 361477 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-30T14:08:35.473619+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-30T13:00:00+00:00 PythonOperator 2023-03-30T14:08:17.654944+00:00 2023-03-30T14:08:21.149135+00:00 0:00:03.494191 361474 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-30T14:08:15.451082+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-30T12:00:00+00:00 TriggerDagRunOperator 2023-03-30T13:14:04.319262+00:00 2023-03-30T13:14:04.808782+00:00 0:00:00.489520 361462 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T13:14:01.866491+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-30T12:00:00+00:00 TriggerDagRunOperator 2023-03-30T13:14:04.281102+00:00 2023-03-30T13:14:04.761070+00:00 0:00:00.479968 361461 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T13:14:01.866518+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-30T12:00:00+00:00 EmrJobFlowSensor 2023-03-30T13:03:44.643847+00:00 2023-03-30T13:13:46.564043+00:00 0:10:01.920196 361454 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-30T13:03:42.338590+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-30T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-30T13:03:24.726897+00:00 2023-03-30T13:03:25.631996+00:00 0:00:00.905099 361452 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-30T13:03:22.321948+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-30T12:00:00+00:00 PythonOperator 2023-03-30T13:03:03.206144+00:00 2023-03-30T13:03:06.927428+00:00 0:00:03.721284 361450 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-30T13:03:00.326530+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-30T11:00:00+00:00 TriggerDagRunOperator 2023-03-30T12:44:58.125981+00:00 2023-03-30T12:44:58.620080+00:00 0:00:00.494099 361445 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T12:44:55.748841+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-30T11:00:00+00:00 TriggerDagRunOperator 2023-03-30T12:44:58.132854+00:00 2023-03-30T12:44:58.594970+00:00 0:00:00.462116 361444 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T12:44:55.748871+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-30T11:00:00+00:00 EmrJobFlowSensor 2023-03-30T12:23:09.241390+00:00 2023-03-30T12:33:11.043574+00:00 0:10:01.802184 361440 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-30T12:23:06.933750+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-30T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-30T12:22:47.210808+00:00 2023-03-30T12:22:48.127884+00:00 0:00:00.917076 361437 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-30T12:22:44.892364+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-30T11:00:00+00:00 PythonOperator 2023-03-30T12:22:27.293133+00:00 2023-03-30T12:22:32.792916+00:00 0:00:05.499783 361434 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-30T12:22:24.874806+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-30T10:00:00+00:00 TriggerDagRunOperator 2023-03-30T11:23:11.309409+00:00 2023-03-30T11:23:11.819470+00:00 0:00:00.510061 361427 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T11:23:08.805982+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-30T10:00:00+00:00 TriggerDagRunOperator 2023-03-30T11:23:11.151785+00:00 2023-03-30T11:23:11.617276+00:00 0:00:00.465491 361426 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T11:23:08.806011+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-30T10:00:00+00:00 EmrJobFlowSensor 2023-03-30T11:12:48.906224+00:00 2023-03-30T11:22:50.713720+00:00 0:10:01.807496 361423 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-30T11:12:46.629961+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-30T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-30T11:12:26.767562+00:00 2023-03-30T11:12:27.651555+00:00 0:00:00.883993 361420 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-30T11:12:24.584918+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-30T10:00:00+00:00 PythonOperator 2023-03-30T11:12:07.028650+00:00 2023-03-30T11:12:10.129192+00:00 0:00:03.100542 361417 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-30T11:12:04.566078+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-30T09:00:00+00:00 TriggerDagRunOperator 2023-03-30T10:13:27.058116+00:00 2023-03-30T10:13:27.539573+00:00 0:00:00.481457 361405 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T10:13:24.503167+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-30T09:00:00+00:00 TriggerDagRunOperator 2023-03-30T10:13:27.037438+00:00 2023-03-30T10:13:27.528547+00:00 0:00:00.491109 361404 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T10:13:24.503138+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-30T09:00:00+00:00 EmrJobFlowSensor 2023-03-30T10:03:11.479877+00:00 2023-03-30T10:13:13.198070+00:00 0:10:01.718193 361397 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-30T10:03:09.131843+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-30T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-30T10:02:49.375337+00:00 2023-03-30T10:02:50.196573+00:00 0:00:00.821236 361395 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-30T10:02:47.075443+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-30T09:00:00+00:00 PythonOperator 2023-03-30T10:02:27.423114+00:00 2023-03-30T10:02:31.483603+00:00 0:00:04.060489 361393 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-30T10:02:25.057504+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-30T08:00:00+00:00 TriggerDagRunOperator 2023-03-30T09:14:17.258477+00:00 2023-03-30T09:14:17.738028+00:00 0:00:00.479551 361386 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T09:14:14.850495+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-30T08:00:00+00:00 TriggerDagRunOperator 2023-03-30T09:14:17.213818+00:00 2023-03-30T09:14:17.688653+00:00 0:00:00.474835 361385 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T09:14:14.850465+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-30T08:00:00+00:00 EmrJobFlowSensor 2023-03-30T09:04:07.142702+00:00 2023-03-30T09:14:08.764551+00:00 0:10:01.621849 361379 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-30T09:04:04.827337+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-30T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-30T09:03:45.335391+00:00 2023-03-30T09:03:46.207484+00:00 0:00:00.872093 361377 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-30T09:03:42.779283+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-30T08:00:00+00:00 PythonOperator 2023-03-30T09:03:23.213570+00:00 2023-03-30T09:03:26.470608+00:00 0:00:03.257038 361375 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-30T09:03:20.790494+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-30T07:00:00+00:00 TriggerDagRunOperator 2023-03-30T08:14:48.208444+00:00 2023-03-30T08:14:48.730476+00:00 0:00:00.522032 361365 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T08:14:45.439393+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-30T07:00:00+00:00 TriggerDagRunOperator 2023-03-30T08:14:48.134152+00:00 2023-03-30T08:14:48.664127+00:00 0:00:00.529975 361364 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T08:14:45.439422+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-30T07:00:00+00:00 EmrJobFlowSensor 2023-03-30T08:03:13.250291+00:00 2023-03-30T08:13:15.024831+00:00 0:10:01.774540 361357 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-30T08:03:11.057630+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-30T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-30T08:02:51.461459+00:00 2023-03-30T08:02:52.489657+00:00 0:00:01.028198 361355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-30T08:02:48.988967+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-30T07:00:00+00:00 PythonOperator 2023-03-30T08:02:29.964357+00:00 2023-03-30T08:02:33.584287+00:00 0:00:03.619930 361353 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-30T08:02:27.021506+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-30T06:00:00+00:00 TriggerDagRunOperator 2023-03-30T07:13:31.446612+00:00 2023-03-30T07:13:31.988882+00:00 0:00:00.542270 361344 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T07:13:28.674030+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-30T06:00:00+00:00 TriggerDagRunOperator 2023-03-30T07:13:31.287435+00:00 2023-03-30T07:13:31.741109+00:00 0:00:00.453674 361343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T07:13:28.674001+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-30T06:00:00+00:00 EmrJobFlowSensor 2023-03-30T07:00:49.047256+00:00 2023-03-30T07:10:50.881375+00:00 0:10:01.834119 361336 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-30T07:00:46.834124+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-30T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-30T07:00:27.055206+00:00 2023-03-30T07:00:27.851188+00:00 0:00:00.795982 361334 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-30T07:00:24.814862+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-30T06:00:00+00:00 PythonOperator 2023-03-30T07:00:05.094054+00:00 2023-03-30T07:00:09.134299+00:00 0:00:04.040245 361332 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-30T07:00:02.792348+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-30T05:00:00+00:00 TriggerDagRunOperator 2023-03-30T06:11:34.538557+00:00 2023-03-30T06:11:35.351951+00:00 0:00:00.813394 361322 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T06:11:30.712312+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-30T05:00:00+00:00 TriggerDagRunOperator 2023-03-30T06:11:33.052222+00:00 2023-03-30T06:11:33.489893+00:00 0:00:00.437671 361321 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T06:11:30.712345+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-30T05:00:00+00:00 EmrJobFlowSensor 2023-03-30T06:00:47.300111+00:00 2023-03-30T06:10:49.423474+00:00 0:10:02.123363 361316 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-30T06:00:44.926243+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-30T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-30T06:00:25.207497+00:00 2023-03-30T06:00:26.138351+00:00 0:00:00.930854 361314 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-30T06:00:22.892084+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-30T05:00:00+00:00 PythonOperator 2023-03-30T06:00:05.541256+00:00 2023-03-30T06:00:09.647770+00:00 0:00:04.106514 361312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-30T06:00:02.804748+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-30T04:00:00+00:00 TriggerDagRunOperator 2023-03-30T05:11:17.862015+00:00 2023-03-30T05:11:18.506580+00:00 0:00:00.644565 361304 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T05:11:15.349050+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-30T04:00:00+00:00 TriggerDagRunOperator 2023-03-30T05:11:17.817432+00:00 2023-03-30T05:11:18.417886+00:00 0:00:00.600454 361303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T05:11:15.349022+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-30T04:00:00+00:00 EmrJobFlowSensor 2023-03-30T05:00:52.331830+00:00 2023-03-30T05:10:54.653271+00:00 0:10:02.321441 361295 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-30T05:00:49.771422+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-30T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-30T05:00:30.296905+00:00 2023-03-30T05:00:31.189435+00:00 0:00:00.892530 361293 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-30T05:00:27.803463+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-30T04:00:00+00:00 PythonOperator 2023-03-30T05:00:08.527161+00:00 2023-03-30T05:00:11.967401+00:00 0:00:03.440240 361291 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-30T05:00:05.807408+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-30T03:00:00+00:00 TriggerDagRunOperator 2023-03-30T04:36:34.285330+00:00 2023-03-30T04:36:34.774732+00:00 0:00:00.489402 361286 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T04:36:31.536980+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-30T03:00:00+00:00 TriggerDagRunOperator 2023-03-30T04:36:34.065845+00:00 2023-03-30T04:36:34.511939+00:00 0:00:00.446094 361285 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T04:36:31.536950+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-30T03:00:00+00:00 EmrJobFlowSensor 2023-03-30T04:07:18.040056+00:00 2023-03-30T04:17:19.867881+00:00 0:10:01.827825 361281 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-30T04:07:15.559489+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-30T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-30T04:06:56.293168+00:00 2023-03-30T04:06:57.249648+00:00 0:00:00.956480 361278 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-30T04:06:53.540252+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-30T03:00:00+00:00 PythonOperator 2023-03-30T04:06:34.361832+00:00 2023-03-30T04:06:38.445427+00:00 0:00:04.083595 361274 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-30T04:06:31.522255+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-30T02:00:00+00:00 TriggerDagRunOperator 2023-03-30T03:11:14.040334+00:00 2023-03-30T03:11:14.544883+00:00 0:00:00.504549 361265 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T03:11:11.386036+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-30T02:00:00+00:00 TriggerDagRunOperator 2023-03-30T03:11:13.757583+00:00 2023-03-30T03:11:14.215980+00:00 0:00:00.458397 361264 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T03:11:11.386007+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-30T02:00:00+00:00 EmrJobFlowSensor 2023-03-30T03:00:49.471820+00:00 2023-03-30T03:10:51.157423+00:00 0:10:01.685603 361256 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-30T03:00:47.312332+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-30T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-30T03:00:29.452012+00:00 2023-03-30T03:00:30.272551+00:00 0:00:00.820539 361254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-30T03:00:27.291792+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-30T02:00:00+00:00 PythonOperator 2023-03-30T03:00:08.035917+00:00 2023-03-30T03:00:12.928453+00:00 0:00:04.892536 361252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-30T03:00:05.309165+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-30T01:00:00+00:00 TriggerDagRunOperator 2023-03-30T02:22:39.715501+00:00 2023-03-30T02:22:40.238156+00:00 0:00:00.522655 361245 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T02:22:36.809981+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-30T01:00:00+00:00 TriggerDagRunOperator 2023-03-30T02:22:39.616377+00:00 2023-03-30T02:22:40.086001+00:00 0:00:00.469624 361244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T02:22:36.809927+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-30T01:00:00+00:00 EmrJobFlowSensor 2023-03-30T02:02:31.345266+00:00 2023-03-30T02:12:33.503204+00:00 0:10:02.157938 361238 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-30T02:02:29.146365+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-30T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-30T02:02:09.551355+00:00 2023-03-30T02:02:10.359383+00:00 0:00:00.808028 361236 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-30T02:02:07.125605+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-30T01:00:00+00:00 PythonOperator 2023-03-30T02:00:23.467426+00:00 2023-03-30T02:00:26.694288+00:00 0:00:03.226862 361233 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-30T02:00:21.228232+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-30T00:00:00+00:00 TriggerDagRunOperator 2023-03-30T01:11:13.737270+00:00 2023-03-30T01:11:14.219801+00:00 0:00:00.482531 361219 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T01:11:11.205633+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-30T00:00:00+00:00 TriggerDagRunOperator 2023-03-30T01:11:13.533086+00:00 2023-03-30T01:11:13.978378+00:00 0:00:00.445292 361218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T01:11:11.205585+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-30T00:00:00+00:00 EmrJobFlowSensor 2023-03-30T01:00:52.857703+00:00 2023-03-30T01:10:54.690261+00:00 0:10:01.832558 361212 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-30T01:00:50.664010+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-30T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-30T01:00:32.835578+00:00 2023-03-30T01:00:33.667776+00:00 0:00:00.832198 361210 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-30T01:00:30.651538+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-30T00:00:00+00:00 PythonOperator 2023-03-30T01:00:10.810480+00:00 2023-03-30T01:00:14.184138+00:00 0:00:03.373658 361208 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-30T01:00:08.623788+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-29T23:00:00+00:00 TriggerDagRunOperator 2023-03-30T00:15:51.709522+00:00 2023-03-30T00:15:52.357997+00:00 0:00:00.648475 361197 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T00:15:47.233720+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-29T23:00:00+00:00 TriggerDagRunOperator 2023-03-30T00:15:51.667804+00:00 2023-03-30T00:15:52.308467+00:00 0:00:00.640663 361196 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-30T00:15:47.233691+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-29T23:00:00+00:00 EmrJobFlowSensor 2023-03-30T00:01:03.183061+00:00 2023-03-30T00:11:05.092911+00:00 0:10:01.909850 361192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-30T00:01:00.789750+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-29T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-30T00:00:40.967848+00:00 2023-03-30T00:00:41.838770+00:00 0:00:00.870922 361190 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-30T00:00:38.759319+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-29T23:00:00+00:00 PythonOperator 2023-03-30T00:00:19.498252+00:00 2023-03-30T00:00:23.689697+00:00 0:00:04.191445 361188 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-30T00:00:16.734228+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-29T22:00:00+00:00 TriggerDagRunOperator 2023-03-29T23:11:13.432313+00:00 2023-03-29T23:11:13.935836+00:00 0:00:00.503523 361178 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T23:11:10.777832+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-29T22:00:00+00:00 TriggerDagRunOperator 2023-03-29T23:11:13.123774+00:00 2023-03-29T23:11:13.605034+00:00 0:00:00.481260 361177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T23:11:10.777860+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-29T22:00:00+00:00 EmrJobFlowSensor 2023-03-29T23:01:00.413502+00:00 2023-03-29T23:11:02.421393+00:00 0:10:02.007891 361169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-29T23:00:57.858063+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-29T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-29T23:00:38.226367+00:00 2023-03-29T23:00:39.039486+00:00 0:00:00.813119 361167 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-29T23:00:35.837527+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-29T22:00:00+00:00 PythonOperator 2023-03-29T23:00:16.518022+00:00 2023-03-29T23:00:20.530976+00:00 0:00:04.012954 361163 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-29T23:00:13.819199+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-29T21:00:00+00:00 TriggerDagRunOperator 2023-03-29T22:18:56.973863+00:00 2023-03-29T22:18:57.525409+00:00 0:00:00.551546 361153 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T22:18:54.297877+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-29T21:00:00+00:00 TriggerDagRunOperator 2023-03-29T22:18:56.811641+00:00 2023-03-29T22:18:57.276215+00:00 0:00:00.464574 361152 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T22:18:54.297833+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-29T21:00:00+00:00 EmrJobFlowSensor 2023-03-29T22:08:47.593797+00:00 2023-03-29T22:18:49.428501+00:00 0:10:01.834704 361149 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-29T22:08:45.326104+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-29T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-29T22:08:29.382863+00:00 2023-03-29T22:08:30.571312+00:00 0:00:01.188449 361146 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-29T22:08:25.306879+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-29T21:00:00+00:00 PythonOperator 2023-03-29T22:08:05.324065+00:00 2023-03-29T22:08:09.346662+00:00 0:00:04.022597 361143 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-29T22:08:03.177169+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-29T20:00:00+00:00 TriggerDagRunOperator 2023-03-29T21:11:43.148359+00:00 2023-03-29T21:11:43.625578+00:00 0:00:00.477219 361131 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T21:11:40.433669+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-29T20:00:00+00:00 TriggerDagRunOperator 2023-03-29T21:11:43.015887+00:00 2023-03-29T21:11:43.456216+00:00 0:00:00.440329 361130 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T21:11:40.433710+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-29T20:00:00+00:00 EmrJobFlowSensor 2023-03-29T21:00:57.279135+00:00 2023-03-29T21:10:59.031908+00:00 0:10:01.752773 361122 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-29T21:00:55.127060+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-29T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-29T21:00:35.272413+00:00 2023-03-29T21:00:36.200836+00:00 0:00:00.928423 361120 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-29T21:00:33.015290+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-29T20:00:00+00:00 PythonOperator 2023-03-29T21:00:15.411132+00:00 2023-03-29T21:00:18.663161+00:00 0:00:03.252029 361118 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-29T21:00:12.997941+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-29T19:00:00+00:00 TriggerDagRunOperator 2023-03-29T20:11:10.177419+00:00 2023-03-29T20:11:10.657127+00:00 0:00:00.479708 361108 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T20:11:07.829114+00:00 2 default_pool