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_emr_steps 2021-05-20T05:00:00+00:00 PythonOperator 2021-05-20T06:12:42.342759+00:00 2021-05-20T06:12:45.491742+00:00 0:00:03.148983 30084 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T06:12:40.124533+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-20T05:00:00+00:00 PythonOperator 2021-05-20T06:12:40.440407+00:00 2021-05-20T06:12:43.820904+00:00 0:00:03.380497 30083 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T06:12:38.161257+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-20T05:00:00+00:00 TriggerDagRunOperator 2021-05-20T06:12:22.445308+00:00 2021-05-20T06:12:22.970259+00:00 0:00:00.524951 30082 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T06:12:20.110679+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-20T05:00:00+00:00 TriggerDagRunOperator 2021-05-20T06:12:22.292566+00:00 2021-05-20T06:12:22.680990+00:00 0:00:00.388424 30081 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T06:12:20.110634+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-20T05:05:00+00:00 EmrJobFlowSensor 2021-05-20T06:06:03.500700+00:00 2021-05-20T06:15:06.121225+00:00 0:09:02.620525 30080 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T06:06:01.424621+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-20T05:05:00+00:00 EmrCreateJobFlowOperator 2021-05-20T06:05:43.538607+00:00 2021-05-20T06:05:45.161115+00:00 0:00:01.622508 30079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-20T06:05:41.409081+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-20T05:05:00+00:00 PythonOperator 2021-05-20T06:05:21.710796+00:00 2021-05-20T06:05:24.922413+00:00 0:00:03.211617 30078 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T06:05:19.388894+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-20T05:00:00+00:00 EmrJobFlowSensor 2021-05-20T06:00:59.484981+00:00 2021-05-20T06:12:02.563251+00:00 0:11:03.078270 30077 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T06:00:56.911038+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-20T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-20T06:00:39.045866+00:00 2021-05-20T06:00:40.713735+00:00 0:00:01.667869 30076 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-20T06:00:36.818060+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-20T05:00:00+00:00 PythonOperator 2021-05-20T06:00:17.143605+00:00 2021-05-20T06:00:20.289709+00:00 0:00:03.146104 30075 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-20T06:00:14.799787+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-20T04:00:00+00:00 EmrJobFlowSensor 2021-05-20T05:24:03.888162+00:00 2021-05-20T05:24:05.431023+00:00 0:00:01.542861 30074 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T05:24:01.075784+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-20T04:00:00+00:00 EmrJobFlowSensor 2021-05-20T05:11:34.999743+00:00 2021-05-20T05:20:37.581543+00:00 0:09:02.581800 30071 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T05:11:32.750629+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-20T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-20T05:11:15.109824+00:00 2021-05-20T05:11:17.058503+00:00 0:00:01.948679 30070 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-20T05:11:12.685546+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-20T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-20T05:11:11.072869+00:00 2021-05-20T05:11:12.863767+00:00 0:00:01.790898 30069 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-20T05:11:08.752500+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-20T04:00:00+00:00 PythonOperator 2021-05-20T05:10:53.314576+00:00 2021-05-20T05:10:56.771685+00:00 0:00:03.457109 30068 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T05:10:50.535523+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-20T04:00:00+00:00 PythonOperator 2021-05-20T05:10:48.732759+00:00 2021-05-20T05:10:52.492451+00:00 0:00:03.759692 30067 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T05:10:46.531261+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-20T04:00:00+00:00 TriggerDagRunOperator 2021-05-20T05:10:29.136164+00:00 2021-05-20T05:10:29.741967+00:00 0:00:00.605803 30066 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T05:10:26.527794+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-20T04:00:00+00:00 TriggerDagRunOperator 2021-05-20T05:10:28.886933+00:00 2021-05-20T05:10:29.340545+00:00 0:00:00.453612 30065 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T05:10:26.527831+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-20T04:05:00+00:00 EmrJobFlowSensor 2021-05-20T05:06:08.357401+00:00 2021-05-20T05:14:10.906109+00:00 0:08:02.548708 30064 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T05:06:06.153605+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-20T04:05:00+00:00 EmrCreateJobFlowOperator 2021-05-20T05:05:42.272101+00:00 2021-05-20T05:05:43.979694+00:00 0:00:01.707593 30063 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-20T05:05:40.131460+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-20T04:05:00+00:00 PythonOperator 2021-05-20T05:05:22.313082+00:00 2021-05-20T05:05:25.461447+00:00 0:00:03.148365 30062 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T05:05:20.113210+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-20T04:00:00+00:00 EmrJobFlowSensor 2021-05-20T05:01:08.076583+00:00 2021-05-20T05:10:10.911052+00:00 0:09:02.834469 30061 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T05:01:05.767742+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-20T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-20T05:00:43.888997+00:00 2021-05-20T05:00:45.619789+00:00 0:00:01.730792 30060 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-20T05:00:41.710925+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-20T04:00:00+00:00 PythonOperator 2021-05-20T05:00:24.006665+00:00 2021-05-20T05:00:27.209422+00:00 0:00:03.202757 30059 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-20T05:00:21.699074+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-20T03:00:00+00:00 EmrJobFlowSensor 2021-05-20T04:12:15.442815+00:00 2021-05-20T04:22:18.186175+00:00 0:10:02.743360 30057 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T04:12:13.128601+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-20T03:00:00+00:00 EmrJobFlowSensor 2021-05-20T04:12:13.331984+00:00 2021-05-20T04:21:16.069695+00:00 0:09:02.737711 30056 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T04:12:11.125161+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-20T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-20T04:11:51.343698+00:00 2021-05-20T04:11:53.126701+00:00 0:00:01.783003 30055 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-20T04:11:49.100627+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-20T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-20T04:11:49.443998+00:00 2021-05-20T04:11:51.155035+00:00 0:00:01.711037 30054 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-20T04:11:47.158073+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-20T03:00:00+00:00 PythonOperator 2021-05-20T04:11:31.857908+00:00 2021-05-20T04:11:35.270819+00:00 0:00:03.412911 30053 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T04:11:29.143632+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-20T03:00:00+00:00 PythonOperator 2021-05-20T04:11:29.340153+00:00 2021-05-20T04:11:33.192011+00:00 0:00:03.851858 30052 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T04:11:27.112252+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-20T03:00:00+00:00 TriggerDagRunOperator 2021-05-20T04:11:17.350177+00:00 2021-05-20T04:11:17.922651+00:00 0:00:00.572474 30051 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T04:11:15.069398+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-20T03:00:00+00:00 TriggerDagRunOperator 2021-05-20T04:11:17.193320+00:00 2021-05-20T04:11:17.635738+00:00 0:00:00.442418 30050 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T04:11:15.069434+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-20T03:05:00+00:00 EmrJobFlowSensor 2021-05-20T04:06:08.600411+00:00 2021-05-20T04:15:11.261953+00:00 0:09:02.661542 30049 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T04:06:06.494296+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-20T03:05:00+00:00 EmrCreateJobFlowOperator 2021-05-20T04:05:46.560448+00:00 2021-05-20T04:05:48.180633+00:00 0:00:01.620185 30048 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-20T04:05:44.446967+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-20T03:05:00+00:00 PythonOperator 2021-05-20T04:05:24.551408+00:00 2021-05-20T04:05:27.680526+00:00 0:00:03.129118 30047 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T04:05:22.428322+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-20T03:00:00+00:00 EmrJobFlowSensor 2021-05-20T04:00:54.200184+00:00 2021-05-20T04:10:57.057590+00:00 0:10:02.857406 30046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T04:00:52.001291+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-20T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-20T04:00:32.383105+00:00 2021-05-20T04:00:34.111688+00:00 0:00:01.728583 30045 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-20T04:00:30.044324+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-20T03:00:00+00:00 PythonOperator 2021-05-20T04:00:12.305830+00:00 2021-05-20T04:00:15.477408+00:00 0:00:03.171578 30044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-20T04:00:09.920474+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-20T02:00:00+00:00 EmrJobFlowSensor 2021-05-20T03:10:17.362002+00:00 2021-05-20T03:20:20.146093+00:00 0:10:02.784091 30042 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T03:10:15.200483+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-20T02:00:00+00:00 EmrJobFlowSensor 2021-05-20T03:10:13.491865+00:00 2021-05-20T03:19:16.248401+00:00 0:09:02.756536 30041 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T03:10:11.244636+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-20T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-20T03:09:54.056656+00:00 2021-05-20T03:09:55.725352+00:00 0:00:01.668696 30040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-20T03:09:51.255818+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-20T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-20T03:09:51.628585+00:00 2021-05-20T03:09:53.709656+00:00 0:00:02.081071 30039 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-20T03:09:49.252114+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-20T02:00:00+00:00 PythonOperator 2021-05-20T03:09:31.486232+00:00 2021-05-20T03:09:34.882121+00:00 0:00:03.395889 30038 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T03:09:29.153832+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-20T02:00:00+00:00 PythonOperator 2021-05-20T03:09:29.893252+00:00 2021-05-20T03:09:33.016166+00:00 0:00:03.122914 30037 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T03:09:27.090097+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-20T02:00:00+00:00 TriggerDagRunOperator 2021-05-20T03:09:21.590384+00:00 2021-05-20T03:09:21.975374+00:00 0:00:00.384990 30036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T03:09:19.013826+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-20T02:00:00+00:00 TriggerDagRunOperator 2021-05-20T03:09:21.299963+00:00 2021-05-20T03:09:21.863211+00:00 0:00:00.563248 30035 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T03:09:19.013866+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-20T02:05:00+00:00 EmrJobFlowSensor 2021-05-20T03:06:26.770825+00:00 2021-05-20T03:15:29.406912+00:00 0:09:02.636087 30034 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T03:06:24.627070+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-20T02:05:00+00:00 EmrCreateJobFlowOperator 2021-05-20T03:06:06.820738+00:00 2021-05-20T03:06:08.594094+00:00 0:00:01.773356 30033 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-20T03:06:04.612458+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-20T02:05:00+00:00 PythonOperator 2021-05-20T03:05:30.958209+00:00 2021-05-20T03:05:34.112880+00:00 0:00:03.154671 30032 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T03:05:28.655269+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-20T02:00:00+00:00 EmrJobFlowSensor 2021-05-20T03:01:10.524999+00:00 2021-05-20T03:09:13.040083+00:00 0:08:02.515084 30031 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T03:01:08.273206+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-20T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-20T03:00:48.816291+00:00 2021-05-20T03:00:50.608851+00:00 0:00:01.792560 30030 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-20T03:00:46.268635+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-20T02:00:00+00:00 PythonOperator 2021-05-20T03:00:26.688210+00:00 2021-05-20T03:00:29.841266+00:00 0:00:03.153056 30029 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-20T03:00:24.258133+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-20T01:00:00+00:00 EmrJobFlowSensor 2021-05-20T02:11:17.198479+00:00 2021-05-20T02:21:19.950055+00:00 0:10:02.751576 30027 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T02:11:15.059678+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-20T01:00:00+00:00 EmrJobFlowSensor 2021-05-20T02:11:13.355684+00:00 2021-05-20T02:21:16.276889+00:00 0:10:02.921205 30026 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T02:11:11.056109+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-20T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-20T02:10:53.203304+00:00 2021-05-20T02:10:54.874053+00:00 0:00:01.670749 30025 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-20T02:10:51.041153+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-20T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-20T02:10:49.512997+00:00 2021-05-20T02:10:51.311260+00:00 0:00:01.798263 30024 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-20T02:10:47.047221+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-20T01:00:00+00:00 PythonOperator 2021-05-20T02:10:26.274244+00:00 2021-05-20T02:10:29.430668+00:00 0:00:03.156424 30023 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T02:10:23.062755+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-20T01:00:00+00:00 PythonOperator 2021-05-20T02:10:21.208801+00:00 2021-05-20T02:10:25.245170+00:00 0:00:04.036369 30022 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T02:10:18.990180+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-20T01:00:00+00:00 TriggerDagRunOperator 2021-05-20T02:10:11.355833+00:00 2021-05-20T02:10:11.854830+00:00 0:00:00.498997 30021 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T02:10:08.949140+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-20T01:00:00+00:00 TriggerDagRunOperator 2021-05-20T02:10:11.218828+00:00 2021-05-20T02:10:11.638058+00:00 0:00:00.419230 30020 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T02:10:08.949174+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-20T01:05:00+00:00 EmrJobFlowSensor 2021-05-20T02:05:58.571395+00:00 2021-05-20T02:15:01.332826+00:00 0:09:02.761431 30019 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T02:05:56.431545+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-20T01:05:00+00:00 EmrCreateJobFlowOperator 2021-05-20T02:05:36.587061+00:00 2021-05-20T02:05:38.269018+00:00 0:00:01.681957 30018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-20T02:05:34.460527+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-20T01:05:00+00:00 PythonOperator 2021-05-20T02:05:14.528613+00:00 2021-05-20T02:05:17.647805+00:00 0:00:03.119192 30017 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T02:05:12.380929+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-20T01:00:00+00:00 EmrJobFlowSensor 2021-05-20T02:00:52.247232+00:00 2021-05-20T02:09:54.935800+00:00 0:09:02.688568 30016 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T02:00:50.017692+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-20T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-20T02:00:30.672480+00:00 2021-05-20T02:00:32.494612+00:00 0:00:01.822132 30015 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-20T02:00:28.159282+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-20T01:00:00+00:00 PythonOperator 2021-05-20T02:00:08.279673+00:00 2021-05-20T02:00:11.506808+00:00 0:00:03.227135 30014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-20T02:00:05.978273+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-20T00:00:00+00:00 EmrJobFlowSensor 2021-05-20T01:15:15.966494+00:00 2021-05-20T01:24:18.633666+00:00 0:09:02.667172 30013 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T01:15:13.651258+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-20T00:00:00+00:00 EmrJobFlowSensor 2021-05-20T01:15:07.736220+00:00 2021-05-20T01:26:10.691992+00:00 0:11:02.955772 30012 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T01:15:05.590082+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-20T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-20T01:14:54.340774+00:00 2021-05-20T01:14:56.024050+00:00 0:00:01.683276 30011 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-20T01:14:51.579683+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-20T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-20T01:14:45.688999+00:00 2021-05-20T01:14:47.345615+00:00 0:00:01.656616 30010 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-20T01:14:43.539026+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-20T00:00:00+00:00 PythonOperator 2021-05-20T01:14:33.990463+00:00 2021-05-20T01:14:37.159654+00:00 0:00:03.169191 30009 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T01:14:31.536136+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-20T00:00:00+00:00 PythonOperator 2021-05-20T01:14:23.706150+00:00 2021-05-20T01:14:27.197690+00:00 0:00:03.491540 30008 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T01:14:21.524028+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-20T00:00:00+00:00 TriggerDagRunOperator 2021-05-20T01:14:20.119866+00:00 2021-05-20T01:14:20.639786+00:00 0:00:00.519920 30007 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T01:14:17.484874+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-20T00:00:00+00:00 TriggerDagRunOperator 2021-05-20T01:14:19.833713+00:00 2021-05-20T01:14:20.283194+00:00 0:00:00.449481 30006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T01:14:17.484916+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-20T00:05:00+00:00 EmrJobFlowSensor 2021-05-20T01:05:58.797284+00:00 2021-05-20T01:16:01.440931+00:00 0:10:02.643647 30004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T01:05:56.632994+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-20T00:05:00+00:00 EmrCreateJobFlowOperator 2021-05-20T01:05:36.758367+00:00 2021-05-20T01:05:38.402964+00:00 0:00:01.644597 30003 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-20T01:05:34.620752+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-20T00:05:00+00:00 PythonOperator 2021-05-20T01:05:16.911990+00:00 2021-05-20T01:05:20.084065+00:00 0:00:03.172075 30002 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T01:05:14.595570+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-20T00:00:00+00:00 EmrJobFlowSensor 2021-05-20T01:01:00.689550+00:00 2021-05-20T01:10:03.604472+00:00 0:09:02.914922 30001 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T01:00:58.283183+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-20T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-20T01:00:38.422447+00:00 2021-05-20T01:00:40.134866+00:00 0:00:01.712419 30000 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-20T01:00:36.223418+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-20T00:00:00+00:00 PythonOperator 2021-05-20T01:00:18.358843+00:00 2021-05-20T01:00:21.529938+00:00 0:00:03.171095 29999 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-20T01:00:16.195763+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-19T23:00:00+00:00 EmrJobFlowSensor 2021-05-20T00:11:22.143196+00:00 2021-05-20T00:21:25.059056+00:00 0:10:02.915860 29998 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T00:11:19.948700+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-19T23:00:00+00:00 EmrJobFlowSensor 2021-05-20T00:11:16.091771+00:00 2021-05-20T00:21:18.876229+00:00 0:10:02.784458 29997 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T00:11:13.946701+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-19T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-20T00:11:02.118429+00:00 2021-05-20T00:11:03.838462+00:00 0:00:01.720033 29996 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-20T00:10:59.919760+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-19T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-20T00:10:54.266152+00:00 2021-05-20T00:10:56.100634+00:00 0:00:01.834482 29995 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-20T00:10:51.910296+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-19T23:00:00+00:00 PythonOperator 2021-05-20T00:10:40.204130+00:00 2021-05-20T00:10:43.511696+00:00 0:00:03.307566 29994 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T00:10:37.907015+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-19T23:00:00+00:00 PythonOperator 2021-05-20T00:10:32.209402+00:00 2021-05-20T00:10:35.387170+00:00 0:00:03.177768 29993 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T00:10:29.965349+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-19T23:00:00+00:00 TriggerDagRunOperator 2021-05-20T00:10:20.646363+00:00 2021-05-20T00:10:21.155084+00:00 0:00:00.508721 29992 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T00:10:17.891942+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-19T23:00:00+00:00 TriggerDagRunOperator 2021-05-20T00:10:20.280611+00:00 2021-05-20T00:10:20.682962+00:00 0:00:00.402351 29991 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T00:10:17.891910+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-19T23:05:00+00:00 EmrJobFlowSensor 2021-05-20T00:06:07.175701+00:00 2021-05-20T00:15:09.868731+00:00 0:09:02.693030 29989 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-20T00:06:04.914918+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-19T23:05:00+00:00 EmrCreateJobFlowOperator 2021-05-20T00:05:43.070323+00:00 2021-05-20T00:05:44.702352+00:00 0:00:01.632029 29988 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-20T00:05:40.892672+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-19T23:05:00+00:00 PythonOperator 2021-05-20T00:05:20.975747+00:00 2021-05-20T00:05:24.143368+00:00 0:00:03.167621 29987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T00:05:18.841293+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-19T23:00:00+00:00 EmrJobFlowSensor 2021-05-20T00:01:10.743196+00:00 2021-05-20T00:10:13.531456+00:00 0:09:02.788260 29986 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-20T00:01:08.423646+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-19T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-20T00:00:48.660138+00:00 2021-05-20T00:00:50.460953+00:00 0:00:01.800815 29985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-20T00:00:46.398595+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-19T23:00:00+00:00 PythonOperator 2021-05-20T00:00:22.511878+00:00 2021-05-20T00:00:25.925673+00:00 0:00:03.413795 29984 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-20T00:00:20.327297+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-19T22:00:00+00:00 EmrJobFlowSensor 2021-05-19T23:11:21.452132+00:00 2021-05-19T23:20:24.066453+00:00 0:09:02.614321 29983 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T23:11:19.296360+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-19T22:00:00+00:00 EmrJobFlowSensor 2021-05-19T23:11:09.671480+00:00 2021-05-19T23:21:12.495558+00:00 0:10:02.824078 29982 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-19T23:11:07.365492+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-19T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T23:10:59.596365+00:00 2021-05-19T23:11:01.266715+00:00 0:00:01.670350 29981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T23:10:57.355565+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-19T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-19T23:10:47.413237+00:00 2021-05-19T23:10:49.144599+00:00 0:00:01.731362 29980 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-19T23:10:45.270910+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-19T22:00:00+00:00 PythonOperator 2021-05-19T23:10:37.564142+00:00 2021-05-19T23:10:40.717427+00:00 0:00:03.153285 29979 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T23:10:35.266413+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-19T22:00:00+00:00 PythonOperator 2021-05-19T23:10:25.551142+00:00 2021-05-19T23:10:28.977299+00:00 0:00:03.426157 29978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-19T23:10:23.252951+00:00 2 default_pool