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 vc-asset-import_v002 check_cluster_status 2021-04-22T01:05:00+00:00 EmrJobFlowSensor 2021-04-22T02:05:59.925249+00:00 2021-04-22T02:15:02.698504+00:00 0:09:02.773255 19849 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T02:05:57.751458+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-22T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-22T02:05:38.080440+00:00 2021-04-22T02:05:39.722859+00:00 0:00:01.642419 19848 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T02:05:35.717077+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-22T01:05:00+00:00 PythonOperator 2021-04-22T02:05:16.052168+00:00 2021-04-22T02:05:19.143135+00:00 0:00:03.090967 19847 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T02:05:13.763802+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T01:00:00+00:00 EmrJobFlowSensor 2021-04-22T02:03:47.919884+00:00 2021-04-22T02:13:50.813983+00:00 0:10:02.894099 19846 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T02:03:45.578678+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T02:03:26.591071+00:00 2021-04-22T02:03:28.355008+00:00 0:00:01.763937 19845 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T02:03:23.500747+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T01:00:00+00:00 PythonOperator 2021-04-22T02:03:06.111179+00:00 2021-04-22T02:03:09.125421+00:00 0:00:03.014242 19844 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T02:03:03.485489+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-22T00:00:00+00:00 EmrJobFlowSensor 2021-04-22T01:13:19.995784+00:00 2021-04-22T01:23:22.823132+00:00 0:10:02.827348 19842 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T01:13:17.719450+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-22T00:00:00+00:00 EmrJobFlowSensor 2021-04-22T01:13:15.931661+00:00 2021-04-22T01:22:18.794966+00:00 0:09:02.863305 19841 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T01:13:13.718613+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-22T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T01:12:57.914534+00:00 2021-04-22T01:12:59.815709+00:00 0:00:01.901175 19840 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T01:12:55.699378+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-22T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T01:12:46.166185+00:00 2021-04-22T01:12:47.854275+00:00 0:00:01.688090 19839 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T01:12:43.857948+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-22T00:00:00+00:00 PythonOperator 2021-04-22T01:12:36.053090+00:00 2021-04-22T01:12:39.005503+00:00 0:00:02.952413 19838 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T01:12:33.691262+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-22T00:00:00+00:00 PythonOperator 2021-04-22T01:12:23.996712+00:00 2021-04-22T01:12:27.178589+00:00 0:00:03.181877 19837 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T01:12:21.671389+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T00:00:00+00:00 TriggerDagRunOperator 2021-04-22T01:12:10.027636+00:00 2021-04-22T01:12:10.581255+00:00 0:00:00.553619 19836 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T01:12:07.653697+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T00:00:00+00:00 TriggerDagRunOperator 2021-04-22T01:12:09.881515+00:00 2021-04-22T01:12:10.315593+00:00 0:00:00.434078 19835 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T01:12:07.653668+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-22T00:05:00+00:00 EmrJobFlowSensor 2021-04-22T01:06:09.200720+00:00 2021-04-22T01:15:11.736386+00:00 0:09:02.535666 19834 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T01:06:06.991154+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-22T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-22T01:05:47.238027+00:00 2021-04-22T01:05:48.894676+00:00 0:00:01.656649 19833 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T01:05:44.969302+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-22T00:05:00+00:00 PythonOperator 2021-04-22T01:05:25.238654+00:00 2021-04-22T01:05:28.332589+00:00 0:00:03.093935 19832 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T01:05:22.960153+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T00:00:00+00:00 EmrJobFlowSensor 2021-04-22T01:00:58.961256+00:00 2021-04-22T01:12:01.979730+00:00 0:11:03.018474 19831 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T01:00:56.646407+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T01:00:39.098584+00:00 2021-04-22T01:00:40.908418+00:00 0:00:01.809834 19830 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T01:00:36.568267+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T00:00:00+00:00 PythonOperator 2021-04-22T01:00:16.898921+00:00 2021-04-22T01:00:20.097116+00:00 0:00:03.198195 19829 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T01:00:14.467916+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-21T23:00:00+00:00 EmrJobFlowSensor 2021-04-22T00:12:25.585105+00:00 2021-04-22T00:21:28.155805+00:00 0:09:02.570700 19827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T00:12:23.204073+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-21T23:00:00+00:00 EmrJobFlowSensor 2021-04-22T00:12:15.491388+00:00 2021-04-22T00:23:18.516485+00:00 0:11:03.025097 19826 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T00:12:13.192279+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-21T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T00:12:03.460155+00:00 2021-04-22T00:12:05.162811+00:00 0:00:01.702656 19825 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T00:12:01.181274+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-21T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T00:11:56.085697+00:00 2021-04-22T00:11:57.911727+00:00 0:00:01.826030 19824 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T00:11:53.123949+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-21T23:00:00+00:00 PythonOperator 2021-04-22T00:11:41.400371+00:00 2021-04-22T00:11:44.602425+00:00 0:00:03.202054 19823 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T00:11:39.108343+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-21T23:00:00+00:00 PythonOperator 2021-04-22T00:11:33.278670+00:00 2021-04-22T00:11:36.407702+00:00 0:00:03.129032 19822 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T00:11:31.095189+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T23:00:00+00:00 TriggerDagRunOperator 2021-04-22T00:11:15.894488+00:00 2021-04-22T00:11:16.275035+00:00 0:00:00.380547 19821 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T00:11:13.087789+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T23:00:00+00:00 TriggerDagRunOperator 2021-04-22T00:11:15.348442+00:00 2021-04-22T00:11:15.868612+00:00 0:00:00.520170 19820 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T00:11:13.087834+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-21T23:05:00+00:00 EmrJobFlowSensor 2021-04-22T00:05:56.794537+00:00 2021-04-22T00:13:59.227719+00:00 0:08:02.433182 19819 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T00:05:54.527983+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-21T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-22T00:05:34.697485+00:00 2021-04-22T00:05:36.433522+00:00 0:00:01.736037 19818 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T00:05:32.512282+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-21T23:05:00+00:00 PythonOperator 2021-04-22T00:05:14.884657+00:00 2021-04-22T00:05:17.819252+00:00 0:00:02.934595 19817 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T00:05:12.501770+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T23:00:00+00:00 EmrJobFlowSensor 2021-04-22T00:01:08.904870+00:00 2021-04-22T00:11:11.793738+00:00 0:10:02.888868 19816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T00:01:06.242930+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T00:00:42.921329+00:00 2021-04-22T00:00:44.656606+00:00 0:00:01.735277 19815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T00:00:40.091465+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T23:00:00+00:00 PythonOperator 2021-04-22T00:00:22.841703+00:00 2021-04-22T00:00:25.836729+00:00 0:00:02.995026 19814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T00:00:20.029218+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-21T22:00:00+00:00 EmrJobFlowSensor 2021-04-21T23:12:23.274464+00:00 2021-04-21T23:22:26.179008+00:00 0:10:02.904544 19812 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T23:12:20.907767+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-21T22:00:00+00:00 EmrJobFlowSensor 2021-04-21T23:12:15.393742+00:00 2021-04-21T23:22:18.203605+00:00 0:10:02.809863 19811 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T23:12:12.963073+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-21T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T23:12:01.512520+00:00 2021-04-21T23:12:03.242020+00:00 0:00:01.729500 19810 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T23:11:59.060045+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-21T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T23:11:53.412951+00:00 2021-04-21T23:11:55.199495+00:00 0:00:01.786544 19809 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T23:11:50.881684+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-21T22:00:00+00:00 PythonOperator 2021-04-21T23:11:41.064767+00:00 2021-04-21T23:11:44.045260+00:00 0:00:02.980493 19808 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T23:11:38.846062+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-21T22:00:00+00:00 PythonOperator 2021-04-21T23:11:33.379718+00:00 2021-04-21T23:11:36.954915+00:00 0:00:03.575197 19807 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T23:11:30.946099+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T22:00:00+00:00 TriggerDagRunOperator 2021-04-21T23:11:15.116524+00:00 2021-04-21T23:11:15.546035+00:00 0:00:00.429511 19806 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T23:11:12.747637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T22:00:00+00:00 TriggerDagRunOperator 2021-04-21T23:11:15.080143+00:00 2021-04-21T23:11:15.614903+00:00 0:00:00.534760 19805 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T23:11:12.747611+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-21T22:05:00+00:00 EmrJobFlowSensor 2021-04-21T23:05:54.681453+00:00 2021-04-21T23:14:57.255830+00:00 0:09:02.574377 19804 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T23:05:52.464647+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-21T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-21T23:05:34.542138+00:00 2021-04-21T23:05:36.181147+00:00 0:00:01.639009 19803 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T23:05:32.388882+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-21T22:05:00+00:00 PythonOperator 2021-04-21T23:05:12.617633+00:00 2021-04-21T23:05:15.531716+00:00 0:00:02.914083 19802 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T23:05:10.351305+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T22:00:00+00:00 EmrJobFlowSensor 2021-04-21T23:01:04.183241+00:00 2021-04-21T23:11:06.954037+00:00 0:10:02.770796 19801 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T23:01:01.931378+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T23:00:42.336823+00:00 2021-04-21T23:00:44.016497+00:00 0:00:01.679674 19800 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T23:00:39.912888+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T22:00:00+00:00 PythonOperator 2021-04-21T23:00:20.485424+00:00 2021-04-21T23:00:23.538764+00:00 0:00:03.053340 19799 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T23:00:17.895569+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-21T21:00:00+00:00 EmrJobFlowSensor 2021-04-21T22:12:11.388513+00:00 2021-04-21T22:21:14.091116+00:00 0:09:02.702603 19797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T22:12:09.188981+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-21T21:00:00+00:00 EmrJobFlowSensor 2021-04-21T22:12:05.522303+00:00 2021-04-21T22:21:08.258120+00:00 0:09:02.735817 19796 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T22:12:03.184264+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-21T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T22:11:49.495197+00:00 2021-04-21T22:11:51.206415+00:00 0:00:01.711218 19795 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T22:11:47.158935+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-21T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T22:11:43.361602+00:00 2021-04-21T22:11:45.195795+00:00 0:00:01.834193 19794 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T22:11:41.096259+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-21T21:00:00+00:00 PythonOperator 2021-04-21T22:11:27.580600+00:00 2021-04-21T22:11:30.803148+00:00 0:00:03.222548 19793 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T22:11:25.057629+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-21T21:00:00+00:00 PythonOperator 2021-04-21T22:11:21.448429+00:00 2021-04-21T22:11:24.611226+00:00 0:00:03.162797 19792 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T22:11:19.006087+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T21:00:00+00:00 TriggerDagRunOperator 2021-04-21T22:11:07.527917+00:00 2021-04-21T22:11:08.043720+00:00 0:00:00.515803 19791 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T22:11:05.066849+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T21:00:00+00:00 TriggerDagRunOperator 2021-04-21T22:11:07.420798+00:00 2021-04-21T22:11:07.857415+00:00 0:00:00.436617 19790 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T22:11:05.066798+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-21T21:05:00+00:00 EmrJobFlowSensor 2021-04-21T22:05:48.696589+00:00 2021-04-21T22:14:51.311903+00:00 0:09:02.615314 19789 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T22:05:46.505151+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-21T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-21T22:05:26.887191+00:00 2021-04-21T22:05:28.661466+00:00 0:00:01.774275 19788 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T22:05:24.555207+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-21T21:05:00+00:00 PythonOperator 2021-04-21T22:05:06.562619+00:00 2021-04-21T22:05:09.501038+00:00 0:00:02.938419 19787 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T22:05:04.427771+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T21:00:00+00:00 EmrJobFlowSensor 2021-04-21T22:00:52.311624+00:00 2021-04-21T22:10:55.077208+00:00 0:10:02.765584 19786 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T22:00:50.145333+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T22:00:30.437533+00:00 2021-04-21T22:00:32.306738+00:00 0:00:01.869205 19785 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T22:00:28.148336+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T21:00:00+00:00 PythonOperator 2021-04-21T22:00:10.728371+00:00 2021-04-21T22:00:13.671895+00:00 0:00:02.943524 19784 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T22:00:08.021665+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-21T20:00:00+00:00 EmrJobFlowSensor 2021-04-21T21:11:45.784069+00:00 2021-04-21T21:21:48.589520+00:00 0:10:02.805451 19782 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T21:11:43.149170+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-21T20:00:00+00:00 EmrJobFlowSensor 2021-04-21T21:11:23.968737+00:00 2021-04-21T21:20:26.636003+00:00 0:09:02.667266 19781 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T21:11:21.055248+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-21T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T21:11:11.656067+00:00 2021-04-21T21:11:13.444473+00:00 0:00:01.788406 19780 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T21:11:09.059712+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-21T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T21:10:59.370269+00:00 2021-04-21T21:11:01.150534+00:00 0:00:01.780265 19779 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T21:10:57.036197+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-21T20:00:00+00:00 PythonOperator 2021-04-21T21:10:45.402427+00:00 2021-04-21T21:10:48.652721+00:00 0:00:03.250294 19778 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T21:10:43.066504+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-21T20:00:00+00:00 PythonOperator 2021-04-21T21:10:39.413216+00:00 2021-04-21T21:10:42.333999+00:00 0:00:02.920783 19777 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T21:10:37.080379+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T20:00:00+00:00 TriggerDagRunOperator 2021-04-21T21:10:25.441499+00:00 2021-04-21T21:10:25.962075+00:00 0:00:00.520576 19776 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T21:10:23.004129+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T20:00:00+00:00 TriggerDagRunOperator 2021-04-21T21:10:25.238701+00:00 2021-04-21T21:10:25.650554+00:00 0:00:00.411853 19775 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T21:10:23.004158+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-21T20:05:00+00:00 EmrJobFlowSensor 2021-04-21T21:06:00.878023+00:00 2021-04-21T21:15:03.416452+00:00 0:09:02.538429 19774 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T21:05:58.450590+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-21T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-21T21:05:38.702337+00:00 2021-04-21T21:05:40.436843+00:00 0:00:01.734506 19773 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T21:05:36.186272+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-21T20:05:00+00:00 PythonOperator 2021-04-21T21:05:18.399358+00:00 2021-04-21T21:05:21.553198+00:00 0:00:03.153840 19772 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T21:05:16.149348+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T20:00:00+00:00 EmrJobFlowSensor 2021-04-21T21:01:12.014641+00:00 2021-04-21T21:10:14.754258+00:00 0:09:02.739617 19771 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T21:01:09.825424+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T21:00:48.105407+00:00 2021-04-21T21:00:50.319358+00:00 0:00:02.213951 19770 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T21:00:45.803148+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T20:00:00+00:00 PythonOperator 2021-04-21T21:00:24.498327+00:00 2021-04-21T21:00:27.461327+00:00 0:00:02.963000 19769 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T21:00:21.789679+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-21T19:00:00+00:00 EmrJobFlowSensor 2021-04-21T20:13:18.767316+00:00 2021-04-21T20:21:21.196238+00:00 0:08:02.428922 19767 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T20:13:16.452147+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-21T19:00:00+00:00 EmrJobFlowSensor 2021-04-21T20:13:12.724146+00:00 2021-04-21T20:22:15.477608+00:00 0:09:02.753462 19766 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T20:13:10.421275+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-21T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T20:12:56.848007+00:00 2021-04-21T20:12:58.675374+00:00 0:00:01.827367 19765 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T20:12:54.471824+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-21T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T20:12:50.814152+00:00 2021-04-21T20:12:52.660958+00:00 0:00:01.846806 19764 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T20:12:48.459481+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-21T19:00:00+00:00 PythonOperator 2021-04-21T20:12:34.918641+00:00 2021-04-21T20:12:37.977569+00:00 0:00:03.058928 19763 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T20:12:32.441046+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-21T19:00:00+00:00 PythonOperator 2021-04-21T20:12:28.847749+00:00 2021-04-21T20:12:32.189067+00:00 0:00:03.341318 19762 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T20:12:26.453330+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T19:00:00+00:00 TriggerDagRunOperator 2021-04-21T20:12:12.640694+00:00 2021-04-21T20:12:13.218602+00:00 0:00:00.577908 19761 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T20:12:10.363355+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T19:00:00+00:00 TriggerDagRunOperator 2021-04-21T20:12:12.570220+00:00 2021-04-21T20:12:13.052821+00:00 0:00:00.482601 19760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T20:12:10.363389+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-21T19:05:00+00:00 EmrJobFlowSensor 2021-04-21T20:06:02.004840+00:00 2021-04-21T20:15:04.759702+00:00 0:09:02.754862 19759 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T20:05:59.856493+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-21T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-21T20:05:39.988004+00:00 2021-04-21T20:05:41.734902+00:00 0:00:01.746898 19758 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T20:05:37.763337+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-21T19:05:00+00:00 PythonOperator 2021-04-21T20:05:18.236295+00:00 2021-04-21T20:05:21.125109+00:00 0:00:02.888814 19757 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T20:05:15.759228+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T19:00:00+00:00 EmrJobFlowSensor 2021-04-21T20:00:55.922720+00:00 2021-04-21T20:11:58.848976+00:00 0:11:02.926256 19756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T20:00:53.366244+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T20:00:33.667725+00:00 2021-04-21T20:00:35.648231+00:00 0:00:01.980506 19755 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T20:00:31.360296+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T19:00:00+00:00 PythonOperator 2021-04-21T20:00:11.658280+00:00 2021-04-21T20:00:14.825487+00:00 0:00:03.167207 19754 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T20:00:09.284370+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-21T18:00:00+00:00 EmrJobFlowSensor 2021-04-21T19:12:42.335696+00:00 2021-04-21T19:20:45.075591+00:00 0:08:02.739895 19752 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T19:12:40.113978+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-21T18:00:00+00:00 EmrJobFlowSensor 2021-04-21T19:12:30.895325+00:00 2021-04-21T19:22:33.475737+00:00 0:10:02.580412 19751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T19:12:28.260187+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-21T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T19:12:20.277459+00:00 2021-04-21T19:12:22.210725+00:00 0:00:01.933266 19750 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T19:12:18.096435+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-21T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T19:12:10.987535+00:00 2021-04-21T19:12:13.431994+00:00 0:00:02.444459 19749 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T19:12:08.092798+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-21T18:00:00+00:00 PythonOperator 2021-04-21T19:12:00.412026+00:00 2021-04-21T19:12:03.375454+00:00 0:00:02.963428 19748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T19:11:58.053897+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-21T18:00:00+00:00 PythonOperator 2021-04-21T19:11:46.174831+00:00 2021-04-21T19:11:49.810609+00:00 0:00:03.635778 19747 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T19:11:43.920780+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T18:00:00+00:00 TriggerDagRunOperator 2021-04-21T19:11:36.239032+00:00 2021-04-21T19:11:36.711346+00:00 0:00:00.472314 19746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T19:11:33.915793+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T18:00:00+00:00 TriggerDagRunOperator 2021-04-21T19:11:36.237905+00:00 2021-04-21T19:11:36.792698+00:00 0:00:00.554793 19745 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T19:11:33.915826+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-21T18:05:00+00:00 EmrJobFlowSensor 2021-04-21T19:05:47.705479+00:00 2021-04-21T19:14:50.620068+00:00 0:09:02.914589 19744 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T19:05:45.419715+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-21T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-21T19:05:25.575059+00:00 2021-04-21T19:05:27.815780+00:00 0:00:02.240721 19743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-21T19:05:23.399413+00:00 2 default_pool