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-07T07:00:00+00:00 EmrJobFlowSensor 2023-03-07T08:01:02.717696+00:00 2023-03-07T08:11:04.519789+00:00 0:10:01.802093 349631 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-07T08:01:00.356737+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-07T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-07T08:00:40.549797+00:00 2023-03-07T08:00:41.714333+00:00 0:00:01.164536 349629 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-07T08:00:38.335572+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-07T07:00:00+00:00 PythonOperator 2023-03-07T08:00:18.461734+00:00 2023-03-07T08:00:22.479964+00:00 0:00:04.018230 349627 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-07T08:00:16.318005+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-07T06:00:00+00:00 TriggerDagRunOperator 2023-03-07T07:57:22.345521+00:00 2023-03-07T07:57:22.823241+00:00 0:00:00.477720 349622 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T07:57:19.941424+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-07T06:00:00+00:00 TriggerDagRunOperator 2023-03-07T07:57:22.347320+00:00 2023-03-07T07:57:22.832155+00:00 0:00:00.484835 349621 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T07:57:19.941454+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-07T06:00:00+00:00 EmrJobFlowSensor 2023-03-07T07:21:36.771159+00:00 2023-03-07T07:31:38.615220+00:00 0:10:01.844061 349618 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-07T07:21:34.584619+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-07T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-07T07:21:14.917083+00:00 2023-03-07T07:21:15.858780+00:00 0:00:00.941697 349615 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-07T07:21:12.561131+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-07T06:00:00+00:00 PythonOperator 2023-03-07T07:20:53.389803+00:00 2023-03-07T07:20:56.346166+00:00 0:00:02.956363 349612 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-07T07:20:50.540646+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-07T05:00:00+00:00 TriggerDagRunOperator 2023-03-07T06:35:11.222600+00:00 2023-03-07T06:35:11.754001+00:00 0:00:00.531401 349602 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T06:35:07.960915+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-07T05:00:00+00:00 TriggerDagRunOperator 2023-03-07T06:35:11.130822+00:00 2023-03-07T06:35:11.683317+00:00 0:00:00.552495 349601 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T06:35:07.960944+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-07T05:00:00+00:00 EmrJobFlowSensor 2023-03-07T06:25:02.458850+00:00 2023-03-07T06:35:04.202967+00:00 0:10:01.744117 349596 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-07T06:25:00.121940+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-07T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-07T06:24:42.547121+00:00 2023-03-07T06:24:43.423568+00:00 0:00:00.876447 349594 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-07T06:24:40.040926+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-07T05:00:00+00:00 PythonOperator 2023-03-07T06:24:22.139576+00:00 2023-03-07T06:24:30.108112+00:00 0:00:07.968536 349590 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-07T06:24:18.009295+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-07T04:00:00+00:00 TriggerDagRunOperator 2023-03-07T05:39:32.078696+00:00 2023-03-07T05:39:32.613372+00:00 0:00:00.534676 349585 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T05:39:29.382070+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-07T04:00:00+00:00 TriggerDagRunOperator 2023-03-07T05:39:31.984587+00:00 2023-03-07T05:39:32.464133+00:00 0:00:00.479546 349584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T05:39:29.382106+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-07T04:00:00+00:00 EmrJobFlowSensor 2023-03-07T05:08:44.224843+00:00 2023-03-07T05:18:46.292387+00:00 0:10:02.067544 349579 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-07T05:08:41.775510+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-07T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-07T05:08:22.118045+00:00 2023-03-07T05:08:23.079677+00:00 0:00:00.961632 349576 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-07T05:08:19.752865+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-07T04:00:00+00:00 PythonOperator 2023-03-07T05:08:00.728978+00:00 2023-03-07T05:08:04.460349+00:00 0:00:03.731371 349574 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-07T05:07:57.738148+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-07T03:00:00+00:00 TriggerDagRunOperator 2023-03-07T04:10:46.234158+00:00 2023-03-07T04:10:46.716455+00:00 0:00:00.482297 349566 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T04:10:43.123337+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-07T03:00:00+00:00 TriggerDagRunOperator 2023-03-07T04:10:45.806140+00:00 2023-03-07T04:10:46.350759+00:00 0:00:00.544619 349565 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T04:10:43.123307+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-07T03:00:00+00:00 EmrJobFlowSensor 2023-03-07T04:02:20.196839+00:00 2023-03-07T04:10:21.771828+00:00 0:08:01.574989 349559 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-07T04:02:17.868572+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-07T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-07T04:00:31.653085+00:00 2023-03-07T04:00:32.466437+00:00 0:00:00.813352 349556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-07T04:00:29.298254+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-07T03:00:00+00:00 PythonOperator 2023-03-07T04:00:09.552907+00:00 2023-03-07T04:00:13.459505+00:00 0:00:03.906598 349554 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-07T04:00:07.283000+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-07T02:00:00+00:00 TriggerDagRunOperator 2023-03-07T03:40:45.450051+00:00 2023-03-07T03:40:45.988651+00:00 0:00:00.538600 349547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T03:40:42.693569+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-07T02:00:00+00:00 TriggerDagRunOperator 2023-03-07T03:40:45.380493+00:00 2023-03-07T03:40:45.941136+00:00 0:00:00.560643 349546 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T03:40:42.693539+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-07T02:00:00+00:00 EmrJobFlowSensor 2023-03-07T03:21:30.689004+00:00 2023-03-07T03:32:32.662789+00:00 0:11:01.973785 349539 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-07T03:21:28.529924+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-07T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-07T03:21:08.668946+00:00 2023-03-07T03:21:09.529776+00:00 0:00:00.860830 349535 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-07T03:21:06.462549+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-07T02:00:00+00:00 PythonOperator 2023-03-07T03:20:48.764208+00:00 2023-03-07T03:20:52.143490+00:00 0:00:03.379282 349532 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-07T03:20:46.445045+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-07T00:00:00+00:00 TriggerDagRunOperator 2023-03-07T01:35:52.051494+00:00 2023-03-07T01:35:52.916815+00:00 0:00:00.865321 349520 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T01:35:48.546364+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-07T00:00:00+00:00 TriggerDagRunOperator 2023-03-07T01:35:51.170683+00:00 2023-03-07T01:35:51.661355+00:00 0:00:00.490672 349519 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T01:35:48.546334+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-07T00:00:00+00:00 EmrJobFlowSensor 2023-03-07T01:23:33.054107+00:00 2023-03-07T01:33:35.135576+00:00 0:10:02.081469 349513 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-07T01:23:28.003647+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-07T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-07T01:23:09.242214+00:00 2023-03-07T01:23:10.122442+00:00 0:00:00.880228 349509 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-07T01:23:06.019263+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-07T00:00:00+00:00 PythonOperator 2023-03-07T01:22:48.160088+00:00 2023-03-07T01:22:52.237610+00:00 0:00:04.077522 349505 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-07T01:22:45.970646+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-06T22:00:00+00:00 TriggerDagRunOperator 2023-03-06T23:14:42.919144+00:00 2023-03-06T23:14:43.459196+00:00 0:00:00.540052 349496 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T23:14:39.944278+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-06T22:00:00+00:00 TriggerDagRunOperator 2023-03-06T23:14:42.607668+00:00 2023-03-06T23:14:43.171664+00:00 0:00:00.563996 349495 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T23:14:39.944246+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-06T22:00:00+00:00 EmrJobFlowSensor 2023-03-06T23:00:55.540219+00:00 2023-03-06T23:10:57.292669+00:00 0:10:01.752450 349487 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-06T23:00:53.110918+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-06T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-06T23:00:31.337430+00:00 2023-03-06T23:00:32.148307+00:00 0:00:00.810877 349484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-06T23:00:28.928200+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-06T22:00:00+00:00 PythonOperator 2023-03-06T23:00:11.259868+00:00 2023-03-06T23:00:14.972386+00:00 0:00:03.712518 349481 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-06T23:00:08.827632+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-06T21:00:00+00:00 TriggerDagRunOperator 2023-03-06T22:20:18.226184+00:00 2023-03-06T22:20:18.721272+00:00 0:00:00.495088 349471 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T22:20:15.672651+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-06T21:00:00+00:00 TriggerDagRunOperator 2023-03-06T22:20:18.199472+00:00 2023-03-06T22:20:18.712024+00:00 0:00:00.512552 349470 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T22:20:15.672679+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-06T21:00:00+00:00 EmrJobFlowSensor 2023-03-06T22:10:02.221353+00:00 2023-03-06T22:20:04.043016+00:00 0:10:01.821663 349467 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-06T22:09:59.228483+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-06T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-06T22:09:39.560969+00:00 2023-03-06T22:09:40.483468+00:00 0:00:00.922499 349463 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-06T22:09:37.236217+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-06T21:00:00+00:00 PythonOperator 2023-03-06T22:09:21.174937+00:00 2023-03-06T22:09:24.345389+00:00 0:00:03.170452 349461 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-06T22:09:17.188574+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-06T20:00:00+00:00 TriggerDagRunOperator 2023-03-06T21:27:07.930214+00:00 2023-03-06T21:27:08.437325+00:00 0:00:00.507111 349451 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T21:27:05.444742+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-06T20:00:00+00:00 TriggerDagRunOperator 2023-03-06T21:27:07.811053+00:00 2023-03-06T21:27:08.278588+00:00 0:00:00.467535 349450 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T21:27:05.444771+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-06T20:00:00+00:00 EmrJobFlowSensor 2023-03-06T21:03:34.954861+00:00 2023-03-06T21:13:36.836982+00:00 0:10:01.882121 349443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-06T21:03:32.736096+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-06T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-06T21:03:15.036904+00:00 2023-03-06T21:03:15.803844+00:00 0:00:00.766940 349441 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-06T21:03:12.716492+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-06T20:00:00+00:00 PythonOperator 2023-03-06T21:02:53.449494+00:00 2023-03-06T21:02:57.573434+00:00 0:00:04.123940 349439 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-06T21:02:50.698075+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-06T19:00:00+00:00 TriggerDagRunOperator 2023-03-06T20:10:58.216240+00:00 2023-03-06T20:10:58.712855+00:00 0:00:00.496615 349428 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T20:10:55.874777+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-06T19:00:00+00:00 TriggerDagRunOperator 2023-03-06T20:10:58.140505+00:00 2023-03-06T20:10:58.600557+00:00 0:00:00.460052 349427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T20:10:55.874812+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-06T19:00:00+00:00 EmrJobFlowSensor 2023-03-06T20:00:49.950740+00:00 2023-03-06T20:10:51.639567+00:00 0:10:01.688827 349420 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-06T20:00:47.716457+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-06T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-06T20:00:28.076866+00:00 2023-03-06T20:00:28.916317+00:00 0:00:00.839451 349418 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-06T20:00:25.698857+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-06T19:00:00+00:00 PythonOperator 2023-03-06T20:00:06.702082+00:00 2023-03-06T20:00:10.679463+00:00 0:00:03.977381 349416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-06T20:00:03.606618+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-06T18:00:00+00:00 TriggerDagRunOperator 2023-03-06T19:12:01.096224+00:00 2023-03-06T19:12:01.687414+00:00 0:00:00.591190 349407 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T19:11:58.535408+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-06T18:00:00+00:00 TriggerDagRunOperator 2023-03-06T19:12:01.005088+00:00 2023-03-06T19:12:01.491245+00:00 0:00:00.486157 349406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T19:11:58.535380+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-06T18:00:00+00:00 EmrJobFlowSensor 2023-03-06T19:01:37.042326+00:00 2023-03-06T19:11:39.022792+00:00 0:10:01.980466 349399 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-06T19:01:34.628228+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-06T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-06T19:01:14.867552+00:00 2023-03-06T19:01:15.797662+00:00 0:00:00.930110 349397 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-06T19:01:12.604871+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-06T18:00:00+00:00 PythonOperator 2023-03-06T19:00:55.255445+00:00 2023-03-06T19:01:01.583661+00:00 0:00:06.328216 349395 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-06T19:00:52.641834+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-06T17:00:00+00:00 TriggerDagRunOperator 2023-03-06T18:11:05.122408+00:00 2023-03-06T18:11:05.654012+00:00 0:00:00.531604 349387 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T18:11:02.701164+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-06T17:00:00+00:00 TriggerDagRunOperator 2023-03-06T18:11:04.925385+00:00 2023-03-06T18:11:05.453355+00:00 0:00:00.527970 349386 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T18:11:02.701194+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-06T17:00:00+00:00 EmrJobFlowSensor 2023-03-06T18:00:49.148305+00:00 2023-03-06T18:10:50.944406+00:00 0:10:01.796101 349379 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-06T18:00:46.987575+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-06T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-06T18:00:29.335681+00:00 2023-03-06T18:00:30.197444+00:00 0:00:00.861763 349377 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-06T18:00:26.966418+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-06T17:00:00+00:00 PythonOperator 2023-03-06T18:00:07.761751+00:00 2023-03-06T18:00:10.835684+00:00 0:00:03.073933 349375 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-06T18:00:04.997332+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-06T16:00:00+00:00 TriggerDagRunOperator 2023-03-06T17:16:13.169845+00:00 2023-03-06T17:16:13.730938+00:00 0:00:00.561093 349369 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T17:16:10.576630+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-06T16:00:00+00:00 TriggerDagRunOperator 2023-03-06T17:16:13.078455+00:00 2023-03-06T17:16:13.531169+00:00 0:00:00.452714 349368 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T17:16:10.576601+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-06T16:00:00+00:00 EmrJobFlowSensor 2023-03-06T17:06:03.840231+00:00 2023-03-06T17:16:05.800061+00:00 0:10:01.959830 349363 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-06T17:06:01.494794+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-06T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-06T17:05:44.191522+00:00 2023-03-06T17:05:45.178374+00:00 0:00:00.986852 349360 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-06T17:05:41.475582+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-06T16:00:00+00:00 PythonOperator 2023-03-06T17:05:22.112806+00:00 2023-03-06T17:05:26.812987+00:00 0:00:04.700181 349357 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-06T17:05:19.519165+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-06T15:00:00+00:00 TriggerDagRunOperator 2023-03-06T16:12:10.471446+00:00 2023-03-06T16:12:10.982647+00:00 0:00:00.511201 349348 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T16:12:06.339366+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-06T15:00:00+00:00 TriggerDagRunOperator 2023-03-06T16:12:08.632415+00:00 2023-03-06T16:12:09.076428+00:00 0:00:00.444013 349347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T16:12:06.339326+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-06T15:00:00+00:00 EmrJobFlowSensor 2023-03-06T16:00:57.829726+00:00 2023-03-06T16:10:59.719604+00:00 0:10:01.889878 349343 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-06T16:00:54.687668+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-06T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-06T16:00:37.809433+00:00 2023-03-06T16:00:38.659182+00:00 0:00:00.849749 349341 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-06T16:00:32.588912+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-06T15:00:00+00:00 PythonOperator 2023-03-06T16:00:15.650493+00:00 2023-03-06T16:00:18.649309+00:00 0:00:02.998816 349339 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-06T16:00:12.503246+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-06T14:00:00+00:00 TriggerDagRunOperator 2023-03-06T15:32:18.239792+00:00 2023-03-06T15:32:18.757713+00:00 0:00:00.517921 349332 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T15:32:15.728710+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-06T14:00:00+00:00 TriggerDagRunOperator 2023-03-06T15:32:18.208759+00:00 2023-03-06T15:32:18.698457+00:00 0:00:00.489698 349331 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T15:32:15.728681+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-06T14:00:00+00:00 EmrJobFlowSensor 2023-03-06T15:13:12.423935+00:00 2023-03-06T15:23:14.197699+00:00 0:10:01.773764 349327 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-06T15:13:09.985165+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-06T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-06T15:12:51.632667+00:00 2023-03-06T15:12:52.745641+00:00 0:00:01.112974 349324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-06T15:12:47.954626+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-06T14:00:00+00:00 PythonOperator 2023-03-06T15:12:28.391451+00:00 2023-03-06T15:12:31.591016+00:00 0:00:03.199565 349321 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-06T15:12:25.935339+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-06T13:00:00+00:00 TriggerDagRunOperator 2023-03-06T14:39:17.200372+00:00 2023-03-06T14:39:17.667908+00:00 0:00:00.467536 349314 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T14:39:14.458543+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-06T13:00:00+00:00 TriggerDagRunOperator 2023-03-06T14:39:17.049103+00:00 2023-03-06T14:39:17.523637+00:00 0:00:00.474534 349313 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T14:39:14.458581+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-06T13:00:00+00:00 EmrJobFlowSensor 2023-03-06T14:25:12.911305+00:00 2023-03-06T14:35:14.746202+00:00 0:10:01.834897 349309 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-06T14:25:10.128069+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-06T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-06T14:24:51.671025+00:00 2023-03-06T14:24:52.581295+00:00 0:00:00.910270 349305 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-06T14:24:48.076825+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-06T12:00:00+00:00 TriggerDagRunOperator 2023-03-06T14:24:30.496709+00:00 2023-03-06T14:24:31.247154+00:00 0:00:00.750445 349301 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T14:24:26.065175+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-06T12:00:00+00:00 TriggerDagRunOperator 2023-03-06T14:24:30.415955+00:00 2023-03-06T14:24:31.144285+00:00 0:00:00.728330 349300 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T14:24:26.065138+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-06T13:00:00+00:00 PythonOperator 2023-03-06T14:24:28.357403+00:00 2023-03-06T14:24:33.120366+00:00 0:00:04.762963 349299 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-06T14:24:26.065189+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-06T12:00:00+00:00 EmrJobFlowSensor 2023-03-06T13:13:10.408030+00:00 2023-03-06T13:23:12.331148+00:00 0:10:01.923118 349292 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-06T13:13:08.069251+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-06T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-06T13:12:48.246475+00:00 2023-03-06T13:12:49.037222+00:00 0:00:00.790747 349289 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-06T13:12:46.052052+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-06T12:00:00+00:00 PythonOperator 2023-03-06T13:12:26.745576+00:00 2023-03-06T13:12:31.121027+00:00 0:00:04.375451 349286 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-06T13:12:23.978517+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-06T11:00:00+00:00 TriggerDagRunOperator 2023-03-06T12:28:17.849917+00:00 2023-03-06T12:28:18.339602+00:00 0:00:00.489685 349281 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T12:28:14.833424+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-06T11:00:00+00:00 TriggerDagRunOperator 2023-03-06T12:28:17.612730+00:00 2023-03-06T12:28:18.096343+00:00 0:00:00.483613 349280 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T12:28:14.833457+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-06T11:00:00+00:00 EmrJobFlowSensor 2023-03-06T12:13:15.294337+00:00 2023-03-06T12:23:17.137527+00:00 0:10:01.843190 349275 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-06T12:13:13.071290+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-06T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-06T12:12:53.458003+00:00 2023-03-06T12:12:54.339463+00:00 0:00:00.881460 349272 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-06T12:12:51.056924+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-06T11:00:00+00:00 PythonOperator 2023-03-06T12:12:31.807824+00:00 2023-03-06T12:12:35.205423+00:00 0:00:03.397599 349269 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-06T12:12:29.100250+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-06T10:00:00+00:00 TriggerDagRunOperator 2023-03-06T11:11:51.334092+00:00 2023-03-06T11:11:51.848527+00:00 0:00:00.514435 349258 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T11:11:48.525629+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-06T10:00:00+00:00 TriggerDagRunOperator 2023-03-06T11:11:51.200169+00:00 2023-03-06T11:11:51.661872+00:00 0:00:00.461703 349257 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T11:11:48.525600+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-06T10:00:00+00:00 EmrJobFlowSensor 2023-03-06T11:00:45.527768+00:00 2023-03-06T11:10:47.355756+00:00 0:10:01.827988 349253 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-06T11:00:43.255984+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-06T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-06T11:00:25.522924+00:00 2023-03-06T11:00:26.401029+00:00 0:00:00.878105 349251 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-06T11:00:23.292072+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-06T10:00:00+00:00 PythonOperator 2023-03-06T11:00:03.736073+00:00 2023-03-06T11:00:07.791929+00:00 0:00:04.055856 349249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-06T11:00:01.381009+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-06T09:00:00+00:00 TriggerDagRunOperator 2023-03-06T10:11:50.212163+00:00 2023-03-06T10:11:50.714285+00:00 0:00:00.502122 349239 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T10:11:47.526464+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-06T09:00:00+00:00 TriggerDagRunOperator 2023-03-06T10:11:49.994368+00:00 2023-03-06T10:11:50.542509+00:00 0:00:00.548141 349238 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-06T10:11:47.526495+00:00 2 default_pool