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-04-05T11:00:00+00:00 TriggerDagRunOperator 2023-04-05T12:41:21.196395+00:00 2023-04-05T12:41:21.689549+00:00 0:00:00.493154 364416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T12:41:18.659170+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-05T11:00:00+00:00 EmrJobFlowSensor 2023-04-05T12:21:32.699400+00:00 2023-04-05T12:31:34.613430+00:00 0:10:01.914030 364412 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-05T12:21:30.399993+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-05T11:00:00+00:00 EmrCreateJobFlowOperator 2023-04-05T12:21:10.638088+00:00 2023-04-05T12:21:11.582230+00:00 0:00:00.944142 364408 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-05T12:21:08.377227+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-05T11:00:00+00:00 PythonOperator 2023-04-05T12:20:51.537745+00:00 2023-04-05T12:20:55.658605+00:00 0:00:04.120860 364406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-05T12:20:48.399275+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-05T10:00:00+00:00 TriggerDagRunOperator 2023-04-05T11:13:25.072535+00:00 2023-04-05T11:13:25.697111+00:00 0:00:00.624576 364398 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T11:13:22.663664+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-05T10:00:00+00:00 TriggerDagRunOperator 2023-04-05T11:13:24.983368+00:00 2023-04-05T11:13:25.468445+00:00 0:00:00.485077 364397 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T11:13:22.663635+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-05T10:00:00+00:00 EmrJobFlowSensor 2023-04-05T11:03:06.010202+00:00 2023-04-05T11:13:07.810375+00:00 0:10:01.800173 364391 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-05T11:03:03.629171+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-05T10:00:00+00:00 EmrCreateJobFlowOperator 2023-04-05T11:02:43.940177+00:00 2023-04-05T11:02:44.837692+00:00 0:00:00.897515 364389 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-05T11:02:41.589614+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-05T10:00:00+00:00 PythonOperator 2023-04-05T11:02:23.772608+00:00 2023-04-05T11:02:27.948987+00:00 0:00:04.176379 364387 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-05T11:02:21.569033+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-05T09:00:00+00:00 TriggerDagRunOperator 2023-04-05T10:35:11.462666+00:00 2023-04-05T10:35:11.959216+00:00 0:00:00.496550 364380 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T10:35:09.071518+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-05T09:00:00+00:00 TriggerDagRunOperator 2023-04-05T10:35:11.452809+00:00 2023-04-05T10:35:11.919131+00:00 0:00:00.466322 364379 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T10:35:09.071478+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-05T09:00:00+00:00 EmrJobFlowSensor 2023-04-05T10:23:42.920078+00:00 2023-04-05T10:33:44.791513+00:00 0:10:01.871435 364373 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-05T10:23:40.640628+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-05T09:00:00+00:00 EmrCreateJobFlowOperator 2023-04-05T10:23:20.752333+00:00 2023-04-05T10:23:21.704187+00:00 0:00:00.951854 364370 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-05T10:23:18.593806+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-05T09:00:00+00:00 PythonOperator 2023-04-05T10:00:22.091884+00:00 2023-04-05T10:00:25.662285+00:00 0:00:03.570401 364367 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-05T10:00:19.740227+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-05T08:00:00+00:00 TriggerDagRunOperator 2023-04-05T09:11:32.486499+00:00 2023-04-05T09:11:32.972806+00:00 0:00:00.486307 364359 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T09:11:29.794112+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-05T08:00:00+00:00 TriggerDagRunOperator 2023-04-05T09:11:32.295220+00:00 2023-04-05T09:11:32.751709+00:00 0:00:00.456489 364358 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T09:11:29.794070+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-05T08:00:00+00:00 EmrJobFlowSensor 2023-04-05T09:01:24.233983+00:00 2023-04-05T09:11:25.998337+00:00 0:10:01.764354 364352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-05T09:01:22.063157+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-05T08:00:00+00:00 EmrCreateJobFlowOperator 2023-04-05T09:01:02.364325+00:00 2023-04-05T09:01:03.390174+00:00 0:00:01.025849 364350 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-05T09:01:00.108668+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-05T08:00:00+00:00 PythonOperator 2023-04-05T09:00:40.245958+00:00 2023-04-05T09:00:44.102008+00:00 0:00:03.856050 364348 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-05T09:00:38.006953+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-05T07:00:00+00:00 TriggerDagRunOperator 2023-04-05T08:16:08.355862+00:00 2023-04-05T08:16:08.899560+00:00 0:00:00.543698 364340 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T08:16:05.142767+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-05T07:00:00+00:00 TriggerDagRunOperator 2023-04-05T08:16:08.235667+00:00 2023-04-05T08:16:08.690601+00:00 0:00:00.454934 364339 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T08:16:05.142727+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-05T07:00:00+00:00 EmrJobFlowSensor 2023-04-05T08:02:56.180846+00:00 2023-04-05T08:10:57.689207+00:00 0:08:01.508361 364333 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-05T08:02:53.270255+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-05T07:00:00+00:00 EmrCreateJobFlowOperator 2023-04-05T08:00:42.079693+00:00 2023-04-05T08:00:43.501150+00:00 0:00:01.421457 364330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-05T08:00:39.834699+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-05T07:00:00+00:00 PythonOperator 2023-04-05T08:00:22.074592+00:00 2023-04-05T08:00:26.107414+00:00 0:00:04.032822 364328 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-05T08:00:19.805298+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-05T06:00:00+00:00 TriggerDagRunOperator 2023-04-05T07:17:32.927024+00:00 2023-04-05T07:17:33.409471+00:00 0:00:00.482447 364319 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T07:17:30.438697+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-05T06:00:00+00:00 TriggerDagRunOperator 2023-04-05T07:17:32.808696+00:00 2023-04-05T07:17:33.270411+00:00 0:00:00.461715 364318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T07:17:30.438669+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-05T06:00:00+00:00 EmrJobFlowSensor 2023-04-05T07:07:10.819904+00:00 2023-04-05T07:17:12.859167+00:00 0:10:02.039263 364314 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-05T07:07:08.532919+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-05T06:00:00+00:00 EmrCreateJobFlowOperator 2023-04-05T07:06:48.800689+00:00 2023-04-05T07:06:49.609602+00:00 0:00:00.808913 364311 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-05T07:06:46.487596+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-05T06:00:00+00:00 PythonOperator 2023-04-05T07:06:32.087537+00:00 2023-04-05T07:06:35.544512+00:00 0:00:03.456975 364308 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-05T07:06:26.479688+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-05T05:00:00+00:00 TriggerDagRunOperator 2023-04-05T06:11:14.805500+00:00 2023-04-05T06:11:15.265950+00:00 0:00:00.460450 364299 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T06:11:11.956342+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-05T05:00:00+00:00 TriggerDagRunOperator 2023-04-05T06:11:14.161529+00:00 2023-04-05T06:11:14.593467+00:00 0:00:00.431938 364298 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T06:11:11.956377+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-05T05:00:00+00:00 EmrJobFlowSensor 2023-04-05T06:01:07.895229+00:00 2023-04-05T06:11:09.589956+00:00 0:10:01.694727 364294 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-05T06:01:05.698899+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-05T05:00:00+00:00 EmrCreateJobFlowOperator 2023-04-05T06:00:46.148400+00:00 2023-04-05T06:00:47.042322+00:00 0:00:00.893922 364292 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-05T06:00:43.677600+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-05T05:00:00+00:00 PythonOperator 2023-04-05T06:00:23.924025+00:00 2023-04-05T06:00:27.307127+00:00 0:00:03.383102 364290 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-05T06:00:21.657818+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-05T04:00:00+00:00 TriggerDagRunOperator 2023-04-05T05:11:12.155383+00:00 2023-04-05T05:11:12.689030+00:00 0:00:00.533647 364281 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T05:11:09.246817+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-05T04:00:00+00:00 TriggerDagRunOperator 2023-04-05T05:11:12.064727+00:00 2023-04-05T05:11:12.636753+00:00 0:00:00.572026 364280 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T05:11:09.246788+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-05T04:00:00+00:00 EmrJobFlowSensor 2023-04-05T05:00:48.158442+00:00 2023-04-05T05:10:49.839447+00:00 0:10:01.681005 364272 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-05T05:00:45.945440+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-05T04:00:00+00:00 EmrCreateJobFlowOperator 2023-04-05T05:00:26.391099+00:00 2023-04-05T05:00:27.264214+00:00 0:00:00.873115 364270 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-05T05:00:23.921547+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-05T04:00:00+00:00 PythonOperator 2023-04-05T05:00:06.269987+00:00 2023-04-05T05:00:10.304677+00:00 0:00:04.034690 364268 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-05T05:00:03.915296+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-05T03:00:00+00:00 TriggerDagRunOperator 2023-04-05T04:16:46.556230+00:00 2023-04-05T04:16:47.080745+00:00 0:00:00.524515 364260 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T04:16:43.898539+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-05T03:00:00+00:00 TriggerDagRunOperator 2023-04-05T04:16:46.334360+00:00 2023-04-05T04:16:46.773811+00:00 0:00:00.439451 364259 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T04:16:43.898494+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-05T03:00:00+00:00 EmrJobFlowSensor 2023-04-05T04:06:27.965493+00:00 2023-04-05T04:16:29.595224+00:00 0:10:01.629731 364256 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-05T04:06:25.348758+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-05T03:00:00+00:00 EmrCreateJobFlowOperator 2023-04-05T04:06:05.631554+00:00 2023-04-05T04:06:06.635070+00:00 0:00:01.003516 364252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-05T04:06:03.326194+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-05T03:00:00+00:00 PythonOperator 2023-04-05T04:05:43.945013+00:00 2023-04-05T04:05:47.359167+00:00 0:00:03.414154 364250 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-05T04:05:41.291791+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-05T02:00:00+00:00 TriggerDagRunOperator 2023-04-05T03:23:48.371098+00:00 2023-04-05T03:23:48.883726+00:00 0:00:00.512628 364239 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T03:23:45.568281+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-05T02:00:00+00:00 TriggerDagRunOperator 2023-04-05T03:23:48.223088+00:00 2023-04-05T03:23:48.736923+00:00 0:00:00.513835 364238 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T03:23:45.568252+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-05T02:00:00+00:00 EmrJobFlowSensor 2023-04-05T03:05:03.985468+00:00 2023-04-05T03:15:05.751762+00:00 0:10:01.766294 364232 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-05T03:05:01.026611+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-05T02:00:00+00:00 EmrCreateJobFlowOperator 2023-04-05T03:04:44.290379+00:00 2023-04-05T03:04:45.285683+00:00 0:00:00.995304 364230 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-05T03:04:39.015131+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-05T02:00:00+00:00 PythonOperator 2023-04-05T03:04:21.540407+00:00 2023-04-05T03:04:25.238789+00:00 0:00:03.698382 364228 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-05T03:04:18.985107+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-05T01:00:00+00:00 TriggerDagRunOperator 2023-04-05T02:11:12.524222+00:00 2023-04-05T02:11:13.045387+00:00 0:00:00.521165 364221 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T02:11:10.245255+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-05T01:00:00+00:00 TriggerDagRunOperator 2023-04-05T02:11:12.452587+00:00 2023-04-05T02:11:12.927951+00:00 0:00:00.475364 364220 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T02:11:10.245222+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-05T01:00:00+00:00 EmrJobFlowSensor 2023-04-05T02:01:05.166083+00:00 2023-04-05T02:11:06.960785+00:00 0:10:01.794702 364213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-05T02:01:02.891998+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-05T01:00:00+00:00 EmrCreateJobFlowOperator 2023-04-05T02:00:44.954342+00:00 2023-04-05T02:00:46.007646+00:00 0:00:01.053304 364211 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-05T02:00:42.736884+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-05T01:00:00+00:00 PythonOperator 2023-04-05T02:00:22.861125+00:00 2023-04-05T02:00:26.968167+00:00 0:00:04.107042 364209 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-05T02:00:20.672165+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-05T00:00:00+00:00 TriggerDagRunOperator 2023-04-05T01:11:12.036850+00:00 2023-04-05T01:11:12.543234+00:00 0:00:00.506384 364194 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T01:11:09.687996+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-05T00:00:00+00:00 TriggerDagRunOperator 2023-04-05T01:11:11.816742+00:00 2023-04-05T01:11:12.269348+00:00 0:00:00.452606 364193 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T01:11:09.687956+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-05T00:00:00+00:00 EmrJobFlowSensor 2023-04-05T01:01:01.149028+00:00 2023-04-05T01:11:03.085863+00:00 0:10:01.936835 364187 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-05T01:00:58.716478+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-05T00:00:00+00:00 EmrCreateJobFlowOperator 2023-04-05T01:00:39.023586+00:00 2023-04-05T01:00:39.835260+00:00 0:00:00.811674 364185 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-05T01:00:36.715325+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-05T00:00:00+00:00 PythonOperator 2023-04-05T01:00:19.216221+00:00 2023-04-05T01:00:22.428008+00:00 0:00:03.211787 364183 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-05T01:00:16.701876+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-04T23:00:00+00:00 TriggerDagRunOperator 2023-04-05T00:12:13.032638+00:00 2023-04-05T00:12:13.514127+00:00 0:00:00.481489 364174 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T00:12:10.392212+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-04T23:00:00+00:00 TriggerDagRunOperator 2023-04-05T00:12:12.688725+00:00 2023-04-05T00:12:13.160869+00:00 0:00:00.472144 364173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-05T00:12:10.392240+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-04T23:00:00+00:00 EmrJobFlowSensor 2023-04-05T00:01:48.901875+00:00 2023-04-05T00:11:50.669832+00:00 0:10:01.767957 364166 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-05T00:01:46.650650+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-04T23:00:00+00:00 EmrCreateJobFlowOperator 2023-04-05T00:01:27.375837+00:00 2023-04-05T00:01:28.219908+00:00 0:00:00.844071 364164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-05T00:01:24.550010+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-04T23:00:00+00:00 PythonOperator 2023-04-05T00:00:22.553607+00:00 2023-04-05T00:00:26.645851+00:00 0:00:04.092244 364161 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-05T00:00:20.246698+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-04T22:00:00+00:00 TriggerDagRunOperator 2023-04-04T23:11:28.438730+00:00 2023-04-04T23:11:28.936020+00:00 0:00:00.497290 364152 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T23:11:26.144864+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-04T22:00:00+00:00 TriggerDagRunOperator 2023-04-04T23:11:28.435294+00:00 2023-04-04T23:11:28.907087+00:00 0:00:00.471793 364151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T23:11:26.144816+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-04T22:00:00+00:00 EmrJobFlowSensor 2023-04-04T23:01:07.147430+00:00 2023-04-04T23:11:08.944454+00:00 0:10:01.797024 364145 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-04T23:01:04.960585+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-04T22:00:00+00:00 EmrCreateJobFlowOperator 2023-04-04T23:00:43.647404+00:00 2023-04-04T23:00:44.590680+00:00 0:00:00.943276 364142 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-04T23:00:40.936966+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-04T22:00:00+00:00 PythonOperator 2023-04-04T23:00:21.121204+00:00 2023-04-04T23:00:24.488722+00:00 0:00:03.367518 364139 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-04T23:00:18.857028+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-04T21:00:00+00:00 TriggerDagRunOperator 2023-04-04T22:11:17.827169+00:00 2023-04-04T22:11:18.371639+00:00 0:00:00.544470 364128 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T22:11:15.126989+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-04T21:00:00+00:00 TriggerDagRunOperator 2023-04-04T22:11:17.483340+00:00 2023-04-04T22:11:17.968895+00:00 0:00:00.485555 364127 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T22:11:15.127017+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-04T21:00:00+00:00 EmrJobFlowSensor 2023-04-04T22:00:58.644036+00:00 2023-04-04T22:11:00.429324+00:00 0:10:01.785288 364120 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-04T22:00:56.399662+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-04T21:00:00+00:00 EmrCreateJobFlowOperator 2023-04-04T22:00:36.642658+00:00 2023-04-04T22:00:37.558627+00:00 0:00:00.915969 364118 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-04T22:00:34.294736+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-04T21:00:00+00:00 PythonOperator 2023-04-04T22:00:16.851941+00:00 2023-04-04T22:00:22.827500+00:00 0:00:05.975559 364116 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-04T22:00:14.277977+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-04T20:00:00+00:00 TriggerDagRunOperator 2023-04-04T21:11:07.104064+00:00 2023-04-04T21:11:07.588584+00:00 0:00:00.484520 364105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T21:11:04.737943+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-04T20:00:00+00:00 TriggerDagRunOperator 2023-04-04T21:11:07.096243+00:00 2023-04-04T21:11:07.613923+00:00 0:00:00.517680 364104 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T21:11:04.737972+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-04T20:00:00+00:00 EmrJobFlowSensor 2023-04-04T21:00:48.423302+00:00 2023-04-04T21:10:50.229325+00:00 0:10:01.806023 364097 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-04T21:00:46.041498+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-04T20:00:00+00:00 EmrCreateJobFlowOperator 2023-04-04T21:00:26.467946+00:00 2023-04-04T21:00:27.375655+00:00 0:00:00.907709 364095 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-04T21:00:24.022536+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-04T20:00:00+00:00 PythonOperator 2023-04-04T21:00:06.664687+00:00 2023-04-04T21:00:10.204266+00:00 0:00:03.539579 364093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-04T21:00:04.004238+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-04T19:00:00+00:00 TriggerDagRunOperator 2023-04-04T20:11:33.999721+00:00 2023-04-04T20:11:34.503653+00:00 0:00:00.503932 364081 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T20:11:31.212920+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-04T19:00:00+00:00 TriggerDagRunOperator 2023-04-04T20:11:33.592177+00:00 2023-04-04T20:11:34.054017+00:00 0:00:00.461840 364080 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T20:11:31.212948+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-04T19:00:00+00:00 EmrJobFlowSensor 2023-04-04T20:01:08.726289+00:00 2023-04-04T20:11:10.558062+00:00 0:10:01.831773 364074 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-04T20:01:06.543746+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-04T19:00:00+00:00 EmrCreateJobFlowOperator 2023-04-04T20:00:46.691535+00:00 2023-04-04T20:00:47.627624+00:00 0:00:00.936089 364072 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-04T20:00:44.523837+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-04T19:00:00+00:00 PythonOperator 2023-04-04T20:00:24.639097+00:00 2023-04-04T20:00:27.952668+00:00 0:00:03.313571 364070 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-04T20:00:22.504274+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-04T18:00:00+00:00 TriggerDagRunOperator 2023-04-04T19:25:02.241040+00:00 2023-04-04T19:25:02.755185+00:00 0:00:00.514145 364061 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T19:24:59.897785+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-04T18:00:00+00:00 TriggerDagRunOperator 2023-04-04T19:25:02.240735+00:00 2023-04-04T19:25:02.745945+00:00 0:00:00.505210 364060 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T19:24:59.897813+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-04T18:00:00+00:00 EmrJobFlowSensor 2023-04-04T19:01:07.642440+00:00 2023-04-04T19:11:09.630123+00:00 0:10:01.987683 364052 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-04T19:01:05.388328+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-04T18:00:00+00:00 EmrCreateJobFlowOperator 2023-04-04T19:00:45.575251+00:00 2023-04-04T19:00:46.488668+00:00 0:00:00.913417 364050 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-04T19:00:43.339870+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-04T18:00:00+00:00 PythonOperator 2023-04-04T19:00:26.118436+00:00 2023-04-04T19:00:30.203807+00:00 0:00:04.085371 364049 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-04T19:00:23.313268+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-04T17:00:00+00:00 TriggerDagRunOperator 2023-04-04T18:20:06.274680+00:00 2023-04-04T18:20:06.784234+00:00 0:00:00.509554 364040 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T18:20:03.240557+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-04T17:00:00+00:00 TriggerDagRunOperator 2023-04-04T18:20:05.825762+00:00 2023-04-04T18:20:06.472065+00:00 0:00:00.646303 364039 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T18:20:03.240586+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-04T17:00:00+00:00 EmrJobFlowSensor 2023-04-04T18:09:40.551702+00:00 2023-04-04T18:19:42.300855+00:00 0:10:01.749153 364034 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-04T18:09:37.973273+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-04T17:00:00+00:00 EmrCreateJobFlowOperator 2023-04-04T18:09:18.276325+00:00 2023-04-04T18:09:19.231457+00:00 0:00:00.955132 364031 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-04T18:09:15.954200+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-04T17:00:00+00:00 PythonOperator 2023-04-04T18:08:58.844767+00:00 2023-04-04T18:09:05.543175+00:00 0:00:06.698408 364028 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-04T18:08:55.964616+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-04T16:00:00+00:00 TriggerDagRunOperator 2023-04-04T17:11:11.704574+00:00 2023-04-04T17:11:12.184644+00:00 0:00:00.480070 364019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T17:11:09.031193+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-04T16:00:00+00:00 TriggerDagRunOperator 2023-04-04T17:11:11.490638+00:00 2023-04-04T17:11:11.963465+00:00 0:00:00.472827 364018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T17:11:09.031162+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-04T16:00:00+00:00 EmrJobFlowSensor 2023-04-04T17:00:51.119581+00:00 2023-04-04T17:10:52.789229+00:00 0:10:01.669648 364011 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-04T17:00:48.907063+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-04T16:00:00+00:00 EmrCreateJobFlowOperator 2023-04-04T17:00:29.180218+00:00 2023-04-04T17:00:30.108671+00:00 0:00:00.928453 364009 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-04T17:00:26.892111+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-04T16:00:00+00:00 PythonOperator 2023-04-04T17:00:09.352614+00:00 2023-04-04T17:00:12.895265+00:00 0:00:03.542651 364007 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-04T17:00:06.863638+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-04T15:00:00+00:00 TriggerDagRunOperator 2023-04-04T16:21:18.666357+00:00 2023-04-04T16:21:19.171057+00:00 0:00:00.504700 363999 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-04T16:21:15.717484+00:00 2 default_pool