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 booking-processing-job_v002 create_emr_steps 2021-04-13T00:00:00+00:00 PythonOperator 2021-04-13T01:10:31.210938+00:00 2021-04-13T01:10:34.724875+00:00 0:00:03.513937 16556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T01:10:28.777133+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T00:00:00+00:00 PythonOperator 2021-04-13T01:10:22.956203+00:00 2021-04-13T01:10:25.721923+00:00 0:00:02.765720 16555 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T01:10:20.745427+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 vc-asset-import_v002 check_cluster_status 2021-04-13T00:05:00+00:00 EmrJobFlowSensor 2021-04-13T01:05:54.977306+00:00 2021-04-13T01:14:57.583633+00:00 0:09:02.606327 16551 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T01:05:52.708545+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T01:05:33.307842+00:00 2021-04-13T01:05:35.029976+00:00 0:00:01.722134 16550 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T01:05:30.754804+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T00:05:00+00:00 PythonOperator 2021-04-13T01:05:10.987995+00:00 2021-04-13T01:05:13.790052+00:00 0:00:02.802057 16549 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T01:05:08.741230+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 booking-processing-job_v002 check_cluster_status 2021-04-12T23:00:00+00:00 EmrJobFlowSensor 2021-04-13T00:12:27.197405+00:00 2021-04-13T00:22:29.932805+00:00 0:10:02.735400 16545 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T00:12:24.955320+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T23:00:00+00:00 EmrJobFlowSensor 2021-04-13T00:12:11.330383+00:00 2021-04-13T00:22:14.348348+00:00 0:10:03.017965 16544 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T00:12:08.940483+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T00:12:05.101674+00:00 2021-04-13T00:12:06.793240+00:00 0:00:01.691566 16543 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T00:12:02.940168+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T00:11:49.467887+00:00 2021-04-13T00:11:51.302924+00:00 0:00:01.835037 16542 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T00:11:46.939394+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T23:00:00+00:00 PythonOperator 2021-04-13T00:11:45.304040+00:00 2021-04-13T00:11:48.738447+00:00 0:00:03.434407 16541 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T00:11:42.918140+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T23:00:00+00:00 PythonOperator 2021-04-13T00:11:27.594594+00:00 2021-04-13T00:11:30.390148+00:00 0:00:02.795554 16540 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T00:11:24.902328+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 vc-asset-import_v002 check_cluster_status 2021-04-12T23:05:00+00:00 EmrJobFlowSensor 2021-04-13T00:08:24.862171+00:00 2021-04-13T00:17:27.418421+00:00 0:09:02.556250 16537 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T00:08:22.585632+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T00:07:54.665023+00:00 2021-04-13T00:07:56.283343+00:00 0:00:01.618320 16536 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T00:07:52.511621+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T23:05:00+00:00 PythonOperator 2021-04-13T00:07:32.824761+00:00 2021-04-13T00:07:35.583697+00:00 0:00:02.758936 16535 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T00:07:30.492652+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 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