Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T09:12:23.952448+00:00 2021-05-05T09:12:25.647731+00:00 0:00:01.695283 24687 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T09:12:21.712912+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T09:12:15.907212+00:00 2021-05-05T09:12:17.767114+00:00 0:00:01.859902 24686 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T09:12:13.705421+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T08:00:00+00:00 PythonOperator 2021-05-05T09:11:58.068305+00:00 2021-05-05T09:12:01.192346+00:00 0:00:03.124041 24685 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T09:11:55.760590+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T08:00:00+00:00 PythonOperator 2021-05-05T09:11:50.104459+00:00 2021-05-05T09:11:53.395485+00:00 0:00:03.291026 24684 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T09:11:47.651908+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T08:00:00+00:00 TriggerDagRunOperator 2021-05-05T09:11:34.137954+00:00 2021-05-05T09:11:34.709537+00:00 0:00:00.571583 24683 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T09:11:31.591971+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T08:00:00+00:00 TriggerDagRunOperator 2021-05-05T09:11:33.806450+00:00 2021-05-05T09:11:34.234684+00:00 0:00:00.428234 24682 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T09:11:31.591923+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-05T08:05:00+00:00 EmrJobFlowSensor 2021-05-05T09:06:05.356949+00:00 2021-05-05T09:15:08.005881+00:00 0:09:02.648932 24681 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T09:06:03.067869+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T08:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T09:05:41.168962+00:00 2021-05-05T09:05:42.827866+00:00 0:00:01.658904 24680 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T09:05:39.059242+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T08:05:00+00:00 PythonOperator 2021-05-05T09:05:19.202252+00:00 2021-05-05T09:05:22.260035+00:00 0:00:03.057783 24679 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T09:05:17.025041+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T08:00:00+00:00 EmrJobFlowSensor 2021-05-05T09:01:04.974472+00:00 2021-05-05T09:11:07.932695+00:00 0:10:02.958223 24678 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T09:01:02.613548+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T09:00:42.928553+00:00 2021-05-05T09:00:44.627665+00:00 0:00:01.699112 24677 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T09:00:40.592515+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T08:00:00+00:00 PythonOperator 2021-05-05T09:00:23.139859+00:00 2021-05-05T09:00:26.183397+00:00 0:00:03.043538 24676 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T09:00:20.519970+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-05T07:00:00+00:00 EmrJobFlowSensor 2021-05-05T08:12:08.121643+00:00 2021-05-05T08:22:10.940461+00:00 0:10:02.818818 24674 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T08:12:05.666891+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-05T07:00:00+00:00 EmrJobFlowSensor 2021-05-05T08:12:02.118778+00:00 2021-05-05T08:21:04.757321+00:00 0:09:02.638543 24673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T08:11:59.670815+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T08:11:46.085825+00:00 2021-05-05T08:11:47.919584+00:00 0:00:01.833759 24672 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T08:11:43.653747+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T08:11:40.092328+00:00 2021-05-05T08:11:41.752907+00:00 0:00:01.660579 24671 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T08:11:37.653520+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T07:00:00+00:00 PythonOperator 2021-05-05T08:11:23.961795+00:00 2021-05-05T08:11:26.968864+00:00 0:00:03.007069 24670 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T08:11:21.567837+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T07:00:00+00:00 PythonOperator 2021-05-05T08:11:19.686100+00:00 2021-05-05T08:11:23.025350+00:00 0:00:03.339250 24669 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T08:11:17.507967+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T07:00:00+00:00 TriggerDagRunOperator 2021-05-05T08:11:05.866148+00:00 2021-05-05T08:11:06.420647+00:00 0:00:00.554499 24668 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T08:11:03.485005+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T07:00:00+00:00 TriggerDagRunOperator 2021-05-05T08:11:05.632219+00:00 2021-05-05T08:11:06.039432+00:00 0:00:00.407213 24667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T08:11:03.484941+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-05T07:05:00+00:00 EmrJobFlowSensor 2021-05-05T08:05:49.360790+00:00 2021-05-05T08:14:52.134343+00:00 0:09:02.773553 24666 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T08:05:46.902733+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T07:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T08:05:27.334243+00:00 2021-05-05T08:05:29.089391+00:00 0:00:01.755148 24665 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T08:05:24.943950+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T07:05:00+00:00 PythonOperator 2021-05-05T08:05:06.981505+00:00 2021-05-05T08:05:10.023961+00:00 0:00:03.042456 24664 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T08:05:04.787488+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T07:00:00+00:00 EmrJobFlowSensor 2021-05-05T08:00:48.580943+00:00 2021-05-05T08:10:51.465929+00:00 0:10:02.884986 24663 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T08:00:46.282552+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T08:00:28.862303+00:00 2021-05-05T08:00:30.717548+00:00 0:00:01.855245 24662 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T08:00:26.276773+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T07:00:00+00:00 PythonOperator 2021-05-05T08:00:06.674721+00:00 2021-05-05T08:00:09.706758+00:00 0:00:03.032037 24661 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T08:00:04.184125+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-05T06:00:00+00:00 EmrJobFlowSensor 2021-05-05T07:11:15.126685+00:00 2021-05-05T07:20:17.694581+00:00 0:09:02.567896 24659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T07:11:12.914013+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-05T06:00:00+00:00 EmrJobFlowSensor 2021-05-05T07:11:03.825345+00:00 2021-05-05T07:20:06.650882+00:00 0:09:02.825537 24658 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T07:11:00.904671+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T07:10:55.332142+00:00 2021-05-05T07:10:57.113830+00:00 0:00:01.781688 24657 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T07:10:52.895033+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T07:10:41.725076+00:00 2021-05-05T07:10:43.511287+00:00 0:00:01.786211 24656 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T07:10:38.949930+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T06:00:00+00:00 PythonOperator 2021-05-05T07:10:33.372594+00:00 2021-05-05T07:10:36.422505+00:00 0:00:03.049911 24655 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T07:10:30.874365+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T06:00:00+00:00 PythonOperator 2021-05-05T07:10:21.480385+00:00 2021-05-05T07:10:24.732285+00:00 0:00:03.251900 24654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T07:10:18.856302+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T06:00:00+00:00 TriggerDagRunOperator 2021-05-05T07:10:13.143730+00:00 2021-05-05T07:10:13.685037+00:00 0:00:00.541307 24653 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T07:10:10.794769+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T06:00:00+00:00 TriggerDagRunOperator 2021-05-05T07:10:12.988299+00:00 2021-05-05T07:10:13.426739+00:00 0:00:00.438440 24652 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T07:10:10.794803+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-05T06:05:00+00:00 EmrJobFlowSensor 2021-05-05T07:06:14.704249+00:00 2021-05-05T07:14:17.301789+00:00 0:08:02.597540 24651 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T07:06:12.454714+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T06:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T07:05:48.442685+00:00 2021-05-05T07:05:50.103186+00:00 0:00:01.660501 24650 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T07:05:46.322164+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T06:05:00+00:00 PythonOperator 2021-05-05T07:05:20.372028+00:00 2021-05-05T07:05:23.386850+00:00 0:00:03.014822 24649 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T07:05:18.291985+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T06:00:00+00:00 EmrJobFlowSensor 2021-05-05T07:00:56.323290+00:00 2021-05-05T07:09:59.120757+00:00 0:09:02.797467 24648 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T07:00:53.848892+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T07:00:34.199547+00:00 2021-05-05T07:00:35.914322+00:00 0:00:01.714775 24647 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T07:00:31.829553+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T06:00:00+00:00 PythonOperator 2021-05-05T07:00:12.337792+00:00 2021-05-05T07:00:15.391026+00:00 0:00:03.053234 24646 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T07:00:09.872204+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-05T05:00:00+00:00 EmrJobFlowSensor 2021-05-05T06:11:43.731622+00:00 2021-05-05T06:19:46.350945+00:00 0:08:02.619323 24644 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T06:11:41.338857+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-05T05:00:00+00:00 EmrJobFlowSensor 2021-05-05T06:11:27.710773+00:00 2021-05-05T06:25:31.055548+00:00 0:14:03.344775 24643 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T06:11:25.326202+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T06:11:23.548542+00:00 2021-05-05T06:11:25.258972+00:00 0:00:01.710430 24642 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T06:11:21.321376+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T06:11:05.755775+00:00 2021-05-05T06:11:07.561114+00:00 0:00:01.805339 24641 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T06:11:03.369295+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T05:00:00+00:00 PythonOperator 2021-05-05T06:11:01.513999+00:00 2021-05-05T06:11:04.552572+00:00 0:00:03.038573 24640 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T06:10:59.309937+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T05:00:00+00:00 PythonOperator 2021-05-05T06:10:43.608051+00:00 2021-05-05T06:10:47.071611+00:00 0:00:03.463560 24639 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T06:10:41.288426+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T05:00:00+00:00 TriggerDagRunOperator 2021-05-05T06:10:37.801049+00:00 2021-05-05T06:10:38.333666+00:00 0:00:00.532617 24638 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T06:10:35.284057+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T05:00:00+00:00 TriggerDagRunOperator 2021-05-05T06:10:37.689804+00:00 2021-05-05T06:10:38.102696+00:00 0:00:00.412892 24637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T06:10:35.284031+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-05T05:05:00+00:00 EmrJobFlowSensor 2021-05-05T06:05:48.995753+00:00 2021-05-05T06:13:51.542791+00:00 0:08:02.547038 24636 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T06:05:46.797972+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T05:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T06:05:26.863714+00:00 2021-05-05T06:05:28.526233+00:00 0:00:01.662519 24635 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T06:05:24.743470+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T05:05:00+00:00 PythonOperator 2021-05-05T06:05:05.040011+00:00 2021-05-05T06:05:08.136289+00:00 0:00:03.096278 24634 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T06:05:02.756113+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T05:00:00+00:00 EmrJobFlowSensor 2021-05-05T06:00:58.419223+00:00 2021-05-05T06:10:01.178232+00:00 0:09:02.759009 24633 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T06:00:56.122980+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T06:00:36.456347+00:00 2021-05-05T06:00:38.269066+00:00 0:00:01.812719 24632 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T06:00:34.107117+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T05:00:00+00:00 PythonOperator 2021-05-05T06:00:14.796392+00:00 2021-05-05T06:00:17.841690+00:00 0:00:03.045298 24631 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T06:00:12.085336+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-05T04:00:00+00:00 EmrJobFlowSensor 2021-05-05T05:10:14.872773+00:00 2021-05-05T05:20:17.688644+00:00 0:10:02.815871 24629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T05:10:12.631207+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-05T04:00:00+00:00 EmrJobFlowSensor 2021-05-05T05:10:10.836509+00:00 2021-05-05T05:20:13.617881+00:00 0:10:02.781372 24628 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T05:10:08.628470+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T05:09:54.847995+00:00 2021-05-05T05:09:56.655192+00:00 0:00:01.807197 24627 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T05:09:52.604154+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T05:09:50.789216+00:00 2021-05-05T05:09:52.514318+00:00 0:00:01.725102 24626 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T05:09:48.601451+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T04:00:00+00:00 PythonOperator 2021-05-05T05:09:33.016581+00:00 2021-05-05T05:09:36.066313+00:00 0:00:03.049732 24625 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T05:09:30.653501+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T04:00:00+00:00 PythonOperator 2021-05-05T05:09:28.846771+00:00 2021-05-05T05:09:32.157311+00:00 0:00:03.310540 24624 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T05:09:26.546049+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T04:00:00+00:00 TriggerDagRunOperator 2021-05-05T05:09:10.960749+00:00 2021-05-05T05:09:11.464885+00:00 0:00:00.504136 24623 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T05:09:08.575527+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T04:00:00+00:00 TriggerDagRunOperator 2021-05-05T05:09:10.911318+00:00 2021-05-05T05:09:11.493876+00:00 0:00:00.582558 24622 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T05:09:08.575492+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-05T04:05:00+00:00 EmrJobFlowSensor 2021-05-05T05:05:50.369319+00:00 2021-05-05T05:14:52.939914+00:00 0:09:02.570595 24621 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T05:05:48.223960+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T04:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T05:05:28.634612+00:00 2021-05-05T05:05:30.287307+00:00 0:00:01.652695 24620 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T05:05:26.265493+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T04:05:00+00:00 PythonOperator 2021-05-05T05:05:06.520707+00:00 2021-05-05T05:05:09.499431+00:00 0:00:02.978724 24619 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T05:05:04.252336+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T04:00:00+00:00 EmrJobFlowSensor 2021-05-05T05:00:58.038530+00:00 2021-05-05T05:09:00.613139+00:00 0:08:02.574609 24618 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T05:00:55.611257+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T05:00:36.061562+00:00 2021-05-05T05:00:37.893449+00:00 0:00:01.831887 24617 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T05:00:33.656865+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T04:00:00+00:00 PythonOperator 2021-05-05T05:00:14.000980+00:00 2021-05-05T05:00:17.067492+00:00 0:00:03.066512 24616 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T05:00:11.554949+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-05T03:00:00+00:00 EmrJobFlowSensor 2021-05-05T04:11:42.713257+00:00 2021-05-05T04:19:45.209794+00:00 0:08:02.496537 24614 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T04:11:40.494470+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-05T03:00:00+00:00 EmrJobFlowSensor 2021-05-05T04:11:32.617952+00:00 2021-05-05T04:20:35.163434+00:00 0:09:02.545482 24613 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T04:11:30.484110+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T04:11:20.622609+00:00 2021-05-05T04:11:22.318126+00:00 0:00:01.695517 24612 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T04:11:18.417850+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T04:11:10.943255+00:00 2021-05-05T04:11:12.725625+00:00 0:00:01.782370 24611 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T04:11:08.414925+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T03:00:00+00:00 PythonOperator 2021-05-05T04:10:59.033785+00:00 2021-05-05T04:11:02.090557+00:00 0:00:03.056772 24610 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T04:10:56.461740+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T03:00:00+00:00 PythonOperator 2021-05-05T04:10:49.322932+00:00 2021-05-05T04:10:52.607920+00:00 0:00:03.284988 24609 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T04:10:46.462767+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T03:00:00+00:00 TriggerDagRunOperator 2021-05-05T04:10:40.803577+00:00 2021-05-05T04:10:41.339220+00:00 0:00:00.535643 24608 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T04:10:38.453954+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T03:00:00+00:00 TriggerDagRunOperator 2021-05-05T04:10:40.764815+00:00 2021-05-05T04:10:41.186660+00:00 0:00:00.421845 24607 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T04:10:38.453996+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-05T03:05:00+00:00 EmrJobFlowSensor 2021-05-05T04:05:56.045098+00:00 2021-05-05T04:14:58.727813+00:00 0:09:02.682715 24606 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T04:05:53.859028+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T03:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T04:05:34.353836+00:00 2021-05-05T04:05:36.008626+00:00 0:00:01.654790 24605 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T04:05:31.835529+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T03:05:00+00:00 PythonOperator 2021-05-05T04:05:12.190862+00:00 2021-05-05T04:05:15.200700+00:00 0:00:03.009838 24604 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T04:05:09.871755+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T03:00:00+00:00 EmrJobFlowSensor 2021-05-05T04:01:15.697685+00:00 2021-05-05T04:10:18.491335+00:00 0:09:02.793650 24603 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T04:01:13.320215+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T04:00:49.432011+00:00 2021-05-05T04:00:51.105352+00:00 0:00:01.673341 24602 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T04:00:47.296832+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T03:00:00+00:00 PythonOperator 2021-05-05T04:00:21.398148+00:00 2021-05-05T04:00:24.441309+00:00 0:00:03.043161 24601 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T04:00:19.211344+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-05T02:00:00+00:00 EmrJobFlowSensor 2021-05-05T03:12:23.276499+00:00 2021-05-05T03:21:25.925378+00:00 0:09:02.648879 24599 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T03:12:20.845092+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-05T02:00:00+00:00 EmrJobFlowSensor 2021-05-05T03:12:02.976494+00:00 2021-05-05T03:20:05.568398+00:00 0:08:02.591904 24598 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T03:12:00.710260+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T03:11:48.893261+00:00 2021-05-05T03:11:50.576411+00:00 0:00:01.683150 24597 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T03:11:46.700565+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T03:11:34.901275+00:00 2021-05-05T03:11:36.569746+00:00 0:00:01.668471 24596 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T03:11:32.686330+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T02:00:00+00:00 PythonOperator 2021-05-05T03:11:26.865032+00:00 2021-05-05T03:11:30.159805+00:00 0:00:03.294773 24595 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T03:11:24.629773+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T02:00:00+00:00 PythonOperator 2021-05-05T03:11:12.989965+00:00 2021-05-05T03:11:16.069176+00:00 0:00:03.079211 24594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T03:11:10.616750+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T02:00:00+00:00 TriggerDagRunOperator 2021-05-05T03:11:07.203352+00:00 2021-05-05T03:11:07.645289+00:00 0:00:00.441937 24593 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T03:11:04.612839+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T02:00:00+00:00 TriggerDagRunOperator 2021-05-05T03:11:06.995918+00:00 2021-05-05T03:11:07.527085+00:00 0:00:00.531167 24592 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T03:11:04.612809+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-05T02:05:00+00:00 EmrJobFlowSensor 2021-05-05T03:05:50.280704+00:00 2021-05-05T03:14:52.904433+00:00 0:09:02.623729 24591 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T03:05:48.108489+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T02:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T03:05:30.498939+00:00 2021-05-05T03:05:32.160471+00:00 0:00:01.661532 24590 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T03:05:28.090499+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T02:05:00+00:00 PythonOperator 2021-05-05T03:05:08.443267+00:00 2021-05-05T03:05:11.425550+00:00 0:00:02.982283 24589 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T03:05:06.089124+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T02:00:00+00:00 EmrJobFlowSensor 2021-05-05T03:00:56.058873+00:00 2021-05-05T03:10:58.961594+00:00 0:10:02.902721 24588 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T03:00:53.646488+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T03:00:33.808227+00:00 2021-05-05T03:00:35.518040+00:00 0:00:01.709813 24587 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T03:00:31.583449+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T02:00:00+00:00 PythonOperator 2021-05-05T03:00:11.853389+00:00 2021-05-05T03:00:14.957248+00:00 0:00:03.103859 24586 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T03:00:09.535280+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-05T01:00:00+00:00 EmrJobFlowSensor 2021-05-05T02:11:01.392247+00:00 2021-05-05T02:21:04.231233+00:00 0:10:02.838986 24584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T02:10:59.161487+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-05T01:00:00+00:00 EmrJobFlowSensor 2021-05-05T02:10:55.298567+00:00 2021-05-05T02:20:58.117137+00:00 0:10:02.818570 24583 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T02:10:53.045233+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T02:10:39.371005+00:00 2021-05-05T02:10:41.075212+00:00 0:00:01.704207 24582 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T02:10:37.057359+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T02:10:33.291000+00:00 2021-05-05T02:10:34.971290+00:00 0:00:01.680290 24581 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T02:10:31.040629+00:00 2 default_pool