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-history-job_v002 create_cluster_and_add_emr_steps 2021-05-01T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T03:15:03.222036+00:00 2021-05-01T03:15:05.020429+00:00 0:00:01.798393 23147 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T03:15:00.937748+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-01T02:00:00+00:00 PythonOperator 2021-05-01T03:14:46.421113+00:00 2021-05-01T03:14:49.717852+00:00 0:00:03.296739 23146 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T03:14:42.919397+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-01T02:00:00+00:00 PythonOperator 2021-05-01T03:14:44.413643+00:00 2021-05-01T03:14:47.954704+00:00 0:00:03.541061 23145 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T03:14:40.917618+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T02:00:00+00:00 TriggerDagRunOperator 2021-05-01T03:14:35.392524+00:00 2021-05-01T03:14:35.822234+00:00 0:00:00.429710 23144 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T03:14:32.910697+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T02:00:00+00:00 TriggerDagRunOperator 2021-05-01T03:14:35.381091+00:00 2021-05-01T03:14:35.925097+00:00 0:00:00.544006 23143 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T03:14:32.910666+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-01T02:05:00+00:00 EmrJobFlowSensor 2021-05-01T03:06:06.249746+00:00 2021-05-01T03:15:08.895004+00:00 0:09:02.645258 23142 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T03:06:03.968033+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-01T02:05:00+00:00 EmrCreateJobFlowOperator 2021-05-01T03:05:44.472875+00:00 2021-05-01T03:05:46.195864+00:00 0:00:01.722989 23141 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T03:05:41.961346+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-01T02:05:00+00:00 PythonOperator 2021-05-01T03:05:24.023426+00:00 2021-05-01T03:05:27.059888+00:00 0:00:03.036462 23140 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T03:05:21.840191+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T02:00:00+00:00 EmrJobFlowSensor 2021-05-01T03:04:22.174622+00:00 2021-05-01T03:14:25.150009+00:00 0:10:02.975387 23139 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T03:04:19.844054+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T03:04:01.931797+00:00 2021-05-01T03:04:03.823927+00:00 0:00:01.892130 23138 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T03:03:59.693151+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T02:00:00+00:00 PythonOperator 2021-05-01T03:03:39.927286+00:00 2021-05-01T03:03:43.035221+00:00 0:00:03.107935 23137 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T03:03:37.675411+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-01T01:00:00+00:00 EmrJobFlowSensor 2021-05-01T02:10:17.845579+00:00 2021-05-01T02:20:20.603233+00:00 0:10:02.757654 23135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T02:10:15.422313+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-01T01:00:00+00:00 EmrJobFlowSensor 2021-05-01T02:10:17.851403+00:00 2021-05-01T02:20:20.837592+00:00 0:10:02.986189 23134 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T02:10:15.422351+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-01T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T02:09:56.070535+00:00 2021-05-01T02:09:57.884595+00:00 0:00:01.814060 23133 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T02:09:53.467363+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-01T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T02:09:55.966423+00:00 2021-05-01T02:09:57.702563+00:00 0:00:01.736140 23132 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T02:09:53.467317+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-01T01:00:00+00:00 PythonOperator 2021-05-01T02:09:35.651480+00:00 2021-05-01T02:09:38.695129+00:00 0:00:03.043649 23131 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T02:09:33.361275+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-01T01:00:00+00:00 PythonOperator 2021-05-01T02:09:33.695586+00:00 2021-05-01T02:09:36.945514+00:00 0:00:03.249928 23130 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T02:09:31.359295+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T01:00:00+00:00 TriggerDagRunOperator 2021-05-01T02:09:17.687441+00:00 2021-05-01T02:09:18.297225+00:00 0:00:00.609784 23129 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T02:09:15.345249+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T01:00:00+00:00 TriggerDagRunOperator 2021-05-01T02:09:17.626094+00:00 2021-05-01T02:09:18.047910+00:00 0:00:00.421816 23128 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T02:09:15.345285+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-01T01:05:00+00:00 EmrJobFlowSensor 2021-05-01T02:06:05.364370+00:00 2021-05-01T02:15:08.169770+00:00 0:09:02.805400 23127 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T02:06:03.100845+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-01T01:05:00+00:00 EmrCreateJobFlowOperator 2021-05-01T02:05:41.413504+00:00 2021-05-01T02:05:43.159816+00:00 0:00:01.746312 23126 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T02:05:39.155550+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-01T01:05:00+00:00 PythonOperator 2021-05-01T02:05:21.257902+00:00 2021-05-01T02:05:24.268376+00:00 0:00:03.010474 23125 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T02:05:19.058686+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T01:00:00+00:00 EmrJobFlowSensor 2021-05-01T02:00:57.002527+00:00 2021-05-01T02:08:59.614606+00:00 0:08:02.612079 23124 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T02:00:54.581727+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T02:00:36.725251+00:00 2021-05-01T02:00:38.488600+00:00 0:00:01.763349 23123 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T02:00:34.513202+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T01:00:00+00:00 PythonOperator 2021-05-01T02:00:15.195674+00:00 2021-05-01T02:00:18.230652+00:00 0:00:03.034978 23122 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T02:00:12.499064+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-01T00:00:00+00:00 EmrJobFlowSensor 2021-05-01T01:11:14.895657+00:00 2021-05-01T01:21:17.837323+00:00 0:10:02.941666 23120 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T01:11:12.529001+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-01T00:00:00+00:00 EmrJobFlowSensor 2021-05-01T01:11:02.711639+00:00 2021-05-01T01:20:05.346747+00:00 0:09:02.635108 23119 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T01:11:00.511103+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-01T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T01:10:52.876481+00:00 2021-05-01T01:10:54.556506+00:00 0:00:01.680025 23118 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T01:10:50.506388+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-01T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T01:10:40.799545+00:00 2021-05-01T01:10:42.504240+00:00 0:00:01.704695 23117 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T01:10:38.546594+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-01T00:00:00+00:00 PythonOperator 2021-05-01T01:10:30.908010+00:00 2021-05-01T01:10:34.029522+00:00 0:00:03.121512 23116 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T01:10:28.557517+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-01T00:00:00+00:00 PythonOperator 2021-05-01T01:10:18.864424+00:00 2021-05-01T01:10:22.090434+00:00 0:00:03.226010 23115 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T01:10:16.452071+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T00:00:00+00:00 TriggerDagRunOperator 2021-05-01T01:10:06.719878+00:00 2021-05-01T01:10:07.124714+00:00 0:00:00.404836 23114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T01:10:04.350249+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T00:00:00+00:00 TriggerDagRunOperator 2021-05-01T01:10:06.747199+00:00 2021-05-01T01:10:07.277285+00:00 0:00:00.530086 23113 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T01:10:04.350294+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-01T00:05:00+00:00 EmrJobFlowSensor 2021-05-01T01:06:00.453112+00:00 2021-05-01T01:15:03.205913+00:00 0:09:02.752801 23112 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T01:05:57.964536+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-01T00:05:00+00:00 EmrCreateJobFlowOperator 2021-05-01T01:05:40.159064+00:00 2021-05-01T01:05:41.785270+00:00 0:00:01.626206 23111 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T01:05:37.944109+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-01T00:05:00+00:00 PythonOperator 2021-05-01T01:05:18.211786+00:00 2021-05-01T01:05:21.224203+00:00 0:00:03.012417 23110 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T01:05:15.822297+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T00:00:00+00:00 EmrJobFlowSensor 2021-05-01T01:00:47.795390+00:00 2021-05-01T01:09:50.655504+00:00 0:09:02.860114 23109 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T01:00:45.403298+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T01:00:25.753440+00:00 2021-05-01T01:00:27.550339+00:00 0:00:01.796899 23108 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T01:00:23.448673+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T00:00:00+00:00 PythonOperator 2021-05-01T01:00:05.786929+00:00 2021-05-01T01:00:08.959471+00:00 0:00:03.172542 23107 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T01:00:03.284924+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-30T23:00:00+00:00 EmrJobFlowSensor 2021-05-01T00:11:32.599923+00:00 2021-05-01T00:21:35.316168+00:00 0:10:02.716245 23105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T00:11:30.346097+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-30T23:00:00+00:00 EmrJobFlowSensor 2021-05-01T00:11:16.523250+00:00 2021-05-01T00:21:19.450402+00:00 0:10:02.927152 23104 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T00:11:14.308583+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-30T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T00:11:10.766425+00:00 2021-05-01T00:11:12.477812+00:00 0:00:01.711387 23103 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T00:11:08.351367+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-30T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T00:10:54.645246+00:00 2021-05-01T00:10:56.467366+00:00 0:00:01.822120 23102 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T00:10:52.344996+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-30T23:00:00+00:00 PythonOperator 2021-05-01T00:10:48.596070+00:00 2021-05-01T00:10:51.678826+00:00 0:00:03.082756 23101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T00:10:46.288136+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-30T23:00:00+00:00 PythonOperator 2021-05-01T00:10:35.184518+00:00 2021-05-01T00:10:38.450075+00:00 0:00:03.265557 23100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T00:10:32.191987+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T23:00:00+00:00 TriggerDagRunOperator 2021-05-01T00:10:26.745954+00:00 2021-05-01T00:10:27.167718+00:00 0:00:00.421764 23099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T00:10:24.256600+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T23:00:00+00:00 TriggerDagRunOperator 2021-05-01T00:10:26.682856+00:00 2021-05-01T00:10:27.241765+00:00 0:00:00.558909 23098 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T00:10:24.256556+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-30T23:05:00+00:00 EmrJobFlowSensor 2021-05-01T00:06:20.307107+00:00 2021-05-01T00:15:22.937850+00:00 0:09:02.630743 23097 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T00:06:17.967490+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-30T23:05:00+00:00 EmrCreateJobFlowOperator 2021-05-01T00:06:00.388987+00:00 2021-05-01T00:06:02.144925+00:00 0:00:01.755938 23096 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T00:05:57.951916+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-30T23:05:00+00:00 PythonOperator 2021-05-01T00:05:28.014198+00:00 2021-05-01T00:05:31.044200+00:00 0:00:03.030002 23095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T00:05:25.804802+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T23:00:00+00:00 EmrJobFlowSensor 2021-05-01T00:00:59.779748+00:00 2021-05-01T00:10:02.690361+00:00 0:09:02.910613 23094 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T00:00:57.317095+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T00:00:37.693082+00:00 2021-05-01T00:00:39.506689+00:00 0:00:01.813607 23093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T00:00:35.359631+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T23:00:00+00:00 PythonOperator 2021-05-01T00:00:17.428374+00:00 2021-05-01T00:00:20.434764+00:00 0:00:03.006390 23092 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T00:00:15.235179+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-30T22:00:00+00:00 EmrJobFlowSensor 2021-04-30T23:12:46.549595+00:00 2021-04-30T23:22:49.232995+00:00 0:10:02.683400 23091 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T23:12:44.287225+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-30T22:00:00+00:00 EmrJobFlowSensor 2021-04-30T23:12:34.958322+00:00 2021-04-30T23:21:37.701630+00:00 0:09:02.743308 23090 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T23:12:32.243477+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-30T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T23:12:26.396877+00:00 2021-04-30T23:12:28.142729+00:00 0:00:01.745852 23089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T23:12:24.233971+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-30T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T23:12:12.461982+00:00 2021-04-30T23:12:14.274683+00:00 0:00:01.812701 23088 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T23:12:10.224506+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-30T22:00:00+00:00 PythonOperator 2021-04-30T23:12:04.754900+00:00 2021-04-30T23:12:07.982728+00:00 0:00:03.227828 23087 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T23:12:02.217670+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-30T22:00:00+00:00 PythonOperator 2021-04-30T23:11:52.661857+00:00 2021-04-30T23:11:55.711463+00:00 0:00:03.049606 23086 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T23:11:50.205886+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T22:00:00+00:00 TriggerDagRunOperator 2021-04-30T23:11:42.995224+00:00 2021-04-30T23:11:43.504108+00:00 0:00:00.508884 23085 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T23:11:39.991744+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T22:00:00+00:00 TriggerDagRunOperator 2021-04-30T23:11:42.898280+00:00 2021-04-30T23:11:43.311148+00:00 0:00:00.412868 23084 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T23:11:39.991781+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-30T22:05:00+00:00 EmrJobFlowSensor 2021-04-30T23:05:57.988081+00:00 2021-04-30T23:15:00.575905+00:00 0:09:02.587824 23082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T23:05:55.798616+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-30T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-30T23:05:36.078760+00:00 2021-04-30T23:05:37.715573+00:00 0:00:01.636813 23081 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T23:05:33.796378+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-30T22:05:00+00:00 PythonOperator 2021-04-30T23:05:14.205108+00:00 2021-04-30T23:05:17.231740+00:00 0:00:03.026632 23080 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T23:05:11.767720+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T22:00:00+00:00 EmrJobFlowSensor 2021-04-30T23:01:05.759515+00:00 2021-04-30T23:11:08.589866+00:00 0:10:02.830351 23079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T23:01:03.375441+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-04-29T23:00:00+00:00 EmrJobFlowSensor 2021-04-30T23:00:55.695978+00:00 2021-04-30T23:09:58.446075+00:00 0:09:02.750097 23078 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T23:00:53.367685+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T23:00:43.789402+00:00 2021-04-30T23:00:45.523655+00:00 0:00:01.734253 23077 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T23:00:41.293351+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-04-29T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T23:00:35.430353+00:00 2021-04-30T23:00:37.092886+00:00 0:00:01.662533 23076 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T23:00:33.284355+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T22:00:00+00:00 PythonOperator 2021-04-30T23:00:19.468146+00:00 2021-04-30T23:00:22.527709+00:00 0:00:03.059563 23075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T23:00:17.250208+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-04-29T23:00:00+00:00 PythonOperator 2021-04-30T23:00:07.756372+00:00 2021-04-30T23:00:10.837136+00:00 0:00:03.080764 23074 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T23:00:05.241128+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-30T21:00:00+00:00 EmrJobFlowSensor 2021-04-30T22:12:18.807951+00:00 2021-04-30T22:21:21.447358+00:00 0:09:02.639407 23073 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T22:12:16.586438+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-30T21:00:00+00:00 EmrJobFlowSensor 2021-04-30T22:12:16.997507+00:00 2021-04-30T22:22:19.941678+00:00 0:10:02.944171 23072 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T22:12:14.644211+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-30T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T22:11:56.908889+00:00 2021-04-30T22:11:58.746921+00:00 0:00:01.838032 23071 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T22:11:54.552698+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-30T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T22:11:54.738280+00:00 2021-04-30T22:11:56.486474+00:00 0:00:01.748194 23070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T22:11:52.535409+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-30T21:00:00+00:00 PythonOperator 2021-04-30T22:11:36.750910+00:00 2021-04-30T22:11:39.764832+00:00 0:00:03.013922 23069 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T22:11:34.509476+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-30T21:00:00+00:00 PythonOperator 2021-04-30T22:11:34.724536+00:00 2021-04-30T22:11:38.054016+00:00 0:00:03.329480 23068 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T22:11:32.506888+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T21:00:00+00:00 TriggerDagRunOperator 2021-04-30T22:11:15.392660+00:00 2021-04-30T22:11:15.917748+00:00 0:00:00.525088 23067 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T22:11:12.372633+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T21:00:00+00:00 TriggerDagRunOperator 2021-04-30T22:11:15.255630+00:00 2021-04-30T22:11:15.682002+00:00 0:00:00.426372 23066 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T22:11:12.372674+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-30T21:05:00+00:00 EmrJobFlowSensor 2021-04-30T22:06:03.651714+00:00 2021-04-30T22:15:06.335900+00:00 0:09:02.684186 23064 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T22:06:01.474677+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-30T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-30T22:05:41.707549+00:00 2021-04-30T22:05:43.484899+00:00 0:00:01.777350 23063 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T22:05:39.456006+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-30T21:05:00+00:00 PythonOperator 2021-04-30T22:05:19.648913+00:00 2021-04-30T22:05:22.657628+00:00 0:00:03.008715 23062 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T22:05:17.440450+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T21:00:00+00:00 EmrJobFlowSensor 2021-04-30T22:01:01.091548+00:00 2021-04-30T22:10:03.853073+00:00 0:09:02.761525 23061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T22:00:58.922360+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T22:00:39.135203+00:00 2021-04-30T22:00:40.807471+00:00 0:00:01.672268 23060 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T22:00:36.904986+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T21:00:00+00:00 PythonOperator 2021-04-30T22:00:19.287681+00:00 2021-04-30T22:00:22.315011+00:00 0:00:03.027330 23059 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T22:00:16.885991+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-30T20:00:00+00:00 EmrJobFlowSensor 2021-04-30T21:10:32.501103+00:00 2021-04-30T21:19:35.296806+00:00 0:09:02.795703 23058 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T21:10:30.047247+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-30T20:00:00+00:00 EmrJobFlowSensor 2021-04-30T21:10:20.176973+00:00 2021-04-30T21:18:22.620334+00:00 0:08:02.443361 23057 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T21:10:17.951785+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-30T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T21:10:10.102517+00:00 2021-04-30T21:10:11.809353+00:00 0:00:01.706836 23056 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T21:10:07.940597+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-30T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T21:09:58.273050+00:00 2021-04-30T21:10:00.156203+00:00 0:00:01.883153 23055 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T21:09:55.930537+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-30T20:00:00+00:00 PythonOperator 2021-04-30T21:09:50.112868+00:00 2021-04-30T21:09:53.478426+00:00 0:00:03.365558 23054 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T21:09:47.931325+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-30T20:00:00+00:00 PythonOperator 2021-04-30T21:09:38.499739+00:00 2021-04-30T21:09:41.547350+00:00 0:00:03.047611 23053 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T21:09:35.913922+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-30T20:00:00+00:00 TriggerDagRunOperator 2021-04-30T21:09:30.681374+00:00 2021-04-30T21:09:31.234044+00:00 0:00:00.552670 23052 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T21:09:27.785094+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-30T20:00:00+00:00 TriggerDagRunOperator 2021-04-30T21:09:30.629408+00:00 2021-04-30T21:09:31.108396+00:00 0:00:00.478988 23051 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T21:09:27.785123+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-30T20:05:00+00:00 EmrJobFlowSensor 2021-04-30T21:05:56.547164+00:00 2021-04-30T21:14:59.111812+00:00 0:09:02.564648 23049 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T21:05:54.270637+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-30T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-30T21:05:34.587777+00:00 2021-04-30T21:05:36.366333+00:00 0:00:01.778556 23048 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-30T21:05:32.185199+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-30T20:05:00+00:00 PythonOperator 2021-04-30T21:05:08.353481+00:00 2021-04-30T21:05:11.395202+00:00 0:00:03.041721 23047 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T21:05:06.135785+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-30T20:00:00+00:00 EmrJobFlowSensor 2021-04-30T21:01:02.010329+00:00 2021-04-30T21:09:04.732637+00:00 0:08:02.722308 23046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-30T21:00:59.817623+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-30T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-30T21:00:42.074045+00:00 2021-04-30T21:00:43.798492+00:00 0:00:01.724447 23045 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-30T21:00:39.801112+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-30T20:00:00+00:00 PythonOperator 2021-04-30T21:00:20.263775+00:00 2021-04-30T21:00:23.313071+00:00 0:00:03.049296 23044 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-30T21:00:17.782982+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-30T19:00:00+00:00 EmrJobFlowSensor 2021-04-30T20:12:15.390854+00:00 2021-04-30T20:22:18.329223+00:00 0:10:02.938369 23043 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T20:12:12.985846+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-30T19:00:00+00:00 EmrJobFlowSensor 2021-04-30T20:12:15.269052+00:00 2021-04-30T20:22:18.105974+00:00 0:10:02.836922 23042 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-30T20:12:12.985874+00:00 2 default_pool