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-11T09:00:00+00:00 EmrJobFlowSensor 2023-02-11T10:00:55.842554+00:00 2023-02-11T10:10:57.703982+00:00 0:10:01.861428 337693 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-11T10:00:53.433584+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-11T09:00:00+00:00 EmrCreateJobFlowOperator 2023-02-11T10:00:33.663910+00:00 2023-02-11T10:00:34.511916+00:00 0:00:00.848006 337691 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-11T10:00:31.427460+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-11T09:00:00+00:00 PythonOperator 2023-02-11T10:00:11.927125+00:00 2023-02-11T10:00:14.948211+00:00 0:00:03.021086 337689 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-11T10:00:09.391280+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-11T08:00:00+00:00 TriggerDagRunOperator 2023-02-11T09:10:54.727043+00:00 2023-02-11T09:10:55.290065+00:00 0:00:00.563022 337674 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T09:10:52.210488+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-11T08:00:00+00:00 TriggerDagRunOperator 2023-02-11T09:10:54.527205+00:00 2023-02-11T09:10:54.969672+00:00 0:00:00.442467 337673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T09:10:52.210439+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-11T08:00:00+00:00 EmrJobFlowSensor 2023-02-11T09:00:46.539316+00:00 2023-02-11T09:10:48.464396+00:00 0:10:01.925080 337666 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-11T09:00:44.029027+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-11T08:00:00+00:00 EmrCreateJobFlowOperator 2023-02-11T09:00:26.753516+00:00 2023-02-11T09:00:27.571876+00:00 0:00:00.818360 337664 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-11T09:00:23.986863+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-11T08:00:00+00:00 PythonOperator 2023-02-11T09:00:04.336350+00:00 2023-02-11T09:00:08.166504+00:00 0:00:03.830154 337662 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-11T09:00:01.971644+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-11T07:00:00+00:00 TriggerDagRunOperator 2023-02-11T08:15:57.673456+00:00 2023-02-11T08:15:58.264608+00:00 0:00:00.591152 337651 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T08:15:54.876253+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-11T07:00:00+00:00 TriggerDagRunOperator 2023-02-11T08:15:57.515174+00:00 2023-02-11T08:15:57.990048+00:00 0:00:00.474874 337650 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T08:15:54.876297+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-11T07:00:00+00:00 EmrJobFlowSensor 2023-02-11T08:00:58.103818+00:00 2023-02-11T08:10:59.883524+00:00 0:10:01.779706 337643 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-11T08:00:55.873531+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-11T07:00:00+00:00 EmrCreateJobFlowOperator 2023-02-11T08:00:36.169036+00:00 2023-02-11T08:00:37.001540+00:00 0:00:00.832504 337641 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-11T08:00:33.847859+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-11T07:00:00+00:00 PythonOperator 2023-02-11T08:00:16.757981+00:00 2023-02-11T08:00:19.783260+00:00 0:00:03.025279 337639 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-11T08:00:13.822576+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-11T06:00:00+00:00 TriggerDagRunOperator 2023-02-11T07:17:17.760492+00:00 2023-02-11T07:17:18.325496+00:00 0:00:00.565004 337625 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T07:17:15.104558+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-11T06:00:00+00:00 TriggerDagRunOperator 2023-02-11T07:17:17.666890+00:00 2023-02-11T07:17:18.193754+00:00 0:00:00.526864 337624 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T07:17:15.104586+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-11T06:00:00+00:00 EmrJobFlowSensor 2023-02-11T07:01:03.541969+00:00 2023-02-11T07:11:05.393066+00:00 0:10:01.851097 337617 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-11T07:01:00.894044+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-11T06:00:00+00:00 EmrCreateJobFlowOperator 2023-02-11T07:00:41.784369+00:00 2023-02-11T07:00:42.624883+00:00 0:00:00.840514 337615 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-11T07:00:38.794369+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-11T06:00:00+00:00 PythonOperator 2023-02-11T07:00:19.252504+00:00 2023-02-11T07:00:23.329827+00:00 0:00:04.077323 337613 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-11T07:00:16.713013+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-11T05:00:00+00:00 TriggerDagRunOperator 2023-02-11T06:30:30.915970+00:00 2023-02-11T06:30:31.365579+00:00 0:00:00.449609 337601 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T06:30:28.027804+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-11T05:00:00+00:00 TriggerDagRunOperator 2023-02-11T06:30:30.427688+00:00 2023-02-11T06:30:30.882599+00:00 0:00:00.454911 337600 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T06:30:28.027831+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-11T05:00:00+00:00 EmrJobFlowSensor 2023-02-11T06:20:22.649767+00:00 2023-02-11T06:30:24.460146+00:00 0:10:01.810379 337595 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-11T06:20:20.416728+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-11T05:00:00+00:00 EmrCreateJobFlowOperator 2023-02-11T06:20:02.823317+00:00 2023-02-11T06:20:03.735624+00:00 0:00:00.912307 337593 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-11T06:20:00.343062+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-11T05:00:00+00:00 PythonOperator 2023-02-11T06:19:41.657974+00:00 2023-02-11T06:19:49.237032+00:00 0:00:07.579058 337589 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-11T06:19:38.323966+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-11T04:00:00+00:00 TriggerDagRunOperator 2023-02-11T05:11:10.450775+00:00 2023-02-11T05:11:10.900898+00:00 0:00:00.450123 337576 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T05:11:08.092379+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-11T04:00:00+00:00 TriggerDagRunOperator 2023-02-11T05:11:10.451698+00:00 2023-02-11T05:11:10.989010+00:00 0:00:00.537312 337575 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T05:11:08.092349+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-11T04:00:00+00:00 EmrJobFlowSensor 2023-02-11T05:00:52.462899+00:00 2023-02-11T05:10:54.268588+00:00 0:10:01.805689 337567 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-11T05:00:50.162290+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-11T04:00:00+00:00 EmrCreateJobFlowOperator 2023-02-11T05:00:32.704675+00:00 2023-02-11T05:00:33.615329+00:00 0:00:00.910654 337565 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-11T05:00:30.202245+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-11T04:00:00+00:00 PythonOperator 2023-02-11T05:00:10.574566+00:00 2023-02-11T05:00:13.422416+00:00 0:00:02.847850 337563 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-11T05:00:08.144002+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-11T03:00:00+00:00 TriggerDagRunOperator 2023-02-11T04:10:59.268079+00:00 2023-02-11T04:10:59.804538+00:00 0:00:00.536459 337551 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T04:10:57.045487+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-11T03:00:00+00:00 TriggerDagRunOperator 2023-02-11T04:10:59.264434+00:00 2023-02-11T04:10:59.767722+00:00 0:00:00.503288 337550 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T04:10:57.045459+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-11T03:00:00+00:00 EmrJobFlowSensor 2023-02-11T04:00:49.728260+00:00 2023-02-11T04:10:51.542530+00:00 0:10:01.814270 337544 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-11T04:00:47.353211+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-11T03:00:00+00:00 EmrCreateJobFlowOperator 2023-02-11T04:00:27.755315+00:00 2023-02-11T04:00:28.655775+00:00 0:00:00.900460 337542 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-11T04:00:25.399370+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-11T03:00:00+00:00 PythonOperator 2023-02-11T04:00:05.909205+00:00 2023-02-11T04:00:10.140082+00:00 0:00:04.230877 337539 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-11T04:00:03.315097+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-11T02:00:00+00:00 TriggerDagRunOperator 2023-02-11T03:11:28.783598+00:00 2023-02-11T03:11:29.365253+00:00 0:00:00.581655 337526 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T03:11:26.163125+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-11T02:00:00+00:00 TriggerDagRunOperator 2023-02-11T03:11:28.729938+00:00 2023-02-11T03:11:29.278041+00:00 0:00:00.548103 337525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T03:11:26.163096+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-11T02:00:00+00:00 EmrJobFlowSensor 2023-02-11T03:01:05.656665+00:00 2023-02-11T03:11:07.446097+00:00 0:10:01.789432 337519 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-11T03:01:03.430906+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-11T02:00:00+00:00 EmrCreateJobFlowOperator 2023-02-11T03:00:45.414255+00:00 2023-02-11T03:00:46.295558+00:00 0:00:00.881303 337517 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-11T03:00:41.441020+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-11T02:00:00+00:00 PythonOperator 2023-02-11T03:00:23.884713+00:00 2023-02-11T03:00:26.673195+00:00 0:00:02.788482 337515 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-11T03:00:21.361918+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-11T01:00:00+00:00 TriggerDagRunOperator 2023-02-11T02:11:02.493681+00:00 2023-02-11T02:11:03.001327+00:00 0:00:00.507646 337502 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T02:10:59.938741+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-11T01:00:00+00:00 TriggerDagRunOperator 2023-02-11T02:11:02.340384+00:00 2023-02-11T02:11:02.873737+00:00 0:00:00.533353 337501 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T02:10:59.938770+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-11T01:00:00+00:00 EmrJobFlowSensor 2023-02-11T02:00:49.934068+00:00 2023-02-11T02:10:51.684361+00:00 0:10:01.750293 337493 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-11T02:00:47.567461+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-11T01:00:00+00:00 EmrCreateJobFlowOperator 2023-02-11T02:00:29.741214+00:00 2023-02-11T02:00:30.632601+00:00 0:00:00.891387 337491 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-11T02:00:27.515558+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-11T01:00:00+00:00 PythonOperator 2023-02-11T02:00:07.945210+00:00 2023-02-11T02:00:12.353824+00:00 0:00:04.408614 337489 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-11T02:00:05.503860+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-11T00:00:00+00:00 TriggerDagRunOperator 2023-02-11T01:11:17.344017+00:00 2023-02-11T01:11:17.829503+00:00 0:00:00.485486 337470 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T01:11:14.762204+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-11T00:00:00+00:00 TriggerDagRunOperator 2023-02-11T01:11:17.217650+00:00 2023-02-11T01:11:17.675306+00:00 0:00:00.457656 337469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T01:11:14.762232+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-11T00:00:00+00:00 EmrJobFlowSensor 2023-02-11T01:00:57.766147+00:00 2023-02-11T01:10:59.642218+00:00 0:10:01.876071 337462 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-11T01:00:54.958365+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-11T00:00:00+00:00 EmrCreateJobFlowOperator 2023-02-11T01:00:35.247686+00:00 2023-02-11T01:00:36.112898+00:00 0:00:00.865212 337460 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-11T01:00:33.005848+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-11T00:00:00+00:00 PythonOperator 2023-02-11T01:00:13.673046+00:00 2023-02-11T01:00:16.600847+00:00 0:00:02.927801 337458 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-11T01:00:10.876746+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-10T23:00:00+00:00 TriggerDagRunOperator 2023-02-11T00:11:43.488915+00:00 2023-02-11T00:11:43.988797+00:00 0:00:00.499882 337445 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T00:11:40.206382+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-10T23:00:00+00:00 TriggerDagRunOperator 2023-02-11T00:11:43.228686+00:00 2023-02-11T00:11:43.789865+00:00 0:00:00.561179 337444 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-11T00:11:40.206346+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-10T23:00:00+00:00 EmrJobFlowSensor 2023-02-11T00:00:51.211499+00:00 2023-02-11T00:10:53.115387+00:00 0:10:01.903888 337436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-11T00:00:48.017305+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-10T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-11T00:00:28.559840+00:00 2023-02-11T00:00:29.649840+00:00 0:00:01.090000 337434 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-11T00:00:26.011385+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-10T23:00:00+00:00 PythonOperator 2023-02-11T00:00:08.493266+00:00 2023-02-11T00:00:12.390115+00:00 0:00:03.896849 337432 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-11T00:00:05.993176+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-10T22:00:00+00:00 TriggerDagRunOperator 2023-02-10T23:10:56.368295+00:00 2023-02-10T23:10:56.899610+00:00 0:00:00.531315 337418 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T23:10:54.002277+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-10T22:00:00+00:00 TriggerDagRunOperator 2023-02-10T23:10:56.337670+00:00 2023-02-10T23:10:56.858034+00:00 0:00:00.520364 337417 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T23:10:54.002310+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-10T22:00:00+00:00 EmrJobFlowSensor 2023-02-10T23:00:49.261881+00:00 2023-02-10T23:10:51.157193+00:00 0:10:01.895312 337407 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-10T23:00:46.968775+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-10T22:00:00+00:00 EmrCreateJobFlowOperator 2023-02-10T23:00:29.182283+00:00 2023-02-10T23:00:30.145221+00:00 0:00:00.962938 337405 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-10T23:00:26.936321+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-10T22:00:00+00:00 PythonOperator 2023-02-10T23:00:07.308153+00:00 2023-02-10T23:00:10.128051+00:00 0:00:02.819898 337403 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-10T23:00:04.856330+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-10T21:00:00+00:00 TriggerDagRunOperator 2023-02-10T22:11:36.330764+00:00 2023-02-10T22:11:36.882386+00:00 0:00:00.551622 337389 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T22:11:33.822620+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-10T21:00:00+00:00 TriggerDagRunOperator 2023-02-10T22:11:36.304545+00:00 2023-02-10T22:11:36.822341+00:00 0:00:00.517796 337388 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T22:11:33.822648+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-10T21:00:00+00:00 EmrJobFlowSensor 2023-02-10T22:00:50.998573+00:00 2023-02-10T22:10:52.898309+00:00 0:10:01.899736 337381 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-10T22:00:48.664903+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-10T21:00:00+00:00 EmrCreateJobFlowOperator 2023-02-10T22:00:28.951681+00:00 2023-02-10T22:00:29.856396+00:00 0:00:00.904715 337379 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-10T22:00:26.635494+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-10T21:00:00+00:00 PythonOperator 2023-02-10T22:00:09.172707+00:00 2023-02-10T22:00:12.401079+00:00 0:00:03.228372 337377 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-10T22:00:06.541105+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-10T20:00:00+00:00 TriggerDagRunOperator 2023-02-10T21:11:31.496728+00:00 2023-02-10T21:11:31.990114+00:00 0:00:00.493386 337363 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T21:11:28.712581+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-10T20:00:00+00:00 TriggerDagRunOperator 2023-02-10T21:11:31.302067+00:00 2023-02-10T21:11:31.758472+00:00 0:00:00.456405 337362 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T21:11:28.712553+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-10T20:00:00+00:00 EmrJobFlowSensor 2023-02-10T21:01:04.347189+00:00 2023-02-10T21:11:06.301568+00:00 0:10:01.954379 337354 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-10T21:01:01.862786+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-10T20:00:00+00:00 EmrCreateJobFlowOperator 2023-02-10T21:00:42.200899+00:00 2023-02-10T21:00:43.123189+00:00 0:00:00.922290 337352 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-10T21:00:39.845102+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-10T20:00:00+00:00 PythonOperator 2023-02-10T21:00:22.251576+00:00 2023-02-10T21:00:28.111285+00:00 0:00:05.859709 337350 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-10T21:00:19.823709+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-10T19:00:00+00:00 TriggerDagRunOperator 2023-02-10T20:11:32.549139+00:00 2023-02-10T20:11:33.152119+00:00 0:00:00.602980 337337 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T20:11:29.732822+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-10T19:00:00+00:00 TriggerDagRunOperator 2023-02-10T20:11:32.335220+00:00 2023-02-10T20:11:32.806918+00:00 0:00:00.471698 337336 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T20:11:29.732850+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-10T19:00:00+00:00 EmrJobFlowSensor 2023-02-10T20:00:53.443947+00:00 2023-02-10T20:10:55.201981+00:00 0:10:01.758034 337328 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-10T20:00:51.233873+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-10T19:00:00+00:00 EmrCreateJobFlowOperator 2023-02-10T20:00:31.393864+00:00 2023-02-10T20:00:32.139140+00:00 0:00:00.745276 337326 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-10T20:00:29.183749+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-10T19:00:00+00:00 PythonOperator 2023-02-10T20:00:11.449477+00:00 2023-02-10T20:00:15.759293+00:00 0:00:04.309816 337324 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-10T20:00:09.135589+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-10T18:00:00+00:00 TriggerDagRunOperator 2023-02-10T19:11:46.713880+00:00 2023-02-10T19:11:47.383806+00:00 0:00:00.669926 337311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T19:11:44.015179+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-10T18:00:00+00:00 TriggerDagRunOperator 2023-02-10T19:11:46.656857+00:00 2023-02-10T19:11:47.266101+00:00 0:00:00.609244 337310 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T19:11:44.015208+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-10T18:00:00+00:00 EmrJobFlowSensor 2023-02-10T19:01:03.804886+00:00 2023-02-10T19:11:05.583685+00:00 0:10:01.778799 337303 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-10T19:01:01.312030+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-10T18:00:00+00:00 EmrCreateJobFlowOperator 2023-02-10T19:00:43.689885+00:00 2023-02-10T19:00:44.615834+00:00 0:00:00.925949 337301 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-10T19:00:41.230380+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-10T18:00:00+00:00 PythonOperator 2023-02-10T19:00:21.516048+00:00 2023-02-10T19:00:25.268454+00:00 0:00:03.752406 337299 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-10T19:00:19.227814+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-10T17:00:00+00:00 TriggerDagRunOperator 2023-02-10T18:12:06.273718+00:00 2023-02-10T18:12:06.799479+00:00 0:00:00.525761 337285 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T18:12:03.512013+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-10T17:00:00+00:00 TriggerDagRunOperator 2023-02-10T18:12:06.280242+00:00 2023-02-10T18:12:06.758937+00:00 0:00:00.478695 337284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T18:12:03.511986+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-10T17:00:00+00:00 EmrJobFlowSensor 2023-02-10T18:00:59.832568+00:00 2023-02-10T18:11:01.775813+00:00 0:10:01.943245 337274 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-10T18:00:57.493824+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-10T17:00:00+00:00 EmrCreateJobFlowOperator 2023-02-10T18:00:39.999230+00:00 2023-02-10T18:00:40.910003+00:00 0:00:00.910773 337273 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-10T18:00:37.444961+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-10T17:00:00+00:00 PythonOperator 2023-02-10T18:00:17.737863+00:00 2023-02-10T18:00:20.852523+00:00 0:00:03.114660 337272 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-10T18:00:15.389238+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-10T16:00:00+00:00 TriggerDagRunOperator 2023-02-10T17:13:59.136296+00:00 2023-02-10T17:13:59.618553+00:00 0:00:00.482257 337259 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T17:13:56.441530+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-10T16:00:00+00:00 TriggerDagRunOperator 2023-02-10T17:13:59.120451+00:00 2023-02-10T17:13:59.582512+00:00 0:00:00.462061 337258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T17:13:56.441501+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-10T16:00:00+00:00 EmrJobFlowSensor 2023-02-10T17:01:26.498138+00:00 2023-02-10T17:11:28.295826+00:00 0:10:01.797688 337251 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-10T17:01:24.302232+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-10T16:00:00+00:00 EmrCreateJobFlowOperator 2023-02-10T17:01:04.726610+00:00 2023-02-10T17:01:05.611526+00:00 0:00:00.884916 337249 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-10T17:01:02.276391+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-10T16:00:00+00:00 PythonOperator 2023-02-10T17:00:45.441983+00:00 2023-02-10T17:00:48.501307+00:00 0:00:03.059324 337247 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-10T17:00:42.231060+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-10T15:00:00+00:00 TriggerDagRunOperator 2023-02-10T16:11:17.457188+00:00 2023-02-10T16:11:17.981035+00:00 0:00:00.523847 337234 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T16:11:14.764061+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-10T15:00:00+00:00 TriggerDagRunOperator 2023-02-10T16:11:17.271458+00:00 2023-02-10T16:11:17.745539+00:00 0:00:00.474081 337233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T16:11:14.764032+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-10T15:00:00+00:00 EmrJobFlowSensor 2023-02-10T16:01:01.952929+00:00 2023-02-10T16:11:03.896876+00:00 0:10:01.943947 337226 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-10T16:00:58.928758+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-10T15:00:00+00:00 EmrCreateJobFlowOperator 2023-02-10T16:00:39.687087+00:00 2023-02-10T16:00:40.535349+00:00 0:00:00.848262 337224 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-10T16:00:36.913957+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-10T15:00:00+00:00 PythonOperator 2023-02-10T16:00:17.180488+00:00 2023-02-10T16:00:20.251132+00:00 0:00:03.070644 337222 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-10T16:00:14.855354+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-10T14:00:00+00:00 TriggerDagRunOperator 2023-02-10T15:18:17.872760+00:00 2023-02-10T15:18:18.371675+00:00 0:00:00.498915 337209 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T15:18:14.877534+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-10T14:00:00+00:00 TriggerDagRunOperator 2023-02-10T15:18:17.601820+00:00 2023-02-10T15:18:18.165309+00:00 0:00:00.563489 337208 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T15:18:14.877566+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-10T14:00:00+00:00 EmrJobFlowSensor 2023-02-10T15:00:54.113195+00:00 2023-02-10T15:10:55.971425+00:00 0:10:01.858230 337202 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-10T15:00:51.646531+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-10T14:00:00+00:00 EmrCreateJobFlowOperator 2023-02-10T15:00:31.856542+00:00 2023-02-10T15:00:32.675339+00:00 0:00:00.818797 337200 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-10T15:00:29.604713+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-10T14:00:00+00:00 PythonOperator 2023-02-10T15:00:13.204462+00:00 2023-02-10T15:00:16.339795+00:00 0:00:03.135333 337198 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-10T15:00:09.566478+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-10T13:00:00+00:00 TriggerDagRunOperator 2023-02-10T14:11:08.747578+00:00 2023-02-10T14:11:09.248881+00:00 0:00:00.501303 337184 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T14:11:06.305901+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-10T13:00:00+00:00 TriggerDagRunOperator 2023-02-10T14:11:08.721565+00:00 2023-02-10T14:11:09.217581+00:00 0:00:00.496016 337183 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T14:11:06.305950+00:00 2 default_pool