Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-31T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T14:18:20.602518+00:00 2021-03-31T14:18:22.315915+00:00 0:00:01.713397 12071 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T14:18:18.439061+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-31T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T14:18:06.792781+00:00 2021-03-31T14:18:08.575363+00:00 0:00:01.782582 12070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T14:18:04.416616+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-31T13:00:00+00:00 PythonOperator 2021-03-31T14:17:52.667832+00:00 2021-03-31T14:17:55.410590+00:00 0:00:02.742758 12069 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T14:17:50.404177+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-31T13:00:00+00:00 PythonOperator 2021-03-31T14:17:44.715179+00:00 2021-03-31T14:17:47.865469+00:00 0:00:03.150290 12068 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T14:17:42.397710+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T13:00:00+00:00 TriggerDagRunOperator 2021-03-31T14:17:34.934192+00:00 2021-03-31T14:17:35.481378+00:00 0:00:00.547186 12067 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T14:17:32.404366+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T13:00:00+00:00 TriggerDagRunOperator 2021-03-31T14:17:34.807514+00:00 2021-03-31T14:17:35.250163+00:00 0:00:00.442649 12066 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T14:17:32.404335+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-31T13:05:00+00:00 EmrJobFlowSensor 2021-03-31T14:06:03.996064+00:00 2021-03-31T14:15:06.583548+00:00 0:09:02.587484 12064 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T14:06:01.716885+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-31T13:05:00+00:00 EmrCreateJobFlowOperator 2021-03-31T14:05:41.998415+00:00 2021-03-31T14:05:43.849091+00:00 0:00:01.850676 12063 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T14:05:39.675618+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-31T13:05:00+00:00 PythonOperator 2021-03-31T14:05:20.075749+00:00 2021-03-31T14:05:22.837395+00:00 0:00:02.761646 12062 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T14:05:17.646474+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T13:00:00+00:00 EmrJobFlowSensor 2021-03-31T14:00:55.304952+00:00 2021-03-31T14:10:58.144259+00:00 0:10:02.839307 12061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T14:00:53.094295+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T14:00:35.244500+00:00 2021-03-31T14:00:36.974174+00:00 0:00:01.729674 12060 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T14:00:33.060922+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T13:00:00+00:00 PythonOperator 2021-03-31T14:00:13.248581+00:00 2021-03-31T14:00:16.004005+00:00 0:00:02.755424 12059 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T14:00:11.046014+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-31T12:00:00+00:00 EmrJobFlowSensor 2021-03-31T13:12:34.785949+00:00 2021-03-31T13:20:37.329401+00:00 0:08:02.543452 12058 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T13:12:32.400920+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-31T12:00:00+00:00 EmrJobFlowSensor 2021-03-31T13:12:22.662187+00:00 2021-03-31T13:22:25.531334+00:00 0:10:02.869147 12057 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T13:12:20.388381+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-31T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T13:12:12.935375+00:00 2021-03-31T13:12:14.682029+00:00 0:00:01.746654 12056 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T13:12:10.353894+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-31T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T13:12:00.733208+00:00 2021-03-31T13:12:02.624208+00:00 0:00:01.891000 12055 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T13:11:58.289953+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-31T12:00:00+00:00 PythonOperator 2021-03-31T13:11:52.744409+00:00 2021-03-31T13:11:55.549045+00:00 0:00:02.804636 12054 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T13:11:50.344308+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-31T12:00:00+00:00 PythonOperator 2021-03-31T13:11:38.649211+00:00 2021-03-31T13:11:41.587408+00:00 0:00:02.938197 12053 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T13:11:36.271817+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T12:00:00+00:00 TriggerDagRunOperator 2021-03-31T13:11:33.174975+00:00 2021-03-31T13:11:33.740574+00:00 0:00:00.565599 12052 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T13:11:30.077872+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T12:00:00+00:00 TriggerDagRunOperator 2021-03-31T13:11:33.102520+00:00 2021-03-31T13:11:33.615403+00:00 0:00:00.512883 12051 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T13:11:30.077829+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-31T12:05:00+00:00 EmrJobFlowSensor 2021-03-31T13:06:06.828385+00:00 2021-03-31T13:15:09.451783+00:00 0:09:02.623398 12049 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T13:06:04.555200+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-31T12:05:00+00:00 EmrCreateJobFlowOperator 2021-03-31T13:05:44.665941+00:00 2021-03-31T13:05:46.300659+00:00 0:00:01.634718 12048 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T13:05:42.538743+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-31T12:05:00+00:00 PythonOperator 2021-03-31T13:05:23.020887+00:00 2021-03-31T13:05:25.783197+00:00 0:00:02.762310 12047 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T13:05:20.566890+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T12:00:00+00:00 EmrJobFlowSensor 2021-03-31T13:01:04.320048+00:00 2021-03-31T13:11:07.247382+00:00 0:10:02.927334 12046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T13:01:02.021234+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T13:00:42.273793+00:00 2021-03-31T13:00:44.104448+00:00 0:00:01.830655 12045 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T13:00:39.995901+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T12:00:00+00:00 PythonOperator 2021-03-31T13:00:20.132160+00:00 2021-03-31T13:00:22.871978+00:00 0:00:02.739818 12044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T13:00:17.946779+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-31T11:00:00+00:00 EmrJobFlowSensor 2021-03-31T12:12:21.345494+00:00 2021-03-31T12:23:24.399431+00:00 0:11:03.053937 12043 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T12:12:19.117278+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-31T11:00:00+00:00 EmrJobFlowSensor 2021-03-31T12:12:05.380784+00:00 2021-03-31T12:21:08.071487+00:00 0:09:02.690703 12042 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T12:12:03.109524+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-31T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T12:12:01.417156+00:00 2021-03-31T12:12:03.382370+00:00 0:00:01.965214 12041 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T12:11:59.101250+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-31T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T12:11:43.409913+00:00 2021-03-31T12:11:45.249524+00:00 0:00:01.839611 12040 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T12:11:41.085820+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-31T11:00:00+00:00 PythonOperator 2021-03-31T12:11:39.321264+00:00 2021-03-31T12:11:42.244026+00:00 0:00:02.922762 12039 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T12:11:37.079884+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-31T11:00:00+00:00 PythonOperator 2021-03-31T12:11:21.249041+00:00 2021-03-31T12:11:24.037638+00:00 0:00:02.788597 12038 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T12:11:19.059865+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T11:00:00+00:00 TriggerDagRunOperator 2021-03-31T12:11:15.461405+00:00 2021-03-31T12:11:15.938045+00:00 0:00:00.476640 12037 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T12:11:13.056409+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T11:00:00+00:00 TriggerDagRunOperator 2021-03-31T12:11:15.439298+00:00 2021-03-31T12:11:16.047195+00:00 0:00:00.607897 12036 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T12:11:13.056444+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-31T11:05:00+00:00 EmrJobFlowSensor 2021-03-31T12:07:44.966530+00:00 2021-03-31T12:16:47.630601+00:00 0:09:02.664071 12035 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T12:07:42.746623+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-31T11:05:00+00:00 EmrCreateJobFlowOperator 2021-03-31T12:07:16.786854+00:00 2021-03-31T12:07:18.499630+00:00 0:00:01.712776 12034 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T12:07:14.626975+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-31T11:05:00+00:00 PythonOperator 2021-03-31T12:06:47.387159+00:00 2021-03-31T12:06:50.182155+00:00 0:00:02.794996 12033 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T12:06:44.655891+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T11:00:00+00:00 EmrJobFlowSensor 2021-03-31T12:01:03.045622+00:00 2021-03-31T12:11:05.998534+00:00 0:10:02.952912 12031 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T12:01:00.656721+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T12:00:40.838755+00:00 2021-03-31T12:00:42.626157+00:00 0:00:01.787402 12030 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T12:00:38.565076+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T11:00:00+00:00 PythonOperator 2021-03-31T12:00:18.731998+00:00 2021-03-31T12:00:21.436467+00:00 0:00:02.704469 12029 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T12:00:16.523779+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-31T10:00:00+00:00 EmrJobFlowSensor 2021-03-31T11:12:10.972767+00:00 2021-03-31T11:21:13.675339+00:00 0:09:02.702572 12028 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T11:12:08.375013+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-31T10:00:00+00:00 EmrJobFlowSensor 2021-03-31T11:12:02.774099+00:00 2021-03-31T11:23:05.711319+00:00 0:11:02.937220 12027 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T11:12:00.364001+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-31T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T11:11:48.606999+00:00 2021-03-31T11:11:50.280738+00:00 0:00:01.673739 12026 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T11:11:46.353108+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-31T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T11:11:40.977893+00:00 2021-03-31T11:11:42.661853+00:00 0:00:01.683960 12025 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T11:11:38.348292+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-31T10:00:00+00:00 PythonOperator 2021-03-31T11:11:28.715414+00:00 2021-03-31T11:11:31.405043+00:00 0:00:02.689629 12024 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T11:11:26.337608+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-31T10:00:00+00:00 PythonOperator 2021-03-31T11:11:18.850105+00:00 2021-03-31T11:11:21.804117+00:00 0:00:02.954012 12023 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T11:11:16.378443+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T10:00:00+00:00 TriggerDagRunOperator 2021-03-31T11:11:06.777982+00:00 2021-03-31T11:11:07.291838+00:00 0:00:00.513856 12022 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T11:11:04.314753+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T10:00:00+00:00 TriggerDagRunOperator 2021-03-31T11:11:06.528449+00:00 2021-03-31T11:11:06.967845+00:00 0:00:00.439396 12021 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T11:11:04.314784+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-31T10:05:00+00:00 EmrJobFlowSensor 2021-03-31T11:05:48.155061+00:00 2021-03-31T11:14:50.847020+00:00 0:09:02.691959 12020 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T11:05:45.808871+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-31T10:05:00+00:00 EmrCreateJobFlowOperator 2021-03-31T11:05:25.964391+00:00 2021-03-31T11:05:27.573042+00:00 0:00:01.608651 12019 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T11:05:23.804654+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-31T10:05:00+00:00 PythonOperator 2021-03-31T11:05:06.166266+00:00 2021-03-31T11:05:08.942765+00:00 0:00:02.776499 12018 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T11:05:03.780265+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T10:00:00+00:00 EmrJobFlowSensor 2021-03-31T11:00:51.540677+00:00 2021-03-31T11:10:54.246163+00:00 0:10:02.705486 12016 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T11:00:49.348444+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T11:00:29.608955+00:00 2021-03-31T11:00:31.284976+00:00 0:00:01.676021 12015 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T11:00:27.329378+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T10:00:00+00:00 PythonOperator 2021-03-31T11:00:07.683742+00:00 2021-03-31T11:00:10.438723+00:00 0:00:02.754981 12014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T11:00:05.344373+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-31T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T10:23:44.096386+00:00 2021-03-31T10:23:45.790074+00:00 0:00:01.693688 12013 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T10:23:41.868289+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-31T09:00:00+00:00 PythonOperator 2021-03-31T10:21:06.352762+00:00 2021-03-31T10:21:09.363511+00:00 0:00:03.010749 12012 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T10:21:03.780097+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-31T09:00:00+00:00 PythonOperator 2021-03-31T10:21:06.289913+00:00 2021-03-31T10:21:09.030790+00:00 0:00:02.740877 12011 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T10:21:03.780154+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T09:00:00+00:00 TriggerDagRunOperator 2021-03-31T10:20:51.966006+00:00 2021-03-31T10:20:52.505792+00:00 0:00:00.539786 12010 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T10:20:49.624054+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T09:00:00+00:00 TriggerDagRunOperator 2021-03-31T10:20:51.838228+00:00 2021-03-31T10:20:52.254437+00:00 0:00:00.416209 12009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T10:20:49.624082+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-31T09:57:52.043506+00:00 PythonOperator 2021-03-31T10:11:49.135945+00:00 2021-03-31T10:11:51.831671+00:00 0:00:02.695726 12008 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T10:11:46.950012+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-31T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T10:11:24.330664+00:00 2021-03-31T10:11:26.241155+00:00 0:00:01.910491 12007 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-31T08:00:00+00:00 EmrJobFlowSensor 2021-03-31T10:11:18.289008+00:00 2021-03-31T10:23:21.397776+00:00 0:12:03.108768 12006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-31T08:00:00+00:00 PythonOperator 2021-03-31T10:11:06.213244+00:00 2021-03-31T10:11:08.965152+00:00 0:00:02.751908 12005 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-31T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T10:10:39.113272+00:00 2021-03-31T10:10:40.788523+00:00 0:00:01.675251 12004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-31T08:00:00+00:00 PythonOperator 2021-03-31T10:10:27.161530+00:00 2021-03-31T10:10:30.106224+00:00 0:00:02.944694 12003 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-31T09:05:00+00:00 EmrJobFlowSensor 2021-03-31T10:05:54.725111+00:00 2021-03-31T10:14:57.461473+00:00 0:09:02.736362 12002 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T10:05:52.484329+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-31T09:05:00+00:00 EmrCreateJobFlowOperator 2021-03-31T10:05:24.772003+00:00 2021-03-31T10:05:26.436066+00:00 0:00:01.664063 12001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T10:05:22.467695+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-31T09:05:00+00:00 PythonOperator 2021-03-31T10:05:04.570770+00:00 2021-03-31T10:05:07.233564+00:00 0:00:02.662794 12000 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T10:05:02.313218+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T09:00:00+00:00 EmrJobFlowSensor 2021-03-31T10:03:24.546714+00:00 2021-03-31T10:20:28.333125+00:00 0:17:03.786411 11999 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T10:03:22.181849+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T10:03:02.014425+00:00 2021-03-31T10:03:03.761016+00:00 0:00:01.746591 11998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T10:02:59.668484+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-31T08:00:00+00:00 TriggerDagRunOperator 2021-03-31T10:02:45.211696+00:00 2021-03-31T10:02:45.811230+00:00 0:00:00.599534 11997 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T10:02:39.237017+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T09:00:00+00:00 PythonOperator 2021-03-31T10:02:45.133523+00:00 2021-03-31T10:02:48.134475+00:00 0:00:03.000952 11996 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T10:02:39.237067+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-31T08:00:00+00:00 TriggerDagRunOperator 2021-03-31T10:02:42.721036+00:00 2021-03-31T10:02:43.457481+00:00 0:00:00.736445 11994 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T10:02:39.237053+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-31T08:00:00+00:00 EmrJobFlowSensor 2021-03-31T09:48:08.964739+00:00 2021-03-31T09:57:11.644518+00:00 0:09:02.679779 11992 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T09:48:06.601311+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-31T08:05:00+00:00 EmrJobFlowSensor 2021-03-31T09:47:54.989151+00:00 2021-03-31T09:55:57.549436+00:00 0:08:02.560285 11991 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-31T09:47:52.604824+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-31T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-31T09:47:47.318217+00:00 2021-03-31T09:47:49.016649+00:00 0:00:01.698432 11990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-31T09:47:44.594152+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-31T08:05:00+00:00 EmrCreateJobFlowOperator 2021-03-31T09:47:35.002352+00:00 2021-03-31T09:47:36.639044+00:00 0:00:01.636692 11989 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-31T09:47:32.656312+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-31T08:00:00+00:00 PythonOperator 2021-03-31T09:47:25.240601+00:00 2021-03-31T09:47:28.075930+00:00 0:00:02.835329 11988 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-31T09:47:22.859483+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-31T08:05:00+00:00 PythonOperator 2021-03-31T09:47:11.153606+00:00 2021-03-31T09:47:13.953364+00:00 0:00:02.799758 11987 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-31T09:47:08.557974+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-26T12:00:00+00:00 EmrJobFlowSensor 2021-03-26T13:21:10.412036+00:00 2021-03-26T13:33:13.489038+00:00 0:12:03.077002 11877 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T13:21:08.190970+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-26T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T13:20:46.441933+00:00 2021-03-26T13:20:48.243338+00:00 0:00:01.801405 11876 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T13:20:44.159748+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-26T12:00:00+00:00 PythonOperator 2021-03-26T13:20:24.662631+00:00 2021-03-26T13:20:27.619554+00:00 0:00:02.956923 11875 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T13:20:22.026970+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T12:00:00+00:00 TriggerDagRunOperator 2021-03-26T13:20:12.933503+00:00 2021-03-26T13:20:13.321428+00:00 0:00:00.387925 11874 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T13:20:10.068374+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T12:00:00+00:00 TriggerDagRunOperator 2021-03-26T13:20:12.760958+00:00 2021-03-26T13:20:13.274374+00:00 0:00:00.513416 11873 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T13:20:10.068335+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-26T12:05:00+00:00 EmrJobFlowSensor 2021-03-26T13:05:52.085645+00:00 2021-03-26T13:14:54.719349+00:00 0:09:02.633704 11871 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T13:05:49.900099+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-26T12:05:00+00:00 EmrCreateJobFlowOperator 2021-03-26T13:05:32.044247+00:00 2021-03-26T13:05:33.758524+00:00 0:00:01.714277 11870 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T13:05:29.881847+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-26T12:05:00+00:00 PythonOperator 2021-03-26T13:05:10.160253+00:00 2021-03-26T13:05:12.976323+00:00 0:00:02.816070 11869 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T13:05:07.865533+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T12:00:00+00:00 EmrJobFlowSensor 2021-03-26T13:00:53.835412+00:00 2021-03-26T13:09:56.666557+00:00 0:09:02.831145 11868 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T13:00:51.433673+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T13:00:31.699295+00:00 2021-03-26T13:00:33.395196+00:00 0:00:01.695901 11867 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T13:00:29.475150+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T12:00:00+00:00 PythonOperator 2021-03-26T13:00:09.649746+00:00 2021-03-26T13:00:12.552502+00:00 0:00:02.902756 11866 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T13:00:07.399751+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-26T11:00:00+00:00 EmrJobFlowSensor 2021-03-26T12:18:49.696076+00:00 2021-03-26T12:29:52.649753+00:00 0:11:02.953677 11865 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T12:18:47.453115+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-26T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T12:18:27.595546+00:00 2021-03-26T12:18:29.282020+00:00 0:00:01.686474 11864 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T12:18:25.428138+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-26T11:00:00+00:00 PythonOperator 2021-03-26T12:18:05.678354+00:00 2021-03-26T12:18:08.612804+00:00 0:00:02.934450 11863 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T12:18:03.408620+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-26T11:00:00+00:00 TriggerDagRunOperator 2021-03-26T12:17:41.818581+00:00 2021-03-26T12:17:42.313537+00:00 0:00:00.494956 11862 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T12:17:39.461649+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-26T11:00:00+00:00 TriggerDagRunOperator 2021-03-26T12:17:41.713141+00:00 2021-03-26T12:17:42.110789+00:00 0:00:00.397648 11861 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T12:17:39.461605+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-26T11:00:00+00:00 EmrJobFlowSensor 2021-03-26T12:08:22.669544+00:00 2021-03-26T12:17:25.277758+00:00 0:09:02.608214 11860 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-26T12:08:20.464676+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-26T11:05:00+00:00 EmrJobFlowSensor 2021-03-26T12:08:04.734945+00:00 2021-03-26T12:17:07.459872+00:00 0:09:02.724927 11859 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-26T12:08:02.449205+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-26T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-26T12:07:52.652892+00:00 2021-03-26T12:07:54.375413+00:00 0:00:01.722521 11858 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-26T12:07:50.438137+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-26T11:05:00+00:00 EmrCreateJobFlowOperator 2021-03-26T12:07:40.615543+00:00 2021-03-26T12:07:42.369067+00:00 0:00:01.753524 11857 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-26T12:07:38.425242+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-26T11:00:00+00:00 PythonOperator 2021-03-26T12:07:30.753936+00:00 2021-03-26T12:07:33.518332+00:00 0:00:02.764396 11856 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-26T12:07:28.455611+00:00 2 default_pool