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-03T01:00:00+00:00 EmrJobFlowSensor 2023-03-03T02:15:07.561779+00:00 2023-03-03T02:25:09.333395+00:00 0:10:01.771616 347662 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-03T02:15:05.243106+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-03T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-03T02:14:48.710894+00:00 2023-03-03T02:14:49.862923+00:00 0:00:01.152029 347658 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-03T02:14:45.251307+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-03T00:00:00+00:00 TriggerDagRunOperator 2023-03-03T02:14:28.583910+00:00 2023-03-03T02:14:29.202977+00:00 0:00:00.619067 347654 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T02:14:23.205396+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-03T00:00:00+00:00 TriggerDagRunOperator 2023-03-03T02:14:28.594640+00:00 2023-03-03T02:14:29.169223+00:00 0:00:00.574583 347653 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T02:14:23.205427+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-03T01:00:00+00:00 PythonOperator 2023-03-03T02:14:25.520613+00:00 2023-03-03T02:14:32.625773+00:00 0:00:07.105160 347652 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-03T02:14:23.205440+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-03T00:00:00+00:00 EmrJobFlowSensor 2023-03-03T01:54:22.146163+00:00 2023-03-03T02:04:23.971504+00:00 0:10:01.825341 347646 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-03T01:54:19.828571+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-03T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-03T01:54:00.821835+00:00 2023-03-03T01:54:02.021196+00:00 0:00:01.199361 347641 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-03T01:53:57.823990+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-03T00:00:00+00:00 PythonOperator 2023-03-03T01:53:43.106372+00:00 2023-03-03T01:53:50.603305+00:00 0:00:07.496933 347636 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-03T01:53:37.783316+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-02T23:00:00+00:00 TriggerDagRunOperator 2023-03-03T00:24:20.025615+00:00 2023-03-03T00:24:20.523917+00:00 0:00:00.498302 347629 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T00:24:16.992512+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-02T23:00:00+00:00 TriggerDagRunOperator 2023-03-03T00:24:19.712522+00:00 2023-03-03T00:24:20.237181+00:00 0:00:00.524659 347628 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-03T00:24:16.992544+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-02T23:00:00+00:00 EmrJobFlowSensor 2023-03-03T00:11:46.516758+00:00 2023-03-03T00:21:48.306940+00:00 0:10:01.790182 347623 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-03T00:11:44.247508+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-02T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-03T00:11:26.592421+00:00 2023-03-03T00:11:27.637514+00:00 0:00:01.045093 347620 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-03T00:11:24.180560+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-02T23:00:00+00:00 PythonOperator 2023-03-03T00:11:04.982038+00:00 2023-03-03T00:11:08.979915+00:00 0:00:03.997877 347617 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-03T00:11:02.154209+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-02T22:00:00+00:00 TriggerDagRunOperator 2023-03-02T23:10:55.495599+00:00 2023-03-02T23:10:55.997537+00:00 0:00:00.501938 347610 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T23:10:52.315186+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-02T22:00:00+00:00 TriggerDagRunOperator 2023-03-02T23:10:55.184816+00:00 2023-03-02T23:10:55.657249+00:00 0:00:00.472433 347609 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T23:10:52.315227+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-02T22:00:00+00:00 EmrJobFlowSensor 2023-03-02T23:01:39.380784+00:00 2023-03-02T23:10:41.012660+00:00 0:09:01.631876 347603 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-02T23:01:36.791223+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-02T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-02T23:00:46.710883+00:00 2023-03-02T23:00:47.527780+00:00 0:00:00.816897 347599 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-02T23:00:43.963984+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-02T22:00:00+00:00 PythonOperator 2023-03-02T23:00:24.490775+00:00 2023-03-02T23:00:27.747057+00:00 0:00:03.256282 347596 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-02T23:00:19.877015+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-02T21:00:00+00:00 TriggerDagRunOperator 2023-03-02T22:15:46.704745+00:00 2023-03-02T22:15:47.322077+00:00 0:00:00.617332 347587 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T22:15:43.913461+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-02T21:00:00+00:00 TriggerDagRunOperator 2023-03-02T22:15:46.597977+00:00 2023-03-02T22:15:47.173338+00:00 0:00:00.575361 347586 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T22:15:43.913432+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-02T21:00:00+00:00 EmrJobFlowSensor 2023-03-02T22:02:04.343298+00:00 2023-03-02T22:12:06.224258+00:00 0:10:01.880960 347579 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-02T22:02:01.988148+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-02T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-02T22:01:44.571997+00:00 2023-03-02T22:01:45.851727+00:00 0:00:01.279730 347577 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-02T22:01:41.975013+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-02T21:00:00+00:00 PythonOperator 2023-03-02T22:01:23.104232+00:00 2023-03-02T22:01:26.335910+00:00 0:00:03.231678 347575 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-02T22:01:19.824904+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-02T20:00:00+00:00 TriggerDagRunOperator 2023-03-02T21:15:18.371315+00:00 2023-03-02T21:15:19.049174+00:00 0:00:00.677859 347566 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T21:15:15.705554+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-02T20:00:00+00:00 TriggerDagRunOperator 2023-03-02T21:15:18.130657+00:00 2023-03-02T21:15:18.617151+00:00 0:00:00.486494 347565 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T21:15:15.705593+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-02T20:00:00+00:00 EmrJobFlowSensor 2023-03-02T21:05:08.250902+00:00 2023-03-02T21:15:10.047641+00:00 0:10:01.796739 347559 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-02T21:05:06.052871+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-02T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-02T21:04:46.246183+00:00 2023-03-02T21:04:47.083674+00:00 0:00:00.837491 347557 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-02T21:04:44.060871+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-02T20:00:00+00:00 PythonOperator 2023-03-02T21:04:24.147126+00:00 2023-03-02T21:04:28.051587+00:00 0:00:03.904461 347555 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-02T21:04:21.981522+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-02T19:00:00+00:00 TriggerDagRunOperator 2023-03-02T20:12:34.545698+00:00 2023-03-02T20:12:35.099579+00:00 0:00:00.553881 347545 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T20:12:32.031428+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-02T19:00:00+00:00 TriggerDagRunOperator 2023-03-02T20:12:34.357462+00:00 2023-03-02T20:12:34.832129+00:00 0:00:00.474667 347544 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T20:12:32.031400+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-02T19:00:00+00:00 EmrJobFlowSensor 2023-03-02T20:03:13.826686+00:00 2023-03-02T20:12:15.786327+00:00 0:09:01.959641 347537 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-02T20:03:11.296262+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-02T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-02T20:02:51.660095+00:00 2023-03-02T20:02:52.495191+00:00 0:00:00.835096 347535 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-02T20:02:49.277102+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-02T19:00:00+00:00 PythonOperator 2023-03-02T20:02:29.523938+00:00 2023-03-02T20:02:33.469647+00:00 0:00:03.945709 347533 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-02T20:02:27.256868+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-02T18:00:00+00:00 TriggerDagRunOperator 2023-03-02T19:10:22.776144+00:00 2023-03-02T19:10:23.269172+00:00 0:00:00.493028 347524 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T19:10:20.226344+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-02T18:00:00+00:00 TriggerDagRunOperator 2023-03-02T19:10:22.731460+00:00 2023-03-02T19:10:23.240972+00:00 0:00:00.509512 347523 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T19:10:20.226373+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-02T18:00:00+00:00 EmrJobFlowSensor 2023-03-02T19:01:06.643149+00:00 2023-03-02T19:10:08.322616+00:00 0:09:01.679467 347516 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-02T19:01:04.281192+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-02T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-02T19:00:44.639612+00:00 2023-03-02T19:00:45.669823+00:00 0:00:01.030211 347514 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-02T19:00:42.261151+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-02T18:00:00+00:00 PythonOperator 2023-03-02T19:00:22.873012+00:00 2023-03-02T19:00:26.182822+00:00 0:00:03.309810 347512 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-02T19:00:20.242502+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-02T17:00:00+00:00 TriggerDagRunOperator 2023-03-02T18:13:12.351950+00:00 2023-03-02T18:13:12.846464+00:00 0:00:00.494514 347503 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T18:13:09.978913+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-02T17:00:00+00:00 TriggerDagRunOperator 2023-03-02T18:13:12.334357+00:00 2023-03-02T18:13:12.799289+00:00 0:00:00.464932 347502 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T18:13:09.978941+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-02T17:00:00+00:00 EmrJobFlowSensor 2023-03-02T18:01:00.541308+00:00 2023-03-02T18:11:02.790783+00:00 0:10:02.249475 347496 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-02T18:00:58.099230+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-02T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-02T18:00:40.321473+00:00 2023-03-02T18:00:41.210066+00:00 0:00:00.888593 347494 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-02T18:00:37.969424+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-02T17:00:00+00:00 PythonOperator 2023-03-02T18:00:18.156341+00:00 2023-03-02T18:00:22.346207+00:00 0:00:04.189866 347492 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-02T18:00:15.964551+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-02T16:00:00+00:00 TriggerDagRunOperator 2023-03-02T17:24:13.768962+00:00 2023-03-02T17:24:14.286466+00:00 0:00:00.517504 347483 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T17:24:10.760611+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-02T16:00:00+00:00 TriggerDagRunOperator 2023-03-02T17:24:13.440421+00:00 2023-03-02T17:24:13.905137+00:00 0:00:00.464716 347482 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T17:24:10.760638+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-02T16:00:00+00:00 EmrJobFlowSensor 2023-03-02T17:00:58.439631+00:00 2023-03-02T17:11:00.268975+00:00 0:10:01.829344 347474 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-02T17:00:56.152143+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-02T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-02T17:00:36.412201+00:00 2023-03-02T17:00:37.282138+00:00 0:00:00.869937 347472 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-02T17:00:34.125078+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-02T16:00:00+00:00 PythonOperator 2023-03-02T17:00:14.447944+00:00 2023-03-02T17:00:18.404862+00:00 0:00:03.956918 347470 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-02T17:00:12.047551+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-02T15:00:00+00:00 TriggerDagRunOperator 2023-03-02T16:10:19.576805+00:00 2023-03-02T16:10:20.115625+00:00 0:00:00.538820 347461 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T16:10:17.167110+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-02T15:00:00+00:00 TriggerDagRunOperator 2023-03-02T16:10:19.467355+00:00 2023-03-02T16:10:19.990233+00:00 0:00:00.522878 347460 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T16:10:17.167138+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-02T15:00:00+00:00 EmrJobFlowSensor 2023-03-02T16:01:00.335065+00:00 2023-03-02T16:10:02.152025+00:00 0:09:01.816960 347453 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-02T16:00:57.603460+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-02T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-02T16:00:37.901530+00:00 2023-03-02T16:00:38.777143+00:00 0:00:00.875613 347451 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-02T16:00:35.502309+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-02T15:00:00+00:00 PythonOperator 2023-03-02T16:00:16.346922+00:00 2023-03-02T16:00:19.249110+00:00 0:00:02.902188 347450 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-02T16:00:13.447039+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-02T14:00:00+00:00 TriggerDagRunOperator 2023-03-02T15:16:53.672317+00:00 2023-03-02T15:16:54.198114+00:00 0:00:00.525797 347440 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T15:16:51.060472+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-02T14:00:00+00:00 TriggerDagRunOperator 2023-03-02T15:16:53.421748+00:00 2023-03-02T15:16:53.877369+00:00 0:00:00.455621 347439 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T15:16:51.060444+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-02T14:00:00+00:00 EmrJobFlowSensor 2023-03-02T15:06:30.615537+00:00 2023-03-02T15:16:32.393510+00:00 0:10:01.777973 347434 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-02T15:06:28.436460+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-02T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-02T15:06:10.656379+00:00 2023-03-02T15:06:11.806899+00:00 0:00:01.150520 347431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-02T15:06:08.415498+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-02T14:00:00+00:00 PythonOperator 2023-03-02T15:05:49.069066+00:00 2023-03-02T15:05:52.967052+00:00 0:00:03.897986 347428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-02T15:05:46.388732+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-02T13:00:00+00:00 TriggerDagRunOperator 2023-03-02T14:12:32.935831+00:00 2023-03-02T14:12:33.466651+00:00 0:00:00.530820 347419 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T14:12:27.750264+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-02T13:00:00+00:00 TriggerDagRunOperator 2023-03-02T14:12:30.349324+00:00 2023-03-02T14:12:30.817728+00:00 0:00:00.468404 347418 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T14:12:27.750215+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-02T13:00:00+00:00 EmrJobFlowSensor 2023-03-02T14:00:52.308498+00:00 2023-03-02T14:10:54.412146+00:00 0:10:02.103648 347413 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-02T14:00:46.626048+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-02T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-02T14:00:26.857988+00:00 2023-03-02T14:00:27.829193+00:00 0:00:00.971205 347411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-02T14:00:24.607113+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-02T13:00:00+00:00 PythonOperator 2023-03-02T14:00:05.036841+00:00 2023-03-02T14:00:08.366333+00:00 0:00:03.329492 347409 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-02T14:00:02.493008+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-02T12:00:00+00:00 TriggerDagRunOperator 2023-03-02T13:37:04.852289+00:00 2023-03-02T13:37:05.359769+00:00 0:00:00.507480 347403 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T13:37:01.704952+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-02T12:00:00+00:00 TriggerDagRunOperator 2023-03-02T13:37:04.833196+00:00 2023-03-02T13:37:05.313960+00:00 0:00:00.480764 347402 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T13:37:01.704910+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-02T12:00:00+00:00 EmrJobFlowSensor 2023-03-02T13:26:49.018560+00:00 2023-03-02T13:36:50.956857+00:00 0:10:01.938297 347398 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-02T13:26:46.572942+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-02T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-02T13:26:27.361380+00:00 2023-03-02T13:26:28.292990+00:00 0:00:00.931610 347394 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-02T13:26:24.602204+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-02T12:00:00+00:00 PythonOperator 2023-03-02T13:26:09.424780+00:00 2023-03-02T13:26:12.765775+00:00 0:00:03.340995 347390 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-02T13:26:04.482805+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-02T11:00:00+00:00 TriggerDagRunOperator 2023-03-02T13:26:09.327194+00:00 2023-03-02T13:26:09.911566+00:00 0:00:00.584372 347389 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T13:26:04.482760+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-02T11:00:00+00:00 TriggerDagRunOperator 2023-03-02T13:26:06.825780+00:00 2023-03-02T13:26:07.273387+00:00 0:00:00.447607 347388 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T13:26:04.482792+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-02T11:00:00+00:00 EmrJobFlowSensor 2023-03-02T12:16:00.568994+00:00 2023-03-02T12:26:02.594130+00:00 0:10:02.025136 347383 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-02T12:15:57.232905+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-02T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-02T12:15:37.518897+00:00 2023-03-02T12:15:38.442041+00:00 0:00:00.923144 347379 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-02T12:15:35.193153+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-02T11:00:00+00:00 PythonOperator 2023-03-02T12:15:15.734210+00:00 2023-03-02T12:15:19.118329+00:00 0:00:03.384119 347377 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-02T12:15:13.187510+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-02T10:00:00+00:00 TriggerDagRunOperator 2023-03-02T11:50:21.023114+00:00 2023-03-02T11:50:21.488210+00:00 0:00:00.465096 347370 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T11:50:18.138156+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-02T10:00:00+00:00 TriggerDagRunOperator 2023-03-02T11:50:20.842641+00:00 2023-03-02T11:50:21.384450+00:00 0:00:00.541809 347369 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T11:50:18.138126+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-02T10:00:00+00:00 EmrJobFlowSensor 2023-03-02T11:19:32.053049+00:00 2023-03-02T11:29:33.767921+00:00 0:10:01.714872 347364 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-02T11:19:29.745014+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-02T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-02T11:19:11.986618+00:00 2023-03-02T11:19:12.795530+00:00 0:00:00.808912 347361 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-02T11:19:09.713942+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-02T10:00:00+00:00 PythonOperator 2023-03-02T11:18:50.700528+00:00 2023-03-02T11:18:57.293305+00:00 0:00:06.592777 347358 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-02T11:18:47.698565+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-02T09:00:00+00:00 TriggerDagRunOperator 2023-03-02T10:11:53.565923+00:00 2023-03-02T10:11:54.196559+00:00 0:00:00.630636 347347 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T10:11:51.057406+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-02T09:00:00+00:00 TriggerDagRunOperator 2023-03-02T10:11:53.507393+00:00 2023-03-02T10:11:54.056588+00:00 0:00:00.549195 347346 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T10:11:51.057369+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-02T09:00:00+00:00 EmrJobFlowSensor 2023-03-02T10:01:01.078365+00:00 2023-03-02T10:11:02.865473+00:00 0:10:01.787108 347342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-02T10:00:58.609768+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-02T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-02T10:00:38.834160+00:00 2023-03-02T10:00:39.660722+00:00 0:00:00.826562 347340 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-02T10:00:36.602127+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-02T09:00:00+00:00 PythonOperator 2023-03-02T10:00:17.058845+00:00 2023-03-02T10:00:20.096599+00:00 0:00:03.037754 347338 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-02T10:00:14.490101+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-02T08:00:00+00:00 TriggerDagRunOperator 2023-03-02T09:22:47.361368+00:00 2023-03-02T09:22:47.848433+00:00 0:00:00.487065 347332 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T09:22:44.961374+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-02T08:00:00+00:00 TriggerDagRunOperator 2023-03-02T09:22:47.358812+00:00 2023-03-02T09:22:47.881646+00:00 0:00:00.522834 347331 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T09:22:44.961345+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-02T08:00:00+00:00 EmrJobFlowSensor 2023-03-02T09:12:36.123228+00:00 2023-03-02T09:22:37.905782+00:00 0:10:01.782554 347326 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-02T09:12:33.760420+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-02T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-02T09:12:16.012151+00:00 2023-03-02T09:12:16.966653+00:00 0:00:00.954502 347323 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-02T09:12:13.745541+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-02T08:00:00+00:00 PythonOperator 2023-03-02T09:11:54.512750+00:00 2023-03-02T09:11:58.410045+00:00 0:00:03.897295 347320 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-02T09:11:51.547282+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-02T07:00:00+00:00 TriggerDagRunOperator 2023-03-02T08:21:51.323438+00:00 2023-03-02T08:21:51.857832+00:00 0:00:00.534394 347312 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T08:21:48.225497+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-02T07:00:00+00:00 TriggerDagRunOperator 2023-03-02T08:21:51.194668+00:00 2023-03-02T08:21:51.700050+00:00 0:00:00.505382 347311 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T08:21:48.225536+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-02T07:00:00+00:00 EmrJobFlowSensor 2023-03-02T08:09:20.333395+00:00 2023-03-02T08:19:22.215213+00:00 0:10:01.881818 347307 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-02T08:09:18.072492+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-02T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-02T08:08:58.199224+00:00 2023-03-02T08:08:59.034451+00:00 0:00:00.835227 347303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-02T08:08:56.006514+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-02T07:00:00+00:00 PythonOperator 2023-03-02T08:08:38.849544+00:00 2023-03-02T08:08:43.046713+00:00 0:00:04.197169 347301 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-02T08:08:35.904837+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-02T06:00:00+00:00 TriggerDagRunOperator 2023-03-02T07:27:09.737671+00:00 2023-03-02T07:27:10.245668+00:00 0:00:00.507997 347294 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T07:27:06.892312+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-02T06:00:00+00:00 TriggerDagRunOperator 2023-03-02T07:27:09.715076+00:00 2023-03-02T07:27:10.216526+00:00 0:00:00.501450 347293 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T07:27:06.892342+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-02T06:00:00+00:00 EmrJobFlowSensor 2023-03-02T07:17:02.007086+00:00 2023-03-02T07:27:03.656178+00:00 0:10:01.649092 347290 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-02T07:16:59.727980+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-02T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-02T07:16:41.956935+00:00 2023-03-02T07:16:42.771469+00:00 0:00:00.814534 347287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-02T07:16:39.708221+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-02T06:00:00+00:00 PythonOperator 2023-03-02T07:16:17.958073+00:00 2023-03-02T07:16:21.015346+00:00 0:00:03.057273 347284 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-02T07:16:15.691081+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-02T05:00:00+00:00 TriggerDagRunOperator 2023-03-02T06:13:12.758785+00:00 2023-03-02T06:13:13.277838+00:00 0:00:00.519053 347277 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T06:13:10.358522+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-02T05:00:00+00:00 TriggerDagRunOperator 2023-03-02T06:13:12.740445+00:00 2023-03-02T06:13:13.204416+00:00 0:00:00.463971 347276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-02T06:13:10.358552+00:00 2 default_pool