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-16T08:00:00+00:00 EmrJobFlowSensor 2021-04-16T09:18:01.407169+00:00 2021-04-16T09:28:04.397564+00:00 0:10:02.990395 17779 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T09:17:59.168019+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T09:17:39.388065+00:00 2021-04-16T09:17:41.169973+00:00 0:00:01.781908 17778 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T09:17:37.088636+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T09:17:37.685454+00:00 2021-04-16T09:17:39.414000+00:00 0:00:01.728546 17777 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T09:17:35.165798+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T08:00:00+00:00 PythonOperator 2021-04-16T09:17:19.338796+00:00 2021-04-16T09:17:22.271420+00:00 0:00:02.932624 17776 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T09:17:17.019002+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T08:00:00+00:00 PythonOperator 2021-04-16T09:17:17.095306+00:00 2021-04-16T09:17:20.402591+00:00 0:00:03.307285 17775 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T09:17:14.936060+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T08:00:00+00:00 TriggerDagRunOperator 2021-04-16T09:16:53.771098+00:00 2021-04-16T09:16:54.265723+00:00 0:00:00.494625 17774 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T09:16:50.752767+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T08:00:00+00:00 TriggerDagRunOperator 2021-04-16T09:16:53.533591+00:00 2021-04-16T09:16:53.957447+00:00 0:00:00.423856 17773 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T09:16:50.752810+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T08:05:00+00:00 EmrJobFlowSensor 2021-04-16T09:06:03.765768+00:00 2021-04-16T09:15:06.345124+00:00 0:09:02.579356 17771 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T09:06:01.545347+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T09:05:41.804447+00:00 2021-04-16T09:05:43.454700+00:00 0:00:01.650253 17770 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T09:05:39.551226+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T08:05:00+00:00 PythonOperator 2021-04-16T09:05:19.857587+00:00 2021-04-16T09:05:22.964498+00:00 0:00:03.106911 17769 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T09:05:17.452912+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T08:00:00+00:00 EmrJobFlowSensor 2021-04-16T09:00:55.214694+00:00 2021-04-16T09:10:58.582057+00:00 0:10:03.367363 17768 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T09:00:53.002200+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T09:00:33.266272+00:00 2021-04-16T09:00:35.106705+00:00 0:00:01.840433 17767 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T09:00:30.983853+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T08:00:00+00:00 PythonOperator 2021-04-16T09:00:11.798761+00:00 2021-04-16T09:00:14.716389+00:00 0:00:02.917628 17766 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T09:00:08.918272+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T07:00:00+00:00 EmrJobFlowSensor 2021-04-16T08:12:02.336916+00:00 2021-04-16T08:22:05.291321+00:00 0:10:02.954405 17765 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T08:11:59.997618+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T07:00:00+00:00 EmrJobFlowSensor 2021-04-16T08:12:00.927083+00:00 2021-04-16T08:21:03.499492+00:00 0:09:02.572409 17764 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T08:11:58.000706+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T08:11:40.562822+00:00 2021-04-16T08:11:42.253730+00:00 0:00:01.690908 17763 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T08:11:37.987420+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T08:11:38.108542+00:00 2021-04-16T08:11:40.125124+00:00 0:00:02.016582 17762 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T08:11:35.931195+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T07:00:00+00:00 PythonOperator 2021-04-16T08:11:20.108683+00:00 2021-04-16T08:11:23.751224+00:00 0:00:03.642541 17761 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T08:11:17.916504+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T07:00:00+00:00 PythonOperator 2021-04-16T08:11:18.261870+00:00 2021-04-16T08:11:21.238491+00:00 0:00:02.976621 17760 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T08:11:15.916395+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T07:00:00+00:00 TriggerDagRunOperator 2021-04-16T08:10:58.727914+00:00 2021-04-16T08:10:59.223895+00:00 0:00:00.495981 17759 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T08:10:55.901903+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T07:00:00+00:00 TriggerDagRunOperator 2021-04-16T08:10:58.474251+00:00 2021-04-16T08:10:58.917755+00:00 0:00:00.443504 17758 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T08:10:55.901932+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T07:05:00+00:00 EmrJobFlowSensor 2021-04-16T08:06:05.469862+00:00 2021-04-16T08:15:08.128674+00:00 0:09:02.658812 17756 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T08:06:03.284320+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T08:05:43.465209+00:00 2021-04-16T08:05:45.568472+00:00 0:00:02.103263 17755 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T08:05:41.240819+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T07:05:00+00:00 PythonOperator 2021-04-16T08:05:23.430799+00:00 2021-04-16T08:05:26.284060+00:00 0:00:02.853261 17754 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T08:05:21.224760+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T07:00:00+00:00 EmrJobFlowSensor 2021-04-16T08:01:07.205950+00:00 2021-04-16T08:10:09.992700+00:00 0:09:02.786750 17753 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T08:01:04.946683+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T08:00:45.121814+00:00 2021-04-16T08:00:47.026331+00:00 0:00:01.904517 17752 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T08:00:42.822107+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T07:00:00+00:00 PythonOperator 2021-04-16T08:00:24.976983+00:00 2021-04-16T08:00:27.924646+00:00 0:00:02.947663 17751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T08:00:22.804288+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T06:00:00+00:00 EmrJobFlowSensor 2021-04-16T07:35:36.476257+00:00 2021-04-16T07:45:39.270153+00:00 0:10:02.793896 17750 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T07:35:34.165048+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T06:00:00+00:00 EmrJobFlowSensor 2021-04-16T07:35:36.407265+00:00 2021-04-16T07:44:38.959304+00:00 0:09:02.552039 17749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T07:35:34.165075+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T07:35:16.742669+00:00 2021-04-16T07:35:18.588759+00:00 0:00:01.846090 17748 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T07:35:14.145316+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T07:35:16.559430+00:00 2021-04-16T07:35:18.460665+00:00 0:00:01.901235 17747 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T07:35:14.145289+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T06:00:00+00:00 PythonOperator 2021-04-16T07:34:54.547354+00:00 2021-04-16T07:34:57.472666+00:00 0:00:02.925312 17746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T07:34:52.123779+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T06:00:00+00:00 PythonOperator 2021-04-16T07:34:54.424778+00:00 2021-04-16T07:34:57.591604+00:00 0:00:03.166826 17745 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T07:34:52.123752+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T06:00:00+00:00 TriggerDagRunOperator 2021-04-16T07:34:31.191495+00:00 2021-04-16T07:34:31.703610+00:00 0:00:00.512115 17744 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T07:34:28.153376+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T06:00:00+00:00 TriggerDagRunOperator 2021-04-16T07:34:30.687642+00:00 2021-04-16T07:34:31.130984+00:00 0:00:00.443342 17743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T07:34:28.153329+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T06:05:00+00:00 EmrJobFlowSensor 2021-04-16T07:11:17.782530+00:00 2021-04-16T07:20:20.694369+00:00 0:09:02.911839 17742 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T07:11:15.508316+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T06:00:00+00:00 EmrJobFlowSensor 2021-04-16T07:11:18.096998+00:00 2021-04-16T07:34:22.897316+00:00 0:23:04.800318 17741 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T07:11:15.508291+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T07:10:57.926835+00:00 2021-04-16T07:10:59.657572+00:00 0:00:01.730737 17740 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T07:10:55.490833+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T07:10:57.749548+00:00 2021-04-16T07:10:59.559017+00:00 0:00:01.809469 17739 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T07:10:55.490860+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T06:00:00+00:00 PythonOperator 2021-04-16T07:10:36.044747+00:00 2021-04-16T07:10:38.991587+00:00 0:00:02.946840 17738 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T07:10:33.456889+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T06:05:00+00:00 PythonOperator 2021-04-16T07:10:35.852442+00:00 2021-04-16T07:10:38.991312+00:00 0:00:03.138870 17737 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T07:10:33.456916+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T05:00:00+00:00 EmrJobFlowSensor 2021-04-16T06:23:11.943594+00:00 2021-04-16T06:23:13.425389+00:00 0:00:01.481795 17735 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T06:23:09.803301+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T05:00:00+00:00 EmrJobFlowSensor 2021-04-16T06:11:24.723801+00:00 2021-04-16T06:20:27.373127+00:00 0:09:02.649326 17733 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T06:11:22.447534+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T06:11:15.393157+00:00 2021-04-16T06:11:17.095851+00:00 0:00:01.702694 17732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T06:11:12.435272+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T06:11:02.764118+00:00 2021-04-16T06:11:04.782888+00:00 0:00:02.018770 17731 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T06:11:00.444445+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T05:00:00+00:00 PythonOperator 2021-04-16T06:10:52.790525+00:00 2021-04-16T06:10:56.268884+00:00 0:00:03.478359 17730 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T06:10:50.460020+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T05:00:00+00:00 PythonOperator 2021-04-16T06:10:42.559198+00:00 2021-04-16T06:10:45.544576+00:00 0:00:02.985378 17729 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T06:10:40.302955+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T05:00:00+00:00 TriggerDagRunOperator 2021-04-16T06:10:36.850934+00:00 2021-04-16T06:10:37.365308+00:00 0:00:00.514374 17728 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T06:10:34.360537+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T05:00:00+00:00 TriggerDagRunOperator 2021-04-16T06:10:36.812613+00:00 2021-04-16T06:10:37.231644+00:00 0:00:00.419031 17727 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T06:10:34.360491+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T05:05:00+00:00 EmrJobFlowSensor 2021-04-16T06:05:54.118827+00:00 2021-04-16T06:14:56.716386+00:00 0:09:02.597559 17726 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T06:05:51.855171+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T06:05:33.889471+00:00 2021-04-16T06:05:35.541963+00:00 0:00:01.652492 17725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T06:05:31.781169+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T05:05:00+00:00 PythonOperator 2021-04-16T06:05:11.903022+00:00 2021-04-16T06:05:14.749214+00:00 0:00:02.846192 17724 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T06:05:09.733770+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T05:00:00+00:00 EmrJobFlowSensor 2021-04-16T06:01:09.698155+00:00 2021-04-16T06:10:12.336235+00:00 0:09:02.638080 17723 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T06:01:07.436351+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T06:00:45.675235+00:00 2021-04-16T06:00:47.470903+00:00 0:00:01.795668 17722 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T06:00:43.358907+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T05:00:00+00:00 PythonOperator 2021-04-16T06:00:23.592498+00:00 2021-04-16T06:00:26.814026+00:00 0:00:03.221528 17721 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T06:00:21.340933+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T04:00:00+00:00 EmrJobFlowSensor 2021-04-16T05:12:32.510220+00:00 2021-04-16T05:32:36.513501+00:00 0:20:04.003281 17719 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T05:12:30.285105+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T04:00:00+00:00 EmrJobFlowSensor 2021-04-16T05:12:30.806868+00:00 2021-04-16T05:22:33.613728+00:00 0:10:02.806860 17718 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T05:12:28.368796+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T05:12:10.757776+00:00 2021-04-16T05:12:12.510790+00:00 0:00:01.753014 17717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T05:12:08.265520+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T05:12:08.398102+00:00 2021-04-16T05:12:10.403616+00:00 0:00:02.005514 17716 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T05:12:06.263987+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T04:00:00+00:00 PythonOperator 2021-04-16T05:11:49.513974+00:00 2021-04-16T05:11:52.545169+00:00 0:00:03.031195 17715 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T05:11:46.248126+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T04:00:00+00:00 PythonOperator 2021-04-16T05:11:47.388626+00:00 2021-04-16T05:11:51.200569+00:00 0:00:03.811943 17714 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T05:11:44.280256+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T04:00:00+00:00 TriggerDagRunOperator 2021-04-16T05:11:26.661399+00:00 2021-04-16T05:11:27.182112+00:00 0:00:00.520713 17713 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T05:11:24.185045+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T04:00:00+00:00 TriggerDagRunOperator 2021-04-16T05:11:26.496549+00:00 2021-04-16T05:11:26.953065+00:00 0:00:00.456516 17712 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T05:11:24.185014+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T04:05:00+00:00 EmrJobFlowSensor 2021-04-16T05:06:07.763655+00:00 2021-04-16T05:14:10.280563+00:00 0:08:02.516908 17711 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T05:06:05.559171+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T05:05:41.946789+00:00 2021-04-16T05:05:43.620829+00:00 0:00:01.674040 17710 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T05:05:39.429241+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T04:05:00+00:00 PythonOperator 2021-04-16T05:05:19.872813+00:00 2021-04-16T05:05:22.790611+00:00 0:00:02.917798 17709 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T05:05:17.481387+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T04:00:00+00:00 EmrJobFlowSensor 2021-04-16T05:01:05.363143+00:00 2021-04-16T05:11:08.094398+00:00 0:10:02.731255 17708 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T05:01:03.014615+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T05:00:43.221969+00:00 2021-04-16T05:00:45.086684+00:00 0:00:01.864715 17707 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T05:00:40.994202+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T04:00:00+00:00 PythonOperator 2021-04-16T05:00:21.394513+00:00 2021-04-16T05:00:24.354182+00:00 0:00:02.959669 17706 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T05:00:18.958321+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T03:00:00+00:00 EmrJobFlowSensor 2021-04-16T04:10:16.644508+00:00 2021-04-16T04:19:19.500343+00:00 0:09:02.855835 17704 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T04:10:14.263554+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T03:00:00+00:00 EmrJobFlowSensor 2021-04-16T04:10:04.854747+00:00 2021-04-16T04:19:07.692329+00:00 0:09:02.837582 17703 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T04:10:02.193035+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T04:09:54.419986+00:00 2021-04-16T04:09:56.091862+00:00 0:00:01.671876 17702 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T04:09:52.186126+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T04:09:42.313831+00:00 2021-04-16T04:09:44.157343+00:00 0:00:01.843512 17701 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T04:09:40.126870+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T03:00:00+00:00 PythonOperator 2021-04-16T04:09:34.914716+00:00 2021-04-16T04:09:38.117143+00:00 0:00:03.202427 17700 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T04:09:32.120660+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T03:00:00+00:00 PythonOperator 2021-04-16T04:09:22.486956+00:00 2021-04-16T04:09:25.421582+00:00 0:00:02.934626 17699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T04:09:20.108142+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T03:00:00+00:00 TriggerDagRunOperator 2021-04-16T04:09:16.424293+00:00 2021-04-16T04:09:17.159084+00:00 0:00:00.734791 17698 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T04:09:14.103440+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T03:00:00+00:00 TriggerDagRunOperator 2021-04-16T04:09:16.271783+00:00 2021-04-16T04:09:17.007909+00:00 0:00:00.736126 17697 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T04:09:14.103406+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T03:05:00+00:00 EmrJobFlowSensor 2021-04-16T04:05:56.089345+00:00 2021-04-16T04:14:58.584469+00:00 0:09:02.495124 17696 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T04:05:53.863560+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T04:05:36.271176+00:00 2021-04-16T04:05:38.014052+00:00 0:00:01.742876 17695 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T04:05:33.877991+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T03:05:00+00:00 PythonOperator 2021-04-16T04:05:13.885217+00:00 2021-04-16T04:05:16.768149+00:00 0:00:02.882932 17694 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T04:05:11.751850+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T03:00:00+00:00 EmrJobFlowSensor 2021-04-16T04:00:53.558776+00:00 2021-04-16T04:08:56.026643+00:00 0:08:02.467867 17693 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T04:00:51.361838+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T04:00:33.509796+00:00 2021-04-16T04:00:35.344338+00:00 0:00:01.834542 17692 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T04:00:31.287234+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T03:00:00+00:00 PythonOperator 2021-04-16T04:00:11.592735+00:00 2021-04-16T04:00:14.552427+00:00 0:00:02.959692 17691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T04:00:09.216378+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T02:00:00+00:00 EmrJobFlowSensor 2021-04-16T03:11:20.285192+00:00 2021-04-16T03:21:22.995854+00:00 0:10:02.710662 17689 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T03:11:17.968834+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T02:00:00+00:00 EmrJobFlowSensor 2021-04-16T03:11:04.477231+00:00 2021-04-16T03:20:07.438981+00:00 0:09:02.961750 17688 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T03:11:01.894789+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T03:10:49.992893+00:00 2021-04-16T03:10:51.653575+00:00 0:00:01.660682 17687 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T03:10:47.828605+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T03:10:38.317323+00:00 2021-04-16T03:10:40.094374+00:00 0:00:01.777051 17686 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T03:10:35.818933+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T02:00:00+00:00 PythonOperator 2021-04-16T03:10:26.042298+00:00 2021-04-16T03:10:29.210831+00:00 0:00:03.168533 17685 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T03:10:23.808831+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T02:00:00+00:00 PythonOperator 2021-04-16T03:10:18.294954+00:00 2021-04-16T03:10:21.210056+00:00 0:00:02.915102 17684 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T03:10:15.796250+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T02:00:00+00:00 TriggerDagRunOperator 2021-04-16T03:10:06.147057+00:00 2021-04-16T03:10:06.671036+00:00 0:00:00.523979 17683 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T03:10:03.786565+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T02:00:00+00:00 TriggerDagRunOperator 2021-04-16T03:10:05.981376+00:00 2021-04-16T03:10:06.402020+00:00 0:00:00.420644 17682 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T03:10:03.786535+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T02:05:00+00:00 EmrJobFlowSensor 2021-04-16T03:05:59.910506+00:00 2021-04-16T03:15:02.873553+00:00 0:09:02.963047 17681 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T03:05:57.398079+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T03:05:37.715873+00:00 2021-04-16T03:05:39.492724+00:00 0:00:01.776851 17680 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T03:05:35.377012+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T02:05:00+00:00 PythonOperator 2021-04-16T03:05:17.831475+00:00 2021-04-16T03:05:20.678371+00:00 0:00:02.846896 17679 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T03:05:15.368347+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T02:00:00+00:00 EmrJobFlowSensor 2021-04-16T03:00:49.230799+00:00 2021-04-16T03:09:51.817612+00:00 0:09:02.586813 17678 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T03:00:46.805590+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T03:00:26.889239+00:00 2021-04-16T03:00:28.608375+00:00 0:00:01.719136 17677 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T03:00:24.783407+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T02:00:00+00:00 PythonOperator 2021-04-16T03:00:05.367824+00:00 2021-04-16T03:00:08.341043+00:00 0:00:02.973219 17676 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T03:00:02.765674+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T01:00:00+00:00 EmrJobFlowSensor 2021-04-16T02:11:24.869458+00:00 2021-04-16T02:20:27.448518+00:00 0:09:02.579060 17674 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T02:11:22.102411+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T01:00:00+00:00 EmrJobFlowSensor 2021-04-16T02:11:22.515087+00:00 2021-04-16T02:21:25.648117+00:00 0:10:03.133030 17673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T02:11:20.140630+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T02:11:04.418182+00:00 2021-04-16T02:11:06.197825+00:00 0:00:01.779643 17672 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T02:11:02.085029+00:00 2 default_pool