Task Instances

  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 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 booking-processing-job_v002 check_cluster_status 2021-04-12T22:00:00+00:00 EmrJobFlowSensor 2021-04-12T23:12:05.099299+00:00 2021-04-12T23:22:07.881859+00:00 0:10:02.782560 16530 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T23:12:02.745520+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T22:00:00+00:00 EmrJobFlowSensor 2021-04-12T23:11:46.916660+00:00 2021-04-12T23:21:49.695693+00:00 0:10:02.779033 16529 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T23:11:44.606752+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T23:11:38.803083+00:00 2021-04-12T23:11:40.477416+00:00 0:00:01.674333 16528 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T23:11:36.603973+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T23:11:22.803882+00:00 2021-04-12T23:11:24.543785+00:00 0:00:01.739903 16527 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T23:11:20.585655+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T22:00:00+00:00 PythonOperator 2021-04-12T23:11:16.904415+00:00 2021-04-12T23:11:19.965356+00:00 0:00:03.060941 16526 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T23:11:14.587104+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T22:00:00+00:00 PythonOperator 2021-04-12T23:11:00.941591+00:00 2021-04-12T23:11:03.760784+00:00 0:00:02.819193 16525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T23:10:58.582204+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 vc-asset-import_v002 check_cluster_status 2021-04-12T22:05:00+00:00 EmrJobFlowSensor 2021-04-12T23:05:58.195008+00:00 2021-04-12T23:14:00.619333+00:00 0:08:02.424325 16522 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T23:05:56.055171+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T23:05:38.194826+00:00 2021-04-12T23:05:39.938569+00:00 0:00:01.743743 16521 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T23:05:35.937834+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T22:05:00+00:00 PythonOperator 2021-04-12T23:05:16.336419+00:00 2021-04-12T23:05:19.321395+00:00 0:00:02.984976 16520 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T23:05:13.976573+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-history-job_v002 check_cluster_status 2021-04-12T21:00:00+00:00 EmrJobFlowSensor 2021-04-12T22:10:04.184998+00:00 2021-04-12T22:20:06.954915+00:00 0:10:02.769917 16515 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T22:10:02.027840+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T21:00:00+00:00 EmrJobFlowSensor 2021-04-12T22:09:48.489208+00:00 2021-04-12T22:19:51.185015+00:00 0:10:02.695807 16514 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T22:09:46.050313+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T22:09:42.422153+00:00 2021-04-12T22:09:44.269850+00:00 0:00:01.847697 16513 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T22:09:40.056134+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T22:09:26.401480+00:00 2021-04-12T22:09:28.085083+00:00 0:00:01.683603 16512 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T22:09:24.046234+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T21:00:00+00:00 PythonOperator 2021-04-12T22:09:22.328331+00:00 2021-04-12T22:09:25.403141+00:00 0:00:03.074810 16511 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T22:09:19.985931+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T21:00:00+00:00 PythonOperator 2021-04-12T22:09:06.232118+00:00 2021-04-12T22:09:09.141234+00:00 0:00:02.909116 16510 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T22:09:03.891404+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 vc-asset-import_v002 check_cluster_status 2021-04-12T21:05:00+00:00 EmrJobFlowSensor 2021-04-12T22:05:51.807427+00:00 2021-04-12T22:14:54.468575+00:00 0:09:02.661148 16507 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T22:05:49.679066+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T22:05:28.002313+00:00 2021-04-12T22:05:29.632210+00:00 0:00:01.629897 16506 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T22:05:25.669069+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T21:05:00+00:00 PythonOperator 2021-04-12T22:05:08.084915+00:00 2021-04-12T22:05:10.753289+00:00 0:00:02.668374 16505 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T22:05:05.644638+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 booking-processing-job_v002 check_cluster_status 2021-04-12T20:00:00+00:00 EmrJobFlowSensor 2021-04-12T21:23:56.731778+00:00 2021-04-12T21:23:58.211610+00:00 0:00:01.479832 16500 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T21:23:54.476141+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T20:00:00+00:00 EmrJobFlowSensor 2021-04-12T21:11:21.730181+00:00 2021-04-12T21:20:24.421133+00:00 0:09:02.690952 16498 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T21:11:19.425036+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T21:11:11.608100+00:00 2021-04-12T21:11:13.392344+00:00 0:00:01.784244 16497 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T21:11:09.414255+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T21:11:00.181612+00:00 2021-04-12T21:11:02.232976+00:00 0:00:02.051364 16496 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T21:10:57.405023+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T20:00:00+00:00 PythonOperator 2021-04-12T21:10:49.949247+00:00 2021-04-12T21:10:53.023753+00:00 0:00:03.074506 16495 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T21:10:47.481348+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T20:00:00+00:00 PythonOperator 2021-04-12T21:10:37.616173+00:00 2021-04-12T21:10:40.300792+00:00 0:00:02.684619 16494 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T21:10:35.394170+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 vc-asset-import_v002 check_cluster_status 2021-04-12T20:05:00+00:00 EmrJobFlowSensor 2021-04-12T21:05:59.098128+00:00 2021-04-12T21:15:01.689806+00:00 0:09:02.591678 16491 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T21:05:56.895955+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T21:05:38.985156+00:00 2021-04-12T21:05:40.627780+00:00 0:00:01.642624 16490 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T21:05:36.875721+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T20:05:00+00:00 PythonOperator 2021-04-12T21:05:15.345281+00:00 2021-04-12T21:05:18.132213+00:00 0:00:02.786932 16489 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T21:05:12.814802+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-history-job_v002 check_cluster_status 2021-04-12T19:00:00+00:00 EmrJobFlowSensor 2021-04-12T20:10:21.004685+00:00 2021-04-12T20:31:25.264417+00:00 0:21:04.259732 16484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T20:10:18.785964+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T19:00:00+00:00 EmrJobFlowSensor 2021-04-12T20:10:19.304986+00:00 2021-04-12T20:19:22.028598+00:00 0:09:02.723612 16483 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T20:10:16.786080+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T20:09:59.253105+00:00 2021-04-12T20:10:01.053538+00:00 0:00:01.800433 16482 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T20:09:56.732326+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T20:09:59.160638+00:00 2021-04-12T20:10:00.880559+00:00 0:00:01.719921 16481 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T20:09:56.732258+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T19:00:00+00:00 PythonOperator 2021-04-12T20:09:37.230458+00:00 2021-04-12T20:09:40.056543+00:00 0:00:02.826085 16480 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T20:09:34.764369+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T19:00:00+00:00 PythonOperator 2021-04-12T20:09:37.134413+00:00 2021-04-12T20:09:40.138425+00:00 0:00:03.004012 16479 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T20:09:34.764402+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 vc-asset-import_v002 check_cluster_status 2021-04-12T19:05:00+00:00 EmrJobFlowSensor 2021-04-12T20:06:52.826884+00:00 2021-04-12T20:15:55.294312+00:00 0:09:02.467428 16476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T20:06:50.521481+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T20:06:30.720542+00:00 2021-04-12T20:06:32.823673+00:00 0:00:02.103131 16475 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T20:06:28.498509+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T19:05:00+00:00 PythonOperator 2021-04-12T20:05:14.625555+00:00 2021-04-12T20:05:17.508717+00:00 0:00:02.883162 16474 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T20:05:12.378554+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 booking-processing-job_v002 check_cluster_status 2021-04-12T18:00:00+00:00 EmrJobFlowSensor 2021-04-12T19:12:18.227555+00:00 2021-04-12T19:22:21.135961+00:00 0:10:02.908406 16469 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T19:12:15.894174+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T18:00:00+00:00 EmrJobFlowSensor 2021-04-12T19:12:14.293630+00:00 2021-04-12T19:20:16.949716+00:00 0:08:02.656086 16468 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T19:12:11.886863+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T19:11:56.657340+00:00 2021-04-12T19:11:58.348744+00:00 0:00:01.691404 16467 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T19:11:53.866031+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T19:11:54.342453+00:00 2021-04-12T19:11:56.431066+00:00 0:00:02.088613 16466 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T19:11:51.853458+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T18:00:00+00:00 PythonOperator 2021-04-12T19:11:36.284975+00:00 2021-04-12T19:11:39.247741+00:00 0:00:02.962766 16465 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T19:11:33.813633+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T18:00:00+00:00 PythonOperator 2021-04-12T19:11:32.180505+00:00 2021-04-12T19:11:35.246540+00:00 0:00:03.066035 16464 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T19:11:29.858096+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 vc-asset-import_v002 check_cluster_status 2021-04-12T18:05:00+00:00 EmrJobFlowSensor 2021-04-12T19:06:09.616746+00:00 2021-04-12T19:15:12.276652+00:00 0:09:02.659906 16461 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T19:06:07.344403+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T19:05:47.586459+00:00 2021-04-12T19:05:49.212924+00:00 0:00:01.626465 16460 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T19:05:45.380443+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T18:05:00+00:00 PythonOperator 2021-04-12T19:05:21.400126+00:00 2021-04-12T19:05:24.170180+00:00 0:00:02.770054 16459 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T19:05:19.304583+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-history-job_v002 check_cluster_status 2021-04-12T17:00:00+00:00 EmrJobFlowSensor 2021-04-12T18:09:55.510601+00:00 2021-04-12T18:18:58.063226+00:00 0:09:02.552625 16454 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T18:09:53.209650+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T17:00:00+00:00 EmrJobFlowSensor 2021-04-12T18:09:51.532680+00:00 2021-04-12T18:18:54.175897+00:00 0:09:02.643217 16453 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T18:09:49.271350+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T18:09:35.722190+00:00 2021-04-12T18:09:37.530695+00:00 0:00:01.808505 16452 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T18:09:33.248312+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T18:09:29.628854+00:00 2021-04-12T18:09:31.304738+00:00 0:00:01.675884 16451 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T18:09:27.189556+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T17:00:00+00:00 PythonOperator 2021-04-12T18:09:13.484327+00:00 2021-04-12T18:09:16.215944+00:00 0:00:02.731617 16450 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T18:09:11.145968+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T17:00:00+00:00 PythonOperator 2021-04-12T18:09:09.860897+00:00 2021-04-12T18:09:13.152141+00:00 0:00:03.291244 16449 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T18:09:07.142869+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 vc-asset-import_v002 check_cluster_status 2021-04-12T17:05:00+00:00 EmrJobFlowSensor 2021-04-12T18:06:14.981657+00:00 2021-04-12T18:15:17.678700+00:00 0:09:02.697043 16446 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T18:06:12.813017+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T18:05:55.059239+00:00 2021-04-12T18:05:56.681283+00:00 0:00:01.622044 16445 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T18:05:52.794975+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T17:05:00+00:00 PythonOperator 2021-04-12T18:05:24.976025+00:00 2021-04-12T18:05:27.746994+00:00 0:00:02.770969 16444 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T18:05:22.769133+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-history-job_v002 check_cluster_status 2021-04-12T16:00:00+00:00 EmrJobFlowSensor 2021-04-12T17:12:11.049197+00:00 2021-04-12T17:21:13.699946+00:00 0:09:02.650749 16439 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T17:12:08.891513+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T16:00:00+00:00 EmrJobFlowSensor 2021-04-12T17:12:07.037750+00:00 2021-04-12T17:21:09.725126+00:00 0:09:02.687376 16438 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T17:12:04.887170+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T17:11:48.999866+00:00 2021-04-12T17:11:50.639283+00:00 0:00:01.639417 16437 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T17:11:46.796360+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T17:11:45.317904+00:00 2021-04-12T17:11:47.014783+00:00 0:00:01.696879 16436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T17:11:42.851041+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T16:00:00+00:00 PythonOperator 2021-04-12T17:11:27.034139+00:00 2021-04-12T17:11:29.729697+00:00 0:00:02.695558 16435 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T17:11:24.767290+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T16:00:00+00:00 PythonOperator 2021-04-12T17:11:25.194661+00:00 2021-04-12T17:11:28.349244+00:00 0:00:03.154583 16434 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T17:11:22.767775+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 vc-asset-import_v002 check_cluster_status 2021-04-12T16:05:00+00:00 EmrJobFlowSensor 2021-04-12T17:05:58.502918+00:00 2021-04-12T17:15:01.179260+00:00 0:09:02.676342 16431 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T17:05:56.104040+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T17:05:36.845938+00:00 2021-04-12T17:05:38.633370+00:00 0:00:01.787432 16430 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T17:05:34.090414+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T16:05:00+00:00 PythonOperator 2021-04-12T17:05:08.335149+00:00 2021-04-12T17:05:11.006528+00:00 0:00:02.671379 16429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T17:05:06.048902+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