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-02-14T17:00:00+00:00 EmrJobFlowSensor 2023-02-14T18:00:50.871479+00:00 2023-02-14T18:10:52.823554+00:00 0:10:01.952075 339731 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-14T18:00:46.158438+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-14T17:00:00+00:00 EmrCreateJobFlowOperator 2023-02-14T18:00:26.384975+00:00 2023-02-14T18:00:27.427105+00:00 0:00:01.042130 339729 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-14T18:00:24.133020+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-14T17:00:00+00:00 PythonOperator 2023-02-14T18:00:06.521253+00:00 2023-02-14T18:00:09.433163+00:00 0:00:02.911910 339727 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-14T18:00:04.112770+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-14T16:00:00+00:00 TriggerDagRunOperator 2023-02-14T17:19:59.696593+00:00 2023-02-14T17:20:00.335050+00:00 0:00:00.638457 339716 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T17:19:56.928536+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-14T16:00:00+00:00 TriggerDagRunOperator 2023-02-14T17:19:59.673455+00:00 2023-02-14T17:20:00.504654+00:00 0:00:00.831199 339715 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T17:19:56.928508+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-14T16:00:00+00:00 EmrJobFlowSensor 2023-02-14T17:06:42.674954+00:00 2023-02-14T17:16:44.384940+00:00 0:10:01.709986 339710 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-14T17:06:40.483831+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-14T16:00:00+00:00 EmrCreateJobFlowOperator 2023-02-14T17:06:22.678154+00:00 2023-02-14T17:06:23.579149+00:00 0:00:00.900995 339707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-14T17:06:20.466735+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-14T16:00:00+00:00 PythonOperator 2023-02-14T17:06:01.272202+00:00 2023-02-14T17:06:05.060541+00:00 0:00:03.788339 339704 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-14T17:05:58.450003+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-14T15:00:00+00:00 TriggerDagRunOperator 2023-02-14T16:11:40.303541+00:00 2023-02-14T16:11:40.757884+00:00 0:00:00.454343 339690 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T16:11:34.947154+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-14T15:00:00+00:00 TriggerDagRunOperator 2023-02-14T16:11:37.150409+00:00 2023-02-14T16:11:37.617615+00:00 0:00:00.467206 339689 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T16:11:34.947121+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-14T15:00:00+00:00 EmrJobFlowSensor 2023-02-14T16:00:51.117761+00:00 2023-02-14T16:10:52.972172+00:00 0:10:01.854411 339684 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-14T16:00:48.541428+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-14T15:00:00+00:00 EmrCreateJobFlowOperator 2023-02-14T16:00:31.133107+00:00 2023-02-14T16:00:32.059607+00:00 0:00:00.926500 339682 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-14T16:00:28.504407+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-14T15:00:00+00:00 PythonOperator 2023-02-14T16:00:09.214418+00:00 2023-02-14T16:00:12.121929+00:00 0:00:02.907511 339680 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-14T16:00:06.506517+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-14T14:00:00+00:00 TriggerDagRunOperator 2023-02-14T15:17:54.297603+00:00 2023-02-14T15:17:54.761296+00:00 0:00:00.463693 339669 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T15:17:51.521321+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-14T14:00:00+00:00 TriggerDagRunOperator 2023-02-14T15:17:54.039929+00:00 2023-02-14T15:17:54.504468+00:00 0:00:00.464539 339668 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T15:17:51.521294+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-14T14:00:00+00:00 EmrJobFlowSensor 2023-02-14T15:01:07.676731+00:00 2023-02-14T15:11:09.487492+00:00 0:10:01.810761 339661 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-14T15:01:05.328990+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-14T14:00:00+00:00 EmrCreateJobFlowOperator 2023-02-14T15:00:44.026630+00:00 2023-02-14T15:00:44.859838+00:00 0:00:00.833208 339659 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-14T15:00:41.277831+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-14T14:00:00+00:00 PythonOperator 2023-02-14T15:00:23.425692+00:00 2023-02-14T15:00:24.351228+00:00 0:00:00.925536 339657 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-14T15:00:21.139082+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-14T13:00:00+00:00 TriggerDagRunOperator 2023-02-14T14:56:23.274454+00:00 2023-02-14T14:56:23.761998+00:00 0:00:00.487544 339649 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T14:56:20.753497+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-14T13:00:00+00:00 TriggerDagRunOperator 2023-02-14T14:56:23.199465+00:00 2023-02-14T14:56:23.666455+00:00 0:00:00.466990 339648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T14:56:20.753528+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-14T13:00:00+00:00 EmrJobFlowSensor 2023-02-14T14:37:53.971793+00:00 2023-02-14T14:47:55.814020+00:00 0:10:01.842227 339643 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-14T14:37:51.416359+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-14T13:00:00+00:00 EmrCreateJobFlowOperator 2023-02-14T14:37:33.829814+00:00 2023-02-14T14:37:34.761666+00:00 0:00:00.931852 339640 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-14T14:37:31.368451+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-14T13:00:00+00:00 PythonOperator 2023-02-14T14:37:12.064522+00:00 2023-02-14T14:37:16.207678+00:00 0:00:04.143156 339637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-14T14:37:09.352167+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-14T12:00:00+00:00 TriggerDagRunOperator 2023-02-14T13:33:00.328790+00:00 2023-02-14T13:33:00.843366+00:00 0:00:00.514576 339627 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T13:32:57.465662+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-14T12:00:00+00:00 TriggerDagRunOperator 2023-02-14T13:33:00.211831+00:00 2023-02-14T13:33:00.714476+00:00 0:00:00.502645 339626 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T13:32:57.465691+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-14T12:00:00+00:00 EmrJobFlowSensor 2023-02-14T13:20:41.122171+00:00 2023-02-14T13:30:43.154500+00:00 0:10:02.032329 339620 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-14T13:20:38.799979+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-14T12:00:00+00:00 EmrCreateJobFlowOperator 2023-02-14T13:20:20.021904+00:00 2023-02-14T13:20:20.983342+00:00 0:00:00.961438 339618 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-14T13:20:16.784658+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-14T12:00:00+00:00 PythonOperator 2023-02-14T13:00:17.262608+00:00 2023-02-14T13:00:21.158956+00:00 0:00:03.896348 339614 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-14T13:00:14.936876+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-14T11:00:00+00:00 TriggerDagRunOperator 2023-02-14T12:15:07.742945+00:00 2023-02-14T12:15:08.427465+00:00 0:00:00.684520 339601 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T12:15:04.787029+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-14T11:00:00+00:00 TriggerDagRunOperator 2023-02-14T12:15:07.650842+00:00 2023-02-14T12:15:08.301761+00:00 0:00:00.650919 339600 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T12:15:04.786997+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-14T11:00:00+00:00 EmrJobFlowSensor 2023-02-14T12:00:50.219153+00:00 2023-02-14T12:10:52.026660+00:00 0:10:01.807507 339596 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-14T12:00:47.488830+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-14T11:00:00+00:00 EmrCreateJobFlowOperator 2023-02-14T12:00:27.705881+00:00 2023-02-14T12:00:28.591281+00:00 0:00:00.885400 339594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-14T12:00:25.471831+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-14T11:00:00+00:00 PythonOperator 2023-02-14T12:00:07.812581+00:00 2023-02-14T12:00:10.731380+00:00 0:00:02.918799 339592 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-14T12:00:05.449930+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-14T10:00:00+00:00 TriggerDagRunOperator 2023-02-14T11:11:14.060388+00:00 2023-02-14T11:11:14.603351+00:00 0:00:00.542963 339581 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T11:11:11.677657+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-14T10:00:00+00:00 TriggerDagRunOperator 2023-02-14T11:11:13.916736+00:00 2023-02-14T11:11:14.366074+00:00 0:00:00.449338 339580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T11:11:11.677693+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-14T10:00:00+00:00 EmrJobFlowSensor 2023-02-14T11:00:53.748094+00:00 2023-02-14T11:10:55.890603+00:00 0:10:02.142509 339573 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-14T11:00:51.436670+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-14T10:00:00+00:00 EmrCreateJobFlowOperator 2023-02-14T11:00:31.605025+00:00 2023-02-14T11:00:32.477395+00:00 0:00:00.872370 339571 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-14T11:00:29.336082+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-14T10:00:00+00:00 PythonOperator 2023-02-14T11:00:11.698895+00:00 2023-02-14T11:00:14.690011+00:00 0:00:02.991116 339569 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-14T11:00:09.250078+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-14T09:00:00+00:00 TriggerDagRunOperator 2023-02-14T10:11:17.124586+00:00 2023-02-14T10:11:17.659935+00:00 0:00:00.535349 339556 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T10:11:14.702586+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-14T09:00:00+00:00 TriggerDagRunOperator 2023-02-14T10:11:17.030701+00:00 2023-02-14T10:11:17.549796+00:00 0:00:00.519095 339555 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T10:11:14.702620+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-14T09:00:00+00:00 EmrJobFlowSensor 2023-02-14T10:00:56.394949+00:00 2023-02-14T10:10:58.038834+00:00 0:10:01.643885 339548 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-14T10:00:53.990502+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-14T09:00:00+00:00 EmrCreateJobFlowOperator 2023-02-14T10:00:34.150871+00:00 2023-02-14T10:00:34.995797+00:00 0:00:00.844926 339546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-14T10:00:31.910077+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-14T09:00:00+00:00 PythonOperator 2023-02-14T10:00:14.258108+00:00 2023-02-14T10:00:18.116071+00:00 0:00:03.857963 339544 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-14T10:00:11.897511+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-14T08:00:00+00:00 TriggerDagRunOperator 2023-02-14T09:11:23.457282+00:00 2023-02-14T09:11:23.947318+00:00 0:00:00.490036 339529 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T09:11:20.322312+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-14T08:00:00+00:00 TriggerDagRunOperator 2023-02-14T09:11:23.301086+00:00 2023-02-14T09:11:23.744679+00:00 0:00:00.443593 339528 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T09:11:20.322275+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-14T08:00:00+00:00 EmrJobFlowSensor 2023-02-14T09:00:59.158170+00:00 2023-02-14T09:11:01.540835+00:00 0:10:02.382665 339521 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-14T09:00:56.308478+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-14T08:00:00+00:00 EmrCreateJobFlowOperator 2023-02-14T09:00:38.433802+00:00 2023-02-14T09:00:39.337878+00:00 0:00:00.904076 339519 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-14T09:00:36.192925+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-14T08:00:00+00:00 PythonOperator 2023-02-14T09:00:16.719462+00:00 2023-02-14T09:00:20.729582+00:00 0:00:04.010120 339517 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-14T09:00:14.195287+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-14T07:00:00+00:00 TriggerDagRunOperator 2023-02-14T08:10:57.344614+00:00 2023-02-14T08:10:57.876206+00:00 0:00:00.531592 339503 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T08:10:54.404647+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-14T07:00:00+00:00 TriggerDagRunOperator 2023-02-14T08:10:57.123748+00:00 2023-02-14T08:10:57.627199+00:00 0:00:00.503451 339502 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T08:10:54.404678+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-14T07:00:00+00:00 EmrJobFlowSensor 2023-02-14T08:00:51.442111+00:00 2023-02-14T08:10:53.173059+00:00 0:10:01.730948 339496 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-14T08:00:49.108003+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-14T07:00:00+00:00 EmrCreateJobFlowOperator 2023-02-14T08:00:29.596434+00:00 2023-02-14T08:00:30.435959+00:00 0:00:00.839525 339494 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-14T08:00:27.114283+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-14T07:00:00+00:00 PythonOperator 2023-02-14T08:00:09.312126+00:00 2023-02-14T08:00:12.250463+00:00 0:00:02.938337 339492 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-14T08:00:07.002702+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-14T06:00:00+00:00 TriggerDagRunOperator 2023-02-14T07:11:23.319411+00:00 2023-02-14T07:11:23.828204+00:00 0:00:00.508793 339477 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T07:11:20.263871+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-14T06:00:00+00:00 TriggerDagRunOperator 2023-02-14T07:11:23.153850+00:00 2023-02-14T07:11:23.616504+00:00 0:00:00.462654 339476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T07:11:20.263900+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-14T06:00:00+00:00 EmrJobFlowSensor 2023-02-14T07:01:03.361585+00:00 2023-02-14T07:11:05.187807+00:00 0:10:01.826222 339470 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-14T07:01:00.691666+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-14T06:00:00+00:00 EmrCreateJobFlowOperator 2023-02-14T07:00:40.845480+00:00 2023-02-14T07:00:41.760777+00:00 0:00:00.915297 339467 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-14T07:00:38.564454+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-14T06:00:00+00:00 PythonOperator 2023-02-14T07:00:21.251198+00:00 2023-02-14T07:00:25.183016+00:00 0:00:03.931818 339465 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-14T07:00:18.546773+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-14T05:00:00+00:00 TriggerDagRunOperator 2023-02-14T06:14:46.654611+00:00 2023-02-14T06:14:47.126785+00:00 0:00:00.472174 339453 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T06:14:43.317454+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-14T05:00:00+00:00 TriggerDagRunOperator 2023-02-14T06:14:46.307952+00:00 2023-02-14T06:14:46.805868+00:00 0:00:00.497916 339452 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T06:14:43.317427+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-14T05:00:00+00:00 EmrJobFlowSensor 2023-02-14T06:04:26.646718+00:00 2023-02-14T06:14:28.411251+00:00 0:10:01.764533 339445 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-14T06:04:24.290733+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-14T05:00:00+00:00 EmrCreateJobFlowOperator 2023-02-14T06:04:04.631376+00:00 2023-02-14T06:04:05.522757+00:00 0:00:00.891381 339443 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-14T06:04:02.231697+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-14T05:00:00+00:00 PythonOperator 2023-02-14T06:03:43.265328+00:00 2023-02-14T06:03:46.361045+00:00 0:00:03.095717 339441 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-14T06:03:40.215307+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-14T04:00:00+00:00 TriggerDagRunOperator 2023-02-14T05:11:04.695680+00:00 2023-02-14T05:11:05.198250+00:00 0:00:00.502570 339430 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T05:11:01.721314+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-14T04:00:00+00:00 TriggerDagRunOperator 2023-02-14T05:11:04.458370+00:00 2023-02-14T05:11:04.905935+00:00 0:00:00.447565 339429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T05:11:01.721271+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-14T04:00:00+00:00 EmrJobFlowSensor 2023-02-14T05:00:57.417086+00:00 2023-02-14T05:10:59.250680+00:00 0:10:01.833594 339422 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-14T05:00:55.052861+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-14T04:00:00+00:00 EmrCreateJobFlowOperator 2023-02-14T05:00:37.161730+00:00 2023-02-14T05:00:37.981821+00:00 0:00:00.820091 339420 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-14T05:00:34.970646+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-14T04:00:00+00:00 PythonOperator 2023-02-14T05:00:15.878852+00:00 2023-02-14T05:00:19.108192+00:00 0:00:03.229340 339418 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-14T05:00:12.938334+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-14T03:00:00+00:00 TriggerDagRunOperator 2023-02-14T04:11:42.262249+00:00 2023-02-14T04:11:42.801237+00:00 0:00:00.538988 339406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T04:11:39.612685+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-14T03:00:00+00:00 TriggerDagRunOperator 2023-02-14T04:11:42.250616+00:00 2023-02-14T04:11:42.763232+00:00 0:00:00.512616 339405 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T04:11:39.612719+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-14T03:00:00+00:00 EmrJobFlowSensor 2023-02-14T04:00:46.470027+00:00 2023-02-14T04:10:48.356698+00:00 0:10:01.886671 339397 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-14T04:00:44.100523+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-14T03:00:00+00:00 EmrCreateJobFlowOperator 2023-02-14T04:00:26.206393+00:00 2023-02-14T04:00:26.997143+00:00 0:00:00.790750 339395 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-14T04:00:23.971316+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-14T03:00:00+00:00 PythonOperator 2023-02-14T04:00:04.349027+00:00 2023-02-14T04:00:07.308259+00:00 0:00:02.959232 339393 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-14T04:00:01.952910+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-14T02:00:00+00:00 TriggerDagRunOperator 2023-02-14T03:11:11.053280+00:00 2023-02-14T03:11:11.590455+00:00 0:00:00.537175 339380 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T03:11:08.078422+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-14T02:00:00+00:00 TriggerDagRunOperator 2023-02-14T03:11:10.899960+00:00 2023-02-14T03:11:11.414310+00:00 0:00:00.514350 339379 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T03:11:08.078459+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-14T02:00:00+00:00 EmrJobFlowSensor 2023-02-14T03:01:02.498891+00:00 2023-02-14T03:11:04.500449+00:00 0:10:02.001558 339372 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-14T03:00:59.798266+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-14T02:00:00+00:00 EmrCreateJobFlowOperator 2023-02-14T03:00:40.230178+00:00 2023-02-14T03:00:41.103907+00:00 0:00:00.873729 339370 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-14T03:00:37.699655+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-14T02:00:00+00:00 PythonOperator 2023-02-14T03:00:19.962385+00:00 2023-02-14T03:00:23.845064+00:00 0:00:03.882679 339368 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-14T03:00:17.690691+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-14T01:00:00+00:00 TriggerDagRunOperator 2023-02-14T02:11:23.753558+00:00 2023-02-14T02:11:24.304001+00:00 0:00:00.550443 339353 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T02:11:20.935681+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-14T01:00:00+00:00 TriggerDagRunOperator 2023-02-14T02:11:23.496173+00:00 2023-02-14T02:11:23.971228+00:00 0:00:00.475055 339352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T02:11:20.935641+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-14T01:00:00+00:00 EmrJobFlowSensor 2023-02-14T02:00:48.293575+00:00 2023-02-14T02:10:50.031419+00:00 0:10:01.737844 339344 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-14T02:00:45.713136+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-14T01:00:00+00:00 EmrCreateJobFlowOperator 2023-02-14T02:00:26.194325+00:00 2023-02-14T02:00:27.096859+00:00 0:00:00.902534 339342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-14T02:00:23.696480+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-14T01:00:00+00:00 PythonOperator 2023-02-14T02:00:04.606157+00:00 2023-02-14T02:00:09.344382+00:00 0:00:04.738225 339340 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-14T02:00:01.702991+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-14T00:00:00+00:00 TriggerDagRunOperator 2023-02-14T01:11:12.477179+00:00 2023-02-14T01:11:12.976556+00:00 0:00:00.499377 339321 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T01:11:09.815029+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-14T00:00:00+00:00 TriggerDagRunOperator 2023-02-14T01:11:12.344393+00:00 2023-02-14T01:11:12.863741+00:00 0:00:00.519348 339320 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T01:11:09.815057+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-14T00:00:00+00:00 EmrJobFlowSensor 2023-02-14T01:01:02.959351+00:00 2023-02-14T01:11:04.967993+00:00 0:10:02.008642 339312 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-14T01:01:00.423220+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-14T00:00:00+00:00 EmrCreateJobFlowOperator 2023-02-14T01:00:40.882083+00:00 2023-02-14T01:00:41.709348+00:00 0:00:00.827265 339310 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-14T01:00:38.423199+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-14T00:00:00+00:00 PythonOperator 2023-02-14T01:00:18.854412+00:00 2023-02-14T01:00:25.595055+00:00 0:00:06.740643 339308 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-14T01:00:16.395114+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-13T23:00:00+00:00 TriggerDagRunOperator 2023-02-14T00:11:16.349418+00:00 2023-02-14T00:11:16.823416+00:00 0:00:00.473998 339295 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T00:11:13.576456+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-13T23:00:00+00:00 TriggerDagRunOperator 2023-02-14T00:11:16.116114+00:00 2023-02-14T00:11:16.585757+00:00 0:00:00.469643 339294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-14T00:11:13.576426+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-13T23:00:00+00:00 EmrJobFlowSensor 2023-02-14T00:01:07.900334+00:00 2023-02-14T00:11:09.838215+00:00 0:10:01.937881 339286 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-14T00:01:05.630689+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-13T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-14T00:00:43.935487+00:00 2023-02-14T00:00:44.735026+00:00 0:00:00.799539 339284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-14T00:00:41.617007+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-13T23:00:00+00:00 PythonOperator 2023-02-14T00:00:24.204253+00:00 2023-02-14T00:00:27.168536+00:00 0:00:02.964283 339283 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-14T00:00:21.541547+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-13T22:00:00+00:00 TriggerDagRunOperator 2023-02-13T23:11:16.165538+00:00 2023-02-13T23:11:16.706898+00:00 0:00:00.541360 339268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T23:11:13.421173+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-13T22:00:00+00:00 TriggerDagRunOperator 2023-02-13T23:11:15.907585+00:00 2023-02-13T23:11:16.373099+00:00 0:00:00.465514 339267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T23:11:13.421211+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-13T22:00:00+00:00 EmrJobFlowSensor 2023-02-13T23:01:04.866688+00:00 2023-02-13T23:11:06.687795+00:00 0:10:01.821107 339260 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-13T23:01:02.659224+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-13T22:00:00+00:00 EmrCreateJobFlowOperator 2023-02-13T23:00:42.953290+00:00 2023-02-13T23:00:43.800711+00:00 0:00:00.847421 339257 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-13T23:00:40.631050+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-13T22:00:00+00:00 PythonOperator 2023-02-13T23:00:21.084226+00:00 2023-02-13T23:00:24.861343+00:00 0:00:03.777117 339254 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-13T23:00:18.619862+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-13T21:00:00+00:00 TriggerDagRunOperator 2023-02-13T22:11:18.437293+00:00 2023-02-13T22:11:19.160762+00:00 0:00:00.723469 339239 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T22:11:15.936489+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-13T21:00:00+00:00 TriggerDagRunOperator 2023-02-13T22:11:18.411326+00:00 2023-02-13T22:11:19.153644+00:00 0:00:00.742318 339238 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-13T22:11:15.936517+00:00 2 default_pool