Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success vc-asset-import_v002 create_emr_steps 2021-05-08T21:05:00+00:00 PythonOperator 2021-05-08T22:05:10.549146+00:00 2021-05-08T22:05:13.652124+00:00 0:00:03.102978 25963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T22:05:08.397637+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T21:00:00+00:00 EmrJobFlowSensor 2021-05-08T22:00:58.078640+00:00 2021-05-08T22:22:02.509657+00:00 0:21:04.431017 25962 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T22:00:55.927653+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T22:00:36.103674+00:00 2021-05-08T22:00:37.805932+00:00 0:00:01.702258 25961 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T22:00:33.844214+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T21:00:00+00:00 PythonOperator 2021-05-08T22:00:16.254057+00:00 2021-05-08T22:00:19.336429+00:00 0:00:03.082372 25960 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T22:00:13.853374+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-08T20:00:00+00:00 EmrJobFlowSensor 2021-05-08T21:12:16.492774+00:00 2021-05-08T21:20:18.954567+00:00 0:08:02.461793 25958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T21:12:14.400821+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-08T20:00:00+00:00 EmrJobFlowSensor 2021-05-08T21:12:03.182938+00:00 2021-05-08T21:21:05.837170+00:00 0:09:02.654232 25957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T21:12:00.471866+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T21:11:54.522428+00:00 2021-05-08T21:11:56.316692+00:00 0:00:01.794264 25956 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T21:11:52.333332+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T21:11:40.941567+00:00 2021-05-08T21:11:42.634210+00:00 0:00:01.692643 25955 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T21:11:38.334772+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T20:00:00+00:00 PythonOperator 2021-05-08T21:11:32.505657+00:00 2021-05-08T21:11:35.531716+00:00 0:00:03.026059 25954 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T21:11:30.317426+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T20:00:00+00:00 PythonOperator 2021-05-08T21:11:19.255009+00:00 2021-05-08T21:11:22.683989+00:00 0:00:03.428980 25953 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T21:11:16.383452+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T20:00:00+00:00 TriggerDagRunOperator 2021-05-08T21:11:12.583079+00:00 2021-05-08T21:11:13.120783+00:00 0:00:00.537704 25952 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T21:11:10.299581+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T20:00:00+00:00 TriggerDagRunOperator 2021-05-08T21:11:12.519947+00:00 2021-05-08T21:11:12.972123+00:00 0:00:00.452176 25951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T21:11:10.299540+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T20:05:00+00:00 EmrJobFlowSensor 2021-05-08T21:06:02.164851+00:00 2021-05-08T21:14:04.716368+00:00 0:08:02.551517 25950 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T21:05:59.746066+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T20:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T21:05:39.872734+00:00 2021-05-08T21:05:41.688123+00:00 0:00:01.815389 25949 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T21:05:37.506176+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T20:05:00+00:00 PythonOperator 2021-05-08T21:05:19.642279+00:00 2021-05-08T21:05:22.668258+00:00 0:00:03.025979 25948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T21:05:17.475645+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T20:00:00+00:00 EmrJobFlowSensor 2021-05-08T21:00:50.898101+00:00 2021-05-08T21:10:53.686056+00:00 0:10:02.787955 25947 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T21:00:48.801814+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T21:00:29.427475+00:00 2021-05-08T21:00:31.223982+00:00 0:00:01.796507 25946 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T21:00:26.850817+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T20:00:00+00:00 PythonOperator 2021-05-08T21:00:08.984246+00:00 2021-05-08T21:00:12.084932+00:00 0:00:03.100686 25945 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T21:00:06.713395+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-08T19:00:00+00:00 EmrJobFlowSensor 2021-05-08T20:10:31.891760+00:00 2021-05-08T20:18:34.343764+00:00 0:08:02.452004 25943 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T20:10:29.274380+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-08T19:00:00+00:00 EmrJobFlowSensor 2021-05-08T20:10:29.670113+00:00 2021-05-08T20:20:32.601639+00:00 0:10:02.931526 25942 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T20:10:27.260249+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T20:10:09.645170+00:00 2021-05-08T20:10:11.320959+00:00 0:00:01.675789 25941 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T20:10:07.126229+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T20:10:07.242151+00:00 2021-05-08T20:10:09.310342+00:00 0:00:02.068191 25940 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T20:10:05.120760+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T19:00:00+00:00 PythonOperator 2021-05-08T20:09:47.446552+00:00 2021-05-08T20:09:50.547791+00:00 0:00:03.101239 25939 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T20:09:45.117065+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T19:00:00+00:00 PythonOperator 2021-05-08T20:09:45.615901+00:00 2021-05-08T20:09:48.938464+00:00 0:00:03.322563 25938 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T20:09:43.167912+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T19:00:00+00:00 TriggerDagRunOperator 2021-05-08T20:09:29.903500+00:00 2021-05-08T20:09:30.414713+00:00 0:00:00.511213 25937 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T20:09:27.147557+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T19:00:00+00:00 TriggerDagRunOperator 2021-05-08T20:09:29.459622+00:00 2021-05-08T20:09:29.856442+00:00 0:00:00.396820 25936 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T20:09:27.147604+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T19:05:00+00:00 EmrJobFlowSensor 2021-05-08T20:06:35.008330+00:00 2021-05-08T20:15:37.752578+00:00 0:09:02.744248 25935 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T20:06:32.746723+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T19:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T20:06:14.855555+00:00 2021-05-08T20:06:16.532136+00:00 0:00:01.676581 25934 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T20:06:12.723952+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T19:05:00+00:00 PythonOperator 2021-05-08T20:05:53.076815+00:00 2021-05-08T20:05:56.147236+00:00 0:00:03.070421 25933 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T20:05:50.841541+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T19:00:00+00:00 EmrJobFlowSensor 2021-05-08T20:01:06.321392+00:00 2021-05-08T20:09:08.845806+00:00 0:08:02.524414 25932 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T20:01:04.186154+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T20:00:44.206182+00:00 2021-05-08T20:00:45.919911+00:00 0:00:01.713729 25931 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T20:00:42.125363+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T19:00:00+00:00 PythonOperator 2021-05-08T20:00:24.524390+00:00 2021-05-08T20:00:27.561382+00:00 0:00:03.036992 25930 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T20:00:22.103058+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-08T18:00:00+00:00 EmrJobFlowSensor 2021-05-08T19:11:12.836000+00:00 2021-05-08T19:21:15.589951+00:00 0:10:02.753951 25928 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T19:11:10.594478+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-08T18:00:00+00:00 EmrJobFlowSensor 2021-05-08T19:11:06.946652+00:00 2021-05-08T19:20:09.759402+00:00 0:09:02.812750 25927 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T19:11:04.661501+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T19:10:53.161985+00:00 2021-05-08T19:10:54.850757+00:00 0:00:01.688772 25926 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T19:10:50.645122+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T19:10:46.864714+00:00 2021-05-08T19:10:48.562962+00:00 0:00:01.698248 25925 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T19:10:44.561522+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T18:00:00+00:00 PythonOperator 2021-05-08T19:10:31.081545+00:00 2021-05-08T19:10:34.457408+00:00 0:00:03.375863 25924 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T19:10:28.472549+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T18:00:00+00:00 PythonOperator 2021-05-08T19:10:24.656377+00:00 2021-05-08T19:10:27.792336+00:00 0:00:03.135959 25923 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T19:10:22.363891+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T18:00:00+00:00 TriggerDagRunOperator 2021-05-08T19:10:18.856540+00:00 2021-05-08T19:10:19.359582+00:00 0:00:00.503042 25922 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T19:10:16.341684+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T18:00:00+00:00 TriggerDagRunOperator 2021-05-08T19:10:18.585327+00:00 2021-05-08T19:10:19.013680+00:00 0:00:00.428353 25921 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T19:10:16.341633+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T18:05:00+00:00 EmrJobFlowSensor 2021-05-08T19:05:51.997477+00:00 2021-05-08T19:14:54.520556+00:00 0:09:02.523079 25920 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T19:05:49.857056+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T18:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T19:05:30.296804+00:00 2021-05-08T19:05:31.924877+00:00 0:00:01.628073 25919 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T19:05:27.768355+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T18:05:00+00:00 PythonOperator 2021-05-08T19:05:07.968139+00:00 2021-05-08T19:05:11.044246+00:00 0:00:03.076107 25918 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T19:05:05.667376+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T18:00:00+00:00 EmrJobFlowSensor 2021-05-08T19:01:05.246966+00:00 2021-05-08T19:10:08.041545+00:00 0:09:02.794579 25917 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T19:01:03.096774+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T19:00:41.097674+00:00 2021-05-08T19:00:42.977299+00:00 0:00:01.879625 25916 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T19:00:38.892598+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T18:00:00+00:00 PythonOperator 2021-05-08T19:00:21.214986+00:00 2021-05-08T19:00:24.486948+00:00 0:00:03.271962 25915 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T19:00:18.836239+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-08T17:00:00+00:00 EmrJobFlowSensor 2021-05-08T18:10:19.485009+00:00 2021-05-08T18:19:22.136948+00:00 0:09:02.651939 25913 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T18:10:17.067549+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-08T17:00:00+00:00 EmrJobFlowSensor 2021-05-08T18:10:11.387526+00:00 2021-05-08T18:19:14.052828+00:00 0:09:02.665302 25912 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T18:10:09.142051+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T18:09:57.932445+00:00 2021-05-08T18:09:59.711358+00:00 0:00:01.778913 25911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T18:09:55.054258+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T18:09:49.413249+00:00 2021-05-08T18:09:51.112604+00:00 0:00:01.699355 25910 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T18:09:46.994587+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T17:00:00+00:00 PythonOperator 2021-05-08T18:09:35.321845+00:00 2021-05-08T18:09:38.410249+00:00 0:00:03.088404 25909 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T18:09:32.967599+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T17:00:00+00:00 PythonOperator 2021-05-08T18:09:27.334079+00:00 2021-05-08T18:09:30.668606+00:00 0:00:03.334527 25908 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T18:09:24.970424+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T17:00:00+00:00 TriggerDagRunOperator 2021-05-08T18:09:15.488322+00:00 2021-05-08T18:09:16.068665+00:00 0:00:00.580343 25907 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T18:09:12.967270+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T17:00:00+00:00 TriggerDagRunOperator 2021-05-08T18:09:15.333195+00:00 2021-05-08T18:09:15.858048+00:00 0:00:00.524853 25906 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T18:09:12.967318+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T17:05:00+00:00 EmrJobFlowSensor 2021-05-08T18:05:54.992307+00:00 2021-05-08T18:14:57.632523+00:00 0:09:02.640216 25905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T18:05:52.551535+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T17:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T18:05:32.975825+00:00 2021-05-08T18:05:34.735656+00:00 0:00:01.759831 25904 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T18:05:30.446471+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T17:05:00+00:00 PythonOperator 2021-05-08T18:05:10.694460+00:00 2021-05-08T18:05:13.732671+00:00 0:00:03.038211 25903 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T18:05:08.446563+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T17:00:00+00:00 EmrJobFlowSensor 2021-05-08T18:01:06.319315+00:00 2021-05-08T18:09:09.019159+00:00 0:08:02.699844 25902 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T18:01:03.841408+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T18:00:45.821644+00:00 2021-05-08T18:00:47.658697+00:00 0:00:01.837053 25901 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T18:00:43.581082+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T17:00:00+00:00 PythonOperator 2021-05-08T18:00:23.829642+00:00 2021-05-08T18:00:27.007743+00:00 0:00:03.178101 25900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T18:00:21.560484+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-08T16:00:00+00:00 EmrJobFlowSensor 2021-05-08T17:11:33.797187+00:00 2021-05-08T17:20:36.585198+00:00 0:09:02.788011 25898 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T17:11:31.546297+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-08T16:00:00+00:00 EmrJobFlowSensor 2021-05-08T17:11:25.853009+00:00 2021-05-08T17:20:28.779070+00:00 0:09:02.926061 25897 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T17:11:23.515852+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T17:11:11.680777+00:00 2021-05-08T17:11:13.528556+00:00 0:00:01.847779 25896 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T17:11:09.505719+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T17:11:03.712935+00:00 2021-05-08T17:11:05.415882+00:00 0:00:01.702947 25895 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T17:11:01.485656+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T16:00:00+00:00 PythonOperator 2021-05-08T17:10:50.109313+00:00 2021-05-08T17:10:53.239312+00:00 0:00:03.129999 25894 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T17:10:47.413320+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T16:00:00+00:00 PythonOperator 2021-05-08T17:10:41.476646+00:00 2021-05-08T17:10:44.817245+00:00 0:00:03.340599 25893 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T17:10:39.403636+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T16:00:00+00:00 TriggerDagRunOperator 2021-05-08T17:10:25.701053+00:00 2021-05-08T17:10:26.242759+00:00 0:00:00.541706 25892 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T17:10:23.395331+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T16:00:00+00:00 TriggerDagRunOperator 2021-05-08T17:10:25.557141+00:00 2021-05-08T17:10:25.999325+00:00 0:00:00.442184 25891 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T17:10:23.395383+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T16:05:00+00:00 EmrJobFlowSensor 2021-05-08T17:06:05.174289+00:00 2021-05-08T17:15:07.965584+00:00 0:09:02.791295 25890 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T17:06:02.898387+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T16:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T17:05:42.988264+00:00 2021-05-08T17:05:44.666202+00:00 0:00:01.677938 25889 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T17:05:40.822734+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T16:05:00+00:00 PythonOperator 2021-05-08T17:05:23.052895+00:00 2021-05-08T17:05:26.057699+00:00 0:00:03.004804 25888 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T17:05:20.803375+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T16:00:00+00:00 EmrJobFlowSensor 2021-05-08T17:00:58.796006+00:00 2021-05-08T17:10:01.536722+00:00 0:09:02.740716 25887 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T17:00:56.463640+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T17:00:38.566994+00:00 2021-05-08T17:00:40.283367+00:00 0:00:01.716373 25886 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T17:00:36.318497+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T16:00:00+00:00 PythonOperator 2021-05-08T17:00:16.785830+00:00 2021-05-08T17:00:19.909006+00:00 0:00:03.123176 25885 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T17:00:14.350868+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-08T15:00:00+00:00 EmrJobFlowSensor 2021-05-08T16:11:18.705909+00:00 2021-05-08T16:19:21.215945+00:00 0:08:02.510036 25883 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T16:11:16.051360+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-08T15:00:00+00:00 EmrJobFlowSensor 2021-05-08T16:11:12.216901+00:00 2021-05-08T16:21:15.318146+00:00 0:10:03.101245 25882 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T16:11:10.037755+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T16:10:56.200130+00:00 2021-05-08T16:10:58.026458+00:00 0:00:01.826328 25881 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T16:10:54.010426+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T16:10:52.258967+00:00 2021-05-08T16:10:54.136505+00:00 0:00:01.877538 25880 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T16:10:50.004523+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T15:00:00+00:00 PythonOperator 2021-05-08T16:10:36.162689+00:00 2021-05-08T16:10:39.259702+00:00 0:00:03.097013 25879 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T16:10:33.983140+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T15:00:00+00:00 PythonOperator 2021-05-08T16:10:30.325661+00:00 2021-05-08T16:10:33.629767+00:00 0:00:03.304106 25878 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T16:10:27.965882+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T15:00:00+00:00 TriggerDagRunOperator 2021-05-08T16:10:18.340638+00:00 2021-05-08T16:10:18.865614+00:00 0:00:00.524976 25877 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T16:10:15.880372+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T15:00:00+00:00 TriggerDagRunOperator 2021-05-08T16:10:17.998146+00:00 2021-05-08T16:10:18.502033+00:00 0:00:00.503887 25876 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T16:10:15.880324+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T15:05:00+00:00 EmrJobFlowSensor 2021-05-08T16:06:05.611828+00:00 2021-05-08T16:15:08.153775+00:00 0:09:02.541947 25875 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T16:06:03.457730+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T15:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T16:05:43.521405+00:00 2021-05-08T16:05:45.147442+00:00 0:00:01.626037 25874 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T16:05:41.394250+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T15:05:00+00:00 PythonOperator 2021-05-08T16:05:21.559226+00:00 2021-05-08T16:05:24.712052+00:00 0:00:03.152826 25873 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T16:05:19.369838+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T15:00:00+00:00 EmrJobFlowSensor 2021-05-08T16:00:50.911422+00:00 2021-05-08T16:09:53.740637+00:00 0:09:02.829215 25872 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T16:00:48.697055+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T16:00:29.043789+00:00 2021-05-08T16:00:30.843767+00:00 0:00:01.799978 25871 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T16:00:26.648283+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T15:00:00+00:00 PythonOperator 2021-05-08T16:00:08.815985+00:00 2021-05-08T16:00:11.933744+00:00 0:00:03.117759 25870 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T16:00:06.634979+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-08T14:00:00+00:00 EmrJobFlowSensor 2021-05-08T15:12:58.352586+00:00 2021-05-08T15:21:01.030557+00:00 0:08:02.677971 25869 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T15:12:55.951777+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-08T14:00:00+00:00 EmrJobFlowSensor 2021-05-08T15:12:36.065279+00:00 2021-05-08T15:22:38.800049+00:00 0:10:02.734770 25868 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T15:12:33.902113+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T15:12:22.154210+00:00 2021-05-08T15:12:24.061188+00:00 0:00:01.906978 25867 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T15:12:19.948032+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T15:12:14.046421+00:00 2021-05-08T15:12:15.796921+00:00 0:00:01.750500 25866 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T15:12:11.865764+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T14:00:00+00:00 PythonOperator 2021-05-08T15:12:02.011006+00:00 2021-05-08T15:12:05.063298+00:00 0:00:03.052292 25865 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T15:11:59.857827+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T14:00:00+00:00 PythonOperator 2021-05-08T15:11:54.189878+00:00 2021-05-08T15:11:57.547857+00:00 0:00:03.357979 25864 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T15:11:51.820558+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T14:00:00+00:00 TriggerDagRunOperator 2021-05-08T15:11:42.202396+00:00 2021-05-08T15:11:42.790746+00:00 0:00:00.588350 25863 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T15:11:39.812513+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T14:00:00+00:00 TriggerDagRunOperator 2021-05-08T15:11:42.129805+00:00 2021-05-08T15:11:42.530059+00:00 0:00:00.400254 25862 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T15:11:39.812485+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T14:05:00+00:00 EmrJobFlowSensor 2021-05-08T15:06:20.548082+00:00 2021-05-08T15:15:23.262825+00:00 0:09:02.714743 25860 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T15:06:18.409333+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T14:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T15:05:50.457765+00:00 2021-05-08T15:05:52.075834+00:00 0:00:01.618069 25859 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T15:05:48.362340+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T14:05:00+00:00 PythonOperator 2021-05-08T15:05:24.635798+00:00 2021-05-08T15:05:27.691978+00:00 0:00:03.056180 25858 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T15:05:22.276004+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T14:00:00+00:00 EmrJobFlowSensor 2021-05-08T15:01:05.980967+00:00 2021-05-08T15:11:08.876032+00:00 0:10:02.895065 25857 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T15:01:03.895666+00:00 2 default_pool