Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-28T23:00:00+00:00 TriggerDagRunOperator 2023-03-29T00:15:37.140623+00:00 2023-03-29T00:15:37.621108+00:00 0:00:00.480485 360695 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-29T00:15:34.591291+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-28T23:00:00+00:00 EmrJobFlowSensor 2023-03-29T00:00:56.377399+00:00 2023-03-29T00:10:58.153528+00:00 0:10:01.776129 360687 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-29T00:00:54.197819+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-28T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-29T00:00:36.361347+00:00 2023-03-29T00:00:37.592268+00:00 0:00:01.230921 360685 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-29T00:00:34.133263+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-28T23:00:00+00:00 PythonOperator 2023-03-29T00:00:12.455629+00:00 2023-03-29T00:00:17.603938+00:00 0:00:05.148309 360683 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-29T00:00:10.109955+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-28T22:00:00+00:00 TriggerDagRunOperator 2023-03-28T23:14:29.062451+00:00 2023-03-28T23:14:29.573036+00:00 0:00:00.510585 360675 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T23:14:25.902735+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-28T22:00:00+00:00 TriggerDagRunOperator 2023-03-28T23:14:28.910540+00:00 2023-03-28T23:14:29.368949+00:00 0:00:00.458409 360674 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T23:14:25.902781+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-28T22:00:00+00:00 EmrJobFlowSensor 2023-03-28T23:00:56.718688+00:00 2023-03-28T23:10:58.403535+00:00 0:10:01.684847 360668 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-28T23:00:54.387683+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-28T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-28T23:00:38.135221+00:00 2023-03-28T23:00:38.939044+00:00 0:00:00.803823 360665 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-28T23:00:34.388095+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-28T22:00:00+00:00 PythonOperator 2023-03-28T23:00:14.959840+00:00 2023-03-28T23:00:18.195534+00:00 0:00:03.235694 360662 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-28T23:00:12.319577+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-28T21:00:00+00:00 TriggerDagRunOperator 2023-03-28T22:11:28.234749+00:00 2023-03-28T22:11:28.734466+00:00 0:00:00.499717 360649 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T22:11:25.387664+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-28T21:00:00+00:00 TriggerDagRunOperator 2023-03-28T22:11:27.956152+00:00 2023-03-28T22:11:28.405314+00:00 0:00:00.449162 360648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T22:11:25.387621+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-28T21:00:00+00:00 EmrJobFlowSensor 2023-03-28T22:01:01.273481+00:00 2023-03-28T22:11:03.019772+00:00 0:10:01.746291 360642 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-28T22:00:59.056729+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-28T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-28T22:00:39.344656+00:00 2023-03-28T22:00:40.236190+00:00 0:00:00.891534 360640 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-28T22:00:37.039140+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-28T21:00:00+00:00 PythonOperator 2023-03-28T22:00:19.142747+00:00 2023-03-28T22:00:23.297124+00:00 0:00:04.154377 360638 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-28T22:00:16.974620+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-28T20:00:00+00:00 TriggerDagRunOperator 2023-03-28T21:10:31.591333+00:00 2023-03-28T21:10:32.113517+00:00 0:00:00.522184 360627 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T21:10:28.711781+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-28T20:00:00+00:00 TriggerDagRunOperator 2023-03-28T21:10:31.554473+00:00 2023-03-28T21:10:32.007886+00:00 0:00:00.453413 360626 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T21:10:28.711744+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-28T20:00:00+00:00 EmrJobFlowSensor 2023-03-28T21:01:11.430169+00:00 2023-03-28T21:10:13.298074+00:00 0:09:01.867905 360620 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-28T21:01:09.066231+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-28T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-28T21:00:33.093085+00:00 2023-03-28T21:00:34.264506+00:00 0:00:01.171421 360617 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-28T21:00:28.806499+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-28T20:00:00+00:00 PythonOperator 2023-03-28T21:00:09.919426+00:00 2023-03-28T21:00:13.534160+00:00 0:00:03.614734 360615 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-28T21:00:06.754095+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-28T19:00:00+00:00 TriggerDagRunOperator 2023-03-28T20:11:05.206734+00:00 2023-03-28T20:11:05.727551+00:00 0:00:00.520817 360605 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T20:11:02.712065+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-28T19:00:00+00:00 TriggerDagRunOperator 2023-03-28T20:11:05.023033+00:00 2023-03-28T20:11:05.511055+00:00 0:00:00.488022 360604 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T20:11:02.712038+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-28T19:00:00+00:00 EmrJobFlowSensor 2023-03-28T20:00:48.155309+00:00 2023-03-28T20:10:50.072984+00:00 0:10:01.917675 360596 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-28T20:00:45.849461+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-28T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-28T20:00:26.288377+00:00 2023-03-28T20:00:27.116196+00:00 0:00:00.827819 360594 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-28T20:00:23.812342+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-28T19:00:00+00:00 PythonOperator 2023-03-28T20:00:04.516042+00:00 2023-03-28T20:00:07.927041+00:00 0:00:03.410999 360592 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-28T20:00:01.825476+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-28T18:00:00+00:00 TriggerDagRunOperator 2023-03-28T19:11:22.523910+00:00 2023-03-28T19:11:23.056176+00:00 0:00:00.532266 360581 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T19:11:20.272714+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-28T18:00:00+00:00 TriggerDagRunOperator 2023-03-28T19:11:22.518502+00:00 2023-03-28T19:11:23.001606+00:00 0:00:00.483104 360580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T19:11:20.272682+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-28T18:00:00+00:00 EmrJobFlowSensor 2023-03-28T19:01:03.631246+00:00 2023-03-28T19:11:05.342705+00:00 0:10:01.711459 360575 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-28T19:01:01.334927+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-28T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-28T19:00:44.190298+00:00 2023-03-28T19:00:45.117686+00:00 0:00:00.927388 360573 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-28T19:00:41.315151+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-28T18:00:00+00:00 PythonOperator 2023-03-28T19:00:21.563667+00:00 2023-03-28T19:00:25.297923+00:00 0:00:03.734256 360571 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-28T19:00:19.295867+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-28T17:00:00+00:00 TriggerDagRunOperator 2023-03-28T18:10:05.417878+00:00 2023-03-28T18:10:06.090671+00:00 0:00:00.672793 360560 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T18:10:02.759895+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-28T17:00:00+00:00 TriggerDagRunOperator 2023-03-28T18:10:05.227395+00:00 2023-03-28T18:10:05.710096+00:00 0:00:00.482701 360559 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T18:10:02.759868+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-28T17:00:00+00:00 EmrJobFlowSensor 2023-03-28T18:00:59.302400+00:00 2023-03-28T18:10:01.033296+00:00 0:09:01.730896 360552 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-28T18:00:56.799665+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-28T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-28T18:00:37.020155+00:00 2023-03-28T18:00:37.910908+00:00 0:00:00.890753 360550 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-28T18:00:34.721629+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-28T17:00:00+00:00 PythonOperator 2023-03-28T18:00:15.280181+00:00 2023-03-28T18:00:18.505400+00:00 0:00:03.225219 360548 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-28T18:00:12.650491+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-28T16:00:00+00:00 TriggerDagRunOperator 2023-03-28T17:18:06.990870+00:00 2023-03-28T17:18:07.502229+00:00 0:00:00.511359 360538 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T17:18:04.335780+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-28T16:00:00+00:00 TriggerDagRunOperator 2023-03-28T17:18:06.813708+00:00 2023-03-28T17:18:07.298614+00:00 0:00:00.484906 360537 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T17:18:04.335809+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-28T16:00:00+00:00 EmrJobFlowSensor 2023-03-28T17:07:54.222154+00:00 2023-03-28T17:17:55.887327+00:00 0:10:01.665173 360532 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-28T17:07:52.022948+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-28T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-28T17:07:34.329770+00:00 2023-03-28T17:07:35.183800+00:00 0:00:00.854030 360529 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-28T17:07:31.951851+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-28T16:00:00+00:00 PythonOperator 2023-03-28T17:07:12.746662+00:00 2023-03-28T17:07:16.196769+00:00 0:00:03.450107 360526 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-28T17:07:09.933692+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-28T15:00:00+00:00 TriggerDagRunOperator 2023-03-28T16:26:44.840487+00:00 2023-03-28T16:26:45.471180+00:00 0:00:00.630693 360518 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T16:26:42.497992+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-28T15:00:00+00:00 TriggerDagRunOperator 2023-03-28T16:26:44.819898+00:00 2023-03-28T16:26:45.471021+00:00 0:00:00.651123 360517 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T16:26:42.498021+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-28T15:00:00+00:00 EmrJobFlowSensor 2023-03-28T16:12:36.921826+00:00 2023-03-28T16:22:38.700121+00:00 0:10:01.778295 360512 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-28T16:12:34.513610+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-28T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-28T16:12:16.891251+00:00 2023-03-28T16:12:17.837649+00:00 0:00:00.946398 360509 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-28T16:12:14.497439+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-28T15:00:00+00:00 PythonOperator 2023-03-28T16:11:55.496357+00:00 2023-03-28T16:12:05.411828+00:00 0:00:09.915471 360506 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-28T16:11:52.525382+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-28T14:00:00+00:00 TriggerDagRunOperator 2023-03-28T15:31:09.319266+00:00 2023-03-28T15:31:09.798653+00:00 0:00:00.479387 360499 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T15:31:06.448202+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-28T14:00:00+00:00 TriggerDagRunOperator 2023-03-28T15:31:09.082376+00:00 2023-03-28T15:31:09.544706+00:00 0:00:00.462330 360498 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T15:31:06.448173+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-28T14:00:00+00:00 EmrJobFlowSensor 2023-03-28T15:02:48.907429+00:00 2023-03-28T15:12:50.698040+00:00 0:10:01.790611 360492 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-28T15:02:46.729097+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-28T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-28T15:02:26.864079+00:00 2023-03-28T15:02:27.707835+00:00 0:00:00.843756 360490 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-28T15:02:24.695317+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-28T14:00:00+00:00 PythonOperator 2023-03-28T15:02:04.836389+00:00 2023-03-28T15:02:08.891256+00:00 0:00:04.054867 360488 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-28T15:02:02.677545+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-28T13:00:00+00:00 TriggerDagRunOperator 2023-03-28T14:22:56.248431+00:00 2023-03-28T14:22:56.732486+00:00 0:00:00.484055 360480 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T14:22:53.560406+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-28T13:00:00+00:00 TriggerDagRunOperator 2023-03-28T14:22:56.112942+00:00 2023-03-28T14:22:56.634658+00:00 0:00:00.521716 360479 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T14:22:53.560378+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-28T13:00:00+00:00 EmrJobFlowSensor 2023-03-28T14:09:32.080476+00:00 2023-03-28T14:19:33.957426+00:00 0:10:01.876950 360474 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-28T14:09:29.304997+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-28T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-28T14:09:11.266050+00:00 2023-03-28T14:09:12.419670+00:00 0:00:01.153620 360470 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-28T14:09:07.215485+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-28T12:00:00+00:00 TriggerDagRunOperator 2023-03-28T14:08:50.911916+00:00 2023-03-28T14:08:51.637503+00:00 0:00:00.725587 360466 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T14:08:45.216411+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-28T13:00:00+00:00 PythonOperator 2023-03-28T14:08:49.738451+00:00 2023-03-28T14:08:54.001287+00:00 0:00:04.262836 360465 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-28T14:08:45.216480+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-28T12:00:00+00:00 TriggerDagRunOperator 2023-03-28T14:08:49.717634+00:00 2023-03-28T14:08:50.285068+00:00 0:00:00.567434 360464 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T14:08:45.216455+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-28T12:00:00+00:00 EmrJobFlowSensor 2023-03-28T13:30:29.754420+00:00 2023-03-28T13:40:31.644545+00:00 0:10:01.890125 360458 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-28T13:30:27.475668+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-28T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-28T13:30:07.819552+00:00 2023-03-28T13:30:08.888254+00:00 0:00:01.068702 360455 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-28T13:30:05.455922+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-28T12:00:00+00:00 PythonOperator 2023-03-28T13:29:46.591391+00:00 2023-03-28T13:29:52.119156+00:00 0:00:05.527765 360452 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-28T13:29:43.608334+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-28T11:00:00+00:00 TriggerDagRunOperator 2023-03-28T12:21:13.289042+00:00 2023-03-28T12:21:13.833911+00:00 0:00:00.544869 360444 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T12:21:10.865992+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-28T11:00:00+00:00 TriggerDagRunOperator 2023-03-28T12:21:13.262836+00:00 2023-03-28T12:21:13.722713+00:00 0:00:00.459877 360443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T12:21:10.865965+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-28T11:00:00+00:00 EmrJobFlowSensor 2023-03-28T12:10:57.955776+00:00 2023-03-28T12:20:59.787206+00:00 0:10:01.831430 360440 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-28T12:10:55.733859+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-28T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-28T12:10:37.861873+00:00 2023-03-28T12:10:39.171017+00:00 0:00:01.309144 360437 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-28T12:10:33.654520+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-28T11:00:00+00:00 PythonOperator 2023-03-28T12:10:15.771417+00:00 2023-03-28T12:10:19.757814+00:00 0:00:03.986397 360434 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-28T12:10:13.637711+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-28T10:00:00+00:00 TriggerDagRunOperator 2023-03-28T11:30:52.537916+00:00 2023-03-28T11:30:53.072350+00:00 0:00:00.534434 360425 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T11:30:49.601039+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-28T10:00:00+00:00 TriggerDagRunOperator 2023-03-28T11:30:52.329565+00:00 2023-03-28T11:30:52.793844+00:00 0:00:00.464279 360424 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T11:30:49.601070+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-28T10:00:00+00:00 EmrJobFlowSensor 2023-03-28T11:16:57.752565+00:00 2023-03-28T11:26:59.539199+00:00 0:10:01.786634 360420 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-28T11:16:55.432762+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-28T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-28T11:16:35.588018+00:00 2023-03-28T11:16:36.673037+00:00 0:00:01.085019 360417 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-28T11:16:33.428378+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-28T10:00:00+00:00 PythonOperator 2023-03-28T11:16:16.309535+00:00 2023-03-28T11:16:19.583698+00:00 0:00:03.274163 360415 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-28T11:16:13.359692+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-28T09:00:00+00:00 TriggerDagRunOperator 2023-03-28T10:22:07.501242+00:00 2023-03-28T10:22:07.999706+00:00 0:00:00.498464 360406 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T10:22:04.854788+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-28T09:00:00+00:00 TriggerDagRunOperator 2023-03-28T10:22:07.317697+00:00 2023-03-28T10:22:07.838241+00:00 0:00:00.520544 360405 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T10:22:04.854760+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-28T09:00:00+00:00 EmrJobFlowSensor 2023-03-28T10:11:43.302152+00:00 2023-03-28T10:21:45.222975+00:00 0:10:01.920823 360400 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-28T10:11:40.776836+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-28T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-28T10:11:22.958791+00:00 2023-03-28T10:11:23.777211+00:00 0:00:00.818420 360397 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-28T10:11:20.755342+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-28T09:00:00+00:00 PythonOperator 2023-03-28T10:11:01.602796+00:00 2023-03-28T10:11:05.504182+00:00 0:00:03.901386 360394 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-28T10:10:58.736029+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-28T08:00:00+00:00 TriggerDagRunOperator 2023-03-28T09:21:59.820461+00:00 2023-03-28T09:22:00.411681+00:00 0:00:00.591220 360386 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T09:21:57.109702+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-28T08:00:00+00:00 TriggerDagRunOperator 2023-03-28T09:21:59.778916+00:00 2023-03-28T09:22:00.360104+00:00 0:00:00.581188 360385 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T09:21:57.109661+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-28T08:00:00+00:00 EmrJobFlowSensor 2023-03-28T09:11:32.308167+00:00 2023-03-28T09:21:34.173651+00:00 0:10:01.865484 360381 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-28T09:11:29.971984+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-28T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-28T09:11:10.294408+00:00 2023-03-28T09:11:11.184023+00:00 0:00:00.889615 360378 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-28T09:11:07.951764+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-28T08:00:00+00:00 PythonOperator 2023-03-28T09:10:53.454470+00:00 2023-03-28T09:10:56.992654+00:00 0:00:03.538184 360375 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-28T09:10:47.888419+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-28T07:00:00+00:00 TriggerDagRunOperator 2023-03-28T08:12:26.067194+00:00 2023-03-28T08:12:26.624257+00:00 0:00:00.557063 360367 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T08:12:23.509675+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-28T07:00:00+00:00 TriggerDagRunOperator 2023-03-28T08:12:26.024022+00:00 2023-03-28T08:12:26.591826+00:00 0:00:00.567804 360366 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T08:12:23.509702+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-28T07:00:00+00:00 EmrJobFlowSensor 2023-03-28T08:01:09.445745+00:00 2023-03-28T08:11:11.195173+00:00 0:10:01.749428 360359 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-28T08:01:07.191382+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-28T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-28T08:00:50.159052+00:00 2023-03-28T08:00:51.107772+00:00 0:00:00.948720 360357 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-28T08:00:45.195833+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-28T07:00:00+00:00 PythonOperator 2023-03-28T08:00:25.312207+00:00 2023-03-28T08:00:29.481604+00:00 0:00:04.169397 360355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-28T08:00:23.037467+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-28T06:00:00+00:00 TriggerDagRunOperator 2023-03-28T07:10:52.275906+00:00 2023-03-28T07:10:52.811199+00:00 0:00:00.535293 360346 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T07:10:49.221044+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-28T06:00:00+00:00 TriggerDagRunOperator 2023-03-28T07:10:52.061467+00:00 2023-03-28T07:10:52.526974+00:00 0:00:00.465507 360345 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T07:10:49.221088+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-28T06:00:00+00:00 EmrJobFlowSensor 2023-03-28T07:01:44.771393+00:00 2023-03-28T07:10:46.685300+00:00 0:09:01.913907 360337 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-28T07:01:41.793321+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-28T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-28T07:00:28.702990+00:00 2023-03-28T07:00:29.534114+00:00 0:00:00.831124 360335 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-28T07:00:26.564505+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-28T06:00:00+00:00 PythonOperator 2023-03-28T07:00:07.380676+00:00 2023-03-28T07:00:10.805632+00:00 0:00:03.424956 360333 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-28T07:00:04.614076+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-28T05:00:00+00:00 TriggerDagRunOperator 2023-03-28T06:55:04.556540+00:00 2023-03-28T06:55:05.104125+00:00 0:00:00.547585 360329 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T06:55:01.932032+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-28T05:00:00+00:00 TriggerDagRunOperator 2023-03-28T06:55:04.415000+00:00 2023-03-28T06:55:04.926090+00:00 0:00:00.511090 360328 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T06:55:01.932003+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-28T05:00:00+00:00 EmrJobFlowSensor 2023-03-28T06:30:07.785213+00:00 2023-03-28T06:40:09.531861+00:00 0:10:01.746648 360323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-28T06:30:05.039464+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-28T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-28T06:29:47.418327+00:00 2023-03-28T06:29:48.395235+00:00 0:00:00.976908 360320 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-28T06:29:45.005761+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-28T05:00:00+00:00 PythonOperator 2023-03-28T06:29:26.084898+00:00 2023-03-28T06:29:30.414647+00:00 0:00:04.329749 360317 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-28T06:29:22.983547+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-28T04:00:00+00:00 TriggerDagRunOperator 2023-03-28T05:16:14.639228+00:00 2023-03-28T05:16:15.181275+00:00 0:00:00.542047 360309 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T05:16:11.843115+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-28T04:00:00+00:00 TriggerDagRunOperator 2023-03-28T05:16:14.353807+00:00 2023-03-28T05:16:14.803024+00:00 0:00:00.449217 360308 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T05:16:11.843156+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-28T04:00:00+00:00 EmrJobFlowSensor 2023-03-28T05:05:50.169552+00:00 2023-03-28T05:15:52.113619+00:00 0:10:01.944067 360304 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-28T05:05:47.681081+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-28T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-28T05:05:28.098008+00:00 2023-03-28T05:05:29.048131+00:00 0:00:00.950123 360301 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-28T05:05:25.680832+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-28T04:00:00+00:00 PythonOperator 2023-03-28T05:05:06.493140+00:00 2023-03-28T05:05:10.527668+00:00 0:00:04.034528 360297 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-28T05:05:03.541563+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-28T03:00:00+00:00 TriggerDagRunOperator 2023-03-28T04:24:46.115641+00:00 2023-03-28T04:24:46.622684+00:00 0:00:00.507043 360288 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-28T04:24:43.695741+00:00 2 default_pool