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 booking-processing-job_v002 check_cluster_status 2021-04-24T07:00:00+00:00 EmrJobFlowSensor 2021-04-24T08:10:56.938810+00:00 2021-04-24T08:19:59.656425+00:00 0:09:02.717615 20681 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T08:10:54.443951+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T07:00:00+00:00 EmrJobFlowSensor 2021-04-24T08:10:50.524101+00:00 2021-04-24T08:19:53.176013+00:00 0:09:02.651912 20680 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T08:10:48.335214+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T08:10:34.622620+00:00 2021-04-24T08:10:36.364451+00:00 0:00:01.741831 20679 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T08:10:32.313376+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T08:10:28.578210+00:00 2021-04-24T08:10:30.365721+00:00 0:00:01.787511 20678 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T08:10:26.314689+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T07:00:00+00:00 PythonOperator 2021-04-24T08:10:14.534888+00:00 2021-04-24T08:10:17.749113+00:00 0:00:03.214225 20677 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T08:10:12.298470+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T07:00:00+00:00 PythonOperator 2021-04-24T08:10:06.659268+00:00 2021-04-24T08:10:09.599789+00:00 0:00:02.940521 20676 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T08:10:04.295563+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T07:00:00+00:00 TriggerDagRunOperator 2021-04-24T08:09:55.042822+00:00 2021-04-24T08:09:55.577870+00:00 0:00:00.535048 20675 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T08:09:52.346567+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T07:00:00+00:00 TriggerDagRunOperator 2021-04-24T08:09:54.978832+00:00 2021-04-24T08:09:55.468743+00:00 0:00:00.489911 20674 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T08:09:52.346516+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T07:05:00+00:00 EmrJobFlowSensor 2021-04-24T08:06:00.142250+00:00 2021-04-24T08:16:02.841871+00:00 0:10:02.699621 20673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T08:05:57.756640+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T08:05:40.183179+00:00 2021-04-24T08:05:41.820833+00:00 0:00:01.637654 20672 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T08:05:37.744621+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T07:05:00+00:00 PythonOperator 2021-04-24T08:05:17.953621+00:00 2021-04-24T08:05:20.910492+00:00 0:00:02.956871 20671 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T08:05:15.594752+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T07:00:00+00:00 EmrJobFlowSensor 2021-04-24T08:00:47.522026+00:00 2021-04-24T08:09:50.131247+00:00 0:09:02.609221 20670 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T08:00:45.118228+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T08:00:25.410915+00:00 2021-04-24T08:00:27.106223+00:00 0:00:01.695308 20669 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T08:00:23.158148+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T07:00:00+00:00 PythonOperator 2021-04-24T08:00:05.912448+00:00 2021-04-24T08:00:08.938712+00:00 0:00:03.026264 20668 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T08:00:03.147313+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T06:00:00+00:00 EmrJobFlowSensor 2021-04-24T07:11:18.688807+00:00 2021-04-24T07:21:21.493298+00:00 0:10:02.804491 20666 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T07:11:16.418003+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T06:00:00+00:00 EmrJobFlowSensor 2021-04-24T07:11:08.827707+00:00 2021-04-24T07:21:11.633956+00:00 0:10:02.806249 20665 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T07:11:06.413239+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T07:10:56.753505+00:00 2021-04-24T07:10:58.425570+00:00 0:00:01.672065 20664 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T07:10:54.460698+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T07:10:46.866293+00:00 2021-04-24T07:10:48.557331+00:00 0:00:01.691038 20663 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T07:10:44.447194+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T06:00:00+00:00 PythonOperator 2021-04-24T07:10:34.868986+00:00 2021-04-24T07:10:37.929401+00:00 0:00:03.060415 20662 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T07:10:32.317677+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T06:00:00+00:00 PythonOperator 2021-04-24T07:10:27.105231+00:00 2021-04-24T07:10:30.267464+00:00 0:00:03.162233 20661 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T07:10:24.353263+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T06:00:00+00:00 TriggerDagRunOperator 2021-04-24T07:10:18.801552+00:00 2021-04-24T07:10:19.313013+00:00 0:00:00.511461 20660 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T07:10:16.206435+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T06:00:00+00:00 TriggerDagRunOperator 2021-04-24T07:10:18.469081+00:00 2021-04-24T07:10:18.895036+00:00 0:00:00.425955 20659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T07:10:16.206393+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T06:05:00+00:00 EmrJobFlowSensor 2021-04-24T07:06:01.890867+00:00 2021-04-24T07:15:04.541095+00:00 0:09:02.650228 20658 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T07:05:59.751009+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T07:05:40.056944+00:00 2021-04-24T07:05:41.829944+00:00 0:00:01.773000 20657 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T07:05:37.721952+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T06:05:00+00:00 PythonOperator 2021-04-24T07:05:17.938888+00:00 2021-04-24T07:05:20.868732+00:00 0:00:02.929844 20656 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T07:05:15.702816+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T06:00:00+00:00 EmrJobFlowSensor 2021-04-24T07:00:57.706561+00:00 2021-04-24T07:10:00.431855+00:00 0:09:02.725294 20655 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T07:00:55.363069+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T07:00:37.478182+00:00 2021-04-24T07:00:39.166023+00:00 0:00:01.687841 20654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T07:00:35.293243+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T06:00:00+00:00 PythonOperator 2021-04-24T07:00:13.945981+00:00 2021-04-24T07:00:17.002730+00:00 0:00:03.056749 20653 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T07:00:11.228300+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T05:00:00+00:00 EmrJobFlowSensor 2021-04-24T06:10:11.630691+00:00 2021-04-24T06:20:14.527214+00:00 0:10:02.896523 20651 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T06:10:09.317259+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T05:00:00+00:00 EmrJobFlowSensor 2021-04-24T06:10:07.618115+00:00 2021-04-24T06:20:10.446116+00:00 0:10:02.828001 20650 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T06:10:05.311221+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T06:09:49.712982+00:00 2021-04-24T06:09:51.519245+00:00 0:00:01.806263 20649 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T06:09:47.359997+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T06:09:45.707750+00:00 2021-04-24T06:09:47.504636+00:00 0:00:01.796886 20648 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T06:09:43.360167+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T05:00:00+00:00 PythonOperator 2021-04-24T06:09:28.012543+00:00 2021-04-24T06:09:31.202700+00:00 0:00:03.190157 20647 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T06:09:25.184552+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T05:00:00+00:00 PythonOperator 2021-04-24T06:09:23.352320+00:00 2021-04-24T06:09:27.323632+00:00 0:00:03.971312 20646 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T06:09:21.169325+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T05:00:00+00:00 TriggerDagRunOperator 2021-04-24T06:09:03.519286+00:00 2021-04-24T06:09:04.176733+00:00 0:00:00.657447 20645 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T06:09:01.151658+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T05:00:00+00:00 TriggerDagRunOperator 2021-04-24T06:09:03.457888+00:00 2021-04-24T06:09:03.981536+00:00 0:00:00.523648 20644 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T06:09:01.151613+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T05:05:00+00:00 EmrJobFlowSensor 2021-04-24T06:05:53.155521+00:00 2021-04-24T06:13:55.563752+00:00 0:08:02.408231 20643 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T06:05:50.889340+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T06:05:31.081485+00:00 2021-04-24T06:05:32.743087+00:00 0:00:01.661602 20642 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T06:05:28.871599+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T05:05:00+00:00 PythonOperator 2021-04-24T06:05:05.239263+00:00 2021-04-24T06:05:08.284499+00:00 0:00:03.045236 20641 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T06:05:02.818505+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T05:00:00+00:00 EmrJobFlowSensor 2021-04-24T06:00:52.786543+00:00 2021-04-24T06:08:55.289754+00:00 0:08:02.503211 20640 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T06:00:50.226131+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T06:00:30.957310+00:00 2021-04-24T06:00:32.666227+00:00 0:00:01.708917 20639 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T06:00:28.357563+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T05:00:00+00:00 PythonOperator 2021-04-24T06:00:08.843436+00:00 2021-04-24T06:00:11.860268+00:00 0:00:03.016832 20638 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T06:00:06.188858+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T04:00:00+00:00 EmrJobFlowSensor 2021-04-24T05:11:01.982794+00:00 2021-04-24T05:21:04.789272+00:00 0:10:02.806478 20636 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T05:10:59.284870+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T04:00:00+00:00 EmrJobFlowSensor 2021-04-24T05:10:55.453089+00:00 2021-04-24T05:19:58.137000+00:00 0:09:02.683911 20635 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T05:10:53.210556+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T05:10:39.508971+00:00 2021-04-24T05:10:41.234504+00:00 0:00:01.725533 20634 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T05:10:37.206143+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T05:10:33.773710+00:00 2021-04-24T05:10:35.577940+00:00 0:00:01.804230 20633 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T05:10:31.258574+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T04:00:00+00:00 PythonOperator 2021-04-24T05:10:19.757135+00:00 2021-04-24T05:10:23.019707+00:00 0:00:03.262572 20632 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T05:10:17.244470+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T04:00:00+00:00 PythonOperator 2021-04-24T05:10:11.675657+00:00 2021-04-24T05:10:15.253347+00:00 0:00:03.577690 20631 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T05:10:09.154101+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T04:00:00+00:00 TriggerDagRunOperator 2021-04-24T05:10:01.532031+00:00 2021-04-24T05:10:02.075558+00:00 0:00:00.543527 20630 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T05:09:59.067626+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T04:00:00+00:00 TriggerDagRunOperator 2021-04-24T05:10:01.407338+00:00 2021-04-24T05:10:01.861446+00:00 0:00:00.454108 20629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T05:09:59.067673+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T04:05:00+00:00 EmrJobFlowSensor 2021-04-24T05:05:56.627949+00:00 2021-04-24T05:14:59.257058+00:00 0:09:02.629109 20628 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T05:05:54.414070+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T05:05:34.755840+00:00 2021-04-24T05:05:36.589737+00:00 0:00:01.833897 20627 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T05:05:32.391168+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T04:05:00+00:00 PythonOperator 2021-04-24T05:05:12.535551+00:00 2021-04-24T05:05:15.485012+00:00 0:00:02.949461 20626 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T05:05:10.319322+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T04:00:00+00:00 EmrJobFlowSensor 2021-04-24T05:00:50.232240+00:00 2021-04-24T05:09:53.032969+00:00 0:09:02.800729 20625 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T05:00:47.804932+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T05:00:28.177264+00:00 2021-04-24T05:00:30.254252+00:00 0:00:02.076988 20624 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T05:00:25.823078+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T04:00:00+00:00 PythonOperator 2021-04-24T05:00:08.116093+00:00 2021-04-24T05:00:11.107816+00:00 0:00:02.991723 20623 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T05:00:05.720153+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T03:00:00+00:00 EmrJobFlowSensor 2021-04-24T04:10:22.158345+00:00 2021-04-24T04:20:25.147068+00:00 0:10:02.988723 20621 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T04:10:19.895547+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T03:00:00+00:00 EmrJobFlowSensor 2021-04-24T04:10:16.175197+00:00 2021-04-24T04:21:19.103744+00:00 0:11:02.928547 20620 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T04:10:13.947328+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T04:10:02.947924+00:00 2021-04-24T04:10:04.780752+00:00 0:00:01.832828 20619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T04:09:59.862431+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T04:09:54.428381+00:00 2021-04-24T04:09:56.111447+00:00 0:00:01.683066 20618 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T04:09:51.864904+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T03:00:00+00:00 PythonOperator 2021-04-24T04:09:40.699668+00:00 2021-04-24T04:09:43.627526+00:00 0:00:02.927858 20617 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T04:09:37.860361+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T03:00:00+00:00 PythonOperator 2021-04-24T04:09:32.343731+00:00 2021-04-24T04:09:35.551781+00:00 0:00:03.208050 20616 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T04:09:29.969132+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T03:00:00+00:00 TriggerDagRunOperator 2021-04-24T04:09:16.332413+00:00 2021-04-24T04:09:16.874384+00:00 0:00:00.541971 20615 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T04:09:13.868640+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T03:00:00+00:00 TriggerDagRunOperator 2021-04-24T04:09:16.245888+00:00 2021-04-24T04:09:16.673366+00:00 0:00:00.427478 20614 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T04:09:13.868587+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T03:05:00+00:00 EmrJobFlowSensor 2021-04-24T04:06:03.567003+00:00 2021-04-24T04:15:06.245982+00:00 0:09:02.678979 20613 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T04:06:01.395488+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T04:05:41.428783+00:00 2021-04-24T04:05:43.079804+00:00 0:00:01.651021 20612 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T04:05:39.302136+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T03:05:00+00:00 PythonOperator 2021-04-24T04:05:19.673264+00:00 2021-04-24T04:05:22.600750+00:00 0:00:02.927486 20611 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T04:05:17.272160+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T03:00:00+00:00 EmrJobFlowSensor 2021-04-24T04:01:04.956807+00:00 2021-04-24T04:09:07.623253+00:00 0:08:02.666446 20610 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T04:01:02.756325+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T04:00:42.988564+00:00 2021-04-24T04:00:44.720244+00:00 0:00:01.731680 20609 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T04:00:40.655405+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T03:00:00+00:00 PythonOperator 2021-04-24T04:00:20.980018+00:00 2021-04-24T04:00:23.943826+00:00 0:00:02.963808 20608 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T04:00:18.638535+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T02:00:00+00:00 EmrJobFlowSensor 2021-04-24T03:11:12.098319+00:00 2021-04-24T03:20:14.835740+00:00 0:09:02.737421 20606 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T03:11:09.844767+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T02:00:00+00:00 EmrJobFlowSensor 2021-04-24T03:11:10.010882+00:00 2021-04-24T03:21:12.796500+00:00 0:10:02.785618 20605 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T03:11:07.836597+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T03:10:50.685738+00:00 2021-04-24T03:10:52.481366+00:00 0:00:01.795628 20604 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T03:10:47.944523+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T03:10:48.421168+00:00 2021-04-24T03:10:50.150792+00:00 0:00:01.729624 20603 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T03:10:45.947013+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T02:00:00+00:00 PythonOperator 2021-04-24T03:10:28.025804+00:00 2021-04-24T03:10:31.011460+00:00 0:00:02.985656 20602 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T03:10:25.805483+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T02:00:00+00:00 PythonOperator 2021-04-24T03:10:26.011504+00:00 2021-04-24T03:10:29.178419+00:00 0:00:03.166915 20601 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T03:10:23.813255+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T02:00:00+00:00 TriggerDagRunOperator 2021-04-24T03:10:16.137118+00:00 2021-04-24T03:10:16.714652+00:00 0:00:00.577534 20600 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T03:10:13.797545+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T02:00:00+00:00 TriggerDagRunOperator 2021-04-24T03:10:16.115595+00:00 2021-04-24T03:10:16.713866+00:00 0:00:00.598271 20599 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T03:10:13.797498+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T02:05:00+00:00 EmrJobFlowSensor 2021-04-24T03:06:05.482538+00:00 2021-04-24T03:14:07.827348+00:00 0:08:02.344810 20598 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T03:06:03.234118+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T03:05:43.486663+00:00 2021-04-24T03:05:45.871790+00:00 0:00:02.385127 20597 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T03:05:41.191527+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T02:05:00+00:00 PythonOperator 2021-04-24T03:05:19.497955+00:00 2021-04-24T03:05:22.412837+00:00 0:00:02.914882 20596 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T03:05:17.156296+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T02:00:00+00:00 EmrJobFlowSensor 2021-04-24T03:01:00.914340+00:00 2021-04-24T03:10:03.646373+00:00 0:09:02.732033 20595 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T03:00:58.559992+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T03:00:38.756687+00:00 2021-04-24T03:00:40.551060+00:00 0:00:01.794373 20594 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T03:00:36.363028+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T02:00:00+00:00 PythonOperator 2021-04-24T03:00:19.725794+00:00 2021-04-24T03:00:22.782443+00:00 0:00:03.056649 20593 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T03:00:16.326791+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T01:00:00+00:00 EmrJobFlowSensor 2021-04-24T02:11:00.717285+00:00 2021-04-24T02:21:03.415229+00:00 0:10:02.697944 20591 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T02:10:58.307045+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T01:00:00+00:00 EmrJobFlowSensor 2021-04-24T02:10:56.468053+00:00 2021-04-24T02:18:58.986994+00:00 0:08:02.518941 20590 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T02:10:54.294375+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T02:10:38.410859+00:00 2021-04-24T02:10:40.120027+00:00 0:00:01.709168 20589 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T02:10:36.220576+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T02:10:35.022493+00:00 2021-04-24T02:10:36.841181+00:00 0:00:01.818688 20588 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T02:10:32.359940+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T01:00:00+00:00 PythonOperator 2021-04-24T02:10:18.388261+00:00 2021-04-24T02:10:21.638897+00:00 0:00:03.250636 20587 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T02:10:16.193961+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T01:00:00+00:00 PythonOperator 2021-04-24T02:10:12.559784+00:00 2021-04-24T02:10:15.555720+00:00 0:00:02.995936 20586 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T02:10:10.268574+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T01:00:00+00:00 TriggerDagRunOperator 2021-04-24T02:09:54.968044+00:00 2021-04-24T02:09:55.400909+00:00 0:00:00.432865 20585 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T02:09:52.155774+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T01:00:00+00:00 TriggerDagRunOperator 2021-04-24T02:09:54.677298+00:00 2021-04-24T02:09:55.211087+00:00 0:00:00.533789 20584 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T02:09:52.155803+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T01:05:00+00:00 EmrJobFlowSensor 2021-04-24T02:05:58.079021+00:00 2021-04-24T02:15:00.653023+00:00 0:09:02.574002 20583 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T02:05:55.830664+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T02:05:36.204921+00:00 2021-04-24T02:05:37.806216+00:00 0:00:01.601295 20582 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T02:05:33.862151+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T01:05:00+00:00 PythonOperator 2021-04-24T02:05:14.045646+00:00 2021-04-24T02:05:17.111735+00:00 0:00:03.066089 20581 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T02:05:11.800545+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T01:00:00+00:00 EmrJobFlowSensor 2021-04-24T02:00:47.566060+00:00 2021-04-24T02:09:50.247796+00:00 0:09:02.681736 20580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T02:00:45.272981+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T02:00:27.778826+00:00 2021-04-24T02:00:29.888839+00:00 0:00:02.110013 20579 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T02:00:25.257887+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T01:00:00+00:00 PythonOperator 2021-04-24T02:00:05.795872+00:00 2021-04-24T02:00:08.785896+00:00 0:00:02.990024 20578 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T02:00:03.264073+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T00:00:00+00:00 EmrJobFlowSensor 2021-04-24T01:10:24.280781+00:00 2021-04-24T01:20:27.232767+00:00 0:10:02.951986 20576 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T01:10:21.751445+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T00:00:00+00:00 EmrJobFlowSensor 2021-04-24T01:10:14.169352+00:00 2021-04-24T01:20:17.041827+00:00 0:10:02.872475 20575 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T01:10:11.748828+00:00 2 default_pool