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 trigger_dagrun_booking-processing-job_v002 2021-04-27T08:00:00+00:00 TriggerDagRunOperator 2021-04-27T09:12:08.501311+00:00 2021-04-27T09:12:08.920639+00:00 0:00:00.419328 21779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T09:12:06.195706+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T08:05:00+00:00 EmrJobFlowSensor 2021-04-27T09:06:01.846224+00:00 2021-04-27T09:15:04.442879+00:00 0:09:02.596655 21778 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T09:05:59.541230+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T09:05:39.968208+00:00 2021-04-27T09:05:41.723537+00:00 0:00:01.755329 21777 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T09:05:37.481190+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T08:05:00+00:00 PythonOperator 2021-04-27T09:05:19.544995+00:00 2021-04-27T09:05:22.510885+00:00 0:00:02.965890 21776 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T09:05:17.390821+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T08:00:00+00:00 EmrJobFlowSensor 2021-04-27T09:02:59.462077+00:00 2021-04-27T09:12:02.235150+00:00 0:09:02.773073 21775 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T09:02:57.196725+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T09:02:37.437859+00:00 2021-04-27T09:02:39.216311+00:00 0:00:01.778452 21774 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T09:02:35.162676+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T08:00:00+00:00 PythonOperator 2021-04-27T09:02:17.736152+00:00 2021-04-27T09:02:20.717815+00:00 0:00:02.981663 21773 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T09:02:15.017282+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T07:00:00+00:00 EmrJobFlowSensor 2021-04-27T08:12:20.636558+00:00 2021-04-27T08:23:23.669649+00:00 0:11:03.033091 21771 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T08:12:18.200453+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T07:00:00+00:00 EmrJobFlowSensor 2021-04-27T08:12:16.583243+00:00 2021-04-27T08:22:19.430400+00:00 0:10:02.847157 21770 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T08:12:14.195098+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T08:11:58.460864+00:00 2021-04-27T08:12:00.290826+00:00 0:00:01.829962 21769 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T08:11:56.265883+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T08:11:54.468005+00:00 2021-04-27T08:11:56.255300+00:00 0:00:01.787295 21768 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T08:11:52.153494+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T07:00:00+00:00 PythonOperator 2021-04-27T08:11:38.802173+00:00 2021-04-27T08:11:42.159425+00:00 0:00:03.357252 21767 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T08:11:36.141737+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T07:00:00+00:00 PythonOperator 2021-04-27T08:11:34.341903+00:00 2021-04-27T08:11:37.749917+00:00 0:00:03.408014 21766 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T08:11:32.142375+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T07:00:00+00:00 TriggerDagRunOperator 2021-04-27T08:11:14.808911+00:00 2021-04-27T08:11:15.232730+00:00 0:00:00.423819 21765 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T08:11:12.125786+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T07:00:00+00:00 TriggerDagRunOperator 2021-04-27T08:11:14.425014+00:00 2021-04-27T08:11:14.958574+00:00 0:00:00.533560 21764 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T08:11:12.125754+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T07:05:00+00:00 EmrJobFlowSensor 2021-04-27T08:06:02.047767+00:00 2021-04-27T08:15:04.743170+00:00 0:09:02.695403 21763 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T08:05:59.579333+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T08:05:39.961665+00:00 2021-04-27T08:05:41.675860+00:00 0:00:01.714195 21762 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T08:05:37.570743+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T07:05:00+00:00 PythonOperator 2021-04-27T08:05:19.502817+00:00 2021-04-27T08:05:22.490790+00:00 0:00:02.987973 21761 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T08:05:17.284864+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T07:00:00+00:00 EmrJobFlowSensor 2021-04-27T08:01:03.316409+00:00 2021-04-27T08:11:06.110521+00:00 0:10:02.794112 21760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T08:01:00.860062+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T08:00:41.261609+00:00 2021-04-27T08:00:43.093268+00:00 0:00:01.831659 21759 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T08:00:38.879777+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T07:00:00+00:00 PythonOperator 2021-04-27T08:00:19.318799+00:00 2021-04-27T08:00:22.279410+00:00 0:00:02.960611 21758 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T08:00:16.862742+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T06:00:00+00:00 EmrJobFlowSensor 2021-04-27T07:12:12.678293+00:00 2021-04-27T07:24:15.743581+00:00 0:12:03.065288 21756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T07:12:10.496281+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T06:00:00+00:00 EmrJobFlowSensor 2021-04-27T07:12:02.912993+00:00 2021-04-27T07:21:05.725221+00:00 0:09:02.812228 21755 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T07:12:00.554470+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T07:11:51.017943+00:00 2021-04-27T07:11:52.797060+00:00 0:00:01.779117 21754 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T07:11:48.486554+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T07:11:40.592681+00:00 2021-04-27T07:11:42.368123+00:00 0:00:01.775442 21753 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T07:11:38.423840+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T06:00:00+00:00 PythonOperator 2021-04-27T07:11:31.071564+00:00 2021-04-27T07:11:34.388925+00:00 0:00:03.317361 21752 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T07:11:28.544390+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T06:00:00+00:00 PythonOperator 2021-04-27T07:11:19.708431+00:00 2021-04-27T07:11:22.870148+00:00 0:00:03.161717 21751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T07:11:16.541115+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T06:00:00+00:00 TriggerDagRunOperator 2021-04-27T07:11:10.862224+00:00 2021-04-27T07:11:11.376311+00:00 0:00:00.514087 21750 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T07:11:08.425690+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T06:00:00+00:00 TriggerDagRunOperator 2021-04-27T07:11:10.812823+00:00 2021-04-27T07:11:11.239955+00:00 0:00:00.427132 21749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T07:11:08.425734+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T06:05:00+00:00 EmrJobFlowSensor 2021-04-27T07:06:04.534920+00:00 2021-04-27T07:14:07.233429+00:00 0:08:02.698509 21748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T07:06:01.968030+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T07:05:42.198064+00:00 2021-04-27T07:05:43.996677+00:00 0:00:01.798613 21747 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T07:05:39.853416+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T06:05:00+00:00 PythonOperator 2021-04-27T07:05:21.882382+00:00 2021-04-27T07:05:24.843170+00:00 0:00:02.960788 21746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T07:05:19.766498+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T06:00:00+00:00 EmrJobFlowSensor 2021-04-27T07:00:47.330699+00:00 2021-04-27T07:10:50.191882+00:00 0:10:02.861183 21745 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T07:00:44.995763+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T07:00:25.240501+00:00 2021-04-27T07:00:26.907061+00:00 0:00:01.666560 21744 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T07:00:22.956328+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T06:00:00+00:00 PythonOperator 2021-04-27T07:00:05.570828+00:00 2021-04-27T07:00:08.569159+00:00 0:00:02.998331 21743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T07:00:02.956833+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T05:00:00+00:00 EmrJobFlowSensor 2021-04-27T06:22:03.960007+00:00 2021-04-27T06:22:05.509030+00:00 0:00:01.549023 21741 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T06:22:01.683964+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T05:00:00+00:00 EmrJobFlowSensor 2021-04-27T06:10:12.211477+00:00 2021-04-27T06:18:14.858413+00:00 0:08:02.646936 21739 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T06:10:10.050977+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T06:09:56.421374+00:00 2021-04-27T06:09:58.106941+00:00 0:00:01.685567 21738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T06:09:54.141114+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T06:09:50.293138+00:00 2021-04-27T06:09:52.087243+00:00 0:00:01.794105 21737 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T06:09:48.051487+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T05:00:00+00:00 PythonOperator 2021-04-27T06:09:34.520633+00:00 2021-04-27T06:09:37.769046+00:00 0:00:03.248413 21736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T06:09:31.993155+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T05:00:00+00:00 PythonOperator 2021-04-27T06:09:30.502731+00:00 2021-04-27T06:09:33.908908+00:00 0:00:03.406177 21735 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T06:09:27.964846+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T05:00:00+00:00 TriggerDagRunOperator 2021-04-27T06:09:12.109388+00:00 2021-04-27T06:09:12.670600+00:00 0:00:00.561212 21734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T06:09:09.836460+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T05:00:00+00:00 TriggerDagRunOperator 2021-04-27T06:09:12.060938+00:00 2021-04-27T06:09:12.481296+00:00 0:00:00.420358 21733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T06:09:09.836496+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T05:05:00+00:00 EmrJobFlowSensor 2021-04-27T06:05:49.558879+00:00 2021-04-27T06:14:52.109521+00:00 0:09:02.550642 21732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T06:05:47.400857+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T06:05:29.876248+00:00 2021-04-27T06:05:31.611331+00:00 0:00:01.735083 21731 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T06:05:27.386832+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T05:05:00+00:00 PythonOperator 2021-04-27T06:05:07.476670+00:00 2021-04-27T06:05:10.413516+00:00 0:00:02.936846 21730 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T06:05:05.362286+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T05:00:00+00:00 EmrJobFlowSensor 2021-04-27T06:00:57.198949+00:00 2021-04-27T06:08:59.790126+00:00 0:08:02.591177 21729 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T06:00:54.703168+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T06:00:35.233752+00:00 2021-04-27T06:00:36.938031+00:00 0:00:01.704279 21728 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T06:00:32.763970+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T05:00:00+00:00 PythonOperator 2021-04-27T06:00:06.794681+00:00 2021-04-27T06:00:09.766825+00:00 0:00:02.972144 21727 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T06:00:04.526572+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T04:00:00+00:00 EmrJobFlowSensor 2021-04-27T05:12:22.240766+00:00 2021-04-27T05:20:24.757650+00:00 0:08:02.516884 21725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T05:12:19.865749+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T04:00:00+00:00 EmrJobFlowSensor 2021-04-27T05:12:18.211306+00:00 2021-04-27T05:22:20.968723+00:00 0:10:02.757417 21724 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T05:12:15.856021+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T05:12:02.358554+00:00 2021-04-27T05:12:04.135249+00:00 0:00:01.776695 21723 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T05:11:59.387219+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T05:11:57.731308+00:00 2021-04-27T05:11:59.573824+00:00 0:00:01.842516 21722 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T05:11:55.385797+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T04:00:00+00:00 PythonOperator 2021-04-27T05:11:39.853422+00:00 2021-04-27T05:11:42.962413+00:00 0:00:03.108991 21721 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T05:11:37.353587+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T04:00:00+00:00 PythonOperator 2021-04-27T05:11:35.786804+00:00 2021-04-27T05:11:38.989105+00:00 0:00:03.202301 21720 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T05:11:33.459297+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T04:00:00+00:00 TriggerDagRunOperator 2021-04-27T05:11:25.717794+00:00 2021-04-27T05:11:26.234077+00:00 0:00:00.516283 21719 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T05:11:23.291681+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T04:00:00+00:00 TriggerDagRunOperator 2021-04-27T05:11:25.483883+00:00 2021-04-27T05:11:25.892490+00:00 0:00:00.408607 21718 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T05:11:23.291728+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T04:05:00+00:00 EmrJobFlowSensor 2021-04-27T05:05:52.784980+00:00 2021-04-27T05:14:55.415549+00:00 0:09:02.630569 21717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T05:05:50.524026+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T05:05:30.907770+00:00 2021-04-27T05:05:32.662785+00:00 0:00:01.755015 21716 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T05:05:28.507375+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T04:05:00+00:00 PythonOperator 2021-04-27T05:05:08.594761+00:00 2021-04-27T05:05:11.641408+00:00 0:00:03.046647 21715 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T05:05:06.454797+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T04:00:00+00:00 EmrJobFlowSensor 2021-04-27T05:01:04.188164+00:00 2021-04-27T05:11:07.291345+00:00 0:10:03.103181 21714 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T05:01:01.762293+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T05:00:42.106610+00:00 2021-04-27T05:00:44.085587+00:00 0:00:01.978977 21713 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T05:00:39.643703+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T04:00:00+00:00 PythonOperator 2021-04-27T05:00:21.839425+00:00 2021-04-27T05:00:24.828681+00:00 0:00:02.989256 21712 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T05:00:19.518572+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T03:00:00+00:00 EmrJobFlowSensor 2021-04-27T04:11:01.392492+00:00 2021-04-27T04:21:04.305078+00:00 0:10:02.912586 21710 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T04:10:59.100062+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T03:00:00+00:00 EmrJobFlowSensor 2021-04-27T04:10:55.630490+00:00 2021-04-27T04:20:58.559173+00:00 0:10:02.928683 21709 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T04:10:53.163592+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T04:10:39.348408+00:00 2021-04-27T04:10:41.042303+00:00 0:00:01.693895 21708 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T04:10:37.068218+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T04:10:35.410734+00:00 2021-04-27T04:10:37.139044+00:00 0:00:01.728310 21707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T04:10:33.040742+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T03:00:00+00:00 PythonOperator 2021-04-27T04:10:19.367125+00:00 2021-04-27T04:10:22.387656+00:00 0:00:03.020531 21706 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T04:10:17.025527+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T03:00:00+00:00 PythonOperator 2021-04-27T04:10:13.708448+00:00 2021-04-27T04:10:16.955007+00:00 0:00:03.246559 21705 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T04:10:11.021689+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T03:00:00+00:00 TriggerDagRunOperator 2021-04-27T04:10:05.527268+00:00 2021-04-27T04:10:05.957998+00:00 0:00:00.430730 21704 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T04:10:03.012459+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T03:00:00+00:00 TriggerDagRunOperator 2021-04-27T04:10:05.373148+00:00 2021-04-27T04:10:05.920770+00:00 0:00:00.547622 21703 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T04:10:03.012495+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T03:05:00+00:00 EmrJobFlowSensor 2021-04-27T04:05:59.231077+00:00 2021-04-27T04:14:01.785358+00:00 0:08:02.554281 21702 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T04:05:56.652240+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T04:05:38.780906+00:00 2021-04-27T04:05:40.553229+00:00 0:00:01.772323 21701 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T04:05:36.541136+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T03:05:00+00:00 PythonOperator 2021-04-27T04:05:16.714180+00:00 2021-04-27T04:05:19.695364+00:00 0:00:02.981184 21700 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T04:05:14.474611+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T03:00:00+00:00 EmrJobFlowSensor 2021-04-27T04:00:56.100484+00:00 2021-04-27T04:09:58.700904+00:00 0:09:02.600420 21699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T04:00:53.890504+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T04:00:34.175292+00:00 2021-04-27T04:00:35.886119+00:00 0:00:01.710827 21698 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T04:00:31.831335+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T03:00:00+00:00 PythonOperator 2021-04-27T04:00:12.112067+00:00 2021-04-27T04:00:15.208796+00:00 0:00:03.096729 21697 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T04:00:09.798279+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T02:00:00+00:00 EmrJobFlowSensor 2021-04-27T03:12:17.244594+00:00 2021-04-27T03:22:20.162721+00:00 0:10:02.918127 21695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T03:12:15.058533+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T02:00:00+00:00 EmrJobFlowSensor 2021-04-27T03:12:09.332082+00:00 2021-04-27T03:20:11.921506+00:00 0:08:02.589424 21694 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T03:12:07.044901+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T03:11:57.671306+00:00 2021-04-27T03:11:59.343232+00:00 0:00:01.671926 21693 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T03:11:55.050204+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T03:11:49.402580+00:00 2021-04-27T03:11:51.108510+00:00 0:00:01.705930 21692 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T03:11:47.035324+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T02:00:00+00:00 PythonOperator 2021-04-27T03:11:35.373909+00:00 2021-04-27T03:11:38.705421+00:00 0:00:03.331512 21691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T03:11:33.045878+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T02:00:00+00:00 PythonOperator 2021-04-27T03:11:21.206680+00:00 2021-04-27T03:11:24.232973+00:00 0:00:03.026293 21690 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T03:11:19.006984+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T02:00:00+00:00 TriggerDagRunOperator 2021-04-27T03:11:01.332011+00:00 2021-04-27T03:11:01.792449+00:00 0:00:00.460438 21689 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T03:10:58.984332+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T02:00:00+00:00 TriggerDagRunOperator 2021-04-27T03:11:01.238229+00:00 2021-04-27T03:11:01.809099+00:00 0:00:00.570870 21688 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T03:10:58.984359+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T02:05:00+00:00 EmrJobFlowSensor 2021-04-27T03:06:02.429594+00:00 2021-04-27T03:15:05.061505+00:00 0:09:02.631911 21687 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T03:06:00.229355+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T03:05:38.536444+00:00 2021-04-27T03:05:40.313073+00:00 0:00:01.776629 21686 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T03:05:36.190909+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T02:05:00+00:00 PythonOperator 2021-04-27T03:05:16.261354+00:00 2021-04-27T03:05:19.228602+00:00 0:00:02.967248 21685 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T03:05:14.171204+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T02:00:00+00:00 EmrJobFlowSensor 2021-04-27T03:00:51.641190+00:00 2021-04-27T03:10:54.433745+00:00 0:10:02.792555 21684 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T03:00:49.499235+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T03:00:29.798025+00:00 2021-04-27T03:00:31.503120+00:00 0:00:01.705095 21683 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T03:00:27.467775+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T02:00:00+00:00 PythonOperator 2021-04-27T03:00:10.037850+00:00 2021-04-27T03:00:13.065154+00:00 0:00:03.027304 21682 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T03:00:07.415898+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T01:00:00+00:00 EmrJobFlowSensor 2021-04-27T02:11:12.451101+00:00 2021-04-27T02:21:15.318194+00:00 0:10:02.867093 21680 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T02:11:10.190027+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T01:00:00+00:00 EmrJobFlowSensor 2021-04-27T02:11:00.790374+00:00 2021-04-27T02:20:03.460094+00:00 0:09:02.669720 21679 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T02:10:58.254130+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T02:10:52.355236+00:00 2021-04-27T02:10:54.250917+00:00 0:00:01.895681 21678 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T02:10:50.089564+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T02:10:38.722149+00:00 2021-04-27T02:10:40.566521+00:00 0:00:01.844372 21677 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T02:10:36.145768+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T01:00:00+00:00 PythonOperator 2021-04-27T02:10:30.300625+00:00 2021-04-27T02:10:33.485815+00:00 0:00:03.185190 21676 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T02:10:28.063105+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T01:00:00+00:00 PythonOperator 2021-04-27T02:10:16.184048+00:00 2021-04-27T02:10:19.141951+00:00 0:00:02.957903 21675 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T02:10:14.046378+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T01:00:00+00:00 TriggerDagRunOperator 2021-04-27T02:10:12.313710+00:00 2021-04-27T02:10:12.915033+00:00 0:00:00.601323 21674 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T02:10:10.052063+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T01:00:00+00:00 TriggerDagRunOperator 2021-04-27T02:10:12.293089+00:00 2021-04-27T02:10:12.780063+00:00 0:00:00.486974 21673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T02:10:10.052104+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T01:05:00+00:00 EmrJobFlowSensor 2021-04-27T02:06:01.635433+00:00 2021-04-27T02:14:04.143155+00:00 0:08:02.507722 21672 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T02:05:59.271762+00:00 2 default_pool