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-04-03T19:00:00+00:00 TriggerDagRunOperator 2023-04-03T20:11:11.459320+00:00 2023-04-03T20:11:11.976564+00:00 0:00:00.517244 363585 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T20:11:09.258808+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-03T19:00:00+00:00 EmrJobFlowSensor 2023-04-03T20:00:52.781783+00:00 2023-04-03T20:10:54.725753+00:00 0:10:01.943970 363578 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-03T20:00:50.320949+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-03T19:00:00+00:00 EmrCreateJobFlowOperator 2023-04-03T20:00:30.904059+00:00 2023-04-03T20:00:31.838145+00:00 0:00:00.934086 363576 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-03T20:00:28.233380+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-03T19:00:00+00:00 PythonOperator 2023-04-03T20:00:08.420279+00:00 2023-04-03T20:00:12.512742+00:00 0:00:04.092463 363574 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-03T20:00:06.196069+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-03T18:00:00+00:00 TriggerDagRunOperator 2023-04-03T19:15:49.450552+00:00 2023-04-03T19:15:49.930131+00:00 0:00:00.479579 363564 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T19:15:47.133845+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-03T18:00:00+00:00 TriggerDagRunOperator 2023-04-03T19:15:49.446717+00:00 2023-04-03T19:15:49.952531+00:00 0:00:00.505814 363563 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T19:15:47.133873+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-03T18:00:00+00:00 EmrJobFlowSensor 2023-04-03T19:05:37.215863+00:00 2023-04-03T19:15:39.022073+00:00 0:10:01.806210 363559 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-03T19:05:34.206144+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-03T18:00:00+00:00 EmrCreateJobFlowOperator 2023-04-03T19:05:16.317244+00:00 2023-04-03T19:05:17.532617+00:00 0:00:01.215373 363556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-03T19:05:12.148218+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-03T18:00:00+00:00 PythonOperator 2023-04-03T19:04:54.370920+00:00 2023-04-03T19:04:58.567276+00:00 0:00:04.196356 363553 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-03T19:04:52.131073+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-03T17:00:00+00:00 TriggerDagRunOperator 2023-04-03T18:11:31.233285+00:00 2023-04-03T18:11:31.767103+00:00 0:00:00.533818 363543 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T18:11:28.798512+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-03T17:00:00+00:00 TriggerDagRunOperator 2023-04-03T18:11:31.171876+00:00 2023-04-03T18:11:31.658208+00:00 0:00:00.486332 363542 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T18:11:28.798557+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-03T17:00:00+00:00 EmrJobFlowSensor 2023-04-03T18:01:06.529480+00:00 2023-04-03T18:11:08.355983+00:00 0:10:01.826503 363536 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-03T18:01:04.015281+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-03T17:00:00+00:00 EmrCreateJobFlowOperator 2023-04-03T18:00:44.162486+00:00 2023-04-03T18:00:45.133906+00:00 0:00:00.971420 363534 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-03T18:00:41.933220+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-03T17:00:00+00:00 PythonOperator 2023-04-03T18:00:22.183888+00:00 2023-04-03T18:00:25.535277+00:00 0:00:03.351389 363532 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-03T18:00:19.868043+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-03T16:00:00+00:00 TriggerDagRunOperator 2023-04-03T17:17:18.190798+00:00 2023-04-03T17:17:18.653677+00:00 0:00:00.462879 363522 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T17:17:15.568030+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-03T16:00:00+00:00 TriggerDagRunOperator 2023-04-03T17:17:18.006803+00:00 2023-04-03T17:17:18.485552+00:00 0:00:00.478749 363521 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T17:17:15.567991+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-03T16:00:00+00:00 EmrJobFlowSensor 2023-04-03T17:07:00.766532+00:00 2023-04-03T17:17:02.651333+00:00 0:10:01.884801 363517 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-03T17:06:58.393017+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-03T16:00:00+00:00 EmrCreateJobFlowOperator 2023-04-03T17:06:40.550088+00:00 2023-04-03T17:06:41.447330+00:00 0:00:00.897242 363513 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-03T17:06:38.379769+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-03T16:00:00+00:00 PythonOperator 2023-04-03T17:06:19.120179+00:00 2023-04-03T17:06:23.139747+00:00 0:00:04.019568 363510 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-03T17:06:16.233485+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-03T15:00:00+00:00 TriggerDagRunOperator 2023-04-03T16:33:57.637669+00:00 2023-04-03T16:33:58.120897+00:00 0:00:00.483228 363503 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T16:33:55.255048+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-03T15:00:00+00:00 TriggerDagRunOperator 2023-04-03T16:33:57.619054+00:00 2023-04-03T16:33:58.096965+00:00 0:00:00.477911 363502 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T16:33:55.255021+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-03T15:00:00+00:00 EmrJobFlowSensor 2023-04-03T16:16:01.493971+00:00 2023-04-03T16:26:03.342035+00:00 0:10:01.848064 363499 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-03T16:15:59.092910+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-03T15:00:00+00:00 EmrCreateJobFlowOperator 2023-04-03T16:15:39.270363+00:00 2023-04-03T16:15:40.069251+00:00 0:00:00.798888 363496 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-03T16:15:37.095433+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-03T15:00:00+00:00 PythonOperator 2023-04-03T16:15:17.648875+00:00 2023-04-03T16:15:20.821752+00:00 0:00:03.172877 363493 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-03T16:15:15.060427+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-03T14:00:00+00:00 TriggerDagRunOperator 2023-04-03T15:11:43.718100+00:00 2023-04-03T15:11:44.202642+00:00 0:00:00.484542 363483 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T15:11:41.570998+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-03T14:00:00+00:00 TriggerDagRunOperator 2023-04-03T15:11:43.722009+00:00 2023-04-03T15:11:44.202649+00:00 0:00:00.480640 363482 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T15:11:41.571030+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-03T14:00:00+00:00 EmrJobFlowSensor 2023-04-03T15:01:00.311601+00:00 2023-04-03T15:11:02.301526+00:00 0:10:01.989925 363478 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-03T15:00:57.636964+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-03T14:00:00+00:00 EmrCreateJobFlowOperator 2023-04-03T15:00:35.957820+00:00 2023-04-03T15:00:36.781278+00:00 0:00:00.823458 363476 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-03T15:00:33.580308+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-03T14:00:00+00:00 PythonOperator 2023-04-03T15:00:15.746115+00:00 2023-04-03T15:00:18.923620+00:00 0:00:03.177505 363474 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-03T15:00:13.568600+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-03T13:00:00+00:00 TriggerDagRunOperator 2023-04-03T14:11:08.638056+00:00 2023-04-03T14:11:09.336875+00:00 0:00:00.698819 363460 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T14:11:05.284198+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-03T13:00:00+00:00 TriggerDagRunOperator 2023-04-03T14:11:07.502081+00:00 2023-04-03T14:11:07.941864+00:00 0:00:00.439783 363459 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T14:11:05.284163+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-03T12:00:00+00:00 TriggerDagRunOperator 2023-04-03T14:10:53.028376+00:00 2023-04-03T14:10:53.855695+00:00 0:00:00.827319 363457 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T14:10:45.263380+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-03T13:00:00+00:00 EmrJobFlowSensor 2023-04-03T14:10:52.891226+00:00 2023-04-03T14:10:53.894872+00:00 0:00:01.003646 363456 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-03T14:10:45.263325+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-03T12:00:00+00:00 TriggerDagRunOperator 2023-04-03T14:10:47.603693+00:00 2023-04-03T14:10:48.063439+00:00 0:00:00.459746 363454 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T14:10:45.263367+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-03T13:00:00+00:00 EmrCreateJobFlowOperator 2023-04-03T14:00:41.976304+00:00 2023-04-03T14:00:42.850559+00:00 0:00:00.874255 363450 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-03T14:00:37.773561+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-03T13:00:00+00:00 PythonOperator 2023-04-03T14:00:18.002717+00:00 2023-04-03T14:00:21.538181+00:00 0:00:03.535464 363448 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-03T14:00:15.738364+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-03T12:00:00+00:00 EmrJobFlowSensor 2023-04-03T13:58:53.764099+00:00 2023-04-03T14:08:55.526555+00:00 0:10:01.762456 363445 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-03T13:58:51.577785+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-03T12:00:00+00:00 EmrCreateJobFlowOperator 2023-04-03T13:58:31.748170+00:00 2023-04-03T13:58:32.548799+00:00 0:00:00.800629 363442 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-03T13:58:29.561123+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-03T12:00:00+00:00 PythonOperator 2023-04-03T13:58:12.582491+00:00 2023-04-03T13:58:15.900656+00:00 0:00:03.318165 363439 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-03T13:58:09.598234+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-03T11:00:00+00:00 TriggerDagRunOperator 2023-04-03T12:12:59.084065+00:00 2023-04-03T12:12:59.553172+00:00 0:00:00.469107 363432 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T12:12:56.740146+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-03T11:00:00+00:00 TriggerDagRunOperator 2023-04-03T12:12:59.076130+00:00 2023-04-03T12:12:59.567108+00:00 0:00:00.490978 363431 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T12:12:56.740176+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-03T11:00:00+00:00 EmrJobFlowSensor 2023-04-03T12:00:59.851064+00:00 2023-04-03T12:11:01.761324+00:00 0:10:01.910260 363423 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-03T12:00:57.654415+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-03T11:00:00+00:00 EmrCreateJobFlowOperator 2023-04-03T12:00:39.813364+00:00 2023-04-03T12:00:40.678603+00:00 0:00:00.865239 363421 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-03T12:00:37.638105+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-03T11:00:00+00:00 PythonOperator 2023-04-03T12:00:18.143584+00:00 2023-04-03T12:00:21.603663+00:00 0:00:03.460079 363419 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-03T12:00:15.589058+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-03T10:00:00+00:00 TriggerDagRunOperator 2023-04-03T11:11:19.123050+00:00 2023-04-03T11:11:19.607252+00:00 0:00:00.484202 363411 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T11:11:16.615613+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-03T10:00:00+00:00 TriggerDagRunOperator 2023-04-03T11:11:19.005170+00:00 2023-04-03T11:11:19.475067+00:00 0:00:00.469897 363410 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T11:11:16.615563+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-03T10:00:00+00:00 EmrJobFlowSensor 2023-04-03T11:00:55.517140+00:00 2023-04-03T11:10:57.517709+00:00 0:10:02.000569 363403 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-03T11:00:52.590113+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-03T10:00:00+00:00 EmrCreateJobFlowOperator 2023-04-03T11:00:34.733410+00:00 2023-04-03T11:00:35.615659+00:00 0:00:00.882249 363401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-03T11:00:32.566287+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-03T10:00:00+00:00 PythonOperator 2023-04-03T11:00:13.289655+00:00 2023-04-03T11:00:16.944301+00:00 0:00:03.654646 363399 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-03T11:00:10.612325+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-03T09:00:00+00:00 TriggerDagRunOperator 2023-04-03T10:11:11.860664+00:00 2023-04-03T10:11:12.341233+00:00 0:00:00.480569 363391 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T10:11:09.505511+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-03T09:00:00+00:00 TriggerDagRunOperator 2023-04-03T10:11:11.777323+00:00 2023-04-03T10:11:12.232247+00:00 0:00:00.454924 363390 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T10:11:09.505471+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-03T09:00:00+00:00 EmrJobFlowSensor 2023-04-03T10:01:01.654103+00:00 2023-04-03T10:11:03.505950+00:00 0:10:01.851847 363383 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-03T10:00:59.069567+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-03T09:00:00+00:00 EmrCreateJobFlowOperator 2023-04-03T10:00:39.268199+00:00 2023-04-03T10:00:40.192741+00:00 0:00:00.924542 363381 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-03T10:00:37.048124+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-03T09:00:00+00:00 PythonOperator 2023-04-03T10:00:19.473301+00:00 2023-04-03T10:00:22.714597+00:00 0:00:03.241296 363379 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-03T10:00:17.031259+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-03T08:00:00+00:00 TriggerDagRunOperator 2023-04-03T09:11:12.329820+00:00 2023-04-03T09:11:12.803070+00:00 0:00:00.473250 363370 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T09:11:09.845787+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-03T08:00:00+00:00 TriggerDagRunOperator 2023-04-03T09:11:12.184118+00:00 2023-04-03T09:11:12.665649+00:00 0:00:00.481531 363369 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T09:11:09.845752+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-03T08:00:00+00:00 EmrJobFlowSensor 2023-04-03T09:01:02.041355+00:00 2023-04-03T09:11:03.760183+00:00 0:10:01.718828 363363 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-03T09:00:59.691055+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-03T08:00:00+00:00 EmrCreateJobFlowOperator 2023-04-03T09:00:40.229562+00:00 2023-04-03T09:00:41.156587+00:00 0:00:00.927025 363361 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-03T09:00:37.619637+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-03T08:00:00+00:00 PythonOperator 2023-04-03T09:00:19.957896+00:00 2023-04-03T09:00:24.028881+00:00 0:00:04.070985 363359 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-03T09:00:17.603734+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-03T07:00:00+00:00 TriggerDagRunOperator 2023-04-03T08:17:28.754817+00:00 2023-04-03T08:17:29.247069+00:00 0:00:00.492252 363350 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T08:17:26.090227+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-03T07:00:00+00:00 TriggerDagRunOperator 2023-04-03T08:17:28.437452+00:00 2023-04-03T08:17:28.910788+00:00 0:00:00.473336 363349 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T08:17:26.090255+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-03T07:00:00+00:00 EmrJobFlowSensor 2023-04-03T08:00:50.045116+00:00 2023-04-03T08:10:52.251435+00:00 0:10:02.206319 363341 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-03T08:00:47.536352+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-03T07:00:00+00:00 EmrCreateJobFlowOperator 2023-04-03T08:00:28.835864+00:00 2023-04-03T08:00:30.223681+00:00 0:00:01.387817 363339 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-03T08:00:25.496702+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-03T07:00:00+00:00 PythonOperator 2023-04-03T08:00:08.481439+00:00 2023-04-03T08:00:12.094027+00:00 0:00:03.612588 363338 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-03T08:00:05.501826+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-03T06:00:00+00:00 TriggerDagRunOperator 2023-04-03T07:11:40.702569+00:00 2023-04-03T07:11:41.219297+00:00 0:00:00.516728 363330 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T07:11:38.235359+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-03T06:00:00+00:00 TriggerDagRunOperator 2023-04-03T07:11:40.638966+00:00 2023-04-03T07:11:41.106321+00:00 0:00:00.467355 363329 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T07:11:38.235388+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-03T06:00:00+00:00 EmrJobFlowSensor 2023-04-03T07:01:25.107525+00:00 2023-04-03T07:11:26.824303+00:00 0:10:01.716778 363322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-03T07:01:22.824930+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-03T06:00:00+00:00 EmrCreateJobFlowOperator 2023-04-03T07:01:03.174527+00:00 2023-04-03T07:01:04.082207+00:00 0:00:00.907680 363320 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-03T07:01:00.818078+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-03T06:00:00+00:00 PythonOperator 2023-04-03T07:00:41.088127+00:00 2023-04-03T07:00:45.351585+00:00 0:00:04.263458 363318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-03T07:00:38.772384+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-03T05:00:00+00:00 TriggerDagRunOperator 2023-04-03T06:29:02.513241+00:00 2023-04-03T06:29:03.046034+00:00 0:00:00.532793 363310 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T06:28:59.952109+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-03T05:00:00+00:00 TriggerDagRunOperator 2023-04-03T06:29:02.332102+00:00 2023-04-03T06:29:02.822073+00:00 0:00:00.489971 363309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T06:28:59.952138+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-03T05:00:00+00:00 EmrJobFlowSensor 2023-04-03T06:18:47.449865+00:00 2023-04-03T06:28:49.220552+00:00 0:10:01.770687 363306 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-03T06:18:45.275846+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-03T05:00:00+00:00 EmrCreateJobFlowOperator 2023-04-03T06:18:27.730924+00:00 2023-04-03T06:18:29.120921+00:00 0:00:01.389997 363303 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-03T06:18:23.257232+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-03T05:00:00+00:00 PythonOperator 2023-04-03T06:18:05.857895+00:00 2023-04-03T06:18:09.369233+00:00 0:00:03.511338 363300 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-03T06:18:03.237147+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-03T04:00:00+00:00 TriggerDagRunOperator 2023-04-03T05:11:25.713345+00:00 2023-04-03T05:11:26.527897+00:00 0:00:00.814552 363290 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T05:11:22.742774+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-03T04:00:00+00:00 TriggerDagRunOperator 2023-04-03T05:11:25.303665+00:00 2023-04-03T05:11:26.127327+00:00 0:00:00.823662 363289 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T05:11:22.742802+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-03T04:00:00+00:00 EmrJobFlowSensor 2023-04-03T05:00:58.916865+00:00 2023-04-03T05:11:00.671376+00:00 0:10:01.754511 363280 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-03T05:00:56.620441+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-03T04:00:00+00:00 EmrCreateJobFlowOperator 2023-04-03T05:00:37.134983+00:00 2023-04-03T05:00:38.066770+00:00 0:00:00.931787 363278 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-03T05:00:34.624965+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-03T04:00:00+00:00 PythonOperator 2023-04-03T05:00:15.312525+00:00 2023-04-03T05:00:18.750390+00:00 0:00:03.437865 363276 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-03T05:00:12.612462+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-03T03:00:00+00:00 TriggerDagRunOperator 2023-04-03T04:12:26.102417+00:00 2023-04-03T04:12:26.676529+00:00 0:00:00.574112 363266 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T04:12:23.262319+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-03T03:00:00+00:00 TriggerDagRunOperator 2023-04-03T04:12:25.413339+00:00 2023-04-03T04:12:26.180947+00:00 0:00:00.767608 363265 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T04:12:23.262352+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-03T03:00:00+00:00 EmrJobFlowSensor 2023-04-03T04:01:04.569483+00:00 2023-04-03T04:12:06.574111+00:00 0:11:02.004628 363260 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-03T04:01:02.086505+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-03T03:00:00+00:00 EmrCreateJobFlowOperator 2023-04-03T04:00:42.315387+00:00 2023-04-03T04:00:43.172971+00:00 0:00:00.857584 363258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-03T04:00:40.090529+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-03T03:00:00+00:00 PythonOperator 2023-04-03T04:00:20.256037+00:00 2023-04-03T04:00:23.530035+00:00 0:00:03.273998 363256 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-03T04:00:18.032907+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-03T02:00:00+00:00 TriggerDagRunOperator 2023-04-03T03:27:12.986930+00:00 2023-04-03T03:27:13.485760+00:00 0:00:00.498830 363247 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T03:27:10.338439+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-03T02:00:00+00:00 TriggerDagRunOperator 2023-04-03T03:27:12.762717+00:00 2023-04-03T03:27:13.271725+00:00 0:00:00.509008 363246 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T03:27:10.338410+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-03T02:00:00+00:00 EmrJobFlowSensor 2023-04-03T03:17:02.359880+00:00 2023-04-03T03:27:04.255682+00:00 0:10:01.895802 363242 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-03T03:16:59.853244+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-03T02:00:00+00:00 EmrCreateJobFlowOperator 2023-04-03T03:16:42.050739+00:00 2023-04-03T03:16:42.987037+00:00 0:00:00.936298 363239 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-03T03:16:39.762798+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-03T02:00:00+00:00 PythonOperator 2023-04-03T03:16:20.166238+00:00 2023-04-03T03:16:23.700997+00:00 0:00:03.534759 363236 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-03T03:16:17.747561+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-03T01:00:00+00:00 TriggerDagRunOperator 2023-04-03T02:23:30.384468+00:00 2023-04-03T02:23:30.932298+00:00 0:00:00.547830 363226 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T02:23:27.674541+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-03T01:00:00+00:00 TriggerDagRunOperator 2023-04-03T02:23:30.327903+00:00 2023-04-03T02:23:30.787792+00:00 0:00:00.459889 363225 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T02:23:27.674513+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-03T01:00:00+00:00 EmrJobFlowSensor 2023-04-03T02:13:20.915962+00:00 2023-04-03T02:23:22.788430+00:00 0:10:01.872468 363220 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-03T02:13:18.623339+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-03T01:00:00+00:00 EmrCreateJobFlowOperator 2023-04-03T02:13:01.072839+00:00 2023-04-03T02:13:02.070461+00:00 0:00:00.997622 363217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-03T02:12:58.574109+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-03T01:00:00+00:00 PythonOperator 2023-04-03T02:12:39.497375+00:00 2023-04-03T02:12:43.147946+00:00 0:00:03.650571 363214 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-03T02:12:36.546610+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-04-03T00:00:00+00:00 TriggerDagRunOperator 2023-04-03T01:23:16.349444+00:00 2023-04-03T01:23:16.881941+00:00 0:00:00.532497 363200 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T01:23:13.935984+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-03T00:00:00+00:00 TriggerDagRunOperator 2023-04-03T01:23:16.340830+00:00 2023-04-03T01:23:16.785390+00:00 0:00:00.444560 363199 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T01:23:13.935947+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-04-03T00:00:00+00:00 EmrJobFlowSensor 2023-04-03T01:12:57.967170+00:00 2023-04-03T01:22:59.777981+00:00 0:10:01.810811 363194 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-04-03T01:12:55.643272+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-04-03T00:00:00+00:00 EmrCreateJobFlowOperator 2023-04-03T01:12:35.948204+00:00 2023-04-03T01:12:36.899932+00:00 0:00:00.951728 363191 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-04-03T01:12:33.589889+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-04-03T00:00:00+00:00 PythonOperator 2023-04-03T01:12:16.433930+00:00 2023-04-03T01:12:24.193963+00:00 0:00:07.760033 363188 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-04-03T01:12:13.572595+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-04-02T23:00:00+00:00 TriggerDagRunOperator 2023-04-03T00:30:36.554177+00:00 2023-04-03T00:30:37.028416+00:00 0:00:00.474239 363180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-04-03T00:30:33.910124+00:00 2 default_pool