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 trigger_dagrun_campaign-history-job_v002 2021-04-27T22:00:00+00:00 TriggerDagRunOperator 2021-04-27T23:10:14.129060+00:00 2021-04-27T23:10:14.524697+00:00 0:00:00.395637 21995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T23:10:11.650094+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T22:00:00+00:00 TriggerDagRunOperator 2021-04-27T23:10:13.970796+00:00 2021-04-27T23:10:14.510460+00:00 0:00:00.539664 21994 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T23:10:11.650128+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T22:05:00+00:00 EmrJobFlowSensor 2021-04-27T23:05:59.341633+00:00 2021-04-27T23:16:02.103181+00:00 0:10:02.761548 21993 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T23:05:57.210817+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T23:05:37.448831+00:00 2021-04-27T23:05:39.163555+00:00 0:00:01.714724 21992 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T23:05:35.195620+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T22:05:00+00:00 PythonOperator 2021-04-27T23:05:17.386910+00:00 2021-04-27T23:05:20.360707+00:00 0:00:02.973797 21991 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T23:05:15.128655+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T22:00:00+00:00 EmrJobFlowSensor 2021-04-27T23:01:05.309800+00:00 2021-04-27T23:10:07.988516+00:00 0:09:02.678716 21990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T23:01:02.693302+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-04-26T23:00:00+00:00 EmrJobFlowSensor 2021-04-27T23:00:46.799933+00:00 2021-04-27T23:09:49.380803+00:00 0:09:02.580870 21989 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T23:00:44.624619+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T23:00:42.897626+00:00 2021-04-27T23:00:44.703880+00:00 0:00:01.806254 21988 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T23:00:40.611220+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-04-26T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T23:00:27.166336+00:00 2021-04-27T23:00:28.822764+00:00 0:00:01.656428 21987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T23:00:24.602593+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T22:00:00+00:00 PythonOperator 2021-04-27T23:00:22.799362+00:00 2021-04-27T23:00:26.201084+00:00 0:00:03.401722 21986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T23:00:20.596640+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-04-26T23:00:00+00:00 PythonOperator 2021-04-27T23:00:05.313455+00:00 2021-04-27T23:00:08.425898+00:00 0:00:03.112443 21985 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T23:00:02.585549+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T21:00:00+00:00 EmrJobFlowSensor 2021-04-27T22:12:24.767169+00:00 2021-04-27T22:21:27.471383+00:00 0:09:02.704214 21983 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T22:12:22.602339+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T21:00:00+00:00 EmrJobFlowSensor 2021-04-27T22:12:16.726425+00:00 2021-04-27T22:22:19.604812+00:00 0:10:02.878387 21982 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T22:12:14.595031+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T22:12:02.901015+00:00 2021-04-27T22:12:04.764048+00:00 0:00:01.863033 21981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T22:12:00.583023+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T22:11:44.882423+00:00 2021-04-27T22:11:46.565643+00:00 0:00:01.683220 21980 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T22:11:42.562914+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T21:00:00+00:00 PythonOperator 2021-04-27T22:11:26.914094+00:00 2021-04-27T22:11:29.940733+00:00 0:00:03.026639 21979 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T22:11:24.562996+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T21:00:00+00:00 PythonOperator 2021-04-27T22:11:20.730390+00:00 2021-04-27T22:11:23.968407+00:00 0:00:03.238017 21978 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T22:11:18.503398+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T21:00:00+00:00 TriggerDagRunOperator 2021-04-27T22:11:07.080184+00:00 2021-04-27T22:11:07.486795+00:00 0:00:00.406611 21977 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T22:11:04.558601+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T21:00:00+00:00 TriggerDagRunOperator 2021-04-27T22:11:06.830995+00:00 2021-04-27T22:11:07.355783+00:00 0:00:00.524788 21976 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T22:11:04.558646+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T21:05:00+00:00 EmrJobFlowSensor 2021-04-27T22:05:58.423794+00:00 2021-04-27T22:15:00.999231+00:00 0:09:02.575437 21975 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T22:05:56.007963+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T22:05:34.351264+00:00 2021-04-27T22:05:36.007288+00:00 0:00:01.656024 21974 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T22:05:32.047847+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T21:05:00+00:00 PythonOperator 2021-04-27T22:05:12.075410+00:00 2021-04-27T22:05:15.062891+00:00 0:00:02.987481 21973 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T22:05:09.944785+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T21:00:00+00:00 EmrJobFlowSensor 2021-04-27T22:00:55.819199+00:00 2021-04-27T22:10:58.566456+00:00 0:10:02.747257 21972 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T22:00:53.593599+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T22:00:35.910376+00:00 2021-04-27T22:00:37.754883+00:00 0:00:01.844507 21971 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T22:00:33.546103+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T21:00:00+00:00 PythonOperator 2021-04-27T22:00:12.445694+00:00 2021-04-27T22:00:15.634023+00:00 0:00:03.188329 21970 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T22:00:09.464137+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T20:00:00+00:00 EmrJobFlowSensor 2021-04-27T21:12:27.037864+00:00 2021-04-27T21:22:29.931380+00:00 0:10:02.893516 21968 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T21:12:24.554016+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T20:00:00+00:00 EmrJobFlowSensor 2021-04-27T21:12:14.860056+00:00 2021-04-27T21:22:17.794216+00:00 0:10:02.934160 21967 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T21:12:12.501744+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T21:12:05.104590+00:00 2021-04-27T21:12:06.926823+00:00 0:00:01.822233 21966 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T21:12:02.559526+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T21:11:52.649542+00:00 2021-04-27T21:11:54.435370+00:00 0:00:01.785828 21965 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T21:11:50.392646+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T20:00:00+00:00 PythonOperator 2021-04-27T21:11:33.094520+00:00 2021-04-27T21:11:36.040453+00:00 0:00:02.945933 21964 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T21:11:30.371278+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T20:00:00+00:00 PythonOperator 2021-04-27T21:11:29.064457+00:00 2021-04-27T21:11:32.844071+00:00 0:00:03.779614 21963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T21:11:26.369410+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T20:00:00+00:00 TriggerDagRunOperator 2021-04-27T21:11:20.785799+00:00 2021-04-27T21:11:21.202241+00:00 0:00:00.416442 21962 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T21:11:18.367163+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T20:00:00+00:00 TriggerDagRunOperator 2021-04-27T21:11:20.730901+00:00 2021-04-27T21:11:21.251671+00:00 0:00:00.520770 21961 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T21:11:18.367127+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T20:05:00+00:00 EmrJobFlowSensor 2021-04-27T21:06:05.951566+00:00 2021-04-27T21:16:08.673206+00:00 0:10:02.721640 21960 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T21:06:03.808130+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T21:05:44.145177+00:00 2021-04-27T21:05:45.789782+00:00 0:00:01.644605 21959 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T21:05:41.788825+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T20:05:00+00:00 PythonOperator 2021-04-27T21:05:21.866588+00:00 2021-04-27T21:05:24.835531+00:00 0:00:02.968943 21958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T21:05:19.722170+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T20:00:00+00:00 EmrJobFlowSensor 2021-04-27T21:00:57.699604+00:00 2021-04-27T21:11:00.448849+00:00 0:10:02.749245 21957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T21:00:55.360886+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T21:00:37.582340+00:00 2021-04-27T21:00:39.393565+00:00 0:00:01.811225 21956 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T21:00:35.260816+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T20:00:00+00:00 PythonOperator 2021-04-27T21:00:05.968007+00:00 2021-04-27T21:00:09.050492+00:00 0:00:03.082485 21955 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T21:00:03.221615+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T19:00:00+00:00 EmrJobFlowSensor 2021-04-27T20:24:15.975740+00:00 2021-04-27T20:24:17.452814+00:00 0:00:01.477074 21953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T20:24:13.818575+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T19:00:00+00:00 EmrJobFlowSensor 2021-04-27T20:12:28.808366+00:00 2021-04-27T20:21:31.310073+00:00 0:09:02.501707 21951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T20:12:26.643946+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T20:12:25.219580+00:00 2021-04-27T20:12:27.108156+00:00 0:00:01.888576 21950 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T20:12:22.645456+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T20:12:07.124106+00:00 2021-04-27T20:12:09.043251+00:00 0:00:01.919145 21949 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T20:12:04.749252+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T19:00:00+00:00 PythonOperator 2021-04-27T20:11:53.073045+00:00 2021-04-27T20:11:56.121904+00:00 0:00:03.048859 21948 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T20:11:50.611482+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T19:00:00+00:00 PythonOperator 2021-04-27T20:11:38.974494+00:00 2021-04-27T20:11:41.991758+00:00 0:00:03.017264 21947 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T20:11:36.665158+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T19:00:00+00:00 TriggerDagRunOperator 2021-04-27T20:11:31.421393+00:00 2021-04-27T20:11:31.976374+00:00 0:00:00.554981 21946 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T20:11:28.476778+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T19:00:00+00:00 TriggerDagRunOperator 2021-04-27T20:11:31.122523+00:00 2021-04-27T20:11:31.634920+00:00 0:00:00.512397 21945 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T20:11:28.476810+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T19:05:00+00:00 EmrJobFlowSensor 2021-04-27T20:06:10.178841+00:00 2021-04-27T20:15:12.773869+00:00 0:09:02.595028 21944 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T20:06:07.888453+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T20:05:40.084955+00:00 2021-04-27T20:05:41.815096+00:00 0:00:01.730141 21943 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T20:05:37.848671+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T19:05:00+00:00 PythonOperator 2021-04-27T20:05:20.116866+00:00 2021-04-27T20:05:23.067551+00:00 0:00:02.950685 21942 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T20:05:17.800690+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T19:00:00+00:00 EmrJobFlowSensor 2021-04-27T20:01:03.835691+00:00 2021-04-27T20:11:06.644598+00:00 0:10:02.808907 21941 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T20:01:01.460382+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T20:00:41.603854+00:00 2021-04-27T20:00:43.381060+00:00 0:00:01.777206 21940 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T20:00:39.390400+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T19:00:00+00:00 PythonOperator 2021-04-27T20:00:21.721407+00:00 2021-04-27T20:00:24.751615+00:00 0:00:03.030208 21939 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T20:00:19.288807+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T18:00:00+00:00 EmrJobFlowSensor 2021-04-27T19:23:55.620748+00:00 2021-04-27T19:23:57.089113+00:00 0:00:01.468365 21937 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T19:23:53.460810+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T18:00:00+00:00 EmrJobFlowSensor 2021-04-27T19:23:47.684584+00:00 2021-04-27T19:23:49.291472+00:00 0:00:01.606888 21936 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T19:23:45.451982+00:00 3 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T19:12:08.438043+00:00 2021-04-27T19:12:10.173084+00:00 0:00:01.735041 21933 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T19:12:06.215266+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T19:12:02.460089+00:00 2021-04-27T19:12:04.507406+00:00 0:00:02.047317 21932 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T19:12:00.220371+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T18:00:00+00:00 PythonOperator 2021-04-27T19:11:46.312308+00:00 2021-04-27T19:11:49.314211+00:00 0:00:03.001903 21931 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T19:11:44.188640+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T18:00:00+00:00 PythonOperator 2021-04-27T19:11:40.558319+00:00 2021-04-27T19:11:43.865231+00:00 0:00:03.306912 21930 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T19:11:38.257815+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T18:00:00+00:00 TriggerDagRunOperator 2021-04-27T19:11:26.694000+00:00 2021-04-27T19:11:27.181868+00:00 0:00:00.487868 21929 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T19:11:24.246803+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T18:00:00+00:00 TriggerDagRunOperator 2021-04-27T19:11:26.712297+00:00 2021-04-27T19:11:27.290337+00:00 0:00:00.578040 21928 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T19:11:24.246856+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T18:05:00+00:00 EmrJobFlowSensor 2021-04-27T19:06:06.131680+00:00 2021-04-27T19:15:08.744640+00:00 0:09:02.612960 21927 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T19:06:03.745264+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T19:05:43.971508+00:00 2021-04-27T19:05:45.727402+00:00 0:00:01.755894 21926 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T19:05:41.630529+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T18:05:00+00:00 PythonOperator 2021-04-27T19:05:19.977317+00:00 2021-04-27T19:05:22.943346+00:00 0:00:02.966029 21925 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T19:05:17.601921+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T18:00:00+00:00 EmrJobFlowSensor 2021-04-27T19:00:59.607126+00:00 2021-04-27T19:11:02.566544+00:00 0:10:02.959418 21924 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T19:00:57.114220+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T19:00:37.489892+00:00 2021-04-27T19:00:39.189203+00:00 0:00:01.699311 21923 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T19:00:35.102041+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T18:00:00+00:00 PythonOperator 2021-04-27T19:00:17.651418+00:00 2021-04-27T19:00:20.706470+00:00 0:00:03.055052 21922 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T19:00:15.075772+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T17:00:00+00:00 EmrJobFlowSensor 2021-04-27T18:10:08.155731+00:00 2021-04-27T18:20:10.928635+00:00 0:10:02.772904 21920 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T18:10:05.913769+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T17:00:00+00:00 EmrJobFlowSensor 2021-04-27T18:10:04.265567+00:00 2021-04-27T18:19:06.982625+00:00 0:09:02.717058 21919 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T18:10:01.953189+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T18:09:46.395396+00:00 2021-04-27T18:09:48.096082+00:00 0:00:01.700686 21918 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T18:09:43.966127+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T18:09:42.369075+00:00 2021-04-27T18:09:44.219483+00:00 0:00:01.850408 21917 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T18:09:39.896692+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T17:00:00+00:00 PythonOperator 2021-04-27T18:09:24.268932+00:00 2021-04-27T18:09:27.521825+00:00 0:00:03.252893 21916 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T18:09:21.854982+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T17:00:00+00:00 PythonOperator 2021-04-27T18:09:19.984235+00:00 2021-04-27T18:09:22.981213+00:00 0:00:02.996978 21915 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T18:09:17.853106+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T17:00:00+00:00 TriggerDagRunOperator 2021-04-27T18:09:10.200086+00:00 2021-04-27T18:09:10.740039+00:00 0:00:00.539953 21914 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T18:09:07.845792+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T17:00:00+00:00 TriggerDagRunOperator 2021-04-27T18:09:10.096142+00:00 2021-04-27T18:09:10.494761+00:00 0:00:00.398619 21913 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T18:09:07.845828+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T17:05:00+00:00 EmrJobFlowSensor 2021-04-27T18:05:55.763446+00:00 2021-04-27T18:15:58.506224+00:00 0:10:02.742778 21912 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T18:05:53.505593+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T18:05:33.676781+00:00 2021-04-27T18:05:35.370715+00:00 0:00:01.693934 21911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T18:05:31.491004+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T17:05:00+00:00 PythonOperator 2021-04-27T18:05:13.700652+00:00 2021-04-27T18:05:16.761665+00:00 0:00:03.061013 21910 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T18:05:11.466818+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T17:00:00+00:00 EmrJobFlowSensor 2021-04-27T18:00:49.211741+00:00 2021-04-27T18:08:51.698994+00:00 0:08:02.487253 21909 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T18:00:47.018583+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T18:00:29.218174+00:00 2021-04-27T18:00:30.894099+00:00 0:00:01.675925 21908 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T18:00:27.003092+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T17:00:00+00:00 PythonOperator 2021-04-27T18:00:07.772718+00:00 2021-04-27T18:00:10.762204+00:00 0:00:02.989486 21907 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T18:00:05.044984+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T16:00:00+00:00 EmrJobFlowSensor 2021-04-27T17:11:12.104890+00:00 2021-04-27T17:21:14.908162+00:00 0:10:02.803272 21905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T17:11:09.889034+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T16:00:00+00:00 EmrJobFlowSensor 2021-04-27T17:11:02.292818+00:00 2021-04-27T17:19:04.984460+00:00 0:08:02.691642 21904 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T17:10:59.944776+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T17:10:49.982221+00:00 2021-04-27T17:10:51.674648+00:00 0:00:01.692427 21903 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T17:10:47.828932+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T17:10:40.209936+00:00 2021-04-27T17:10:41.988755+00:00 0:00:01.778819 21902 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T17:10:37.822180+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T16:00:00+00:00 PythonOperator 2021-04-27T17:10:30.113889+00:00 2021-04-27T17:10:33.332491+00:00 0:00:03.218602 21901 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T17:10:27.810238+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T16:00:00+00:00 PythonOperator 2021-04-27T17:10:19.992561+00:00 2021-04-27T17:10:22.976462+00:00 0:00:02.983901 21900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T17:10:17.802978+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T16:00:00+00:00 TriggerDagRunOperator 2021-04-27T17:10:06.337694+00:00 2021-04-27T17:10:06.775142+00:00 0:00:00.437448 21899 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T17:10:03.790278+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T16:00:00+00:00 TriggerDagRunOperator 2021-04-27T17:10:06.345572+00:00 2021-04-27T17:10:06.888766+00:00 0:00:00.543194 21898 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T17:10:03.790245+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T16:05:00+00:00 EmrJobFlowSensor 2021-04-27T17:05:51.710360+00:00 2021-04-27T17:15:54.387719+00:00 0:10:02.677359 21897 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T17:05:49.486144+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T17:05:31.717146+00:00 2021-04-27T17:05:33.438465+00:00 0:00:01.721319 21896 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T17:05:29.468240+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T16:05:00+00:00 PythonOperator 2021-04-27T17:05:09.614115+00:00 2021-04-27T17:05:12.570872+00:00 0:00:02.956757 21895 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T17:05:07.453449+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T16:00:00+00:00 EmrJobFlowSensor 2021-04-27T17:00:57.110055+00:00 2021-04-27T17:09:59.728539+00:00 0:09:02.618484 21894 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T17:00:54.930278+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T17:00:35.298950+00:00 2021-04-27T17:00:37.000532+00:00 0:00:01.701582 21893 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T17:00:32.908994+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T16:00:00+00:00 PythonOperator 2021-04-27T17:00:13.198314+00:00 2021-04-27T17:00:16.217685+00:00 0:00:03.019371 21892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T17:00:10.895324+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T15:00:00+00:00 EmrJobFlowSensor 2021-04-27T16:11:50.897001+00:00 2021-04-27T16:20:53.410464+00:00 0:09:02.513463 21890 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T16:11:48.699766+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T15:00:00+00:00 EmrJobFlowSensor 2021-04-27T16:11:49.135669+00:00 2021-04-27T16:21:51.991025+00:00 0:10:02.855356 21889 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T16:11:46.700451+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T16:11:28.993681+00:00 2021-04-27T16:11:30.787923+00:00 0:00:01.794242 21888 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T16:11:26.683811+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T16:11:26.931566+00:00 2021-04-27T16:11:28.664844+00:00 0:00:01.733278 21887 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T16:11:24.686393+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T15:00:00+00:00 PythonOperator 2021-04-27T16:11:09.931979+00:00 2021-04-27T16:11:13.112230+00:00 0:00:03.180251 21886 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T16:11:06.639280+00:00 2 default_pool