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-05-06T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-06T15:01:38.403249+00:00 2023-05-06T15:01:39.223904+00:00 0:00:00.820655 374179 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-06T15:01:35.877456+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-06T14:00:00+00:00 PythonOperator 2023-05-06T15:00:15.383285+00:00 2023-05-06T15:00:16.382219+00:00 0:00:00.998934 374176 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-06T15:00:12.697671+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-06T13:00:00+00:00 TriggerDagRunOperator 2023-05-06T14:28:19.400147+00:00 2023-05-06T14:28:19.802677+00:00 0:00:00.402530 374165 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T14:28:16.685143+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-06T13:00:00+00:00 TriggerDagRunOperator 2023-05-06T14:28:19.324814+00:00 2023-05-06T14:28:19.801386+00:00 0:00:00.476572 374164 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T14:28:16.685188+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-06T13:00:00+00:00 EmrJobFlowSensor 2023-05-06T14:17:53.427979+00:00 2023-05-06T14:27:55.251568+00:00 0:10:01.823589 374159 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-06T14:17:51.286719+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-06T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-06T14:17:33.641779+00:00 2023-05-06T14:17:34.650839+00:00 0:00:01.009060 374156 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-06T14:17:31.289228+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-06T13:00:00+00:00 PythonOperator 2023-05-06T14:17:11.861004+00:00 2023-05-06T14:17:12.808511+00:00 0:00:00.947507 374153 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-06T14:17:09.282305+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-06T12:00:00+00:00 TriggerDagRunOperator 2023-05-06T13:19:01.468955+00:00 2023-05-06T13:19:01.905725+00:00 0:00:00.436770 374142 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T13:18:58.409806+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-06T12:00:00+00:00 TriggerDagRunOperator 2023-05-06T13:19:01.353062+00:00 2023-05-06T13:19:01.688549+00:00 0:00:00.335487 374141 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T13:18:58.409770+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-06T12:00:00+00:00 EmrJobFlowSensor 2023-05-06T13:00:50.677257+00:00 2023-05-06T13:10:52.439376+00:00 0:10:01.762119 374135 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-06T13:00:48.413871+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-06T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-06T13:00:28.425328+00:00 2023-05-06T13:00:29.321378+00:00 0:00:00.896050 374133 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-06T13:00:26.340311+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-06T12:00:00+00:00 PythonOperator 2023-05-06T13:00:08.893518+00:00 2023-05-06T13:00:09.956894+00:00 0:00:01.063376 374131 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-06T13:00:06.320668+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-06T11:00:00+00:00 TriggerDagRunOperator 2023-05-06T12:27:58.333724+00:00 2023-05-06T12:27:58.803538+00:00 0:00:00.469814 374117 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T12:27:55.408514+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-06T11:00:00+00:00 TriggerDagRunOperator 2023-05-06T12:27:58.311900+00:00 2023-05-06T12:27:58.693656+00:00 0:00:00.381756 374116 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T12:27:55.408546+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-06T11:00:00+00:00 EmrJobFlowSensor 2023-05-06T12:00:46.051188+00:00 2023-05-06T12:10:47.970045+00:00 0:10:01.918857 374114 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-06T12:00:43.605301+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-06T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-06T12:00:25.836238+00:00 2023-05-06T12:00:26.779165+00:00 0:00:00.942927 374112 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-06T12:00:23.519521+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-06T11:00:00+00:00 PythonOperator 2023-05-06T12:00:03.914052+00:00 2023-05-06T12:00:04.855409+00:00 0:00:00.941357 374110 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-06T12:00:01.519007+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-06T10:00:00+00:00 TriggerDagRunOperator 2023-05-06T11:11:39.071878+00:00 2023-05-06T11:11:39.525520+00:00 0:00:00.453642 374098 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T11:11:36.496690+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-06T10:00:00+00:00 TriggerDagRunOperator 2023-05-06T11:11:38.839931+00:00 2023-05-06T11:11:39.286679+00:00 0:00:00.446748 374097 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T11:11:36.496720+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-06T10:00:00+00:00 EmrJobFlowSensor 2023-05-06T11:01:04.814506+00:00 2023-05-06T11:11:06.768373+00:00 0:10:01.953867 374089 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-06T11:01:02.553027+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-06T10:00:00+00:00 EmrCreateJobFlowOperator 2023-05-06T11:00:42.954098+00:00 2023-05-06T11:00:44.175130+00:00 0:00:01.221032 374087 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-06T11:00:40.595206+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-06T10:00:00+00:00 PythonOperator 2023-05-06T11:00:23.265682+00:00 2023-05-06T11:00:24.335494+00:00 0:00:01.069812 374085 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-06T11:00:20.586516+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-06T09:00:00+00:00 TriggerDagRunOperator 2023-05-06T10:12:06.650232+00:00 2023-05-06T10:12:07.097558+00:00 0:00:00.447326 374075 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T10:12:03.123454+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-06T09:00:00+00:00 TriggerDagRunOperator 2023-05-06T10:12:06.140393+00:00 2023-05-06T10:12:06.643485+00:00 0:00:00.503092 374074 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T10:12:03.123410+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-06T09:00:00+00:00 EmrJobFlowSensor 2023-05-06T10:01:43.075789+00:00 2023-05-06T10:11:44.904386+00:00 0:10:01.828597 374068 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-06T10:01:40.890179+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-06T09:00:00+00:00 EmrCreateJobFlowOperator 2023-05-06T10:01:21.490572+00:00 2023-05-06T10:01:22.681262+00:00 0:00:01.190690 374066 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-06T10:01:18.793940+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-06T09:00:00+00:00 PythonOperator 2023-05-06T10:01:00.897658+00:00 2023-05-06T10:01:01.832398+00:00 0:00:00.934740 374064 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-06T10:00:58.710538+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-06T08:00:00+00:00 TriggerDagRunOperator 2023-05-06T09:14:47.418976+00:00 2023-05-06T09:14:47.887583+00:00 0:00:00.468607 374051 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T09:14:44.948005+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-06T08:00:00+00:00 TriggerDagRunOperator 2023-05-06T09:14:47.318295+00:00 2023-05-06T09:14:47.659554+00:00 0:00:00.341259 374050 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T09:14:44.947975+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-06T08:00:00+00:00 EmrJobFlowSensor 2023-05-06T09:04:36.649772+00:00 2023-05-06T09:14:38.432779+00:00 0:10:01.783007 374043 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-06T09:04:34.445572+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-06T08:00:00+00:00 EmrCreateJobFlowOperator 2023-05-06T09:04:14.650657+00:00 2023-05-06T09:04:15.423823+00:00 0:00:00.773166 374041 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-06T09:04:12.423881+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-06T08:00:00+00:00 PythonOperator 2023-05-06T09:03:55.248312+00:00 2023-05-06T09:03:56.200238+00:00 0:00:00.951926 374039 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-06T09:03:52.128396+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-06T07:00:00+00:00 TriggerDagRunOperator 2023-05-06T08:11:44.645303+00:00 2023-05-06T08:11:45.209981+00:00 0:00:00.564678 374028 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T08:11:41.992986+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-06T07:00:00+00:00 TriggerDagRunOperator 2023-05-06T08:11:44.516766+00:00 2023-05-06T08:11:44.883659+00:00 0:00:00.366893 374027 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T08:11:41.992957+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-06T07:00:00+00:00 EmrJobFlowSensor 2023-05-06T08:01:35.092736+00:00 2023-05-06T08:11:36.987866+00:00 0:10:01.895130 374021 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-06T08:01:32.808901+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-06T07:00:00+00:00 EmrCreateJobFlowOperator 2023-05-06T08:01:14.949081+00:00 2023-05-06T08:01:15.749765+00:00 0:00:00.800684 374019 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-06T08:01:12.786367+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-06T07:00:00+00:00 PythonOperator 2023-05-06T08:00:15.963054+00:00 2023-05-06T08:00:16.911279+00:00 0:00:00.948225 374015 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-06T08:00:13.606292+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-06T06:00:00+00:00 TriggerDagRunOperator 2023-05-06T07:11:09.031977+00:00 2023-05-06T07:11:09.500965+00:00 0:00:00.468988 374004 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T07:11:06.192735+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-06T06:00:00+00:00 TriggerDagRunOperator 2023-05-06T07:11:08.977294+00:00 2023-05-06T07:11:09.378946+00:00 0:00:00.401652 374003 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T07:11:06.192688+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-06T06:00:00+00:00 EmrJobFlowSensor 2023-05-06T07:01:00.450526+00:00 2023-05-06T07:11:02.545135+00:00 0:10:02.094609 373996 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-06T07:00:57.892037+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-06T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-06T07:00:38.100869+00:00 2023-05-06T07:00:38.846017+00:00 0:00:00.745148 373994 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-06T07:00:35.788578+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-06T06:00:00+00:00 PythonOperator 2023-05-06T07:00:18.278213+00:00 2023-05-06T07:00:19.355893+00:00 0:00:01.077680 373992 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-06T07:00:15.690024+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-06T05:00:00+00:00 TriggerDagRunOperator 2023-05-06T06:11:22.572837+00:00 2023-05-06T06:11:23.071599+00:00 0:00:00.498762 373980 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T06:11:20.319585+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-06T05:00:00+00:00 TriggerDagRunOperator 2023-05-06T06:11:22.505160+00:00 2023-05-06T06:11:22.941807+00:00 0:00:00.436647 373979 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T06:11:20.319548+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-06T05:00:00+00:00 EmrJobFlowSensor 2023-05-06T06:01:02.789422+00:00 2023-05-06T06:11:04.760176+00:00 0:10:01.970754 373973 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-06T06:01:00.286396+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-06T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-06T06:00:40.326240+00:00 2023-05-06T06:00:41.051095+00:00 0:00:00.724855 373971 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-06T06:00:38.008391+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-06T05:00:00+00:00 PythonOperator 2023-05-06T06:00:18.200494+00:00 2023-05-06T06:00:19.327783+00:00 0:00:01.127289 373969 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-06T06:00:15.940337+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-06T04:00:00+00:00 TriggerDagRunOperator 2023-05-06T05:11:39.836335+00:00 2023-05-06T05:11:40.303000+00:00 0:00:00.466665 373955 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T05:11:36.811685+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-06T04:00:00+00:00 TriggerDagRunOperator 2023-05-06T05:11:39.745060+00:00 2023-05-06T05:11:40.091013+00:00 0:00:00.345953 373954 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T05:11:36.811643+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-06T04:00:00+00:00 EmrJobFlowSensor 2023-05-06T05:01:26.820762+00:00 2023-05-06T05:11:28.617258+00:00 0:10:01.796496 373948 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-06T05:01:24.111158+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-06T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-06T05:01:04.540361+00:00 2023-05-06T05:01:05.431079+00:00 0:00:00.890718 373946 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-06T05:01:02.044432+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-06T04:00:00+00:00 PythonOperator 2023-05-06T05:00:42.491478+00:00 2023-05-06T05:00:43.559661+00:00 0:00:01.068183 373944 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-06T05:00:40.025090+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-06T03:00:00+00:00 TriggerDagRunOperator 2023-05-06T04:12:02.197155+00:00 2023-05-06T04:12:02.600818+00:00 0:00:00.403663 373929 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T04:11:59.619368+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-06T03:00:00+00:00 TriggerDagRunOperator 2023-05-06T04:12:01.962837+00:00 2023-05-06T04:12:02.403126+00:00 0:00:00.440289 373928 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T04:11:59.619333+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-06T03:00:00+00:00 EmrJobFlowSensor 2023-05-06T04:00:55.921066+00:00 2023-05-06T04:10:57.845461+00:00 0:10:01.924395 373923 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-06T04:00:53.710405+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-06T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-06T04:00:33.830264+00:00 2023-05-06T04:00:34.699789+00:00 0:00:00.869525 373921 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-06T04:00:31.666734+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-06T03:00:00+00:00 PythonOperator 2023-05-06T04:00:12.060760+00:00 2023-05-06T04:00:12.990464+00:00 0:00:00.929704 373919 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-06T04:00:09.648476+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-06T02:00:00+00:00 TriggerDagRunOperator 2023-05-06T03:12:14.265469+00:00 2023-05-06T03:12:14.760068+00:00 0:00:00.494599 373907 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T03:12:11.184837+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-06T02:00:00+00:00 TriggerDagRunOperator 2023-05-06T03:12:14.149843+00:00 2023-05-06T03:12:14.494638+00:00 0:00:00.344795 373906 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T03:12:11.184794+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-06T02:00:00+00:00 EmrJobFlowSensor 2023-05-06T03:01:07.353215+00:00 2023-05-06T03:12:09.274278+00:00 0:11:01.921063 373899 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-06T03:01:05.134440+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-06T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-06T03:00:46.167694+00:00 2023-05-06T03:00:47.013907+00:00 0:00:00.846213 373897 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-06T03:00:43.120656+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-06T02:00:00+00:00 PythonOperator 2023-05-06T03:00:25.230069+00:00 2023-05-06T03:00:26.224572+00:00 0:00:00.994503 373895 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-06T03:00:23.056407+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-06T01:00:00+00:00 TriggerDagRunOperator 2023-05-06T02:11:06.846219+00:00 2023-05-06T02:11:07.271046+00:00 0:00:00.424827 373880 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T02:11:04.248327+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-06T01:00:00+00:00 TriggerDagRunOperator 2023-05-06T02:11:06.710518+00:00 2023-05-06T02:11:07.055484+00:00 0:00:00.344966 373879 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T02:11:04.248298+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-06T01:00:00+00:00 EmrJobFlowSensor 2023-05-06T02:00:57.241073+00:00 2023-05-06T02:10:59.086138+00:00 0:10:01.845065 373871 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-06T02:00:55.030807+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-06T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-06T02:00:37.180239+00:00 2023-05-06T02:00:38.008473+00:00 0:00:00.828234 373869 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-06T02:00:35.004951+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-06T01:00:00+00:00 PythonOperator 2023-05-06T02:00:15.284424+00:00 2023-05-06T02:00:16.219557+00:00 0:00:00.935133 373867 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-06T02:00:12.933832+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-06T00:00:00+00:00 TriggerDagRunOperator 2023-05-06T01:11:20.279477+00:00 2023-05-06T01:11:20.667296+00:00 0:00:00.387819 373848 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T01:11:17.293546+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-06T00:00:00+00:00 TriggerDagRunOperator 2023-05-06T01:11:20.308192+00:00 2023-05-06T01:11:20.776017+00:00 0:00:00.467825 373847 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T01:11:17.293592+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-06T00:00:00+00:00 EmrJobFlowSensor 2023-05-06T01:01:01.658096+00:00 2023-05-06T01:11:03.740120+00:00 0:10:02.082024 373840 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-06T01:00:59.083307+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-06T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-06T01:00:41.597024+00:00 2023-05-06T01:00:42.643636+00:00 0:00:01.046612 373838 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-06T01:00:38.997045+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-06T00:00:00+00:00 PythonOperator 2023-05-06T01:00:19.567080+00:00 2023-05-06T01:00:20.562502+00:00 0:00:00.995422 373835 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-06T01:00:16.918907+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-05T23:00:00+00:00 TriggerDagRunOperator 2023-05-06T00:11:14.185179+00:00 2023-05-06T00:11:14.720880+00:00 0:00:00.535701 373821 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T00:11:11.521874+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-05T23:00:00+00:00 TriggerDagRunOperator 2023-05-06T00:11:14.046353+00:00 2023-05-06T00:11:14.378667+00:00 0:00:00.332314 373820 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-06T00:11:11.521844+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-05T23:00:00+00:00 EmrJobFlowSensor 2023-05-06T00:01:07.005653+00:00 2023-05-06T00:11:08.861608+00:00 0:10:01.855955 373813 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-06T00:01:04.790562+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-05T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-06T00:00:45.282226+00:00 2023-05-06T00:00:46.080151+00:00 0:00:00.797925 373811 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-06T00:00:42.786929+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-05T23:00:00+00:00 PythonOperator 2023-05-06T00:00:24.855001+00:00 2023-05-06T00:00:25.811092+00:00 0:00:00.956091 373809 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-06T00:00:22.663707+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-05T22:00:00+00:00 TriggerDagRunOperator 2023-05-05T23:11:13.000970+00:00 2023-05-05T23:11:13.436556+00:00 0:00:00.435586 373794 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T23:11:09.910252+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-05T22:00:00+00:00 TriggerDagRunOperator 2023-05-05T23:11:12.921665+00:00 2023-05-05T23:11:13.262257+00:00 0:00:00.340592 373793 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T23:11:09.910292+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-05T22:00:00+00:00 EmrJobFlowSensor 2023-05-05T23:01:01.950240+00:00 2023-05-05T23:11:03.921826+00:00 0:10:01.971586 373785 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-05T23:00:59.732318+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-05T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-05T23:00:40.028294+00:00 2023-05-05T23:00:40.847273+00:00 0:00:00.818979 373782 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-05T23:00:37.702954+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-05T22:00:00+00:00 PythonOperator 2023-05-05T23:00:19.902278+00:00 2023-05-05T23:00:20.899954+00:00 0:00:00.997676 373779 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-05T23:00:17.641148+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-05T21:00:00+00:00 TriggerDagRunOperator 2023-05-05T22:10:59.763942+00:00 2023-05-05T22:11:00.393668+00:00 0:00:00.629726 373765 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T22:10:56.886464+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-05T21:00:00+00:00 TriggerDagRunOperator 2023-05-05T22:10:59.769001+00:00 2023-05-05T22:11:00.457362+00:00 0:00:00.688361 373764 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T22:10:56.886419+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-05T21:00:00+00:00 EmrJobFlowSensor 2023-05-05T22:00:52.129433+00:00 2023-05-05T22:10:53.873018+00:00 0:10:01.743585 373756 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-05T22:00:49.904473+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-05T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-05T22:00:32.007932+00:00 2023-05-05T22:00:32.858726+00:00 0:00:00.850794 373754 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-05T22:00:29.803310+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-05T21:00:00+00:00 PythonOperator 2023-05-05T22:00:10.092477+00:00 2023-05-05T22:00:11.063432+00:00 0:00:00.970955 373752 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-05T22:00:07.723291+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-05T20:00:00+00:00 TriggerDagRunOperator 2023-05-05T21:11:19.391521+00:00 2023-05-05T21:11:19.851090+00:00 0:00:00.459569 373739 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T21:11:16.685322+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-05T20:00:00+00:00 TriggerDagRunOperator 2023-05-05T21:11:19.317207+00:00 2023-05-05T21:11:19.665309+00:00 0:00:00.348102 373738 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T21:11:16.685277+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-05T20:00:00+00:00 EmrJobFlowSensor 2023-05-05T21:00:56.261908+00:00 2023-05-05T21:10:58.156261+00:00 0:10:01.894353 373730 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-05T21:00:53.792635+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-05T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-05T21:00:37.203072+00:00 2023-05-05T21:00:37.963268+00:00 0:00:00.760196 373729 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-05T21:00:33.797319+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-05T20:00:00+00:00 PythonOperator 2023-05-05T21:00:14.103934+00:00 2023-05-05T21:00:15.076090+00:00 0:00:00.972156 373727 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-05T21:00:11.699445+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-05T19:00:00+00:00 TriggerDagRunOperator 2023-05-05T20:11:25.849135+00:00 2023-05-05T20:11:26.201830+00:00 0:00:00.352695 373713 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T20:11:23.103652+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-05T19:00:00+00:00 TriggerDagRunOperator 2023-05-05T20:11:25.855188+00:00 2023-05-05T20:11:26.292571+00:00 0:00:00.437383 373712 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T20:11:23.103681+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-05T19:00:00+00:00 EmrJobFlowSensor 2023-05-05T20:01:00.394245+00:00 2023-05-05T20:11:02.253024+00:00 0:10:01.858779 373704 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-05T20:00:57.810305+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-05T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-05T20:00:37.998498+00:00 2023-05-05T20:00:38.828267+00:00 0:00:00.829769 373702 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-05T20:00:35.711712+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-05T19:00:00+00:00 PythonOperator 2023-05-05T20:00:17.859591+00:00 2023-05-05T20:00:18.761117+00:00 0:00:00.901526 373700 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-05T20:00:15.627896+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-05T18:00:00+00:00 TriggerDagRunOperator 2023-05-05T19:11:00.172333+00:00 2023-05-05T19:11:00.630848+00:00 0:00:00.458515 373685 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T19:10:57.631814+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-05T18:00:00+00:00 TriggerDagRunOperator 2023-05-05T19:10:59.841419+00:00 2023-05-05T19:11:00.551316+00:00 0:00:00.709897 373684 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-05T19:10:57.631848+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-05T18:00:00+00:00 EmrJobFlowSensor 2023-05-05T19:00:46.809332+00:00 2023-05-05T19:10:48.574389+00:00 0:10:01.765057 373676 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-05T19:00:44.594232+00:00 2 default_pool