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-01T17:00:00+00:00 PythonOperator 2021-05-01T18:11:43.738718+00:00 2021-05-01T18:11:46.800184+00:00 0:00:03.061466 23369 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T18:11:41.554293+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-01T17:00:00+00:00 PythonOperator 2021-05-01T18:11:41.773271+00:00 2021-05-01T18:11:45.089326+00:00 0:00:03.316055 23368 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T18:11:39.552114+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T17:00:00+00:00 TriggerDagRunOperator 2021-05-01T18:11:32.040044+00:00 2021-05-01T18:11:32.492586+00:00 0:00:00.452542 23367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T18:11:29.582495+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T17:00:00+00:00 TriggerDagRunOperator 2021-05-01T18:11:31.993500+00:00 2021-05-01T18:11:32.583879+00:00 0:00:00.590379 23366 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T18:11:29.582562+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-01T17:05:00+00:00 EmrJobFlowSensor 2021-05-01T18:05:51.186722+00:00 2021-05-01T18:14:53.848046+00:00 0:09:02.661324 23365 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T18:05:49.040696+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-01T17:05:00+00:00 EmrCreateJobFlowOperator 2021-05-01T18:05:29.741176+00:00 2021-05-01T18:05:31.519454+00:00 0:00:01.778278 23364 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T18:05:27.081470+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-01T17:05:00+00:00 PythonOperator 2021-05-01T18:05:09.291128+00:00 2021-05-01T18:05:12.255669+00:00 0:00:02.964541 23363 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T18:05:06.995397+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T17:00:00+00:00 EmrJobFlowSensor 2021-05-01T18:01:04.886547+00:00 2021-05-01T18:11:07.764352+00:00 0:10:02.877805 23362 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T18:01:02.498086+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T18:00:42.740674+00:00 2021-05-01T18:00:44.560553+00:00 0:00:01.819879 23361 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T18:00:40.424639+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T17:00:00+00:00 PythonOperator 2021-05-01T18:00:21.031142+00:00 2021-05-01T18:00:24.078181+00:00 0:00:03.047039 23360 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T18:00:18.406126+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-01T16:00:00+00:00 EmrJobFlowSensor 2021-05-01T17:11:14.839901+00:00 2021-05-01T17:20:17.570861+00:00 0:09:02.730960 23358 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T17:11:12.516903+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-01T16:00:00+00:00 EmrJobFlowSensor 2021-05-01T17:11:06.764804+00:00 2021-05-01T17:21:09.624694+00:00 0:10:02.859890 23357 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T17:11:04.511283+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-01T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T17:10:53.208659+00:00 2021-05-01T17:10:54.976391+00:00 0:00:01.767732 23356 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T17:10:50.504569+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-01T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T17:10:44.959346+00:00 2021-05-01T17:10:46.706113+00:00 0:00:01.746767 23355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T17:10:42.561507+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-01T16:00:00+00:00 PythonOperator 2021-05-01T17:10:33.117476+00:00 2021-05-01T17:10:36.165635+00:00 0:00:03.048159 23354 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T17:10:30.485803+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-01T16:00:00+00:00 PythonOperator 2021-05-01T17:10:25.207183+00:00 2021-05-01T17:10:28.543930+00:00 0:00:03.336747 23353 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T17:10:22.414553+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T16:00:00+00:00 TriggerDagRunOperator 2021-05-01T17:10:16.758324+00:00 2021-05-01T17:10:17.208914+00:00 0:00:00.450590 23352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T17:10:14.411172+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T16:00:00+00:00 TriggerDagRunOperator 2021-05-01T17:10:16.750822+00:00 2021-05-01T17:10:17.302408+00:00 0:00:00.551586 23351 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T17:10:14.411212+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-01T16:05:00+00:00 EmrJobFlowSensor 2021-05-01T17:05:48.049596+00:00 2021-05-01T17:14:50.711872+00:00 0:09:02.662276 23350 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T17:05:45.774990+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-01T16:05:00+00:00 EmrCreateJobFlowOperator 2021-05-01T17:05:28.036371+00:00 2021-05-01T17:05:29.677939+00:00 0:00:01.641568 23349 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T17:05:25.761159+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-01T16:05:00+00:00 PythonOperator 2021-05-01T17:05:06.145906+00:00 2021-05-01T17:05:09.136351+00:00 0:00:02.990445 23348 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T17:05:03.847085+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T16:00:00+00:00 EmrJobFlowSensor 2021-05-01T17:00:59.172224+00:00 2021-05-01T17:10:01.833577+00:00 0:09:02.661353 23347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T17:00:56.904349+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T17:00:37.157164+00:00 2021-05-01T17:00:38.846825+00:00 0:00:01.689661 23346 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T17:00:34.898406+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T16:00:00+00:00 PythonOperator 2021-05-01T17:00:15.173748+00:00 2021-05-01T17:00:18.216469+00:00 0:00:03.042721 23345 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T17:00:12.823771+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-01T15:00:00+00:00 EmrJobFlowSensor 2021-05-01T16:11:35.199035+00:00 2021-05-01T16:21:38.069081+00:00 0:10:02.870046 23343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T16:11:32.477565+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-01T15:00:00+00:00 EmrJobFlowSensor 2021-05-01T16:11:18.939190+00:00 2021-05-01T16:20:21.665510+00:00 0:09:02.726320 23342 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T16:11:16.457308+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-01T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T16:11:12.920885+00:00 2021-05-01T16:11:14.754621+00:00 0:00:01.833736 23341 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T16:11:10.471288+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-01T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T16:10:44.668395+00:00 2021-05-01T16:10:46.366593+00:00 0:00:01.698198 23340 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T16:10:42.316566+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-01T15:00:00+00:00 PythonOperator 2021-05-01T16:10:40.593916+00:00 2021-05-01T16:10:43.892530+00:00 0:00:03.298614 23339 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T16:10:38.308767+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-01T15:00:00+00:00 PythonOperator 2021-05-01T16:10:20.789105+00:00 2021-05-01T16:10:23.959284+00:00 0:00:03.170179 23338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T16:10:18.367167+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T15:00:00+00:00 TriggerDagRunOperator 2021-05-01T16:10:14.707245+00:00 2021-05-01T16:10:15.172552+00:00 0:00:00.465307 23337 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T16:10:12.296359+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T15:00:00+00:00 TriggerDagRunOperator 2021-05-01T16:10:14.694450+00:00 2021-05-01T16:10:15.256514+00:00 0:00:00.562064 23336 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T16:10:12.296397+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-01T15:05:00+00:00 EmrJobFlowSensor 2021-05-01T16:06:12.279104+00:00 2021-05-01T16:14:14.883223+00:00 0:08:02.604119 23335 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T16:06:09.952912+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-01T15:05:00+00:00 EmrCreateJobFlowOperator 2021-05-01T16:05:50.169341+00:00 2021-05-01T16:05:51.834694+00:00 0:00:01.665353 23334 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T16:05:47.878511+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-01T15:05:00+00:00 PythonOperator 2021-05-01T16:05:20.088583+00:00 2021-05-01T16:05:23.053389+00:00 0:00:02.964806 23333 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T16:05:17.844761+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T15:00:00+00:00 EmrJobFlowSensor 2021-05-01T16:00:49.785794+00:00 2021-05-01T16:09:52.594399+00:00 0:09:02.808605 23332 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T16:00:47.365490+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T16:00:27.677423+00:00 2021-05-01T16:00:29.511032+00:00 0:00:01.833609 23331 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T16:00:25.303064+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T15:00:00+00:00 PythonOperator 2021-05-01T16:00:07.403529+00:00 2021-05-01T16:00:10.456129+00:00 0:00:03.052600 23330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T16:00:05.285166+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-01T14:00:00+00:00 EmrJobFlowSensor 2021-05-01T15:14:34.032710+00:00 2021-05-01T15:24:36.921016+00:00 0:10:02.888306 23329 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T15:14:31.567506+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-01T14:00:00+00:00 EmrJobFlowSensor 2021-05-01T15:14:21.923896+00:00 2021-05-01T15:23:24.596999+00:00 0:09:02.673103 23328 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T15:14:19.472853+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-01T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T15:14:11.788071+00:00 2021-05-01T15:14:13.493352+00:00 0:00:01.705281 23327 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T15:14:09.459485+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-01T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T15:14:01.713016+00:00 2021-05-01T15:14:03.545474+00:00 0:00:01.832458 23326 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T15:13:59.453083+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-01T14:00:00+00:00 PythonOperator 2021-05-01T15:13:51.544581+00:00 2021-05-01T15:13:54.846687+00:00 0:00:03.302106 23325 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T15:13:49.332640+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-01T14:00:00+00:00 PythonOperator 2021-05-01T15:13:39.961004+00:00 2021-05-01T15:13:42.977615+00:00 0:00:03.016611 23324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T15:13:37.343865+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T14:00:00+00:00 TriggerDagRunOperator 2021-05-01T15:13:32.122384+00:00 2021-05-01T15:13:32.683488+00:00 0:00:00.561104 23323 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T15:13:29.386569+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T14:00:00+00:00 TriggerDagRunOperator 2021-05-01T15:13:32.004929+00:00 2021-05-01T15:13:32.453004+00:00 0:00:00.448075 23322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T15:13:29.386533+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-01T14:05:00+00:00 EmrJobFlowSensor 2021-05-01T15:05:56.409973+00:00 2021-05-01T15:14:59.090349+00:00 0:09:02.680376 23320 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T15:05:53.973586+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-01T14:05:00+00:00 EmrCreateJobFlowOperator 2021-05-01T15:05:34.433357+00:00 2021-05-01T15:05:36.185264+00:00 0:00:01.751907 23319 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T15:05:31.973826+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-01T14:05:00+00:00 PythonOperator 2021-05-01T15:05:12.173958+00:00 2021-05-01T15:05:15.200155+00:00 0:00:03.026197 23318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T15:05:09.858578+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T14:00:00+00:00 EmrJobFlowSensor 2021-05-01T15:01:03.837744+00:00 2021-05-01T15:10:06.623903+00:00 0:09:02.786159 23317 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T15:01:01.510324+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T15:00:41.747775+00:00 2021-05-01T15:00:43.550204+00:00 0:00:01.802429 23316 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T15:00:39.485978+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T14:00:00+00:00 PythonOperator 2021-05-01T15:00:21.600087+00:00 2021-05-01T15:00:24.678426+00:00 0:00:03.078339 23315 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T15:00:19.384875+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-01T13:00:00+00:00 EmrJobFlowSensor 2021-05-01T14:20:09.076026+00:00 2021-05-01T14:30:11.831460+00:00 0:10:02.755434 23314 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T14:20:06.247771+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-01T13:00:00+00:00 EmrJobFlowSensor 2021-05-01T14:20:06.650494+00:00 2021-05-01T14:29:09.699332+00:00 0:09:03.048838 23313 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T14:20:04.251822+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-01T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T14:19:48.624381+00:00 2021-05-01T14:19:50.306729+00:00 0:00:01.682348 23312 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T14:19:46.260176+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-01T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T14:19:44.515850+00:00 2021-05-01T14:19:46.289980+00:00 0:00:01.774130 23311 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T14:19:42.247290+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-01T13:00:00+00:00 PythonOperator 2021-05-01T14:19:26.304337+00:00 2021-05-01T14:19:29.568595+00:00 0:00:03.264258 23310 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T14:19:24.108142+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-01T13:00:00+00:00 PythonOperator 2021-05-01T14:19:22.300685+00:00 2021-05-01T14:19:25.393583+00:00 0:00:03.092898 23309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T14:19:20.108005+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T13:00:00+00:00 TriggerDagRunOperator 2021-05-01T14:19:04.962613+00:00 2021-05-01T14:19:05.544425+00:00 0:00:00.581812 23308 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T14:19:02.094907+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T13:00:00+00:00 TriggerDagRunOperator 2021-05-01T14:19:04.423964+00:00 2021-05-01T14:19:05.033116+00:00 0:00:00.609152 23307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T14:19:02.094952+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T13:00:00+00:00 EmrJobFlowSensor 2021-05-01T14:08:30.934448+00:00 2021-05-01T14:18:33.713532+00:00 0:10:02.779084 23306 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T14:08:28.586903+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-01T13:05:00+00:00 EmrJobFlowSensor 2021-05-01T14:08:16.894978+00:00 2021-05-01T14:17:19.542180+00:00 0:09:02.647202 23305 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T14:08:14.593555+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T14:08:08.736753+00:00 2021-05-01T14:08:10.493544+00:00 0:00:01.756791 23304 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T14:08:06.522368+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-01T13:05:00+00:00 EmrCreateJobFlowOperator 2021-05-01T14:07:56.723629+00:00 2021-05-01T14:07:58.367840+00:00 0:00:01.644211 23303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T14:07:54.509007+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T13:00:00+00:00 PythonOperator 2021-05-01T14:07:46.798132+00:00 2021-05-01T14:07:49.821619+00:00 0:00:03.023487 23302 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T14:07:44.505472+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-01T13:05:00+00:00 PythonOperator 2021-05-01T14:07:35.285067+00:00 2021-05-01T14:07:38.267489+00:00 0:00:02.982422 23301 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T14:07:32.497393+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-01T12:00:00+00:00 EmrJobFlowSensor 2021-05-01T13:09:55.024549+00:00 2021-05-01T13:19:57.887007+00:00 0:10:02.862458 23299 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T13:09:52.733892+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-01T12:00:00+00:00 EmrJobFlowSensor 2021-05-01T13:09:47.455372+00:00 2021-05-01T13:17:49.946280+00:00 0:08:02.490908 23298 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T13:09:44.772739+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-01T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T13:09:33.081729+00:00 2021-05-01T13:09:34.910301+00:00 0:00:01.828572 23297 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T13:09:30.705722+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-01T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T13:09:26.806660+00:00 2021-05-01T13:09:28.486031+00:00 0:00:01.679371 23296 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T13:09:24.706244+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-01T12:00:00+00:00 PythonOperator 2021-05-01T13:09:11.001296+00:00 2021-05-01T13:09:14.363839+00:00 0:00:03.362543 23295 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T13:09:08.760409+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-01T12:00:00+00:00 PythonOperator 2021-05-01T13:09:05.433935+00:00 2021-05-01T13:09:08.490622+00:00 0:00:03.056687 23294 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T13:09:02.686704+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T12:00:00+00:00 TriggerDagRunOperator 2021-05-01T13:08:57.065122+00:00 2021-05-01T13:08:57.590342+00:00 0:00:00.525220 23293 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T13:08:54.685600+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T12:00:00+00:00 TriggerDagRunOperator 2021-05-01T13:08:56.926578+00:00 2021-05-01T13:08:57.407959+00:00 0:00:00.481381 23292 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T13:08:54.685568+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-01T12:05:00+00:00 EmrJobFlowSensor 2021-05-01T13:06:06.558013+00:00 2021-05-01T13:15:09.207547+00:00 0:09:02.649534 23291 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T13:06:04.447488+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-01T12:05:00+00:00 EmrCreateJobFlowOperator 2021-05-01T13:05:42.613024+00:00 2021-05-01T13:05:44.253047+00:00 0:00:01.640023 23290 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T13:05:40.323448+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-01T12:05:00+00:00 PythonOperator 2021-05-01T13:05:20.689484+00:00 2021-05-01T13:05:23.686055+00:00 0:00:02.996571 23289 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T13:05:18.367858+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T12:00:00+00:00 EmrJobFlowSensor 2021-05-01T13:00:50.098320+00:00 2021-05-01T13:08:52.578846+00:00 0:08:02.480526 23288 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T13:00:47.853369+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T13:00:28.186503+00:00 2021-05-01T13:00:29.874158+00:00 0:00:01.687655 23287 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T13:00:25.849105+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T12:00:00+00:00 PythonOperator 2021-05-01T13:00:08.644190+00:00 2021-05-01T13:00:11.734309+00:00 0:00:03.090119 23286 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T13:00:05.778496+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-01T11:00:00+00:00 EmrJobFlowSensor 2021-05-01T12:12:28.758005+00:00 2021-05-01T12:21:31.274650+00:00 0:09:02.516645 23284 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T12:12:26.440835+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-01T11:00:00+00:00 EmrJobFlowSensor 2021-05-01T12:12:26.968325+00:00 2021-05-01T12:21:29.685196+00:00 0:09:02.716871 23283 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T12:12:24.368680+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-01T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T12:12:06.834268+00:00 2021-05-01T12:12:08.581481+00:00 0:00:01.747213 23282 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T12:12:04.362173+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-01T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T12:12:06.789835+00:00 2021-05-01T12:12:08.665685+00:00 0:00:01.875850 23281 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T12:12:04.362224+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-01T11:00:00+00:00 PythonOperator 2021-05-01T12:11:44.809157+00:00 2021-05-01T12:11:48.111944+00:00 0:00:03.302787 23280 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T12:11:42.341013+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-01T11:00:00+00:00 PythonOperator 2021-05-01T12:11:42.422302+00:00 2021-05-01T12:11:45.510084+00:00 0:00:03.087782 23279 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T12:11:40.199815+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T11:00:00+00:00 TriggerDagRunOperator 2021-05-01T12:11:24.668765+00:00 2021-05-01T12:11:25.211676+00:00 0:00:00.542911 23278 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T12:11:22.256299+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T11:00:00+00:00 TriggerDagRunOperator 2021-05-01T12:11:24.627542+00:00 2021-05-01T12:11:25.087208+00:00 0:00:00.459666 23277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T12:11:22.256249+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-01T11:05:00+00:00 EmrJobFlowSensor 2021-05-01T12:05:56.018623+00:00 2021-05-01T12:14:58.549268+00:00 0:09:02.530645 23276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T12:05:53.553786+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-01T11:05:00+00:00 EmrCreateJobFlowOperator 2021-05-01T12:05:33.968123+00:00 2021-05-01T12:05:35.764564+00:00 0:00:01.796441 23275 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T12:05:31.547507+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-01T11:05:00+00:00 PythonOperator 2021-05-01T12:05:11.645880+00:00 2021-05-01T12:05:14.697574+00:00 0:00:03.051694 23274 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T12:05:09.387092+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T11:00:00+00:00 EmrJobFlowSensor 2021-05-01T12:00:57.056774+00:00 2021-05-01T12:10:59.837097+00:00 0:10:02.780323 23273 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T12:00:54.894349+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T12:00:35.383086+00:00 2021-05-01T12:00:37.215975+00:00 0:00:01.832889 23272 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T12:00:32.865240+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T11:00:00+00:00 PythonOperator 2021-05-01T12:00:13.112781+00:00 2021-05-01T12:00:16.130097+00:00 0:00:03.017316 23271 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T12:00:10.689332+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-01T10:00:00+00:00 EmrJobFlowSensor 2021-05-01T11:10:48.848307+00:00 2021-05-01T11:19:51.514561+00:00 0:09:02.666254 23269 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T11:10:46.488403+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-01T10:00:00+00:00 EmrJobFlowSensor 2021-05-01T11:10:46.931325+00:00 2021-05-01T11:19:49.676466+00:00 0:09:02.745141 23268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T11:10:44.559664+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-01T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T11:10:26.846260+00:00 2021-05-01T11:10:28.647295+00:00 0:00:01.801035 23267 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T11:10:24.441619+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-01T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T11:10:26.789247+00:00 2021-05-01T11:10:28.518124+00:00 0:00:01.728877 23266 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T11:10:24.441586+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-01T10:00:00+00:00 PythonOperator 2021-05-01T11:10:06.756249+00:00 2021-05-01T11:10:10.056590+00:00 0:00:03.300341 23265 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T11:10:04.408867+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-01T10:00:00+00:00 PythonOperator 2021-05-01T11:10:04.918724+00:00 2021-05-01T11:10:08.084814+00:00 0:00:03.166090 23264 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T11:10:02.414694+00:00 2 default_pool