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-flow-job_v002 check_cluster_status 2021-03-23T17:00:00+00:00 EmrJobFlowSensor 2021-03-23T18:00:57.083862+00:00 2021-03-23T18:10:59.974377+00:00 0:10:02.890515 10964 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T18:00:54.903564+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T18:00:35.304487+00:00 2021-03-23T18:00:36.982584+00:00 0:00:01.678097 10963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T18:00:32.888462+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T17:00:00+00:00 PythonOperator 2021-03-23T18:00:13.010285+00:00 2021-03-23T18:00:15.825659+00:00 0:00:02.815374 10962 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T18:00:10.819163+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T16:00:00+00:00 EmrJobFlowSensor 2021-03-23T17:11:34.635786+00:00 2021-03-23T17:20:37.190307+00:00 0:09:02.554521 10961 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T17:11:32.442225+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-23T16:00:00+00:00 EmrJobFlowSensor 2021-03-23T17:11:32.597700+00:00 2021-03-23T17:21:35.499496+00:00 0:10:02.901796 10960 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T17:11:30.441017+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T17:11:15.094758+00:00 2021-03-23T17:11:16.781536+00:00 0:00:01.686778 10959 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T17:11:12.425759+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-23T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T17:11:12.699292+00:00 2021-03-23T17:11:14.804722+00:00 0:00:02.105430 10958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T17:11:10.422915+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T16:00:00+00:00 PythonOperator 2021-03-23T17:10:53.303612+00:00 2021-03-23T17:10:56.173765+00:00 0:00:02.870153 10957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T17:10:50.406850+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-23T16:00:00+00:00 PythonOperator 2021-03-23T17:10:51.019304+00:00 2021-03-23T17:10:54.453149+00:00 0:00:03.433845 10956 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T17:10:48.412482+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T16:00:00+00:00 TriggerDagRunOperator 2021-03-23T17:10:43.082443+00:00 2021-03-23T17:10:43.584597+00:00 0:00:00.502154 10955 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T17:10:40.189334+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T16:00:00+00:00 TriggerDagRunOperator 2021-03-23T17:10:42.859095+00:00 2021-03-23T17:10:43.255738+00:00 0:00:00.396643 10954 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T17:10:40.189363+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T16:05:00+00:00 EmrJobFlowSensor 2021-03-23T17:05:53.037017+00:00 2021-03-23T17:13:55.544767+00:00 0:08:02.507750 10952 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T17:05:50.803989+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T16:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T17:05:31.360297+00:00 2021-03-23T17:05:33.099880+00:00 0:00:01.739583 10951 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T17:05:28.950628+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T16:05:00+00:00 PythonOperator 2021-03-23T17:05:09.243646+00:00 2021-03-23T17:05:11.925765+00:00 0:00:02.682119 10950 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T17:05:06.843799+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T16:00:00+00:00 EmrJobFlowSensor 2021-03-23T17:00:50.718831+00:00 2021-03-23T17:09:53.349606+00:00 0:09:02.630775 10949 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T17:00:48.231799+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T17:00:28.602446+00:00 2021-03-23T17:00:30.408922+00:00 0:00:01.806476 10948 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T17:00:26.270857+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T16:00:00+00:00 PythonOperator 2021-03-23T17:00:08.662273+00:00 2021-03-23T17:00:11.559144+00:00 0:00:02.896871 10947 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T17:00:06.253434+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-23T15:00:00+00:00 EmrJobFlowSensor 2021-03-23T16:19:16.770646+00:00 2021-03-23T16:29:19.619186+00:00 0:10:02.848540 10946 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T16:19:13.981546+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T15:00:00+00:00 EmrJobFlowSensor 2021-03-23T16:19:14.463822+00:00 2021-03-23T16:28:17.591641+00:00 0:09:03.127819 10945 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T16:19:11.985333+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-23T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T16:18:56.107080+00:00 2021-03-23T16:18:57.874507+00:00 0:00:01.767427 10944 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T16:18:53.909080+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T16:18:52.118409+00:00 2021-03-23T16:18:53.981389+00:00 0:00:01.862980 10943 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T16:18:49.898927+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-23T15:00:00+00:00 PythonOperator 2021-03-23T16:18:34.339499+00:00 2021-03-23T16:18:37.307379+00:00 0:00:02.967880 10942 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T16:18:31.894498+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T15:00:00+00:00 PythonOperator 2021-03-23T16:18:30.665478+00:00 2021-03-23T16:18:33.598717+00:00 0:00:02.933239 10941 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T16:18:27.958842+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T15:00:00+00:00 TriggerDagRunOperator 2021-03-23T16:18:26.409715+00:00 2021-03-23T16:18:26.925487+00:00 0:00:00.515772 10940 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T16:18:23.950034+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T15:00:00+00:00 TriggerDagRunOperator 2021-03-23T16:18:26.251321+00:00 2021-03-23T16:18:26.667702+00:00 0:00:00.416381 10939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T16:18:23.950086+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T15:05:00+00:00 EmrJobFlowSensor 2021-03-23T16:09:35.274890+00:00 2021-03-23T16:17:37.729776+00:00 0:08:02.454886 10938 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T16:09:33.076713+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T15:00:00+00:00 EmrJobFlowSensor 2021-03-23T16:09:19.657710+00:00 2021-03-23T16:18:22.471059+00:00 0:09:02.813349 10937 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T16:09:17.061445+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T15:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T16:09:07.249446+00:00 2021-03-23T16:09:09.020867+00:00 0:00:01.771421 10936 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T16:09:05.060602+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T16:08:57.208563+00:00 2021-03-23T16:08:58.889245+00:00 0:00:01.680682 10935 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T16:08:55.049296+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T15:05:00+00:00 PythonOperator 2021-03-23T16:08:41.192799+00:00 2021-03-23T16:08:43.938943+00:00 0:00:02.746144 10934 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T16:08:39.030041+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T15:00:00+00:00 PythonOperator 2021-03-23T16:08:31.695037+00:00 2021-03-23T16:08:34.440762+00:00 0:00:02.745725 10933 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T16:08:29.075872+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T14:00:00+00:00 EmrJobFlowSensor 2021-03-23T15:11:57.151137+00:00 2021-03-23T15:20:59.735420+00:00 0:09:02.584283 10931 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T15:11:54.907579+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-23T14:00:00+00:00 EmrJobFlowSensor 2021-03-23T15:11:55.236794+00:00 2021-03-23T15:21:58.000726+00:00 0:10:02.763932 10930 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T15:11:52.910916+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T15:11:35.298452+00:00 2021-03-23T15:11:36.970822+00:00 0:00:01.672370 10929 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T15:11:32.957625+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-23T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T15:11:33.307801+00:00 2021-03-23T15:11:35.119632+00:00 0:00:01.811831 10928 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T15:11:30.957960+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T14:00:00+00:00 PythonOperator 2021-03-23T15:11:13.802677+00:00 2021-03-23T15:11:16.671258+00:00 0:00:02.868581 10927 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T15:11:10.819691+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-23T14:00:00+00:00 PythonOperator 2021-03-23T15:11:12.156690+00:00 2021-03-23T15:11:15.469420+00:00 0:00:03.312730 10926 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T15:11:08.872673+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T14:00:00+00:00 TriggerDagRunOperator 2021-03-23T15:10:59.320002+00:00 2021-03-23T15:10:59.800804+00:00 0:00:00.480802 10925 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T15:10:56.811676+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T14:00:00+00:00 TriggerDagRunOperator 2021-03-23T15:10:59.144819+00:00 2021-03-23T15:10:59.564479+00:00 0:00:00.419660 10924 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T15:10:56.811643+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T14:05:00+00:00 EmrJobFlowSensor 2021-03-23T15:05:56.550749+00:00 2021-03-23T15:15:59.347376+00:00 0:10:02.796627 10923 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T15:05:54.337784+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T14:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T15:05:34.502204+00:00 2021-03-23T15:05:36.130648+00:00 0:00:01.628444 10922 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T15:05:32.320467+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T14:05:00+00:00 PythonOperator 2021-03-23T15:05:14.589216+00:00 2021-03-23T15:05:17.307119+00:00 0:00:02.717903 10921 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T15:05:12.305663+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T14:00:00+00:00 EmrJobFlowSensor 2021-03-23T15:00:50.041177+00:00 2021-03-23T15:10:52.876818+00:00 0:10:02.835641 10920 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T15:00:47.790124+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T15:00:27.936948+00:00 2021-03-23T15:00:29.626019+00:00 0:00:01.689071 10919 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T15:00:25.770137+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T14:00:00+00:00 PythonOperator 2021-03-23T15:00:08.178897+00:00 2021-03-23T15:00:10.931487+00:00 0:00:02.752590 10918 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T15:00:05.720809+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T13:00:00+00:00 EmrJobFlowSensor 2021-03-23T14:12:18.104374+00:00 2021-03-23T14:21:20.827008+00:00 0:09:02.722634 10916 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T14:12:15.659652+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-23T13:00:00+00:00 EmrJobFlowSensor 2021-03-23T14:12:10.036619+00:00 2021-03-23T14:22:12.702211+00:00 0:10:02.665592 10915 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T14:12:07.589972+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T14:11:55.806760+00:00 2021-03-23T14:11:57.604069+00:00 0:00:01.797309 10914 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T14:11:53.520162+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-23T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T14:11:47.674465+00:00 2021-03-23T14:11:49.372104+00:00 0:00:01.697639 10913 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T14:11:45.517760+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T13:00:00+00:00 PythonOperator 2021-03-23T14:11:35.871208+00:00 2021-03-23T14:11:38.806475+00:00 0:00:02.935267 10912 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T14:11:33.489239+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-23T13:00:00+00:00 PythonOperator 2021-03-23T14:11:28.124688+00:00 2021-03-23T14:11:31.193814+00:00 0:00:03.069126 10911 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T14:11:25.493023+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T13:00:00+00:00 TriggerDagRunOperator 2021-03-23T14:11:15.675065+00:00 2021-03-23T14:11:16.066300+00:00 0:00:00.391235 10910 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T14:11:13.456209+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T13:00:00+00:00 TriggerDagRunOperator 2021-03-23T14:11:15.715022+00:00 2021-03-23T14:11:16.209846+00:00 0:00:00.494824 10909 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T14:11:13.456241+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T13:05:00+00:00 EmrJobFlowSensor 2021-03-23T14:05:59.276716+00:00 2021-03-23T14:19:02.377448+00:00 0:13:03.100732 10908 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T14:05:56.970148+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T13:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T14:05:39.136044+00:00 2021-03-23T14:05:40.867626+00:00 0:00:01.731582 10907 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T14:05:36.885469+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T13:05:00+00:00 PythonOperator 2021-03-23T14:05:17.179239+00:00 2021-03-23T14:05:19.983219+00:00 0:00:02.803980 10906 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T14:05:14.864168+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T13:00:00+00:00 EmrJobFlowSensor 2021-03-23T14:00:54.994479+00:00 2021-03-23T14:10:57.767703+00:00 0:10:02.773224 10905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T14:00:52.321717+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T14:00:32.672992+00:00 2021-03-23T14:00:34.519209+00:00 0:00:01.846217 10904 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T14:00:30.360691+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T13:00:00+00:00 PythonOperator 2021-03-23T14:00:10.674896+00:00 2021-03-23T14:00:13.527014+00:00 0:00:02.852118 10903 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T14:00:08.263729+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T12:00:00+00:00 EmrJobFlowSensor 2021-03-23T13:11:16.382932+00:00 2021-03-23T13:20:18.935212+00:00 0:09:02.552280 10901 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T13:11:14.184475+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-23T12:00:00+00:00 EmrJobFlowSensor 2021-03-23T13:11:00.419281+00:00 2021-03-23T13:21:03.291181+00:00 0:10:02.871900 10900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T13:10:58.154273+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T13:10:54.678668+00:00 2021-03-23T13:10:56.409192+00:00 0:00:01.730524 10899 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T13:10:52.244737+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-23T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T13:10:40.428448+00:00 2021-03-23T13:10:42.164574+00:00 0:00:01.736126 10898 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T13:10:38.105848+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T12:00:00+00:00 PythonOperator 2021-03-23T13:10:34.359023+00:00 2021-03-23T13:10:37.086024+00:00 0:00:02.727001 10897 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T13:10:32.100764+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-23T12:00:00+00:00 PythonOperator 2021-03-23T13:10:18.365103+00:00 2021-03-23T13:10:21.493340+00:00 0:00:03.128237 10896 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T13:10:16.090199+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T12:00:00+00:00 TriggerDagRunOperator 2021-03-23T13:10:08.649271+00:00 2021-03-23T13:10:09.117401+00:00 0:00:00.468130 10895 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T13:10:06.159548+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T12:00:00+00:00 TriggerDagRunOperator 2021-03-23T13:10:08.621192+00:00 2021-03-23T13:10:09.143087+00:00 0:00:00.521895 10894 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T13:10:06.159597+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T12:05:00+00:00 EmrJobFlowSensor 2021-03-23T13:05:57.962409+00:00 2021-03-23T13:17:00.930720+00:00 0:11:02.968311 10893 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T13:05:55.672179+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T12:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T13:05:35.748100+00:00 2021-03-23T13:05:37.387216+00:00 0:00:01.639116 10892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T13:05:33.600913+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T12:05:00+00:00 PythonOperator 2021-03-23T13:05:14.151981+00:00 2021-03-23T13:05:16.860719+00:00 0:00:02.708738 10891 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T13:05:11.652627+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T12:00:00+00:00 EmrJobFlowSensor 2021-03-23T13:00:51.210617+00:00 2021-03-23T13:09:53.881524+00:00 0:09:02.670907 10890 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T13:00:49.023585+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T13:00:29.323662+00:00 2021-03-23T13:00:31.075873+00:00 0:00:01.752211 10889 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T13:00:27.060747+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T12:00:00+00:00 PythonOperator 2021-03-23T13:00:09.514932+00:00 2021-03-23T13:00:12.360807+00:00 0:00:02.845875 10888 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T13:00:07.051041+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T11:00:00+00:00 EmrJobFlowSensor 2021-03-23T12:11:59.013321+00:00 2021-03-23T12:21:01.687286+00:00 0:09:02.673965 10886 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T12:11:56.837168+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-23T11:00:00+00:00 EmrJobFlowSensor 2021-03-23T12:11:57.127760+00:00 2021-03-23T12:23:00.063631+00:00 0:11:02.935871 10885 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T12:11:54.837326+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-23T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T12:11:37.571019+00:00 2021-03-23T12:11:39.371092+00:00 0:00:01.800073 10884 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T12:11:34.720130+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T12:11:37.470508+00:00 2021-03-23T12:11:39.164173+00:00 0:00:01.693665 10883 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T12:11:34.720101+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T11:00:00+00:00 PythonOperator 2021-03-23T12:11:15.649425+00:00 2021-03-23T12:11:18.390516+00:00 0:00:02.741091 10882 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T12:11:12.769152+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-23T11:00:00+00:00 PythonOperator 2021-03-23T12:11:12.962037+00:00 2021-03-23T12:11:16.519124+00:00 0:00:03.557087 10881 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T12:11:10.697544+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T11:00:00+00:00 TriggerDagRunOperator 2021-03-23T12:11:07.332275+00:00 2021-03-23T12:11:07.903163+00:00 0:00:00.570888 10880 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T12:11:04.758167+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T11:00:00+00:00 TriggerDagRunOperator 2021-03-23T12:11:07.229446+00:00 2021-03-23T12:11:07.630878+00:00 0:00:00.401432 10879 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T12:11:04.758136+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T11:05:00+00:00 EmrJobFlowSensor 2021-03-23T12:06:02.371260+00:00 2021-03-23T12:18:05.393031+00:00 0:12:03.021771 10878 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T12:06:00.207275+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T11:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T12:05:38.524108+00:00 2021-03-23T12:05:40.186311+00:00 0:00:01.662203 10877 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T12:05:36.189764+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T11:05:00+00:00 PythonOperator 2021-03-23T12:05:14.349948+00:00 2021-03-23T12:05:17.145141+00:00 0:00:02.795193 10876 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T12:05:12.142893+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T11:00:00+00:00 EmrJobFlowSensor 2021-03-23T12:00:57.895743+00:00 2021-03-23T12:11:00.747523+00:00 0:10:02.851780 10875 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T12:00:55.701738+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T12:00:36.084806+00:00 2021-03-23T12:00:37.751016+00:00 0:00:01.666210 10874 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T12:00:33.762543+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-23T11:00:00+00:00 PythonOperator 2021-03-23T12:00:16.549803+00:00 2021-03-23T12:00:19.357354+00:00 0:00:02.807551 10873 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-23T12:00:13.662483+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-23T10:00:00+00:00 EmrJobFlowSensor 2021-03-23T11:11:20.273968+00:00 2021-03-23T11:23:23.304260+00:00 0:12:03.030292 10871 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T11:11:17.853755+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-23T10:00:00+00:00 EmrJobFlowSensor 2021-03-23T11:11:14.415788+00:00 2021-03-23T11:20:16.954462+00:00 0:09:02.538674 10870 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T11:11:11.861416+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-23T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T11:10:57.992294+00:00 2021-03-23T11:10:59.705725+00:00 0:00:01.713431 10869 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T11:10:55.763824+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-23T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T11:10:52.022358+00:00 2021-03-23T11:10:53.805923+00:00 0:00:01.783565 10868 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T11:10:49.757495+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-23T10:00:00+00:00 PythonOperator 2021-03-23T11:10:38.080000+00:00 2021-03-23T11:10:41.132810+00:00 0:00:03.052810 10867 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T11:10:35.745106+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-23T10:00:00+00:00 PythonOperator 2021-03-23T11:10:32.052587+00:00 2021-03-23T11:10:34.890505+00:00 0:00:02.837918 10866 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T11:10:29.740652+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-23T10:00:00+00:00 TriggerDagRunOperator 2021-03-23T11:10:22.032951+00:00 2021-03-23T11:10:22.524188+00:00 0:00:00.491237 10865 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T11:10:19.730949+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-23T10:00:00+00:00 TriggerDagRunOperator 2021-03-23T11:10:21.940511+00:00 2021-03-23T11:10:22.323894+00:00 0:00:00.383383 10864 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T11:10:19.730982+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-23T10:05:00+00:00 EmrJobFlowSensor 2021-03-23T11:06:03.457670+00:00 2021-03-23T11:18:06.421371+00:00 0:12:02.963701 10863 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-23T11:06:01.329958+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-23T10:05:00+00:00 EmrCreateJobFlowOperator 2021-03-23T11:05:41.440574+00:00 2021-03-23T11:05:43.236495+00:00 0:00:01.795921 10862 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-23T11:05:39.307784+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-23T10:05:00+00:00 PythonOperator 2021-03-23T11:05:19.579444+00:00 2021-03-23T11:05:22.359639+00:00 0:00:02.780195 10861 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T11:05:17.352814+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-23T10:00:00+00:00 EmrJobFlowSensor 2021-03-23T11:01:05.256170+00:00 2021-03-23T11:10:07.812966+00:00 0:09:02.556796 10860 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-23T11:01:02.806208+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-23T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-23T11:00:43.070945+00:00 2021-03-23T11:00:44.866383+00:00 0:00:01.795438 10859 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-23T11:00:40.790096+00:00 2 default_pool