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 create_emr_steps 2021-05-02T05:00:00+00:00 PythonOperator 2021-05-02T06:00:20.755661+00:00 2021-05-02T06:00:23.793053+00:00 0:00:03.037392 23542 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T06:00:18.427981+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T04:00:00+00:00 TriggerDagRunOperator 2021-05-02T05:11:19.832275+00:00 2021-05-02T05:11:20.332011+00:00 0:00:00.499736 23535 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T05:11:16.861946+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T04:00:00+00:00 TriggerDagRunOperator 2021-05-02T05:11:19.692849+00:00 2021-05-02T05:11:20.117141+00:00 0:00:00.424292 23534 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T05:11:16.861915+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T04:00:00+00:00 EmrJobFlowSensor 2021-05-02T05:00:55.728243+00:00 2021-05-02T05:10:58.584902+00:00 0:10:02.856659 23529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T05:00:53.503274+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T05:00:34.010220+00:00 2021-05-02T05:00:35.710595+00:00 0:00:01.700375 23528 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T05:00:31.490413+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T04:00:00+00:00 PythonOperator 2021-05-02T05:00:11.654346+00:00 2021-05-02T05:00:14.685179+00:00 0:00:03.030833 23527 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T05:00:09.445910+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T03:00:00+00:00 TriggerDagRunOperator 2021-05-02T04:10:25.098949+00:00 2021-05-02T04:10:25.646549+00:00 0:00:00.547600 23520 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T04:10:22.492917+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T03:00:00+00:00 TriggerDagRunOperator 2021-05-02T04:10:25.035605+00:00 2021-05-02T04:10:25.447782+00:00 0:00:00.412177 23519 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T04:10:22.492866+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T03:00:00+00:00 EmrJobFlowSensor 2021-05-02T04:01:06.205546+00:00 2021-05-02T04:10:09.004793+00:00 0:09:02.799247 23514 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T04:01:04.000934+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T04:00:44.181790+00:00 2021-05-02T04:00:45.882990+00:00 0:00:01.701200 23513 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T04:00:41.983661+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T03:00:00+00:00 PythonOperator 2021-05-02T04:00:24.435202+00:00 2021-05-02T04:00:27.466815+00:00 0:00:03.031613 23512 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T04:00:21.967683+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T02:00:00+00:00 TriggerDagRunOperator 2021-05-02T03:10:23.125588+00:00 2021-05-02T03:10:23.540325+00:00 0:00:00.414737 23505 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T03:10:20.724805+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T02:00:00+00:00 TriggerDagRunOperator 2021-05-02T03:10:23.117681+00:00 2021-05-02T03:10:23.664464+00:00 0:00:00.546783 23504 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T03:10:20.724836+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T02:00:00+00:00 EmrJobFlowSensor 2021-05-02T03:00:56.006456+00:00 2021-05-02T03:09:58.898796+00:00 0:09:02.892340 23499 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T03:00:53.699702+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T03:00:34.082305+00:00 2021-05-02T03:00:35.907587+00:00 0:00:01.825282 23498 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T03:00:31.663355+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T02:00:00+00:00 PythonOperator 2021-05-02T03:00:12.045602+00:00 2021-05-02T03:00:15.094711+00:00 0:00:03.049109 23497 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T03:00:09.658572+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T01:00:00+00:00 TriggerDagRunOperator 2021-05-02T02:13:59.574732+00:00 2021-05-02T02:14:00.104813+00:00 0:00:00.530081 23490 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T02:13:56.856678+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T01:00:00+00:00 TriggerDagRunOperator 2021-05-02T02:13:59.409544+00:00 2021-05-02T02:13:59.826124+00:00 0:00:00.416580 23489 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T02:13:56.856720+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T01:00:00+00:00 EmrJobFlowSensor 2021-05-02T02:04:42.091537+00:00 2021-05-02T02:13:44.775381+00:00 0:09:02.683844 23485 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T02:04:39.854711+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T02:04:22.119776+00:00 2021-05-02T02:04:23.825663+00:00 0:00:01.705887 23484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T02:04:19.835133+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T01:00:00+00:00 PythonOperator 2021-05-02T02:04:00.421436+00:00 2021-05-02T02:04:03.457907+00:00 0:00:03.036471 23483 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T02:03:57.796170+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T00:00:00+00:00 TriggerDagRunOperator 2021-05-02T01:09:54.056003+00:00 2021-05-02T01:09:54.538329+00:00 0:00:00.482326 23475 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T01:09:51.565278+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T00:00:00+00:00 TriggerDagRunOperator 2021-05-02T01:09:54.001500+00:00 2021-05-02T01:09:54.597264+00:00 0:00:00.595764 23474 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T01:09:51.565231+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T00:00:00+00:00 EmrJobFlowSensor 2021-05-02T01:00:46.696611+00:00 2021-05-02T01:09:49.460836+00:00 0:09:02.764225 23470 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T01:00:44.407042+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T01:00:24.722106+00:00 2021-05-02T01:00:26.480170+00:00 0:00:01.758064 23469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T01:00:22.456371+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T00:00:00+00:00 PythonOperator 2021-05-02T01:00:04.875041+00:00 2021-05-02T01:00:08.122584+00:00 0:00:03.247543 23468 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T01:00:02.351138+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T23:00:00+00:00 TriggerDagRunOperator 2021-05-02T00:10:12.262163+00:00 2021-05-02T00:10:12.711175+00:00 0:00:00.449012 23460 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T00:10:09.920920+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T23:00:00+00:00 TriggerDagRunOperator 2021-05-02T00:10:12.209755+00:00 2021-05-02T00:10:12.844784+00:00 0:00:00.635029 23459 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T00:10:09.920981+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T23:00:00+00:00 EmrJobFlowSensor 2021-05-02T00:00:57.425524+00:00 2021-05-02T00:10:00.163531+00:00 0:09:02.738007 23455 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T00:00:54.982712+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T00:00:37.360423+00:00 2021-05-02T00:00:39.112844+00:00 0:00:01.752421 23454 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T00:00:34.963561+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T23:00:00+00:00 PythonOperator 2021-05-02T00:00:15.368464+00:00 2021-05-02T00:00:18.469249+00:00 0:00:03.100785 23453 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T00:00:12.876837+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T22:00:00+00:00 TriggerDagRunOperator 2021-05-01T23:11:22.142947+00:00 2021-05-01T23:11:22.569139+00:00 0:00:00.426192 23445 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T23:11:19.691140+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T22:00:00+00:00 TriggerDagRunOperator 2021-05-01T23:11:21.909499+00:00 2021-05-01T23:11:22.451576+00:00 0:00:00.542077 23444 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T23:11:19.691108+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T22:00:00+00:00 EmrJobFlowSensor 2021-05-01T23:00:56.870296+00:00 2021-05-01T23:10:59.657018+00:00 0:10:02.786722 23439 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T23:00:54.604995+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T23:00:36.929622+00:00 2021-05-01T23:00:38.667094+00:00 0:00:01.737472 23437 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T23:00:34.585269+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T22:00:00+00:00 PythonOperator 2021-05-01T23:00:14.932444+00:00 2021-05-01T23:00:18.041418+00:00 0:00:03.108974 23435 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T23:00:12.501072+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T21:00:00+00:00 TriggerDagRunOperator 2021-05-01T22:10:15.898805+00:00 2021-05-01T22:10:16.405522+00:00 0:00:00.506717 23427 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T22:10:13.262831+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T21:00:00+00:00 TriggerDagRunOperator 2021-05-01T22:10:15.764363+00:00 2021-05-01T22:10:16.178895+00:00 0:00:00.414532 23426 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T22:10:13.262861+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T21:00:00+00:00 EmrJobFlowSensor 2021-05-01T22:00:56.407961+00:00 2021-05-01T22:09:59.207368+00:00 0:09:02.799407 23422 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T22:00:54.151915+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T22:00:26.355676+00:00 2021-05-01T22:00:28.084861+00:00 0:00:01.729185 23421 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T22:00:24.127864+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T21:00:00+00:00 PythonOperator 2021-05-01T22:00:04.871193+00:00 2021-05-01T22:00:08.054843+00:00 0:00:03.183650 23420 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T22:00:02.143546+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T20:00:00+00:00 TriggerDagRunOperator 2021-05-01T21:10:16.787915+00:00 2021-05-01T21:10:17.212493+00:00 0:00:00.424578 23412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T21:10:14.101531+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T20:00:00+00:00 TriggerDagRunOperator 2021-05-01T21:10:16.525392+00:00 2021-05-01T21:10:17.068141+00:00 0:00:00.542749 23411 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T21:10:14.101496+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T20:00:00+00:00 EmrJobFlowSensor 2021-05-01T21:01:07.519954+00:00 2021-05-01T21:10:10.241430+00:00 0:09:02.721476 23407 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T21:01:05.191841+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T21:00:45.379186+00:00 2021-05-01T21:00:47.131644+00:00 0:00:01.752458 23406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T21:00:43.096761+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T20:00:00+00:00 PythonOperator 2021-05-01T21:00:25.321271+00:00 2021-05-01T21:00:28.392797+00:00 0:00:03.071526 23405 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T21:00:23.030647+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T19:00:00+00:00 TriggerDagRunOperator 2021-05-01T20:11:11.127306+00:00 2021-05-01T20:11:11.662335+00:00 0:00:00.535029 23397 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T20:11:08.574738+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T19:00:00+00:00 TriggerDagRunOperator 2021-05-01T20:11:11.040173+00:00 2021-05-01T20:11:11.493611+00:00 0:00:00.453438 23396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T20:11:08.574783+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T19:00:00+00:00 EmrJobFlowSensor 2021-05-01T20:00:55.841254+00:00 2021-05-01T20:10:58.804808+00:00 0:10:02.963554 23392 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T20:00:53.474046+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T20:00:33.591132+00:00 2021-05-01T20:00:35.289379+00:00 0:00:01.698247 23391 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T20:00:31.384844+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T19:00:00+00:00 PythonOperator 2021-05-01T20:00:12.099806+00:00 2021-05-01T20:00:15.129584+00:00 0:00:03.029778 23390 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T20:00:09.316646+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T18:00:00+00:00 TriggerDagRunOperator 2021-05-01T19:10:07.085318+00:00 2021-05-01T19:10:07.556400+00:00 0:00:00.471082 23382 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T19:10:04.769021+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T18:00:00+00:00 TriggerDagRunOperator 2021-05-01T19:10:07.105421+00:00 2021-05-01T19:10:07.640572+00:00 0:00:00.535151 23381 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T19:10:04.769055+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T18:00:00+00:00 EmrJobFlowSensor 2021-05-01T19:00:49.900804+00:00 2021-05-01T19:09:52.659034+00:00 0:09:02.758230 23377 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T19:00:47.383173+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T19:00:29.825349+00:00 2021-05-01T19:00:31.545046+00:00 0:00:01.719697 23376 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T19:00:27.279630+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T18:00:00+00:00 PythonOperator 2021-05-01T19:00:07.637790+00:00 2021-05-01T19:00:10.664523+00:00 0:00:03.026733 23375 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T19:00:05.198618+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T17:00:00+00:00 TriggerDagRunOperator 2021-05-01T18:11:32.040044+00:00 2021-05-01T18:11:32.492586+00:00 0:00:00.452542 23367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T18:11:29.582495+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T17:00:00+00:00 TriggerDagRunOperator 2021-05-01T18:11:31.993500+00:00 2021-05-01T18:11:32.583879+00:00 0:00:00.590379 23366 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T18:11:29.582562+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T17:00:00+00:00 EmrJobFlowSensor 2021-05-01T18:01:04.886547+00:00 2021-05-01T18:11:07.764352+00:00 0:10:02.877805 23362 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T18:01:02.498086+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T18:00:42.740674+00:00 2021-05-01T18:00:44.560553+00:00 0:00:01.819879 23361 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T18:00:40.424639+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T17:00:00+00:00 PythonOperator 2021-05-01T18:00:21.031142+00:00 2021-05-01T18:00:24.078181+00:00 0:00:03.047039 23360 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T18:00:18.406126+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T16:00:00+00:00 TriggerDagRunOperator 2021-05-01T17:10:16.758324+00:00 2021-05-01T17:10:17.208914+00:00 0:00:00.450590 23352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T17:10:14.411172+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T16:00:00+00:00 TriggerDagRunOperator 2021-05-01T17:10:16.750822+00:00 2021-05-01T17:10:17.302408+00:00 0:00:00.551586 23351 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T17:10:14.411212+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T16:00:00+00:00 EmrJobFlowSensor 2021-05-01T17:00:59.172224+00:00 2021-05-01T17:10:01.833577+00:00 0:09:02.661353 23347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T17:00:56.904349+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T17:00:37.157164+00:00 2021-05-01T17:00:38.846825+00:00 0:00:01.689661 23346 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T17:00:34.898406+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T16:00:00+00:00 PythonOperator 2021-05-01T17:00:15.173748+00:00 2021-05-01T17:00:18.216469+00:00 0:00:03.042721 23345 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T17:00:12.823771+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T15:00:00+00:00 TriggerDagRunOperator 2021-05-01T16:10:14.707245+00:00 2021-05-01T16:10:15.172552+00:00 0:00:00.465307 23337 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T16:10:12.296359+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T15:00:00+00:00 TriggerDagRunOperator 2021-05-01T16:10:14.694450+00:00 2021-05-01T16:10:15.256514+00:00 0:00:00.562064 23336 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T16:10:12.296397+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T15:00:00+00:00 EmrJobFlowSensor 2021-05-01T16:00:49.785794+00:00 2021-05-01T16:09:52.594399+00:00 0:09:02.808605 23332 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T16:00:47.365490+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T16:00:27.677423+00:00 2021-05-01T16:00:29.511032+00:00 0:00:01.833609 23331 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T16:00:25.303064+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T15:00:00+00:00 PythonOperator 2021-05-01T16:00:07.403529+00:00 2021-05-01T16:00:10.456129+00:00 0:00:03.052600 23330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T16:00:05.285166+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T14:00:00+00:00 TriggerDagRunOperator 2021-05-01T15:13:32.122384+00:00 2021-05-01T15:13:32.683488+00:00 0:00:00.561104 23323 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T15:13:29.386569+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T14:00:00+00:00 TriggerDagRunOperator 2021-05-01T15:13:32.004929+00:00 2021-05-01T15:13:32.453004+00:00 0:00:00.448075 23322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T15:13:29.386533+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T14:00:00+00:00 EmrJobFlowSensor 2021-05-01T15:01:03.837744+00:00 2021-05-01T15:10:06.623903+00:00 0:09:02.786159 23317 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T15:01:01.510324+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T15:00:41.747775+00:00 2021-05-01T15:00:43.550204+00:00 0:00:01.802429 23316 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T15:00:39.485978+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T14:00:00+00:00 PythonOperator 2021-05-01T15:00:21.600087+00:00 2021-05-01T15:00:24.678426+00:00 0:00:03.078339 23315 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T15:00:19.384875+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T13:00:00+00:00 TriggerDagRunOperator 2021-05-01T14:19:04.962613+00:00 2021-05-01T14:19:05.544425+00:00 0:00:00.581812 23308 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T14:19:02.094907+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T13:00:00+00:00 TriggerDagRunOperator 2021-05-01T14:19:04.423964+00:00 2021-05-01T14:19:05.033116+00:00 0:00:00.609152 23307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T14:19:02.094952+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T13:00:00+00:00 EmrJobFlowSensor 2021-05-01T14:08:30.934448+00:00 2021-05-01T14:18:33.713532+00:00 0:10:02.779084 23306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T14:08:28.586903+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T14:08:08.736753+00:00 2021-05-01T14:08:10.493544+00:00 0:00:01.756791 23304 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T14:08:06.522368+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T13:00:00+00:00 PythonOperator 2021-05-01T14:07:46.798132+00:00 2021-05-01T14:07:49.821619+00:00 0:00:03.023487 23302 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T14:07:44.505472+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T12:00:00+00:00 TriggerDagRunOperator 2021-05-01T13:08:57.065122+00:00 2021-05-01T13:08:57.590342+00:00 0:00:00.525220 23293 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T13:08:54.685600+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T12:00:00+00:00 TriggerDagRunOperator 2021-05-01T13:08:56.926578+00:00 2021-05-01T13:08:57.407959+00:00 0:00:00.481381 23292 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T13:08:54.685568+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T12:00:00+00:00 EmrJobFlowSensor 2021-05-01T13:00:50.098320+00:00 2021-05-01T13:08:52.578846+00:00 0:08:02.480526 23288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T13:00:47.853369+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T13:00:28.186503+00:00 2021-05-01T13:00:29.874158+00:00 0:00:01.687655 23287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T13:00:25.849105+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T12:00:00+00:00 PythonOperator 2021-05-01T13:00:08.644190+00:00 2021-05-01T13:00:11.734309+00:00 0:00:03.090119 23286 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T13:00:05.778496+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T11:00:00+00:00 TriggerDagRunOperator 2021-05-01T12:11:24.668765+00:00 2021-05-01T12:11:25.211676+00:00 0:00:00.542911 23278 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T12:11:22.256299+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T11:00:00+00:00 TriggerDagRunOperator 2021-05-01T12:11:24.627542+00:00 2021-05-01T12:11:25.087208+00:00 0:00:00.459666 23277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T12:11:22.256249+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T11:00:00+00:00 EmrJobFlowSensor 2021-05-01T12:00:57.056774+00:00 2021-05-01T12:10:59.837097+00:00 0:10:02.780323 23273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T12:00:54.894349+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T12:00:35.383086+00:00 2021-05-01T12:00:37.215975+00:00 0:00:01.832889 23272 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T12:00:32.865240+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T11:00:00+00:00 PythonOperator 2021-05-01T12:00:13.112781+00:00 2021-05-01T12:00:16.130097+00:00 0:00:03.017316 23271 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T12:00:10.689332+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T10:00:00+00:00 TriggerDagRunOperator 2021-05-01T11:09:59.340093+00:00 2021-05-01T11:09:59.973416+00:00 0:00:00.633323 23263 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T11:09:56.549589+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T10:00:00+00:00 TriggerDagRunOperator 2021-05-01T11:09:58.897850+00:00 2021-05-01T11:09:59.281872+00:00 0:00:00.384022 23262 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T11:09:56.549686+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T10:00:00+00:00 EmrJobFlowSensor 2021-05-01T11:00:49.496636+00:00 2021-05-01T11:09:52.214084+00:00 0:09:02.717448 23258 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T11:00:47.113754+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T11:00:27.646539+00:00 2021-05-01T11:00:29.527905+00:00 0:00:01.881366 23257 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T11:00:25.166210+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T10:00:00+00:00 PythonOperator 2021-05-01T11:00:07.902964+00:00 2021-05-01T11:00:11.048831+00:00 0:00:03.145867 23256 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T11:00:05.065787+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T09:00:00+00:00 TriggerDagRunOperator 2021-05-01T10:10:12.300235+00:00 2021-05-01T10:10:12.868443+00:00 0:00:00.568208 23248 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T10:10:09.922932+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T09:00:00+00:00 TriggerDagRunOperator 2021-05-01T10:10:12.262821+00:00 2021-05-01T10:10:12.709620+00:00 0:00:00.446799 23247 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T10:10:09.922968+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T09:00:00+00:00 EmrJobFlowSensor 2021-05-01T10:00:47.752567+00:00 2021-05-01T10:09:50.384631+00:00 0:09:02.632064 23243 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T10:00:45.261077+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T10:00:27.574871+00:00 2021-05-01T10:00:29.393322+00:00 0:00:01.818451 23242 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T10:00:25.143795+00:00 2 default_pool