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 check_cluster_status 2023-03-20T15:00:00+00:00 EmrJobFlowSensor 2023-03-20T16:03:02.684392+00:00 2023-03-20T16:13:04.481964+00:00 0:10:01.797572 356575 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-20T16:03:00.307449+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-20T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-20T16:02:40.884990+00:00 2023-03-20T16:02:41.812015+00:00 0:00:00.927025 356573 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-20T16:02:38.177942+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-20T15:00:00+00:00 PythonOperator 2023-03-20T16:02:20.592188+00:00 2023-03-20T16:02:24.576453+00:00 0:00:03.984265 356571 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-20T16:02:18.138778+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-20T14:00:00+00:00 TriggerDagRunOperator 2023-03-20T15:11:06.996250+00:00 2023-03-20T15:11:07.480073+00:00 0:00:00.483823 356563 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T15:11:04.597098+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-20T14:00:00+00:00 TriggerDagRunOperator 2023-03-20T15:11:06.829677+00:00 2023-03-20T15:11:07.316775+00:00 0:00:00.487098 356562 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T15:11:04.597067+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-20T14:00:00+00:00 EmrJobFlowSensor 2023-03-20T15:00:54.453174+00:00 2023-03-20T15:10:56.145695+00:00 0:10:01.692521 356555 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-20T15:00:52.254308+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-20T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-20T15:00:34.539022+00:00 2023-03-20T15:00:35.408283+00:00 0:00:00.869261 356553 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-20T15:00:32.238182+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-20T14:00:00+00:00 PythonOperator 2023-03-20T15:00:12.398099+00:00 2023-03-20T15:00:16.579873+00:00 0:00:04.181774 356550 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-20T15:00:10.217594+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-20T13:00:00+00:00 TriggerDagRunOperator 2023-03-20T14:59:31.365088+00:00 2023-03-20T14:59:31.882832+00:00 0:00:00.517744 356547 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T14:59:28.203746+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-20T13:00:00+00:00 TriggerDagRunOperator 2023-03-20T14:59:30.981122+00:00 2023-03-20T14:59:31.675180+00:00 0:00:00.694058 356546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T14:59:28.203717+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-20T13:00:00+00:00 EmrJobFlowSensor 2023-03-20T14:49:23.019223+00:00 2023-03-20T14:59:24.778672+00:00 0:10:01.759449 356543 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-20T14:49:20.775448+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-20T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-20T14:49:04.233802+00:00 2023-03-20T14:49:06.918313+00:00 0:00:02.684511 356539 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-20T14:48:58.756361+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-20T13:00:00+00:00 PythonOperator 2023-03-20T14:48:41.136430+00:00 2023-03-20T14:48:44.611912+00:00 0:00:03.475482 356536 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-20T14:48:38.755378+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-20T12:00:00+00:00 TriggerDagRunOperator 2023-03-20T13:19:34.596578+00:00 2023-03-20T13:19:35.125225+00:00 0:00:00.528647 356529 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T13:19:31.691006+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-20T12:00:00+00:00 TriggerDagRunOperator 2023-03-20T13:19:34.394110+00:00 2023-03-20T13:19:34.851884+00:00 0:00:00.457774 356528 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T13:19:31.690931+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-20T12:00:00+00:00 EmrJobFlowSensor 2023-03-20T13:09:07.227793+00:00 2023-03-20T13:19:09.019018+00:00 0:10:01.791225 356525 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-20T13:09:04.381426+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-20T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-20T13:08:44.552936+00:00 2023-03-20T13:08:45.514689+00:00 0:00:00.961753 356521 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-20T13:08:42.351050+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-20T12:00:00+00:00 PythonOperator 2023-03-20T13:08:24.915412+00:00 2023-03-20T13:08:27.963274+00:00 0:00:03.047862 356519 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-20T13:08:22.329256+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-20T11:00:00+00:00 TriggerDagRunOperator 2023-03-20T12:26:33.989948+00:00 2023-03-20T12:26:34.514021+00:00 0:00:00.524073 356510 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T12:26:31.122128+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-20T11:00:00+00:00 TriggerDagRunOperator 2023-03-20T12:26:33.916087+00:00 2023-03-20T12:26:34.401014+00:00 0:00:00.484927 356509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T12:26:31.122101+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-20T11:00:00+00:00 EmrJobFlowSensor 2023-03-20T12:14:03.964968+00:00 2023-03-20T12:24:05.812920+00:00 0:10:01.847952 356504 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-20T12:14:01.759415+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-20T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-20T12:13:44.218350+00:00 2023-03-20T12:13:45.172417+00:00 0:00:00.954067 356501 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-20T12:13:41.742117+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-20T11:00:00+00:00 PythonOperator 2023-03-20T12:13:22.452351+00:00 2023-03-20T12:13:26.479590+00:00 0:00:04.027239 356498 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-20T12:13:19.725062+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-20T10:00:00+00:00 TriggerDagRunOperator 2023-03-20T11:11:35.524067+00:00 2023-03-20T11:11:36.071272+00:00 0:00:00.547205 356490 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T11:11:33.115184+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-20T10:00:00+00:00 TriggerDagRunOperator 2023-03-20T11:11:35.408171+00:00 2023-03-20T11:11:35.853367+00:00 0:00:00.445196 356489 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T11:11:33.115212+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-20T10:00:00+00:00 EmrJobFlowSensor 2023-03-20T11:01:15.364756+00:00 2023-03-20T11:11:17.185233+00:00 0:10:01.820477 356482 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-20T11:01:13.191899+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-20T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-20T11:00:53.608651+00:00 2023-03-20T11:00:54.417765+00:00 0:00:00.809114 356480 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-20T11:00:51.201422+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-20T10:00:00+00:00 PythonOperator 2023-03-20T11:00:32.039402+00:00 2023-03-20T11:00:35.690040+00:00 0:00:03.650638 356478 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-20T11:00:29.198668+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-20T09:00:00+00:00 TriggerDagRunOperator 2023-03-20T10:19:45.468123+00:00 2023-03-20T10:19:46.023426+00:00 0:00:00.555303 356470 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T10:19:42.515052+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-20T09:00:00+00:00 TriggerDagRunOperator 2023-03-20T10:19:45.327909+00:00 2023-03-20T10:19:45.941352+00:00 0:00:00.613443 356469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T10:19:42.515082+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-20T09:00:00+00:00 EmrJobFlowSensor 2023-03-20T10:06:20.608828+00:00 2023-03-20T10:16:22.649174+00:00 0:10:02.040346 356465 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-20T10:06:18.201897+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-20T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-20T10:05:58.607320+00:00 2023-03-20T10:05:59.596655+00:00 0:00:00.989335 356462 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-20T10:05:56.179816+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-20T09:00:00+00:00 PythonOperator 2023-03-20T10:05:37.251302+00:00 2023-03-20T10:05:43.026470+00:00 0:00:05.775168 356459 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-20T10:05:34.163995+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-20T08:00:00+00:00 TriggerDagRunOperator 2023-03-20T09:13:48.795708+00:00 2023-03-20T09:13:49.303141+00:00 0:00:00.507433 356450 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T09:13:45.962162+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-20T08:00:00+00:00 TriggerDagRunOperator 2023-03-20T09:13:48.488258+00:00 2023-03-20T09:13:48.980704+00:00 0:00:00.492446 356449 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T09:13:45.962134+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-20T08:00:00+00:00 EmrJobFlowSensor 2023-03-20T09:01:06.296647+00:00 2023-03-20T09:11:08.064922+00:00 0:10:01.768275 356442 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-20T09:01:03.939264+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-20T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-20T09:00:46.345257+00:00 2023-03-20T09:00:47.221056+00:00 0:00:00.875799 356440 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-20T09:00:43.922018+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-20T08:00:00+00:00 PythonOperator 2023-03-20T09:00:24.161687+00:00 2023-03-20T09:00:30.199675+00:00 0:00:06.037988 356438 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-20T09:00:21.905547+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-20T07:00:00+00:00 TriggerDagRunOperator 2023-03-20T08:11:29.760769+00:00 2023-03-20T08:11:30.453011+00:00 0:00:00.692242 356429 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T08:11:27.078707+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-20T07:00:00+00:00 TriggerDagRunOperator 2023-03-20T08:11:29.616647+00:00 2023-03-20T08:11:30.358208+00:00 0:00:00.741561 356428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T08:11:27.078679+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-20T07:00:00+00:00 EmrJobFlowSensor 2023-03-20T08:01:06.787779+00:00 2023-03-20T08:11:08.507775+00:00 0:10:01.719996 356421 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-20T08:01:04.604321+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-20T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-20T08:00:42.903982+00:00 2023-03-20T08:00:43.726589+00:00 0:00:00.822607 356419 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-20T08:00:40.532181+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-20T07:00:00+00:00 PythonOperator 2023-03-20T08:00:20.785204+00:00 2023-03-20T08:00:24.060065+00:00 0:00:03.274861 356417 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-20T08:00:18.511173+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-20T06:00:00+00:00 TriggerDagRunOperator 2023-03-20T07:11:27.973054+00:00 2023-03-20T07:11:28.460001+00:00 0:00:00.486947 356407 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T07:11:25.445089+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-20T06:00:00+00:00 TriggerDagRunOperator 2023-03-20T07:11:27.964843+00:00 2023-03-20T07:11:28.487569+00:00 0:00:00.522726 356406 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T07:11:25.445118+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-20T06:00:00+00:00 EmrJobFlowSensor 2023-03-20T07:01:19.842159+00:00 2023-03-20T07:11:21.648012+00:00 0:10:01.805853 356399 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-20T07:01:17.634433+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-20T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-20T07:00:59.731830+00:00 2023-03-20T07:01:00.760876+00:00 0:00:01.029046 356397 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-20T07:00:57.602637+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-20T06:00:00+00:00 PythonOperator 2023-03-20T07:00:38.402245+00:00 2023-03-20T07:00:41.724219+00:00 0:00:03.321974 356395 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-20T07:00:35.633546+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-20T05:00:00+00:00 TriggerDagRunOperator 2023-03-20T06:12:02.640025+00:00 2023-03-20T06:12:03.160366+00:00 0:00:00.520341 356388 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T06:11:59.864467+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-20T05:00:00+00:00 TriggerDagRunOperator 2023-03-20T06:12:02.323137+00:00 2023-03-20T06:12:02.828001+00:00 0:00:00.504864 356387 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T06:11:59.864439+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-20T05:00:00+00:00 EmrJobFlowSensor 2023-03-20T06:01:41.835444+00:00 2023-03-20T06:11:43.626040+00:00 0:10:01.790596 356381 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-20T06:01:39.614286+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-20T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-20T06:01:20.000706+00:00 2023-03-20T06:01:21.003954+00:00 0:00:01.003248 356379 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-20T06:01:17.574014+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-20T05:00:00+00:00 PythonOperator 2023-03-20T06:00:58.209165+00:00 2023-03-20T06:01:01.402047+00:00 0:00:03.192882 356377 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-20T06:00:55.561282+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-20T04:00:00+00:00 TriggerDagRunOperator 2023-03-20T05:12:41.969965+00:00 2023-03-20T05:12:42.478829+00:00 0:00:00.508864 356370 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T05:12:39.501353+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-20T04:00:00+00:00 TriggerDagRunOperator 2023-03-20T05:12:41.933074+00:00 2023-03-20T05:12:42.426678+00:00 0:00:00.493604 356369 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T05:12:39.501324+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-20T04:00:00+00:00 EmrJobFlowSensor 2023-03-20T05:02:25.310547+00:00 2023-03-20T05:12:27.319961+00:00 0:10:02.009414 356363 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-20T05:02:22.926130+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-20T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-20T05:02:03.316877+00:00 2023-03-20T05:02:04.279128+00:00 0:00:00.962251 356361 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-20T05:02:00.901223+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-20T04:00:00+00:00 PythonOperator 2023-03-20T05:01:43.247206+00:00 2023-03-20T05:01:46.342161+00:00 0:00:03.094955 356359 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-20T05:01:40.903023+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-20T03:00:00+00:00 TriggerDagRunOperator 2023-03-20T04:17:53.733619+00:00 2023-03-20T04:17:54.212461+00:00 0:00:00.478842 356347 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T04:17:51.200321+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-20T03:00:00+00:00 TriggerDagRunOperator 2023-03-20T04:17:53.461577+00:00 2023-03-20T04:17:53.936037+00:00 0:00:00.474460 356346 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T04:17:51.200348+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-20T03:00:00+00:00 EmrJobFlowSensor 2023-03-20T04:00:56.252431+00:00 2023-03-20T04:10:58.164234+00:00 0:10:01.911803 356342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-20T04:00:53.928465+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-20T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-20T04:00:37.107148+00:00 2023-03-20T04:00:38.451145+00:00 0:00:01.343997 356340 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-20T04:00:31.926738+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-20T03:00:00+00:00 PythonOperator 2023-03-20T04:00:12.909512+00:00 2023-03-20T04:00:17.057652+00:00 0:00:04.148140 356338 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-20T04:00:09.909766+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-20T02:00:00+00:00 TriggerDagRunOperator 2023-03-20T03:11:10.779254+00:00 2023-03-20T03:11:11.347559+00:00 0:00:00.568305 356330 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T03:11:08.533915+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-20T02:00:00+00:00 TriggerDagRunOperator 2023-03-20T03:11:10.739156+00:00 2023-03-20T03:11:11.283477+00:00 0:00:00.544321 356329 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T03:11:08.533950+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-20T02:00:00+00:00 EmrJobFlowSensor 2023-03-20T03:00:59.540513+00:00 2023-03-20T03:11:01.517964+00:00 0:10:01.977451 356322 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-20T03:00:57.140645+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-20T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-20T03:00:37.449286+00:00 2023-03-20T03:00:38.396572+00:00 0:00:00.947286 356320 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-20T03:00:35.102012+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-20T02:00:00+00:00 PythonOperator 2023-03-20T03:00:17.464062+00:00 2023-03-20T03:00:20.774361+00:00 0:00:03.310299 356318 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-20T03:00:14.990513+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-20T01:00:00+00:00 TriggerDagRunOperator 2023-03-20T02:16:15.603597+00:00 2023-03-20T02:16:16.152335+00:00 0:00:00.548738 356310 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T02:16:12.590177+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-20T01:00:00+00:00 TriggerDagRunOperator 2023-03-20T02:16:15.314053+00:00 2023-03-20T02:16:15.780641+00:00 0:00:00.466588 356309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T02:16:12.590212+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-20T01:00:00+00:00 EmrJobFlowSensor 2023-03-20T02:05:51.694660+00:00 2023-03-20T02:15:53.556432+00:00 0:10:01.861772 356305 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-20T02:05:49.205560+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-20T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-20T02:05:29.605524+00:00 2023-03-20T02:05:30.613467+00:00 0:00:01.007943 356302 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-20T02:05:27.127263+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-20T01:00:00+00:00 PythonOperator 2023-03-20T02:05:09.858450+00:00 2023-03-20T02:05:12.940199+00:00 0:00:03.081749 356299 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-20T02:05:07.071930+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-20T00:00:00+00:00 TriggerDagRunOperator 2023-03-20T01:34:12.789909+00:00 2023-03-20T01:34:13.302979+00:00 0:00:00.513070 356284 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T01:34:10.159036+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-20T00:00:00+00:00 TriggerDagRunOperator 2023-03-20T01:34:12.684247+00:00 2023-03-20T01:34:13.143976+00:00 0:00:00.459729 356283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T01:34:10.159065+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-20T00:00:00+00:00 EmrJobFlowSensor 2023-03-20T01:01:04.653989+00:00 2023-03-20T01:11:06.493444+00:00 0:10:01.839455 356280 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-20T01:01:02.444655+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-20T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-20T01:00:44.657722+00:00 2023-03-20T01:00:45.704835+00:00 0:00:01.047113 356278 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-20T01:00:42.429289+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-20T00:00:00+00:00 PythonOperator 2023-03-20T01:00:22.621138+00:00 2023-03-20T01:00:28.697766+00:00 0:00:06.076628 356276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-20T01:00:20.417523+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-19T23:00:00+00:00 TriggerDagRunOperator 2023-03-20T00:15:54.323345+00:00 2023-03-20T00:15:54.799825+00:00 0:00:00.476480 356266 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T00:15:51.231958+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-19T23:00:00+00:00 TriggerDagRunOperator 2023-03-20T00:15:53.830045+00:00 2023-03-20T00:15:54.285736+00:00 0:00:00.455691 356265 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T00:15:51.231996+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-19T23:00:00+00:00 EmrJobFlowSensor 2023-03-20T00:02:40.128435+00:00 2023-03-20T00:10:41.777814+00:00 0:08:01.649379 356257 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-20T00:02:37.490174+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-19T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-20T00:00:31.489256+00:00 2023-03-20T00:00:32.411100+00:00 0:00:00.921844 356255 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-20T00:00:29.005055+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-19T23:00:00+00:00 PythonOperator 2023-03-20T00:00:09.404113+00:00 2023-03-20T00:00:12.797595+00:00 0:00:03.393482 356253 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-20T00:00:06.930904+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-19T22:00:00+00:00 TriggerDagRunOperator 2023-03-19T23:11:09.280942+00:00 2023-03-19T23:11:09.829743+00:00 0:00:00.548801 356245 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-19T23:11:07.032340+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-19T22:00:00+00:00 TriggerDagRunOperator 2023-03-19T23:11:09.229121+00:00 2023-03-19T23:11:09.703031+00:00 0:00:00.473910 356244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-19T23:11:07.032305+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-19T22:00:00+00:00 EmrJobFlowSensor 2023-03-19T23:00:50.996521+00:00 2023-03-19T23:10:52.790110+00:00 0:10:01.793589 356236 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-19T23:00:48.712092+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-19T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-19T23:00:28.846680+00:00 2023-03-19T23:00:29.670407+00:00 0:00:00.823727 356233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-19T23:00:26.691285+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-19T22:00:00+00:00 PythonOperator 2023-03-19T23:00:07.174574+00:00 2023-03-19T23:00:10.495117+00:00 0:00:03.320543 356230 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-19T23:00:04.632117+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-19T21:00:00+00:00 TriggerDagRunOperator 2023-03-19T22:11:21.267683+00:00 2023-03-19T22:11:21.785188+00:00 0:00:00.517505 356221 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-19T22:11:18.736541+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-19T21:00:00+00:00 TriggerDagRunOperator 2023-03-19T22:11:21.197615+00:00 2023-03-19T22:11:21.683815+00:00 0:00:00.486200 356220 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-19T22:11:18.736514+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-19T21:00:00+00:00 EmrJobFlowSensor 2023-03-19T22:00:56.152146+00:00 2023-03-19T22:10:57.941778+00:00 0:10:01.789632 356213 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-19T22:00:53.664861+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-19T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-19T22:00:34.159160+00:00 2023-03-19T22:00:35.232145+00:00 0:00:01.072985 356211 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-19T22:00:31.644131+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-19T21:00:00+00:00 PythonOperator 2023-03-19T22:00:14.460730+00:00 2023-03-19T22:00:17.794401+00:00 0:00:03.333671 356209 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-19T22:00:11.634125+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-19T20:00:00+00:00 TriggerDagRunOperator 2023-03-19T21:11:08.884197+00:00 2023-03-19T21:11:09.403488+00:00 0:00:00.519291 356197 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-19T21:11:06.347849+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-19T20:00:00+00:00 TriggerDagRunOperator 2023-03-19T21:11:08.709977+00:00 2023-03-19T21:11:09.193208+00:00 0:00:00.483231 356196 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-19T21:11:06.347821+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-19T20:00:00+00:00 EmrJobFlowSensor 2023-03-19T21:00:51.104597+00:00 2023-03-19T21:10:53.003726+00:00 0:10:01.899129 356190 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-19T21:00:48.679491+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-19T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-19T21:00:28.853911+00:00 2023-03-19T21:00:29.776093+00:00 0:00:00.922182 356187 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-19T21:00:26.664139+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-19T20:00:00+00:00 PythonOperator 2023-03-19T21:00:08.887544+00:00 2023-03-19T21:00:12.932053+00:00 0:00:04.044509 356186 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-19T21:00:06.633105+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-19T19:00:00+00:00 TriggerDagRunOperator 2023-03-19T20:11:02.009943+00:00 2023-03-19T20:11:02.549845+00:00 0:00:00.539902 356174 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-19T20:10:59.653914+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-19T19:00:00+00:00 TriggerDagRunOperator 2023-03-19T20:11:01.887583+00:00 2023-03-19T20:11:02.378273+00:00 0:00:00.490690 356173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-19T20:10:59.653943+00:00 2 default_pool