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 create_cluster_and_add_emr_steps 2021-05-14T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T18:12:26.991044+00:00 2021-05-14T18:12:28.795657+00:00 0:00:01.804613 28086 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T18:12:24.707284+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-14T17:00:00+00:00 PythonOperator 2021-05-14T18:12:11.292454+00:00 2021-05-14T18:12:14.367828+00:00 0:00:03.075374 28085 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T18:12:08.764768+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-14T17:00:00+00:00 PythonOperator 2021-05-14T18:12:04.966506+00:00 2021-05-14T18:12:08.357395+00:00 0:00:03.390889 28084 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T18:12:02.686267+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T17:00:00+00:00 TriggerDagRunOperator 2021-05-14T18:11:59.419101+00:00 2021-05-14T18:11:59.954398+00:00 0:00:00.535297 28083 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T18:11:56.694255+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T17:00:00+00:00 TriggerDagRunOperator 2021-05-14T18:11:59.103788+00:00 2021-05-14T18:11:59.523726+00:00 0:00:00.419938 28082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T18:11:56.694212+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-14T17:05:00+00:00 EmrJobFlowSensor 2021-05-14T18:06:04.404874+00:00 2021-05-14T18:15:07.038079+00:00 0:09:02.633205 28081 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T18:06:02.181351+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-14T17:05:00+00:00 EmrCreateJobFlowOperator 2021-05-14T18:05:42.300387+00:00 2021-05-14T18:05:43.922229+00:00 0:00:01.621842 28080 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T18:05:40.120220+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-14T17:05:00+00:00 PythonOperator 2021-05-14T18:05:20.680817+00:00 2021-05-14T18:05:23.759411+00:00 0:00:03.078594 28079 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T18:05:18.173371+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T17:00:00+00:00 EmrJobFlowSensor 2021-05-14T18:02:32.378506+00:00 2021-05-14T18:11:35.056190+00:00 0:09:02.677684 28078 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T18:02:29.857848+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T18:02:10.068191+00:00 2021-05-14T18:02:11.774055+00:00 0:00:01.705864 28077 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T18:02:07.762975+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T17:00:00+00:00 PythonOperator 2021-05-14T18:01:50.108194+00:00 2021-05-14T18:01:53.270057+00:00 0:00:03.161863 28076 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T18:01:47.692129+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-14T16:00:00+00:00 EmrJobFlowSensor 2021-05-14T17:11:11.661976+00:00 2021-05-14T17:21:14.635952+00:00 0:10:02.973976 28074 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T17:11:09.393389+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-14T16:00:00+00:00 EmrJobFlowSensor 2021-05-14T17:11:11.603014+00:00 2021-05-14T17:21:14.667703+00:00 0:10:03.064689 28073 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T17:11:09.393342+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-14T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T17:10:49.734673+00:00 2021-05-14T17:10:51.537913+00:00 0:00:01.803240 28072 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T17:10:47.345385+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-14T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T17:10:49.583853+00:00 2021-05-14T17:10:51.326068+00:00 0:00:01.742215 28071 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T17:10:47.345420+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-14T16:00:00+00:00 PythonOperator 2021-05-14T17:10:29.902419+00:00 2021-05-14T17:10:33.040813+00:00 0:00:03.138394 28070 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T17:10:27.320809+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-14T16:00:00+00:00 PythonOperator 2021-05-14T17:10:29.581519+00:00 2021-05-14T17:10:32.951177+00:00 0:00:03.369658 28069 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T17:10:27.320772+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T16:00:00+00:00 TriggerDagRunOperator 2021-05-14T17:10:09.570170+00:00 2021-05-14T17:10:10.109110+00:00 0:00:00.538940 28068 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T17:10:07.295934+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T16:00:00+00:00 TriggerDagRunOperator 2021-05-14T17:10:09.482651+00:00 2021-05-14T17:10:09.890990+00:00 0:00:00.408339 28067 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T17:10:07.295974+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-14T16:05:00+00:00 EmrJobFlowSensor 2021-05-14T17:05:51.104952+00:00 2021-05-14T17:14:53.669415+00:00 0:09:02.564463 28066 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T17:05:48.899984+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-14T16:05:00+00:00 EmrCreateJobFlowOperator 2021-05-14T17:05:31.306567+00:00 2021-05-14T17:05:33.007063+00:00 0:00:01.700496 28065 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T17:05:28.973805+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-14T16:05:00+00:00 PythonOperator 2021-05-14T17:05:09.099164+00:00 2021-05-14T17:05:12.205580+00:00 0:00:03.106416 28064 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T17:05:06.753388+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T16:00:00+00:00 EmrJobFlowSensor 2021-05-14T17:00:54.814597+00:00 2021-05-14T17:09:57.670312+00:00 0:09:02.855715 28063 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T17:00:52.188840+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T17:00:32.562248+00:00 2021-05-14T17:00:34.311809+00:00 0:00:01.749561 28062 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T17:00:30.164782+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T16:00:00+00:00 PythonOperator 2021-05-14T17:00:10.823815+00:00 2021-05-14T17:00:13.982696+00:00 0:00:03.158881 28061 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T17:00:08.154819+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-14T15:00:00+00:00 EmrJobFlowSensor 2021-05-14T16:11:23.335320+00:00 2021-05-14T16:21:25.956137+00:00 0:10:02.620817 28059 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T16:11:21.192486+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-14T15:00:00+00:00 EmrJobFlowSensor 2021-05-14T16:11:11.706150+00:00 2021-05-14T16:21:14.516379+00:00 0:10:02.810229 28058 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T16:11:09.182464+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-14T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T16:11:03.463153+00:00 2021-05-14T16:11:05.246177+00:00 0:00:01.783024 28057 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T16:11:01.179622+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-14T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T16:10:49.765779+00:00 2021-05-14T16:10:51.487231+00:00 0:00:01.721452 28056 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T16:10:47.166645+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-14T15:00:00+00:00 PythonOperator 2021-05-14T16:10:41.393241+00:00 2021-05-14T16:10:44.536243+00:00 0:00:03.143002 28055 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T16:10:39.158135+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-14T15:00:00+00:00 PythonOperator 2021-05-14T16:10:27.496517+00:00 2021-05-14T16:10:30.812995+00:00 0:00:03.316478 28054 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T16:10:25.240714+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T15:00:00+00:00 TriggerDagRunOperator 2021-05-14T16:10:17.746639+00:00 2021-05-14T16:10:18.380581+00:00 0:00:00.633942 28053 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T16:10:15.182904+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T15:00:00+00:00 TriggerDagRunOperator 2021-05-14T16:10:17.593690+00:00 2021-05-14T16:10:18.017303+00:00 0:00:00.423613 28052 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T16:10:15.182948+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-14T15:05:00+00:00 EmrJobFlowSensor 2021-05-14T16:05:46.653962+00:00 2021-05-14T16:14:49.328692+00:00 0:09:02.674730 28051 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T16:05:44.592865+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-14T15:05:00+00:00 EmrCreateJobFlowOperator 2021-05-14T16:05:24.744324+00:00 2021-05-14T16:05:26.429340+00:00 0:00:01.685016 28050 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T16:05:22.555639+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-14T15:05:00+00:00 PythonOperator 2021-05-14T16:05:04.571194+00:00 2021-05-14T16:05:07.682948+00:00 0:00:03.111754 28049 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T16:05:02.484251+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T15:00:00+00:00 EmrJobFlowSensor 2021-05-14T16:01:00.496317+00:00 2021-05-14T16:10:03.358978+00:00 0:09:02.862661 28048 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T16:00:58.152426+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T16:00:40.194403+00:00 2021-05-14T16:00:41.928401+00:00 0:00:01.733998 28047 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T16:00:38.045149+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T15:00:00+00:00 PythonOperator 2021-05-14T16:00:18.564570+00:00 2021-05-14T16:00:21.738406+00:00 0:00:03.173836 28046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T16:00:16.000227+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-14T14:00:00+00:00 EmrJobFlowSensor 2021-05-14T15:12:17.790286+00:00 2021-05-14T15:22:20.561460+00:00 0:10:02.771174 28044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T15:12:15.626044+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-14T14:00:00+00:00 EmrJobFlowSensor 2021-05-14T15:12:15.941626+00:00 2021-05-14T15:21:18.795701+00:00 0:09:02.854075 28043 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T15:12:13.620674+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-14T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T15:11:56.189918+00:00 2021-05-14T15:11:58.117882+00:00 0:00:01.927964 28042 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T15:11:53.669961+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-14T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T15:11:54.187273+00:00 2021-05-14T15:11:55.927029+00:00 0:00:01.739756 28041 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T15:11:51.661371+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-14T14:00:00+00:00 PythonOperator 2021-05-14T15:11:36.291771+00:00 2021-05-14T15:11:39.362675+00:00 0:00:03.070904 28040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T15:11:33.592810+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-14T14:00:00+00:00 PythonOperator 2021-05-14T15:11:33.791629+00:00 2021-05-14T15:11:37.455283+00:00 0:00:03.663654 28039 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T15:11:31.592379+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T14:00:00+00:00 TriggerDagRunOperator 2021-05-14T15:11:13.922311+00:00 2021-05-14T15:11:14.459965+00:00 0:00:00.537654 28038 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T15:11:11.547887+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T14:00:00+00:00 TriggerDagRunOperator 2021-05-14T15:11:13.713675+00:00 2021-05-14T15:11:14.268956+00:00 0:00:00.555281 28037 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T15:11:11.547919+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-14T14:05:00+00:00 EmrJobFlowSensor 2021-05-14T15:05:47.052896+00:00 2021-05-14T15:14:49.738215+00:00 0:09:02.685319 28036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T15:05:44.943495+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-14T14:05:00+00:00 EmrCreateJobFlowOperator 2021-05-14T15:05:26.895307+00:00 2021-05-14T15:05:28.570729+00:00 0:00:01.675422 28035 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T15:05:24.807000+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-14T14:05:00+00:00 PythonOperator 2021-05-14T15:05:04.937599+00:00 2021-05-14T15:05:08.044505+00:00 0:00:03.106906 28034 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T15:05:02.785286+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T14:00:00+00:00 EmrJobFlowSensor 2021-05-14T15:00:56.519073+00:00 2021-05-14T15:10:59.256111+00:00 0:10:02.737038 28033 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T15:00:54.285922+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T15:00:34.449246+00:00 2021-05-14T15:00:36.140154+00:00 0:00:01.690908 28032 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T15:00:32.245098+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T14:00:00+00:00 PythonOperator 2021-05-14T15:00:12.604257+00:00 2021-05-14T15:00:15.808647+00:00 0:00:03.204390 28031 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T15:00:10.243958+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-14T13:00:00+00:00 EmrJobFlowSensor 2021-05-14T14:11:14.534181+00:00 2021-05-14T14:23:17.562924+00:00 0:12:03.028743 28029 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T14:11:12.329798+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-14T13:00:00+00:00 EmrJobFlowSensor 2021-05-14T14:11:10.596686+00:00 2021-05-14T14:20:13.441821+00:00 0:09:02.845135 28028 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T14:11:08.324858+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-14T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T14:10:52.532687+00:00 2021-05-14T14:10:54.215513+00:00 0:00:01.682826 28027 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T14:10:50.310637+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-14T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T14:10:50.650444+00:00 2021-05-14T14:10:52.481785+00:00 0:00:01.831341 28026 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T14:10:48.347582+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-14T13:00:00+00:00 PythonOperator 2021-05-14T14:10:30.920281+00:00 2021-05-14T14:10:34.280161+00:00 0:00:03.359880 28025 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T14:10:28.449018+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-14T13:00:00+00:00 PythonOperator 2021-05-14T14:10:28.564454+00:00 2021-05-14T14:10:31.808052+00:00 0:00:03.243598 28024 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T14:10:26.269119+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T13:00:00+00:00 TriggerDagRunOperator 2021-05-14T14:10:10.739733+00:00 2021-05-14T14:10:11.322329+00:00 0:00:00.582596 28023 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T14:10:08.256601+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T13:00:00+00:00 TriggerDagRunOperator 2021-05-14T14:10:10.617806+00:00 2021-05-14T14:10:11.038592+00:00 0:00:00.420786 28022 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T14:10:08.256634+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-14T13:05:00+00:00 EmrJobFlowSensor 2021-05-14T14:05:50.140811+00:00 2021-05-14T14:13:52.636035+00:00 0:08:02.495224 28021 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T14:05:47.858730+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-14T13:05:00+00:00 EmrCreateJobFlowOperator 2021-05-14T14:05:30.068020+00:00 2021-05-14T14:05:31.691981+00:00 0:00:01.623961 28020 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T14:05:27.849676+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-14T13:05:00+00:00 PythonOperator 2021-05-14T14:05:07.936333+00:00 2021-05-14T14:05:11.104057+00:00 0:00:03.167724 28019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T14:05:05.724471+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T13:00:00+00:00 EmrJobFlowSensor 2021-05-14T14:00:49.465105+00:00 2021-05-14T14:09:52.136694+00:00 0:09:02.671589 28018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T14:00:47.326014+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T14:00:27.887738+00:00 2021-05-14T14:00:29.745257+00:00 0:00:01.857519 28017 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T14:00:25.355335+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T13:00:00+00:00 PythonOperator 2021-05-14T14:00:05.818538+00:00 2021-05-14T14:00:09.039680+00:00 0:00:03.221142 28016 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T14:00:03.363268+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-14T12:00:00+00:00 EmrJobFlowSensor 2021-05-14T13:13:30.600509+00:00 2021-05-14T13:23:33.163663+00:00 0:10:02.563154 28014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T13:13:28.054713+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-14T12:00:00+00:00 EmrJobFlowSensor 2021-05-14T13:13:28.183359+00:00 2021-05-14T13:25:31.207140+00:00 0:12:03.023781 28013 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T13:13:25.987806+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-14T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T13:13:10.101449+00:00 2021-05-14T13:13:11.770995+00:00 0:00:01.669546 28012 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T13:13:07.960451+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-14T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T13:13:06.167221+00:00 2021-05-14T13:13:07.900988+00:00 0:00:01.733767 28011 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T13:13:03.953894+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-14T12:00:00+00:00 PythonOperator 2021-05-14T13:12:46.196558+00:00 2021-05-14T13:12:49.297647+00:00 0:00:03.101089 28010 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T13:12:43.934721+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-14T12:00:00+00:00 PythonOperator 2021-05-14T13:12:32.063127+00:00 2021-05-14T13:12:35.380670+00:00 0:00:03.317543 28009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T13:12:29.919091+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T12:00:00+00:00 TriggerDagRunOperator 2021-05-14T13:12:28.637613+00:00 2021-05-14T13:12:29.157932+00:00 0:00:00.520319 28008 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T13:12:25.982267+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T12:00:00+00:00 TriggerDagRunOperator 2021-05-14T13:12:28.464723+00:00 2021-05-14T13:12:28.936148+00:00 0:00:00.471425 28007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T13:12:25.982233+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-14T12:05:00+00:00 EmrJobFlowSensor 2021-05-14T13:06:17.481516+00:00 2021-05-14T13:15:20.206561+00:00 0:09:02.725045 28006 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T13:06:15.255982+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-14T12:05:00+00:00 EmrCreateJobFlowOperator 2021-05-14T13:05:41.168617+00:00 2021-05-14T13:05:42.830632+00:00 0:00:01.662015 28005 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T13:05:39.120911+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-14T12:05:00+00:00 PythonOperator 2021-05-14T13:05:19.318512+00:00 2021-05-14T13:05:22.424785+00:00 0:00:03.106273 28004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T13:05:17.102843+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T12:00:00+00:00 EmrJobFlowSensor 2021-05-14T13:01:04.998612+00:00 2021-05-14T13:12:08.016943+00:00 0:11:03.018331 28003 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T13:01:02.783355+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T13:00:43.075404+00:00 2021-05-14T13:00:44.964160+00:00 0:00:01.888756 28002 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T13:00:40.720003+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T12:00:00+00:00 PythonOperator 2021-05-14T13:00:21.141124+00:00 2021-05-14T13:00:24.303923+00:00 0:00:03.162799 28001 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T13:00:18.703668+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-14T11:00:00+00:00 EmrJobFlowSensor 2021-05-14T12:12:10.378331+00:00 2021-05-14T12:22:13.080074+00:00 0:10:02.701743 27999 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T12:12:08.143513+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-14T11:00:00+00:00 EmrJobFlowSensor 2021-05-14T12:11:54.208778+00:00 2021-05-14T12:23:57.215747+00:00 0:12:03.006969 27998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T12:11:52.034847+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-14T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T12:11:48.281174+00:00 2021-05-14T12:11:50.136089+00:00 0:00:01.854915 27997 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T12:11:46.024445+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-14T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T12:11:34.523799+00:00 2021-05-14T12:11:36.328484+00:00 0:00:01.804685 27996 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T12:11:32.009763+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-14T11:00:00+00:00 PythonOperator 2021-05-14T12:11:28.176243+00:00 2021-05-14T12:11:31.354296+00:00 0:00:03.178053 27995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T12:11:26.008376+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-14T11:00:00+00:00 PythonOperator 2021-05-14T12:11:10.397139+00:00 2021-05-14T12:11:13.744475+00:00 0:00:03.347336 27994 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T12:11:08.055809+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T11:00:00+00:00 TriggerDagRunOperator 2021-05-14T12:11:04.650072+00:00 2021-05-14T12:11:05.058491+00:00 0:00:00.408419 27993 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T12:11:02.060368+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T11:00:00+00:00 TriggerDagRunOperator 2021-05-14T12:11:04.575713+00:00 2021-05-14T12:11:05.125401+00:00 0:00:00.549688 27992 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T12:11:02.060411+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-14T11:05:00+00:00 EmrJobFlowSensor 2021-05-14T12:05:57.575787+00:00 2021-05-14T12:15:00.202840+00:00 0:09:02.627053 27991 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T12:05:55.384983+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-14T11:05:00+00:00 EmrCreateJobFlowOperator 2021-05-14T12:05:35.485899+00:00 2021-05-14T12:05:37.110237+00:00 0:00:01.624338 27990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T12:05:33.315798+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-14T11:05:00+00:00 PythonOperator 2021-05-14T12:05:13.479195+00:00 2021-05-14T12:05:16.615435+00:00 0:00:03.136240 27989 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T12:05:11.290695+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T11:00:00+00:00 EmrJobFlowSensor 2021-05-14T12:00:55.145353+00:00 2021-05-14T12:10:57.923768+00:00 0:10:02.778415 27988 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T12:00:52.691785+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T12:00:32.894593+00:00 2021-05-14T12:00:34.598615+00:00 0:00:01.704022 27987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T12:00:30.663115+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T11:00:00+00:00 PythonOperator 2021-05-14T12:00:12.910869+00:00 2021-05-14T12:00:16.138576+00:00 0:00:03.227707 27986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T12:00:10.607623+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-14T10:00:00+00:00 EmrJobFlowSensor 2021-05-14T11:09:56.638949+00:00 2021-05-14T11:19:59.448046+00:00 0:10:02.809097 27984 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T11:09:54.254360+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-14T10:00:00+00:00 EmrJobFlowSensor 2021-05-14T11:09:50.503663+00:00 2021-05-14T11:18:53.112818+00:00 0:09:02.609155 27983 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T11:09:48.181465+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-14T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T11:09:34.564701+00:00 2021-05-14T11:09:36.445264+00:00 0:00:01.880563 27982 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T11:09:32.159221+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-14T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T11:09:30.677202+00:00 2021-05-14T11:09:32.326427+00:00 0:00:01.649225 27981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-14T11:09:28.169478+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-14T10:00:00+00:00 PythonOperator 2021-05-14T11:09:12.538933+00:00 2021-05-14T11:09:16.180857+00:00 0:00:03.641924 27980 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T11:09:10.078490+00:00 2 default_pool