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-31T23:00:00+00:00 EmrCreateJobFlowOperator 2021-06-01T00:18:50.708461+00:00 2021-06-01T00:18:52.515593+00:00 0:00:01.807132 34914 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-01T00:18:48.537476+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-31T23:00:00+00:00 EmrCreateJobFlowOperator 2021-06-01T00:18:36.881608+00:00 2021-06-01T00:18:38.590186+00:00 0:00:01.708578 34913 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-01T00:18:34.581461+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-31T23:00:00+00:00 PythonOperator 2021-06-01T00:18:28.929590+00:00 2021-06-01T00:18:32.068303+00:00 0:00:03.138713 34912 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T00:18:26.514454+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-31T23:00:00+00:00 PythonOperator 2021-06-01T00:18:16.815082+00:00 2021-06-01T00:18:20.254265+00:00 0:00:03.439183 34911 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T00:18:14.557446+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-31T23:00:00+00:00 TriggerDagRunOperator 2021-06-01T00:18:04.992152+00:00 2021-06-01T00:18:05.437428+00:00 0:00:00.445276 34910 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T00:18:02.485908+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-31T23:00:00+00:00 TriggerDagRunOperator 2021-06-01T00:18:04.930406+00:00 2021-06-01T00:18:05.488160+00:00 0:00:00.557754 34909 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T00:18:02.485936+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-31T23:05:00+00:00 EmrJobFlowSensor 2021-06-01T00:06:11.191321+00:00 2021-06-01T00:14:13.671574+00:00 0:08:02.480253 34907 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T00:06:09.039299+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-31T23:05:00+00:00 EmrCreateJobFlowOperator 2021-06-01T00:05:45.319696+00:00 2021-06-01T00:05:47.066137+00:00 0:00:01.746441 34906 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-01T00:05:43.015489+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-31T23:05:00+00:00 PythonOperator 2021-06-01T00:05:21.128625+00:00 2021-06-01T00:05:24.525188+00:00 0:00:03.396563 34905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T00:05:19.000669+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-05-31T23:00:00+00:00 EmrJobFlowSensor 2021-06-01T00:00:56.896220+00:00 2021-06-01T00:09:59.461234+00:00 0:09:02.565014 34904 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-01T00:00:54.495150+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-31T23:00:00+00:00 EmrJobFlowSensor 2021-06-01T00:00:56.782920+00:00 2021-06-01T00:10:59.666626+00:00 0:10:02.883706 34903 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T00:00:54.495193+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-05-31T23:00:00+00:00 EmrCreateJobFlowOperator 2021-06-01T00:00:37.160422+00:00 2021-06-01T00:00:38.862222+00:00 0:00:01.701800 34902 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-01T00:00:34.445370+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-31T23:00:00+00:00 EmrCreateJobFlowOperator 2021-06-01T00:00:34.732335+00:00 2021-06-01T00:00:36.822337+00:00 0:00:02.090002 34901 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-06-01T00:00:32.460373+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-05-31T23:00:00+00:00 PythonOperator 2021-06-01T00:00:14.683381+00:00 2021-06-01T00:00:17.947260+00:00 0:00:03.263879 34900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-01T00:00:12.429623+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-31T23:00:00+00:00 PythonOperator 2021-06-01T00:00:12.691821+00:00 2021-06-01T00:00:15.848015+00:00 0:00:03.156194 34899 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-06-01T00:00:10.429301+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-31T22:00:00+00:00 EmrJobFlowSensor 2021-05-31T23:12:03.830094+00:00 2021-05-31T23:21:06.592478+00:00 0:09:02.762384 34898 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T23:12:01.492540+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-31T22:00:00+00:00 EmrJobFlowSensor 2021-05-31T23:12:03.871630+00:00 2021-05-31T23:21:06.662028+00:00 0:09:02.790398 34897 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T23:12:01.492498+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-31T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-31T23:11:43.601647+00:00 2021-05-31T23:11:45.300747+00:00 0:00:01.699100 34896 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-31T23:11:41.431129+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-31T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-31T23:11:41.592318+00:00 2021-05-31T23:11:43.374234+00:00 0:00:01.781916 34895 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-31T23:11:39.428829+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-31T22:00:00+00:00 PythonOperator 2021-05-31T23:11:22.801144+00:00 2021-05-31T23:11:26.172559+00:00 0:00:03.371415 34894 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-31T23:11:19.412328+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-31T22:00:00+00:00 PythonOperator 2021-05-31T23:11:20.760251+00:00 2021-05-31T23:11:24.756360+00:00 0:00:03.996109 34893 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-31T23:11:17.414065+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-31T22:00:00+00:00 TriggerDagRunOperator 2021-05-31T23:11:12.217983+00:00 2021-05-31T23:11:12.795503+00:00 0:00:00.577520 34892 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T23:11:09.241954+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-31T22:00:00+00:00 TriggerDagRunOperator 2021-05-31T23:11:12.103960+00:00 2021-05-31T23:11:12.536611+00:00 0:00:00.432651 34891 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T23:11:09.242000+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-31T22:05:00+00:00 EmrJobFlowSensor 2021-05-31T23:06:11.598147+00:00 2021-05-31T23:15:14.148773+00:00 0:09:02.550626 34889 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T23:06:09.270787+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-31T22:05:00+00:00 EmrCreateJobFlowOperator 2021-05-31T23:05:49.751978+00:00 2021-05-31T23:05:51.403060+00:00 0:00:01.651082 34888 airflow-worker-3.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-31T23:05:47.203580+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-31T22:05:00+00:00 PythonOperator 2021-05-31T23:05:27.370435+00:00 2021-05-31T23:05:30.506765+00:00 0:00:03.136330 34887 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-31T23:05:25.127426+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-05-31T22:00:00+00:00 EmrJobFlowSensor 2021-05-31T23:01:07.032646+00:00 2021-05-31T23:10:09.681270+00:00 0:09:02.648624 34886 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T23:01:04.753903+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-31T22:00:00+00:00 EmrJobFlowSensor 2021-05-31T23:01:06.945145+00:00 2021-05-31T23:10:09.560530+00:00 0:09:02.615385 34885 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-31T23:01:04.753937+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-05-30T23:00:00+00:00 EmrJobFlowSensor 2021-05-31T23:00:55.001856+00:00 2021-05-31T23:09:57.669472+00:00 0:09:02.667616 34884 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T23:00:52.742586+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-05-31T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-31T23:00:47.271223+00:00 2021-05-31T23:00:49.027508+00:00 0:00:01.756285 34883 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-31T23:00:44.735144+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-31T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-31T23:00:44.918538+00:00 2021-05-31T23:00:46.935665+00:00 0:00:02.017127 34882 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-31T23:00:42.733295+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-05-30T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-31T23:00:34.958410+00:00 2021-05-31T23:00:36.604910+00:00 0:00:01.646500 34881 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-31T23:00:32.722153+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-05-31T22:00:00+00:00 PythonOperator 2021-05-31T23:00:25.043442+00:00 2021-05-31T23:00:28.201180+00:00 0:00:03.157738 34880 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-31T23:00:22.710066+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-31T22:00:00+00:00 PythonOperator 2021-05-31T23:00:22.963097+00:00 2021-05-31T23:00:26.308817+00:00 0:00:03.345720 34879 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-31T23:00:20.705782+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-05-30T23:00:00+00:00 PythonOperator 2021-05-31T23:00:04.909986+00:00 2021-05-31T23:00:08.168329+00:00 0:00:03.258343 34878 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-31T23:00:02.692817+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-31T21:00:00+00:00 EmrJobFlowSensor 2021-05-31T22:10:18.169354+00:00 2021-05-31T22:19:20.907287+00:00 0:09:02.737933 34877 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T22:10:15.895208+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-31T21:00:00+00:00 EmrJobFlowSensor 2021-05-31T22:10:14.120544+00:00 2021-05-31T22:19:16.604318+00:00 0:09:02.483774 34876 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T22:10:11.894472+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-31T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-31T22:09:58.190575+00:00 2021-05-31T22:09:59.939003+00:00 0:00:01.748428 34875 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-31T22:09:55.901619+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-31T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-31T22:09:52.031867+00:00 2021-05-31T22:09:53.689423+00:00 0:00:01.657556 34874 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-31T22:09:49.830469+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-31T21:00:00+00:00 PythonOperator 2021-05-31T22:09:35.989724+00:00 2021-05-31T22:09:39.497392+00:00 0:00:03.507668 34873 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-31T22:09:33.812134+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-31T21:00:00+00:00 PythonOperator 2021-05-31T22:09:32.600602+00:00 2021-05-31T22:09:35.823210+00:00 0:00:03.222608 34872 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-31T22:09:29.817041+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-31T21:00:00+00:00 TriggerDagRunOperator 2021-05-31T22:09:00.554342+00:00 2021-05-31T22:09:00.970565+00:00 0:00:00.416223 34870 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T22:08:57.740988+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-31T21:00:00+00:00 TriggerDagRunOperator 2021-05-31T22:09:00.224785+00:00 2021-05-31T22:09:00.789982+00:00 0:00:00.565197 34869 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T22:08:57.740936+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-31T21:05:00+00:00 EmrJobFlowSensor 2021-05-31T22:05:59.750227+00:00 2021-05-31T22:15:02.338997+00:00 0:09:02.588770 34868 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T22:05:57.407652+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-31T21:05:00+00:00 EmrCreateJobFlowOperator 2021-05-31T22:05:35.714089+00:00 2021-05-31T22:05:37.428397+00:00 0:00:01.714308 34867 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-31T22:05:33.385384+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-31T21:05:00+00:00 PythonOperator 2021-05-31T22:05:13.460038+00:00 2021-05-31T22:05:16.706816+00:00 0:00:03.246778 34866 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-31T22:05:11.267309+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-05-31T21:00:00+00:00 EmrJobFlowSensor 2021-05-31T22:01:01.541234+00:00 2021-05-31T22:11:04.229908+00:00 0:10:02.688674 34865 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T22:00:59.055766+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-31T21:00:00+00:00 EmrJobFlowSensor 2021-05-31T22:00:49.163613+00:00 2021-05-31T22:08:51.636672+00:00 0:08:02.473059 34864 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-31T22:00:46.891323+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-05-31T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-31T22:00:39.135534+00:00 2021-05-31T22:00:40.841723+00:00 0:00:01.706189 34863 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-31T22:00:36.880193+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-31T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-31T22:00:27.694461+00:00 2021-05-31T22:00:29.392399+00:00 0:00:01.697938 34862 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-31T22:00:24.844271+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-05-31T21:00:00+00:00 PythonOperator 2021-05-31T22:00:19.072668+00:00 2021-05-31T22:00:22.326630+00:00 0:00:03.253962 34861 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-31T22:00:16.843067+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-31T21:00:00+00:00 PythonOperator 2021-05-31T22:00:07.090217+00:00 2021-05-31T22:00:10.283739+00:00 0:00:03.193522 34860 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-31T22:00:04.824176+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-31T20:00:00+00:00 EmrJobFlowSensor 2021-05-31T21:10:36.646321+00:00 2021-05-31T21:18:39.232638+00:00 0:08:02.586317 34859 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T21:10:34.170922+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-31T20:00:00+00:00 EmrJobFlowSensor 2021-05-31T21:10:28.266460+00:00 2021-05-31T21:20:31.042785+00:00 0:10:02.776325 34858 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T21:10:26.094959+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-31T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-31T21:10:16.443588+00:00 2021-05-31T21:10:18.155286+00:00 0:00:01.711698 34857 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-31T21:10:14.152725+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-31T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-31T21:10:06.511520+00:00 2021-05-31T21:10:08.332988+00:00 0:00:01.821468 34856 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-31T21:10:04.147237+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-31T20:00:00+00:00 PythonOperator 2021-05-31T21:09:38.855477+00:00 2021-05-31T21:09:42.504670+00:00 0:00:03.649193 34855 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-31T21:09:36.017222+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-31T20:00:00+00:00 PythonOperator 2021-05-31T21:09:34.265367+00:00 2021-05-31T21:09:38.326678+00:00 0:00:04.061311 34854 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-31T21:09:32.011893+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-31T20:00:00+00:00 TriggerDagRunOperator 2021-05-31T21:09:12.796102+00:00 2021-05-31T21:09:13.310500+00:00 0:00:00.514398 34853 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T21:09:09.992288+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-31T20:00:00+00:00 TriggerDagRunOperator 2021-05-31T21:09:12.784055+00:00 2021-05-31T21:09:13.389594+00:00 0:00:00.605539 34852 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T21:09:09.992316+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-31T20:05:00+00:00 EmrJobFlowSensor 2021-05-31T21:06:09.163980+00:00 2021-05-31T21:16:12.010707+00:00 0:10:02.846727 34850 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T21:06:06.912065+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-31T20:05:00+00:00 EmrCreateJobFlowOperator 2021-05-31T21:05:45.137380+00:00 2021-05-31T21:05:46.792010+00:00 0:00:01.654630 34849 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-31T21:05:42.890799+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-31T20:05:00+00:00 PythonOperator 2021-05-31T21:05:23.018852+00:00 2021-05-31T21:05:26.144589+00:00 0:00:03.125737 34848 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-31T21:05:20.801657+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-31T20:00:00+00:00 EmrJobFlowSensor 2021-05-31T21:00:56.654282+00:00 2021-05-31T21:08:59.092994+00:00 0:08:02.438712 34847 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-31T21:00:54.405387+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-05-31T20:00:00+00:00 EmrJobFlowSensor 2021-05-31T21:00:48.731525+00:00 2021-05-31T21:08:51.264652+00:00 0:08:02.533127 34846 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T21:00:46.398732+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-31T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-31T21:00:34.963927+00:00 2021-05-31T21:00:36.700106+00:00 0:00:01.736179 34845 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-31T21:00:32.387893+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-05-31T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-31T21:00:26.702966+00:00 2021-05-31T21:00:28.385604+00:00 0:00:01.682638 34844 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-31T21:00:24.313615+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-31T20:00:00+00:00 PythonOperator 2021-05-31T21:00:10.816738+00:00 2021-05-31T21:00:14.234824+00:00 0:00:03.418086 34843 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-31T21:00:08.371038+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-05-31T20:00:00+00:00 PythonOperator 2021-05-31T21:00:04.671841+00:00 2021-05-31T21:00:08.003711+00:00 0:00:03.331870 34842 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-31T21:00:02.292306+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-31T19:00:00+00:00 EmrJobFlowSensor 2021-05-31T20:11:53.637843+00:00 2021-05-31T20:21:56.367897+00:00 0:10:02.730054 34841 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T20:11:51.427969+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-31T19:00:00+00:00 EmrJobFlowSensor 2021-05-31T20:11:31.566591+00:00 2021-05-31T20:21:34.360065+00:00 0:10:02.793474 34840 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T20:11:29.407459+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-31T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-31T20:11:21.625711+00:00 2021-05-31T20:11:23.417213+00:00 0:00:01.791502 34839 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-31T20:11:19.400308+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-31T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-31T20:11:09.961376+00:00 2021-05-31T20:11:11.731130+00:00 0:00:01.769754 34838 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-31T20:11:07.457675+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-31T19:00:00+00:00 PythonOperator 2021-05-31T20:10:55.590333+00:00 2021-05-31T20:10:59.179068+00:00 0:00:03.588735 34837 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-31T20:10:53.338385+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-31T19:00:00+00:00 PythonOperator 2021-05-31T20:10:39.652481+00:00 2021-05-31T20:10:42.904064+00:00 0:00:03.251583 34836 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-31T20:10:37.329362+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-31T19:00:00+00:00 TriggerDagRunOperator 2021-05-31T20:10:18.080408+00:00 2021-05-31T20:10:18.677438+00:00 0:00:00.597030 34835 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T20:10:15.309825+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-31T19:00:00+00:00 TriggerDagRunOperator 2021-05-31T20:10:17.801323+00:00 2021-05-31T20:10:18.238496+00:00 0:00:00.437173 34834 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T20:10:15.309797+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-31T19:05:00+00:00 EmrJobFlowSensor 2021-05-31T20:06:06.606062+00:00 2021-05-31T20:14:09.179392+00:00 0:08:02.573330 34832 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T20:06:04.259068+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-31T19:05:00+00:00 EmrCreateJobFlowOperator 2021-05-31T20:05:44.412882+00:00 2021-05-31T20:05:46.033657+00:00 0:00:01.620775 34831 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-31T20:05:42.142465+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-31T19:05:00+00:00 PythonOperator 2021-05-31T20:05:22.265005+00:00 2021-05-31T20:05:25.546142+00:00 0:00:03.281137 34830 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-31T20:05:20.102773+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-05-31T19:00:00+00:00 EmrJobFlowSensor 2021-05-31T20:01:19.910658+00:00 2021-05-31T20:09:22.450688+00:00 0:08:02.540030 34829 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T20:01:17.494231+00:00 2 default_pool
success livepop-shuffle-job_v002 create_cluster_and_add_emr_steps 2021-05-31T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-31T20:00:57.529792+00:00 2021-05-31T20:00:59.210475+00:00 0:00:01.680683 34828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-31T20:00:55.370592+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-31T19:00:00+00:00 EmrJobFlowSensor 2021-05-31T20:00:53.618598+00:00 2021-05-31T20:09:56.334573+00:00 0:09:02.715975 34827 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-31T20:00:51.366208+00:00 2 default_pool
success livepop-shuffle-job_v002 create_emr_steps 2021-05-31T19:00:00+00:00 PythonOperator 2021-05-31T20:00:37.693062+00:00 2021-05-31T20:00:40.979530+00:00 0:00:03.286468 34826 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-31T20:00:35.350685+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-31T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-31T20:00:33.632120+00:00 2021-05-31T20:00:35.479661+00:00 0:00:01.847541 34825 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-31T20:00:31.346290+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-31T19:00:00+00:00 PythonOperator 2021-05-31T20:00:11.661762+00:00 2021-05-31T20:00:15.015514+00:00 0:00:03.353752 34824 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-31T20:00:09.316103+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-31T18:00:00+00:00 EmrJobFlowSensor 2021-05-31T19:10:10.681712+00:00 2021-05-31T19:19:13.321101+00:00 0:09:02.639389 34823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T19:10:08.478779+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-31T18:00:00+00:00 EmrJobFlowSensor 2021-05-31T19:10:06.703451+00:00 2021-05-31T19:20:09.493942+00:00 0:10:02.790491 34822 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T19:10:04.465123+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-31T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-31T19:09:49.069264+00:00 2021-05-31T19:09:50.783345+00:00 0:00:01.714081 34821 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-31T19:09:46.541024+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-31T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-31T19:09:45.072171+00:00 2021-05-31T19:09:46.828642+00:00 0:00:01.756471 34820 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-31T19:09:42.558051+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-31T18:00:00+00:00 PythonOperator 2021-05-31T19:09:29.085126+00:00 2021-05-31T19:09:32.284097+00:00 0:00:03.198971 34819 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-31T19:09:26.473825+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-31T18:00:00+00:00 PythonOperator 2021-05-31T19:09:24.832700+00:00 2021-05-31T19:09:28.415521+00:00 0:00:03.582821 34818 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-31T19:09:22.460566+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-31T18:00:00+00:00 TriggerDagRunOperator 2021-05-31T19:09:09.179480+00:00 2021-05-31T19:09:09.759841+00:00 0:00:00.580361 34817 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T19:09:06.387366+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-31T18:00:00+00:00 TriggerDagRunOperator 2021-05-31T19:09:09.116687+00:00 2021-05-31T19:09:09.520031+00:00 0:00:00.403344 34816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T19:09:06.387405+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-31T18:05:00+00:00 EmrJobFlowSensor 2021-05-31T19:06:07.999568+00:00 2021-05-31T19:15:10.700807+00:00 0:09:02.701239 34814 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T19:06:05.692692+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-31T18:05:00+00:00 EmrCreateJobFlowOperator 2021-05-31T19:05:45.805513+00:00 2021-05-31T19:05:47.515634+00:00 0:00:01.710121 34813 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-31T19:05:43.590683+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-31T18:05:00+00:00 PythonOperator 2021-05-31T19:05:23.760999+00:00 2021-05-31T19:05:27.089031+00:00 0:00:03.328032 34812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-31T19:05:21.500711+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-31T18:00:00+00:00 EmrJobFlowSensor 2021-05-31T19:00:59.844348+00:00 2021-05-31T19:09:02.562287+00:00 0:08:02.717939 34811 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-31T19:00:57.061026+00:00 2 default_pool
success livepop-shuffle-job_v002 check_cluster_status 2021-05-31T18:00:00+00:00 EmrJobFlowSensor 2021-05-31T19:00:59.517752+00:00 2021-05-31T19:09:02.114190+00:00 0:08:02.596438 34810 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-31T19:00:57.061075+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-31T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-31T19:00:37.380104+00:00 2021-05-31T19:00:39.164432+00:00 0:00:01.784328 34809 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-31T19:00:34.987024+00:00 2 default_pool