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-23T03:00:00+00:00 TriggerDagRunOperator 2023-03-23T04:30:31.094332+00:00 2023-03-23T04:30:31.607260+00:00 0:00:00.512928 357835 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T04:30:28.669729+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-23T03:00:00+00:00 EmrJobFlowSensor 2023-03-23T04:00:58.372456+00:00 2023-03-23T04:11:00.194026+00:00 0:10:01.821570 357830 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-23T04:00:56.167585+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-23T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-23T04:00:36.361434+00:00 2023-03-23T04:00:37.207984+00:00 0:00:00.846550 357828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-23T04:00:34.148668+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-23T03:00:00+00:00 PythonOperator 2023-03-23T04:00:16.374986+00:00 2023-03-23T04:00:22.591785+00:00 0:00:06.216799 357826 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-23T04:00:14.130403+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-23T02:00:00+00:00 TriggerDagRunOperator 2023-03-23T03:59:12.848904+00:00 2023-03-23T03:59:13.380930+00:00 0:00:00.532026 357822 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T03:59:10.030103+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-23T02:00:00+00:00 TriggerDagRunOperator 2023-03-23T03:59:12.788651+00:00 2023-03-23T03:59:13.273241+00:00 0:00:00.484590 357821 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T03:59:10.030069+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-23T02:00:00+00:00 EmrJobFlowSensor 2023-03-23T03:22:49.903063+00:00 2023-03-23T03:32:51.731047+00:00 0:10:01.827984 357816 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-23T03:22:47.534724+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-23T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-23T03:22:27.776471+00:00 2023-03-23T03:22:28.639646+00:00 0:00:00.863175 357813 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-23T03:22:25.490562+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-23T02:00:00+00:00 PythonOperator 2023-03-23T03:22:08.335780+00:00 2023-03-23T03:22:11.781173+00:00 0:00:03.445393 357810 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-23T03:22:05.514234+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-23T01:00:00+00:00 TriggerDagRunOperator 2023-03-23T02:16:43.918042+00:00 2023-03-23T02:16:44.434358+00:00 0:00:00.516316 357802 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T02:16:40.985456+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-23T01:00:00+00:00 TriggerDagRunOperator 2023-03-23T02:16:43.703628+00:00 2023-03-23T02:16:44.170539+00:00 0:00:00.466911 357801 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T02:16:40.985420+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-23T01:00:00+00:00 EmrJobFlowSensor 2023-03-23T02:03:33.008975+00:00 2023-03-23T02:13:34.800605+00:00 0:10:01.791630 357794 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-23T02:03:30.621875+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-23T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-23T02:03:12.808431+00:00 2023-03-23T02:03:13.669197+00:00 0:00:00.860766 357792 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-23T02:03:10.605961+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-23T01:00:00+00:00 PythonOperator 2023-03-23T02:02:51.603156+00:00 2023-03-23T02:02:58.921752+00:00 0:00:07.318596 357790 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-23T02:02:48.572574+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-23T00:00:00+00:00 TriggerDagRunOperator 2023-03-23T01:15:55.503392+00:00 2023-03-23T01:15:56.259728+00:00 0:00:00.756336 357776 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T01:15:52.240066+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-23T00:00:00+00:00 TriggerDagRunOperator 2023-03-23T01:15:54.906451+00:00 2023-03-23T01:15:55.988866+00:00 0:00:01.082415 357775 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T01:15:52.240036+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-23T00:00:00+00:00 EmrJobFlowSensor 2023-03-23T01:03:56.587513+00:00 2023-03-23T01:13:58.324402+00:00 0:10:01.736889 357768 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-23T01:03:54.387381+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-23T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-23T01:03:36.604391+00:00 2023-03-23T01:03:37.411911+00:00 0:00:00.807520 357766 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-23T01:03:34.356252+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-23T00:00:00+00:00 PythonOperator 2023-03-23T01:03:15.341835+00:00 2023-03-23T01:03:22.052013+00:00 0:00:06.710178 357764 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-23T01:03:12.390055+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-22T23:00:00+00:00 TriggerDagRunOperator 2023-03-23T00:15:06.886143+00:00 2023-03-23T00:15:07.403027+00:00 0:00:00.516884 357756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T00:15:04.471626+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-22T23:00:00+00:00 TriggerDagRunOperator 2023-03-23T00:15:06.881613+00:00 2023-03-23T00:15:07.379930+00:00 0:00:00.498317 357755 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-23T00:15:04.471599+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-22T23:00:00+00:00 EmrJobFlowSensor 2023-03-23T00:02:15.232073+00:00 2023-03-23T00:12:16.930676+00:00 0:10:01.698603 357750 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-23T00:02:13.031041+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-22T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-23T00:01:53.886200+00:00 2023-03-23T00:01:54.732511+00:00 0:00:00.846311 357748 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-23T00:01:51.010572+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-22T23:00:00+00:00 PythonOperator 2023-03-23T00:00:20.181299+00:00 2023-03-23T00:00:24.410823+00:00 0:00:04.229524 357744 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-23T00:00:17.976807+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-22T22:00:00+00:00 TriggerDagRunOperator 2023-03-22T23:12:20.669606+00:00 2023-03-22T23:12:21.227360+00:00 0:00:00.557754 357734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T23:12:17.765793+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-22T22:00:00+00:00 TriggerDagRunOperator 2023-03-22T23:12:20.560362+00:00 2023-03-22T23:12:21.085756+00:00 0:00:00.525394 357733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T23:12:17.765759+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-22T22:00:00+00:00 EmrJobFlowSensor 2023-03-22T23:00:48.429573+00:00 2023-03-22T23:11:50.354884+00:00 0:11:01.925311 357724 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-22T23:00:45.700805+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-22T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-22T23:00:26.137201+00:00 2023-03-22T23:00:27.056148+00:00 0:00:00.918947 357721 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-22T23:00:23.636664+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-22T22:00:00+00:00 PythonOperator 2023-03-22T23:00:06.217882+00:00 2023-03-22T23:00:15.300370+00:00 0:00:09.082488 357718 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-22T23:00:03.603084+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-22T21:00:00+00:00 TriggerDagRunOperator 2023-03-22T22:11:16.115528+00:00 2023-03-22T22:11:16.592855+00:00 0:00:00.477327 357709 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T22:11:13.477654+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-22T21:00:00+00:00 TriggerDagRunOperator 2023-03-22T22:11:16.028853+00:00 2023-03-22T22:11:16.493784+00:00 0:00:00.464931 357708 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T22:11:13.477695+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-22T21:00:00+00:00 EmrJobFlowSensor 2023-03-22T22:01:05.337679+00:00 2023-03-22T22:11:07.180035+00:00 0:10:01.842356 357701 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-22T22:01:03.194707+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-22T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-22T22:00:45.409269+00:00 2023-03-22T22:00:46.227360+00:00 0:00:00.818091 357699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-22T22:00:43.176407+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-22T21:00:00+00:00 PythonOperator 2023-03-22T22:00:24.049085+00:00 2023-03-22T22:00:27.632179+00:00 0:00:03.583094 357697 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-22T22:00:21.158921+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-22T20:00:00+00:00 TriggerDagRunOperator 2023-03-22T21:12:11.053275+00:00 2023-03-22T21:12:11.637438+00:00 0:00:00.584163 357686 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T21:12:08.446198+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-22T20:00:00+00:00 TriggerDagRunOperator 2023-03-22T21:12:10.963124+00:00 2023-03-22T21:12:11.494609+00:00 0:00:00.531485 357685 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T21:12:08.446168+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-22T20:00:00+00:00 EmrJobFlowSensor 2023-03-22T21:01:44.517519+00:00 2023-03-22T21:11:46.323855+00:00 0:10:01.806336 357679 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-22T21:01:42.232414+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-22T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-22T21:01:22.566349+00:00 2023-03-22T21:01:23.487268+00:00 0:00:00.920919 357677 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-22T21:01:20.190131+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-22T20:00:00+00:00 PythonOperator 2023-03-22T21:01:02.526882+00:00 2023-03-22T21:01:05.659211+00:00 0:00:03.132329 357675 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-22T21:01:00.182433+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-22T19:00:00+00:00 TriggerDagRunOperator 2023-03-22T20:10:59.728246+00:00 2023-03-22T20:11:00.307052+00:00 0:00:00.578806 357664 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T20:10:57.256454+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-22T19:00:00+00:00 TriggerDagRunOperator 2023-03-22T20:10:59.649341+00:00 2023-03-22T20:11:00.211301+00:00 0:00:00.561960 357663 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T20:10:57.256426+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-22T19:00:00+00:00 EmrJobFlowSensor 2023-03-22T20:00:48.449514+00:00 2023-03-22T20:10:50.476247+00:00 0:10:02.026733 357655 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-22T20:00:46.264111+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-22T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-22T20:00:26.833777+00:00 2023-03-22T20:00:27.783555+00:00 0:00:00.949778 357653 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-22T20:00:24.297072+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-22T19:00:00+00:00 PythonOperator 2023-03-22T20:00:07.148334+00:00 2023-03-22T20:00:10.318422+00:00 0:00:03.170088 357651 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-22T20:00:04.290529+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-22T18:00:00+00:00 TriggerDagRunOperator 2023-03-22T19:11:21.044263+00:00 2023-03-22T19:11:21.571714+00:00 0:00:00.527451 357641 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T19:11:18.243858+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-22T18:00:00+00:00 TriggerDagRunOperator 2023-03-22T19:11:20.639858+00:00 2023-03-22T19:11:21.188046+00:00 0:00:00.548188 357640 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T19:11:18.243829+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-22T18:00:00+00:00 EmrJobFlowSensor 2023-03-22T19:01:06.110559+00:00 2023-03-22T19:11:07.962279+00:00 0:10:01.851720 357633 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-22T19:01:03.725068+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-22T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-22T19:00:43.940141+00:00 2023-03-22T19:00:44.868327+00:00 0:00:00.928186 357630 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-22T19:00:41.696728+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-22T18:00:00+00:00 PythonOperator 2023-03-22T19:00:22.229860+00:00 2023-03-22T19:00:27.610090+00:00 0:00:05.380230 357628 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-22T19:00:19.677859+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-22T17:00:00+00:00 TriggerDagRunOperator 2023-03-22T18:11:02.332218+00:00 2023-03-22T18:11:02.847710+00:00 0:00:00.515492 357618 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T18:10:59.883005+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-22T17:00:00+00:00 TriggerDagRunOperator 2023-03-22T18:11:02.019506+00:00 2023-03-22T18:11:02.513347+00:00 0:00:00.493841 357617 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T18:10:59.883038+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-22T17:00:00+00:00 EmrJobFlowSensor 2023-03-22T18:00:55.492897+00:00 2023-03-22T18:10:57.486911+00:00 0:10:01.994014 357610 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-22T18:00:53.001527+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-22T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-22T18:00:33.343384+00:00 2023-03-22T18:00:34.312667+00:00 0:00:00.969283 357608 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-22T18:00:30.973680+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-22T17:00:00+00:00 PythonOperator 2023-03-22T18:00:13.897519+00:00 2023-03-22T18:00:17.234137+00:00 0:00:03.336618 357606 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-22T18:00:10.955752+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-22T16:00:00+00:00 TriggerDagRunOperator 2023-03-22T17:14:30.166232+00:00 2023-03-22T17:14:30.682250+00:00 0:00:00.516018 357598 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T17:14:27.432956+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-22T16:00:00+00:00 TriggerDagRunOperator 2023-03-22T17:14:29.838137+00:00 2023-03-22T17:14:30.335519+00:00 0:00:00.497382 357597 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T17:14:27.432927+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-22T16:00:00+00:00 EmrJobFlowSensor 2023-03-22T17:04:04.648853+00:00 2023-03-22T17:14:06.521418+00:00 0:10:01.872565 357591 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-22T17:04:02.530302+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-22T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-22T17:03:42.668743+00:00 2023-03-22T17:03:43.525734+00:00 0:00:00.856991 357589 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-22T17:03:40.520201+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-22T16:00:00+00:00 PythonOperator 2023-03-22T17:03:20.738001+00:00 2023-03-22T17:03:24.261100+00:00 0:00:03.523099 357587 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-22T17:03:18.499828+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-22T15:00:00+00:00 TriggerDagRunOperator 2023-03-22T16:24:27.132025+00:00 2023-03-22T16:24:27.598270+00:00 0:00:00.466245 357578 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T16:24:23.996424+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-22T15:00:00+00:00 TriggerDagRunOperator 2023-03-22T16:24:26.981059+00:00 2023-03-22T16:24:27.499373+00:00 0:00:00.518314 357577 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T16:24:23.996395+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-22T15:00:00+00:00 EmrJobFlowSensor 2023-03-22T16:14:19.801813+00:00 2023-03-22T16:24:21.585388+00:00 0:10:01.783575 357573 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-22T16:14:17.416262+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-22T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-22T16:13:57.823600+00:00 2023-03-22T16:13:58.655141+00:00 0:00:00.831541 357570 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-22T16:13:55.410369+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-22T15:00:00+00:00 PythonOperator 2023-03-22T16:13:37.728615+00:00 2023-03-22T16:13:41.040099+00:00 0:00:03.311484 357567 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-22T16:13:35.364281+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-22T14:00:00+00:00 TriggerDagRunOperator 2023-03-22T15:27:56.600564+00:00 2023-03-22T15:27:57.148335+00:00 0:00:00.547771 357559 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T15:27:54.116564+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-22T14:00:00+00:00 TriggerDagRunOperator 2023-03-22T15:27:56.534123+00:00 2023-03-22T15:27:57.066601+00:00 0:00:00.532478 357558 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T15:27:54.116593+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-22T14:00:00+00:00 EmrJobFlowSensor 2023-03-22T15:08:24.469844+00:00 2023-03-22T15:18:26.269802+00:00 0:10:01.799958 357554 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-22T15:08:22.105369+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-22T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-22T15:08:02.296778+00:00 2023-03-22T15:08:03.216956+00:00 0:00:00.920178 357551 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-22T15:08:00.085426+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-22T14:00:00+00:00 PythonOperator 2023-03-22T15:07:43.654584+00:00 2023-03-22T15:07:48.587187+00:00 0:00:04.932603 357548 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-22T15:07:40.043304+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-22T13:00:00+00:00 TriggerDagRunOperator 2023-03-22T14:21:54.808943+00:00 2023-03-22T14:21:55.795022+00:00 0:00:00.986079 357541 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T14:21:51.923474+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-22T13:00:00+00:00 TriggerDagRunOperator 2023-03-22T14:21:54.408704+00:00 2023-03-22T14:21:54.856563+00:00 0:00:00.447859 357540 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T14:21:51.923502+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-22T13:00:00+00:00 EmrJobFlowSensor 2023-03-22T14:11:41.598101+00:00 2023-03-22T14:21:43.440867+00:00 0:10:01.842766 357536 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-22T14:11:39.202746+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-22T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-22T14:11:19.326145+00:00 2023-03-22T14:11:20.102159+00:00 0:00:00.776014 357533 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-22T14:11:17.167605+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-22T13:00:00+00:00 PythonOperator 2023-03-22T14:10:57.675628+00:00 2023-03-22T14:11:02.373966+00:00 0:00:04.698338 357530 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-22T14:10:55.214452+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-22T12:00:00+00:00 TriggerDagRunOperator 2023-03-22T13:11:24.504551+00:00 2023-03-22T13:11:25.031807+00:00 0:00:00.527256 357521 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T13:11:21.611519+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-22T12:00:00+00:00 TriggerDagRunOperator 2023-03-22T13:11:24.342965+00:00 2023-03-22T13:11:24.800719+00:00 0:00:00.457754 357520 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T13:11:21.611487+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-22T12:00:00+00:00 EmrJobFlowSensor 2023-03-22T13:01:07.805948+00:00 2023-03-22T13:11:09.581998+00:00 0:10:01.776050 357513 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-22T13:01:05.160399+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-22T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-22T13:00:45.423020+00:00 2023-03-22T13:00:46.291748+00:00 0:00:00.868728 357511 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-22T13:00:43.137800+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-22T12:00:00+00:00 PythonOperator 2023-03-22T13:00:23.249464+00:00 2023-03-22T13:00:27.185664+00:00 0:00:03.936200 357509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-22T13:00:21.093580+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-22T11:00:00+00:00 TriggerDagRunOperator 2023-03-22T12:14:09.592784+00:00 2023-03-22T12:14:10.130447+00:00 0:00:00.537663 357497 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T12:14:06.572349+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-22T11:00:00+00:00 TriggerDagRunOperator 2023-03-22T12:14:09.284388+00:00 2023-03-22T12:14:09.772926+00:00 0:00:00.488538 357496 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T12:14:06.572380+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-22T11:00:00+00:00 EmrJobFlowSensor 2023-03-22T12:01:34.925502+00:00 2023-03-22T12:11:36.587988+00:00 0:10:01.662486 357492 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-22T12:01:32.331844+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-22T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-22T12:01:12.463965+00:00 2023-03-22T12:01:13.266916+00:00 0:00:00.802951 357490 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-22T12:01:10.277560+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-22T11:00:00+00:00 PythonOperator 2023-03-22T12:00:52.452783+00:00 2023-03-22T12:00:56.324013+00:00 0:00:03.871230 357488 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-22T12:00:50.255925+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-22T10:00:00+00:00 TriggerDagRunOperator 2023-03-22T11:25:15.731735+00:00 2023-03-22T11:25:16.442264+00:00 0:00:00.710529 357477 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T11:25:12.409393+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-22T10:00:00+00:00 TriggerDagRunOperator 2023-03-22T11:25:15.160691+00:00 2023-03-22T11:25:15.619322+00:00 0:00:00.458631 357476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T11:25:12.409359+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-22T10:00:00+00:00 EmrJobFlowSensor 2023-03-22T11:01:06.684280+00:00 2023-03-22T11:11:08.474971+00:00 0:10:01.790691 357473 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-22T11:01:04.480465+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-22T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-22T11:00:50.133214+00:00 2023-03-22T11:00:51.031523+00:00 0:00:00.898309 357471 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-22T11:00:44.463662+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-22T10:00:00+00:00 PythonOperator 2023-03-22T11:00:24.901361+00:00 2023-03-22T11:00:28.876168+00:00 0:00:03.974807 357469 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-22T11:00:22.436353+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-22T09:00:00+00:00 TriggerDagRunOperator 2023-03-22T10:16:04.982487+00:00 2023-03-22T10:16:05.483221+00:00 0:00:00.500734 357460 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T10:16:02.299592+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-22T09:00:00+00:00 TriggerDagRunOperator 2023-03-22T10:16:04.724455+00:00 2023-03-22T10:16:05.210241+00:00 0:00:00.485786 357459 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T10:16:02.299564+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-22T09:00:00+00:00 EmrJobFlowSensor 2023-03-22T10:00:56.248725+00:00 2023-03-22T10:10:58.161430+00:00 0:10:01.912705 357451 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-22T10:00:53.651761+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-22T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-22T10:00:34.130167+00:00 2023-03-22T10:00:35.004084+00:00 0:00:00.873917 357449 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-22T10:00:31.694526+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-22T09:00:00+00:00 PythonOperator 2023-03-22T10:00:14.077841+00:00 2023-03-22T10:00:17.300896+00:00 0:00:03.223055 357447 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-22T10:00:11.600923+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-22T08:00:00+00:00 TriggerDagRunOperator 2023-03-22T09:16:47.291196+00:00 2023-03-22T09:16:47.781396+00:00 0:00:00.490200 357441 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T09:16:44.794390+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-22T08:00:00+00:00 TriggerDagRunOperator 2023-03-22T09:16:47.248820+00:00 2023-03-22T09:16:47.766220+00:00 0:00:00.517400 357440 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T09:16:44.794419+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-22T08:00:00+00:00 EmrJobFlowSensor 2023-03-22T09:06:20.085353+00:00 2023-03-22T09:16:21.893684+00:00 0:10:01.808331 357437 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-22T09:06:17.662222+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-22T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-22T09:05:57.854666+00:00 2023-03-22T09:05:58.718825+00:00 0:00:00.864159 357433 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-22T09:05:55.653310+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-22T08:00:00+00:00 PythonOperator 2023-03-22T09:05:37.766620+00:00 2023-03-22T09:05:41.107606+00:00 0:00:03.340986 357431 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-22T09:05:35.621667+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-22T07:00:00+00:00 TriggerDagRunOperator 2023-03-22T08:13:28.070832+00:00 2023-03-22T08:13:28.537054+00:00 0:00:00.466222 357420 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-22T08:13:25.481263+00:00 2 default_pool