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-04-13T01:00:00+00:00 PythonOperator 2021-04-13T02:00:09.993309+00:00 2021-04-13T02:00:12.778363+00:00 0:00:02.785054 16561 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T02:00:07.450542+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T00:00:00+00:00 TriggerDagRunOperator 2021-04-13T01:10:17.317853+00:00 2021-04-13T01:10:18.458169+00:00 0:00:01.140316 16554 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T01:10:14.699694+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T00:00:00+00:00 TriggerDagRunOperator 2021-04-13T01:10:17.113438+00:00 2021-04-13T01:10:18.171106+00:00 0:00:01.057668 16553 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T01:10:14.699722+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T00:00:00+00:00 EmrJobFlowSensor 2021-04-13T01:01:03.034712+00:00 2021-04-13T01:10:05.782206+00:00 0:09:02.747494 16548 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T01:01:00.213823+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T01:00:42.379934+00:00 2021-04-13T01:00:44.106005+00:00 0:00:01.726071 16547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T01:00:40.190815+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T00:00:00+00:00 PythonOperator 2021-04-13T01:00:16.330269+00:00 2021-04-13T01:00:19.051019+00:00 0:00:02.720750 16546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T01:00:14.150949+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T23:00:00+00:00 TriggerDagRunOperator 2021-04-13T00:11:19.297540+00:00 2021-04-13T00:11:19.792964+00:00 0:00:00.495424 16539 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T00:11:16.898923+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T23:00:00+00:00 TriggerDagRunOperator 2021-04-13T00:11:19.130349+00:00 2021-04-13T00:11:19.564659+00:00 0:00:00.434310 16538 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T00:11:16.898885+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T23:00:00+00:00 EmrJobFlowSensor 2021-04-13T00:00:53.538477+00:00 2021-04-13T00:10:56.327010+00:00 0:10:02.788533 16533 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T00:00:51.290186+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T00:00:33.565455+00:00 2021-04-13T00:00:35.249092+00:00 0:00:01.683637 16532 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T00:00:31.246452+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T23:00:00+00:00 PythonOperator 2021-04-13T00:00:11.542797+00:00 2021-04-13T00:00:14.377818+00:00 0:00:02.835021 16531 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T00:00:09.190385+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T22:00:00+00:00 TriggerDagRunOperator 2021-04-12T23:10:55.815081+00:00 2021-04-12T23:10:56.339168+00:00 0:00:00.524087 16524 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T23:10:52.575035+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T22:00:00+00:00 TriggerDagRunOperator 2021-04-12T23:10:55.710233+00:00 2021-04-12T23:10:56.114415+00:00 0:00:00.404182 16523 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T23:10:52.575087+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T22:00:00+00:00 EmrJobFlowSensor 2021-04-12T23:01:45.911044+00:00 2021-04-12T23:10:48.547291+00:00 0:09:02.636247 16519 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T23:01:43.675513+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T23:01:26.176746+00:00 2021-04-12T23:01:27.890454+00:00 0:00:01.713708 16518 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T23:01:23.649140+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T22:00:00+00:00 PythonOperator 2021-04-12T23:01:04.097390+00:00 2021-04-12T23:01:06.856516+00:00 0:00:02.759126 16517 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T23:01:01.577311+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T21:00:00+00:00 TriggerDagRunOperator 2021-04-12T22:09:00.750747+00:00 2021-04-12T22:09:01.156860+00:00 0:00:00.406113 16509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T22:08:57.956906+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T21:00:00+00:00 TriggerDagRunOperator 2021-04-12T22:09:00.537255+00:00 2021-04-12T22:09:01.085051+00:00 0:00:00.547796 16508 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T22:08:57.956874+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T21:00:00+00:00 EmrJobFlowSensor 2021-04-12T22:00:51.392173+00:00 2021-04-12T22:08:53.937850+00:00 0:08:02.545677 16504 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T22:00:49.089689+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T22:00:29.563004+00:00 2021-04-12T22:00:31.236769+00:00 0:00:01.673765 16503 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T22:00:27.063621+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T21:00:00+00:00 PythonOperator 2021-04-12T22:00:07.635171+00:00 2021-04-12T22:00:10.357472+00:00 0:00:02.722301 16502 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T22:00:05.052891+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T20:00:00+00:00 TriggerDagRunOperator 2021-04-12T21:10:33.744260+00:00 2021-04-12T21:10:34.261327+00:00 0:00:00.517067 16493 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T21:10:31.376472+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T20:00:00+00:00 TriggerDagRunOperator 2021-04-12T21:10:33.607237+00:00 2021-04-12T21:10:34.079154+00:00 0:00:00.471917 16492 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T21:10:31.376442+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T20:00:00+00:00 EmrJobFlowSensor 2021-04-12T21:01:12.628871+00:00 2021-04-12T21:10:15.274810+00:00 0:09:02.645939 16488 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T21:01:10.468765+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T21:00:48.822920+00:00 2021-04-12T21:00:50.667810+00:00 0:00:01.844890 16487 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T21:00:46.445458+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T20:00:00+00:00 PythonOperator 2021-04-12T21:00:22.793469+00:00 2021-04-12T21:00:25.524938+00:00 0:00:02.731469 16486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T21:00:20.422386+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T19:00:00+00:00 TriggerDagRunOperator 2021-04-12T20:09:23.112709+00:00 2021-04-12T20:09:23.865689+00:00 0:00:00.752980 16478 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T20:09:20.702496+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T19:00:00+00:00 TriggerDagRunOperator 2021-04-12T20:09:23.021050+00:00 2021-04-12T20:09:23.648746+00:00 0:00:00.627696 16477 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T20:09:20.702545+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T19:00:00+00:00 EmrJobFlowSensor 2021-04-12T20:01:06.895732+00:00 2021-04-12T20:09:09.463808+00:00 0:08:02.568076 16473 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T20:01:04.090727+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T20:00:44.300213+00:00 2021-04-12T20:00:45.972368+00:00 0:00:01.672155 16472 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T20:00:42.076440+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T19:00:00+00:00 PythonOperator 2021-04-12T20:00:24.424648+00:00 2021-04-12T20:00:27.133286+00:00 0:00:02.708638 16471 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T20:00:22.049627+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T18:00:00+00:00 TriggerDagRunOperator 2021-04-12T19:11:10.494080+00:00 2021-04-12T19:11:11.064266+00:00 0:00:00.570186 16463 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T19:11:07.856902+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T18:00:00+00:00 TriggerDagRunOperator 2021-04-12T19:11:10.288449+00:00 2021-04-12T19:11:10.759796+00:00 0:00:00.471347 16462 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T19:11:07.856874+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T18:00:00+00:00 EmrJobFlowSensor 2021-04-12T19:01:03.409285+00:00 2021-04-12T19:11:06.232103+00:00 0:10:02.822818 16458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T19:01:00.952429+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T19:00:40.993083+00:00 2021-04-12T19:00:42.813902+00:00 0:00:01.820819 16457 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T19:00:38.815363+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T18:00:00+00:00 PythonOperator 2021-04-12T19:00:21.225610+00:00 2021-04-12T19:00:24.078920+00:00 0:00:02.853310 16456 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T19:00:18.851958+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T17:00:00+00:00 TriggerDagRunOperator 2021-04-12T18:08:59.565343+00:00 2021-04-12T18:09:00.087049+00:00 0:00:00.521706 16448 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T18:08:57.135727+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T17:00:00+00:00 TriggerDagRunOperator 2021-04-12T18:08:59.435741+00:00 2021-04-12T18:08:59.867141+00:00 0:00:00.431400 16447 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T18:08:57.135695+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T17:00:00+00:00 EmrJobFlowSensor 2021-04-12T18:00:46.664462+00:00 2021-04-12T18:08:49.295853+00:00 0:08:02.631391 16443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T18:00:44.367538+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T18:00:26.515590+00:00 2021-04-12T18:00:28.301798+00:00 0:00:01.786208 16442 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T18:00:24.295528+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T17:00:00+00:00 PythonOperator 2021-04-12T18:00:04.564059+00:00 2021-04-12T18:00:07.339899+00:00 0:00:02.775840 16441 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T18:00:02.214194+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T16:00:00+00:00 TriggerDagRunOperator 2021-04-12T17:11:10.910959+00:00 2021-04-12T17:11:11.316629+00:00 0:00:00.405670 16433 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T17:11:08.690641+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T16:00:00+00:00 TriggerDagRunOperator 2021-04-12T17:11:10.919404+00:00 2021-04-12T17:11:11.464392+00:00 0:00:00.544988 16432 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T17:11:08.690678+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T16:00:00+00:00 EmrJobFlowSensor 2021-04-12T17:00:55.755059+00:00 2021-04-12T17:10:58.469341+00:00 0:10:02.714282 16428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T17:00:53.583213+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T17:00:33.858864+00:00 2021-04-12T17:00:35.773891+00:00 0:00:01.915027 16427 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T17:00:31.553256+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T16:00:00+00:00 PythonOperator 2021-04-12T17:00:11.819539+00:00 2021-04-12T17:00:14.522780+00:00 0:00:02.703241 16426 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T17:00:09.537740+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T15:00:00+00:00 TriggerDagRunOperator 2021-04-12T16:11:18.086995+00:00 2021-04-12T16:11:18.656028+00:00 0:00:00.569033 16418 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T16:11:15.544380+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T15:00:00+00:00 TriggerDagRunOperator 2021-04-12T16:11:17.887732+00:00 2021-04-12T16:11:18.286858+00:00 0:00:00.399126 16417 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T16:11:15.544349+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T15:00:00+00:00 EmrJobFlowSensor 2021-04-12T16:00:59.128922+00:00 2021-04-12T16:11:01.989928+00:00 0:10:02.861006 16413 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T16:00:56.632061+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T16:00:36.822035+00:00 2021-04-12T16:00:38.532956+00:00 0:00:01.710921 16412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T16:00:34.614781+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T15:00:00+00:00 PythonOperator 2021-04-12T16:00:15.010129+00:00 2021-04-12T16:00:17.784138+00:00 0:00:02.774009 16411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T16:00:12.598565+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T14:00:00+00:00 TriggerDagRunOperator 2021-04-12T15:10:21.013794+00:00 2021-04-12T15:10:21.540395+00:00 0:00:00.526601 16403 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T15:10:18.656850+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T14:00:00+00:00 TriggerDagRunOperator 2021-04-12T15:10:20.914183+00:00 2021-04-12T15:10:21.312743+00:00 0:00:00.398560 16402 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T15:10:18.656803+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T14:00:00+00:00 EmrJobFlowSensor 2021-04-12T15:01:04.372665+00:00 2021-04-12T15:10:07.226740+00:00 0:09:02.854075 16398 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T15:01:01.747007+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T15:00:34.263339+00:00 2021-04-12T15:00:35.958605+00:00 0:00:01.695266 16397 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T15:00:31.662894+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T14:00:00+00:00 PythonOperator 2021-04-12T15:00:10.152503+00:00 2021-04-12T15:00:12.986429+00:00 0:00:02.833926 16396 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T15:00:07.626533+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T13:00:00+00:00 TriggerDagRunOperator 2021-04-12T14:10:34.316753+00:00 2021-04-12T14:10:34.834893+00:00 0:00:00.518140 16388 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T14:10:31.685888+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T13:00:00+00:00 TriggerDagRunOperator 2021-04-12T14:10:34.188804+00:00 2021-04-12T14:10:34.621715+00:00 0:00:00.432911 16387 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T14:10:31.685854+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T13:00:00+00:00 EmrJobFlowSensor 2021-04-12T14:01:06.959519+00:00 2021-04-12T14:10:09.634496+00:00 0:09:02.674977 16383 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T14:01:04.694000+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T14:00:44.839604+00:00 2021-04-12T14:00:46.536982+00:00 0:00:01.697378 16382 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T14:00:42.604770+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T13:00:00+00:00 PythonOperator 2021-04-12T14:00:19.541044+00:00 2021-04-12T14:00:22.610240+00:00 0:00:03.069196 16381 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T14:00:16.653046+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T12:00:00+00:00 TriggerDagRunOperator 2021-04-12T13:11:24.482224+00:00 2021-04-12T13:11:25.005263+00:00 0:00:00.523039 16373 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T13:11:22.030996+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T12:00:00+00:00 TriggerDagRunOperator 2021-04-12T13:11:24.298425+00:00 2021-04-12T13:11:24.739902+00:00 0:00:00.441477 16372 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T13:11:22.031030+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T12:00:00+00:00 EmrJobFlowSensor 2021-04-12T13:01:05.484706+00:00 2021-04-12T13:11:08.221048+00:00 0:10:02.736342 16368 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T13:01:03.201212+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T13:00:41.370033+00:00 2021-04-12T13:00:43.068885+00:00 0:00:01.698852 16367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T13:00:39.164881+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T12:00:00+00:00 PythonOperator 2021-04-12T13:00:21.532712+00:00 2021-04-12T13:00:24.262191+00:00 0:00:02.729479 16366 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T13:00:19.090984+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T11:00:00+00:00 TriggerDagRunOperator 2021-04-12T12:11:19.041895+00:00 2021-04-12T12:11:19.572817+00:00 0:00:00.530922 16358 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T12:11:16.435204+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T11:00:00+00:00 TriggerDagRunOperator 2021-04-12T12:11:18.681481+00:00 2021-04-12T12:11:19.139834+00:00 0:00:00.458353 16357 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T12:11:16.435237+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T11:00:00+00:00 EmrJobFlowSensor 2021-04-12T12:01:00.377283+00:00 2021-04-12T12:11:03.288668+00:00 0:10:02.911385 16353 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T12:00:57.763058+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T12:00:40.176052+00:00 2021-04-12T12:00:41.984704+00:00 0:00:01.808652 16352 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T12:00:37.648883+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T11:00:00+00:00 PythonOperator 2021-04-12T12:00:17.787108+00:00 2021-04-12T12:00:20.515405+00:00 0:00:02.728297 16351 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T12:00:15.521501+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T10:00:00+00:00 TriggerDagRunOperator 2021-04-12T11:11:22.541994+00:00 2021-04-12T11:11:23.099967+00:00 0:00:00.557973 16343 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T11:11:20.035272+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T10:00:00+00:00 TriggerDagRunOperator 2021-04-12T11:11:22.299451+00:00 2021-04-12T11:11:22.710456+00:00 0:00:00.411005 16342 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T11:11:20.035238+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T10:00:00+00:00 EmrJobFlowSensor 2021-04-12T11:00:57.223363+00:00 2021-04-12T11:10:59.915618+00:00 0:10:02.692255 16338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T11:00:55.106121+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T11:00:37.345904+00:00 2021-04-12T11:00:39.143228+00:00 0:00:01.797324 16337 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T11:00:35.086672+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T10:00:00+00:00 PythonOperator 2021-04-12T11:00:15.348528+00:00 2021-04-12T11:00:18.463580+00:00 0:00:03.115052 16336 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T11:00:13.001799+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T09:00:00+00:00 TriggerDagRunOperator 2021-04-12T10:14:33.382712+00:00 2021-04-12T10:14:33.938494+00:00 0:00:00.555782 16328 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T10:14:30.559399+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T09:00:00+00:00 TriggerDagRunOperator 2021-04-12T10:14:33.187980+00:00 2021-04-12T10:14:33.623253+00:00 0:00:00.435273 16327 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T10:14:30.559454+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T09:00:00+00:00 EmrJobFlowSensor 2021-04-12T10:00:56.277011+00:00 2021-04-12T10:10:58.964873+00:00 0:10:02.687862 16322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T10:00:54.172881+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T10:00:34.590222+00:00 2021-04-12T10:00:36.397072+00:00 0:00:01.806850 16321 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T10:00:32.150377+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T09:00:00+00:00 PythonOperator 2021-04-12T10:00:12.499521+00:00 2021-04-12T10:00:15.240625+00:00 0:00:02.741104 16320 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T10:00:10.162560+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T08:00:00+00:00 TriggerDagRunOperator 2021-04-12T09:10:37.969875+00:00 2021-04-12T09:10:38.605588+00:00 0:00:00.635713 16313 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T09:10:35.316402+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T08:00:00+00:00 TriggerDagRunOperator 2021-04-12T09:10:37.870961+00:00 2021-04-12T09:10:38.277134+00:00 0:00:00.406173 16312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T09:10:35.316430+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T08:00:00+00:00 EmrJobFlowSensor 2021-04-12T09:01:16.082889+00:00 2021-04-12T09:10:18.729926+00:00 0:09:02.647037 16307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T09:01:13.820183+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T09:00:56.144038+00:00 2021-04-12T09:00:57.826519+00:00 0:00:01.682481 16306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T09:00:53.803272+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T08:00:00+00:00 PythonOperator 2021-04-12T09:00:34.270020+00:00 2021-04-12T09:00:37.207050+00:00 0:00:02.937030 16305 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T09:00:31.852885+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T07:00:00+00:00 TriggerDagRunOperator 2021-04-12T08:11:09.302844+00:00 2021-04-12T08:11:09.807151+00:00 0:00:00.504307 16298 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T08:11:06.495436+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T07:00:00+00:00 TriggerDagRunOperator 2021-04-12T08:11:09.055266+00:00 2021-04-12T08:11:09.467584+00:00 0:00:00.412318 16297 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T08:11:06.495463+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T07:00:00+00:00 EmrJobFlowSensor 2021-04-12T08:00:46.203963+00:00 2021-04-12T08:10:48.995373+00:00 0:10:02.791410 16292 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T08:00:43.877027+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T08:00:26.119037+00:00 2021-04-12T08:00:27.804472+00:00 0:00:01.685435 16291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T08:00:23.863687+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T07:00:00+00:00 PythonOperator 2021-04-12T08:00:04.087806+00:00 2021-04-12T08:00:06.936356+00:00 0:00:02.848550 16290 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T08:00:01.735308+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T06:00:00+00:00 TriggerDagRunOperator 2021-04-12T07:11:28.018687+00:00 2021-04-12T07:11:28.558904+00:00 0:00:00.540217 16283 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T07:11:25.027613+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T06:00:00+00:00 TriggerDagRunOperator 2021-04-12T07:11:27.739034+00:00 2021-04-12T07:11:28.207296+00:00 0:00:00.468262 16282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T07:11:25.027585+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T06:00:00+00:00 EmrJobFlowSensor 2021-04-12T07:01:07.272402+00:00 2021-04-12T07:11:09.996582+00:00 0:10:02.724180 16277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T07:01:05.017257+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T07:00:45.521731+00:00 2021-04-12T07:00:47.237995+00:00 0:00:01.716264 16276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T07:00:42.995760+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T06:00:00+00:00 PythonOperator 2021-04-12T07:00:23.279793+00:00 2021-04-12T07:00:26.175024+00:00 0:00:02.895231 16275 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T07:00:20.922280+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T05:00:00+00:00 TriggerDagRunOperator 2021-04-12T06:09:10.374984+00:00 2021-04-12T06:09:10.949575+00:00 0:00:00.574591 16268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T06:09:07.950204+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T05:00:00+00:00 TriggerDagRunOperator 2021-04-12T06:09:10.169923+00:00 2021-04-12T06:09:10.595335+00:00 0:00:00.425412 16267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T06:09:07.950238+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T05:00:00+00:00 EmrJobFlowSensor 2021-04-12T06:00:58.416856+00:00 2021-04-12T06:09:00.887035+00:00 0:08:02.470179 16262 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T06:00:56.059289+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T06:00:38.781749+00:00 2021-04-12T06:00:40.630007+00:00 0:00:01.848258 16261 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T06:00:36.044439+00:00 2 default_pool