Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success booking-processing-job_v002 create_emr_steps 2021-04-22T16:00:00+00:00 PythonOperator 2021-04-22T17:11:57.213202+00:00 2021-04-22T17:12:00.459220+00:00 0:00:03.246018 20088 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T17:11:54.770430+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-22T16:00:00+00:00 PythonOperator 2021-04-22T17:11:55.151243+00:00 2021-04-22T17:11:58.205746+00:00 0:00:03.054503 20087 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T17:11:52.761019+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T16:00:00+00:00 TriggerDagRunOperator 2021-04-22T17:11:51.242180+00:00 2021-04-22T17:11:51.846293+00:00 0:00:00.604113 20086 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T17:11:48.445393+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T16:00:00+00:00 TriggerDagRunOperator 2021-04-22T17:11:51.197111+00:00 2021-04-22T17:11:51.647415+00:00 0:00:00.450304 20085 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T17:11:48.445354+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-22T16:05:00+00:00 EmrJobFlowSensor 2021-04-22T17:05:57.831370+00:00 2021-04-22T17:14:00.318437+00:00 0:08:02.487067 20083 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T17:05:55.544202+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-22T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-22T17:05:37.910986+00:00 2021-04-22T17:05:39.547976+00:00 0:00:01.636990 20082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T17:05:35.477513+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-22T16:05:00+00:00 PythonOperator 2021-04-22T17:05:16.011832+00:00 2021-04-22T17:05:19.175936+00:00 0:00:03.164104 20081 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T17:05:13.414319+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T16:00:00+00:00 EmrJobFlowSensor 2021-04-22T17:01:01.436475+00:00 2021-04-22T17:10:04.145238+00:00 0:09:02.708763 20080 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T17:00:58.941438+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T17:00:39.181575+00:00 2021-04-22T17:00:40.847343+00:00 0:00:01.665768 20079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T17:00:36.890033+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T16:00:00+00:00 PythonOperator 2021-04-22T17:00:17.123740+00:00 2021-04-22T17:00:21.078392+00:00 0:00:03.954652 20078 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T17:00:14.848515+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-22T15:00:00+00:00 EmrJobFlowSensor 2021-04-22T16:22:38.497285+00:00 2021-04-22T16:31:41.059028+00:00 0:09:02.561743 20077 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T16:22:36.306202+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-22T15:00:00+00:00 EmrJobFlowSensor 2021-04-22T16:22:30.794841+00:00 2021-04-22T16:31:33.431748+00:00 0:09:02.636907 20076 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T16:22:28.340782+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-22T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T16:22:12.675932+00:00 2021-04-22T16:22:14.393492+00:00 0:00:01.717560 20075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T16:22:10.197146+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-22T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T16:22:08.462177+00:00 2021-04-22T16:22:10.220050+00:00 0:00:01.757873 20074 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T16:22:06.188298+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-22T15:00:00+00:00 PythonOperator 2021-04-22T16:21:50.990324+00:00 2021-04-22T16:21:54.121518+00:00 0:00:03.131194 20073 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T16:21:48.154484+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-22T15:00:00+00:00 PythonOperator 2021-04-22T16:21:46.501671+00:00 2021-04-22T16:21:50.613862+00:00 0:00:04.112191 20072 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T16:21:44.165871+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T15:00:00+00:00 TriggerDagRunOperator 2021-04-22T16:21:34.461382+00:00 2021-04-22T16:21:35.003869+00:00 0:00:00.542487 20071 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T16:21:32.082141+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T15:00:00+00:00 TriggerDagRunOperator 2021-04-22T16:21:34.331076+00:00 2021-04-22T16:21:34.767979+00:00 0:00:00.436903 20070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T16:21:32.082114+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T15:00:00+00:00 EmrJobFlowSensor 2021-04-22T16:10:06.944402+00:00 2021-04-22T16:21:09.935248+00:00 0:11:02.990846 20069 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T16:10:04.380394+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-22T15:05:00+00:00 EmrJobFlowSensor 2021-04-22T16:10:06.719595+00:00 2021-04-22T16:18:09.391139+00:00 0:08:02.671544 20068 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T16:10:04.380349+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-22T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-22T16:09:44.872852+00:00 2021-04-22T16:09:46.535372+00:00 0:00:01.662520 20067 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T16:09:42.295043+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T16:09:42.592910+00:00 2021-04-22T16:09:44.673586+00:00 0:00:02.080676 20066 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T16:09:40.292728+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-22T15:05:00+00:00 PythonOperator 2021-04-22T16:09:22.402915+00:00 2021-04-22T16:09:25.346880+00:00 0:00:02.943965 20065 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T16:09:20.236838+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T15:00:00+00:00 PythonOperator 2021-04-22T16:09:21.009571+00:00 2021-04-22T16:09:24.062866+00:00 0:00:03.053295 20064 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T16:09:18.270273+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-22T14:00:00+00:00 EmrJobFlowSensor 2021-04-22T15:12:02.424175+00:00 2021-04-22T15:22:05.189807+00:00 0:10:02.765632 20062 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T15:12:00.061465+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-22T14:00:00+00:00 EmrJobFlowSensor 2021-04-22T15:11:56.111354+00:00 2021-04-22T15:21:58.949358+00:00 0:10:02.838004 20061 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T15:11:53.900617+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-22T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T15:11:40.406125+00:00 2021-04-22T15:11:42.109920+00:00 0:00:01.703795 20060 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T15:11:37.954031+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-22T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T15:11:36.278924+00:00 2021-04-22T15:11:38.086948+00:00 0:00:01.808024 20059 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T15:11:33.846791+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-22T14:00:00+00:00 PythonOperator 2021-04-22T15:11:18.156616+00:00 2021-04-22T15:11:21.118675+00:00 0:00:02.962059 20058 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T15:11:15.835308+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-22T14:00:00+00:00 PythonOperator 2021-04-22T15:11:14.490750+00:00 2021-04-22T15:11:17.917376+00:00 0:00:03.426626 20057 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T15:11:11.832536+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T14:00:00+00:00 TriggerDagRunOperator 2021-04-22T15:11:06.223069+00:00 2021-04-22T15:11:06.690015+00:00 0:00:00.466946 20056 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T15:11:03.819944+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T14:00:00+00:00 TriggerDagRunOperator 2021-04-22T15:11:06.095504+00:00 2021-04-22T15:11:06.674924+00:00 0:00:00.579420 20055 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T15:11:03.819909+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-22T14:05:00+00:00 EmrJobFlowSensor 2021-04-22T15:06:01.447456+00:00 2021-04-22T15:15:04.266994+00:00 0:09:02.819538 20054 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T15:05:59.243823+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-22T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-22T15:05:39.366164+00:00 2021-04-22T15:05:41.088122+00:00 0:00:01.721958 20053 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T15:05:37.153253+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-22T14:05:00+00:00 PythonOperator 2021-04-22T15:05:17.570339+00:00 2021-04-22T15:05:20.778246+00:00 0:00:03.207907 20052 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T15:05:15.252772+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T14:00:00+00:00 EmrJobFlowSensor 2021-04-22T15:00:48.815748+00:00 2021-04-22T15:10:51.603142+00:00 0:10:02.787394 20051 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T15:00:46.552200+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T15:00:24.743112+00:00 2021-04-22T15:00:26.504122+00:00 0:00:01.761010 20050 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T15:00:22.511973+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T14:00:00+00:00 PythonOperator 2021-04-22T15:00:04.891143+00:00 2021-04-22T15:00:07.982745+00:00 0:00:03.091602 20049 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T15:00:02.485669+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-22T13:00:00+00:00 EmrJobFlowSensor 2021-04-22T14:11:16.510684+00:00 2021-04-22T14:21:19.502537+00:00 0:10:02.991853 20047 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T14:11:14.383678+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-22T13:00:00+00:00 EmrJobFlowSensor 2021-04-22T14:11:06.686026+00:00 2021-04-22T14:21:09.451883+00:00 0:10:02.765857 20046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T14:11:04.372852+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-22T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T14:10:54.651970+00:00 2021-04-22T14:10:56.749233+00:00 0:00:02.097263 20045 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T14:10:52.372605+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-22T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T14:10:44.785295+00:00 2021-04-22T14:10:46.537818+00:00 0:00:01.752523 20044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T14:10:42.363761+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-22T13:00:00+00:00 PythonOperator 2021-04-22T14:10:32.683621+00:00 2021-04-22T14:10:35.855537+00:00 0:00:03.171916 20043 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T14:10:30.368751+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-22T13:00:00+00:00 PythonOperator 2021-04-22T14:10:22.720403+00:00 2021-04-22T14:10:25.701661+00:00 0:00:02.981258 20042 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T14:10:20.341356+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T13:00:00+00:00 TriggerDagRunOperator 2021-04-22T14:10:16.776840+00:00 2021-04-22T14:10:17.330459+00:00 0:00:00.553619 20041 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T14:10:14.356526+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T13:00:00+00:00 TriggerDagRunOperator 2021-04-22T14:10:16.672489+00:00 2021-04-22T14:10:17.080057+00:00 0:00:00.407568 20040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T14:10:14.356573+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-22T13:05:00+00:00 EmrJobFlowSensor 2021-04-22T14:05:58.017381+00:00 2021-04-22T14:15:00.640624+00:00 0:09:02.623243 20039 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T14:05:55.859690+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-22T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-22T14:05:36.075527+00:00 2021-04-22T14:05:37.825677+00:00 0:00:01.750150 20038 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T14:05:33.851830+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-22T13:05:00+00:00 PythonOperator 2021-04-22T14:05:16.063388+00:00 2021-04-22T14:05:18.991093+00:00 0:00:02.927705 20037 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T14:05:13.716164+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T13:00:00+00:00 EmrJobFlowSensor 2021-04-22T14:00:59.408537+00:00 2021-04-22T14:10:02.659268+00:00 0:09:03.250731 20036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T14:00:57.270955+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T14:00:38.038837+00:00 2021-04-22T14:00:39.748861+00:00 0:00:01.710024 20035 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T14:00:35.257701+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T13:00:00+00:00 PythonOperator 2021-04-22T14:00:15.835143+00:00 2021-04-22T14:00:18.824576+00:00 0:00:02.989433 20034 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T14:00:13.272162+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-22T12:00:00+00:00 EmrJobFlowSensor 2021-04-22T13:12:48.760993+00:00 2021-04-22T13:21:51.802613+00:00 0:09:03.041620 20032 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T13:12:46.478106+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-22T12:00:00+00:00 EmrJobFlowSensor 2021-04-22T13:12:38.869444+00:00 2021-04-22T13:21:41.615497+00:00 0:09:02.746053 20031 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T13:12:36.470256+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-22T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T13:12:10.732904+00:00 2021-04-22T13:12:12.567166+00:00 0:00:01.834262 20030 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T13:12:08.447400+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-22T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T13:12:08.824626+00:00 2021-04-22T13:12:10.571084+00:00 0:00:01.746458 20029 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T13:12:06.461885+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-22T12:00:00+00:00 PythonOperator 2021-04-22T13:11:48.436628+00:00 2021-04-22T13:11:51.372232+00:00 0:00:02.935604 20028 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T13:11:46.304104+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-22T12:00:00+00:00 PythonOperator 2021-04-22T13:11:47.379520+00:00 2021-04-22T13:11:50.617605+00:00 0:00:03.238085 20027 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T13:11:44.347053+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T12:00:00+00:00 TriggerDagRunOperator 2021-04-22T13:11:22.801227+00:00 2021-04-22T13:11:23.227884+00:00 0:00:00.426657 20026 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T13:11:20.276867+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T12:00:00+00:00 TriggerDagRunOperator 2021-04-22T13:11:22.551166+00:00 2021-04-22T13:11:23.092718+00:00 0:00:00.541552 20025 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T13:11:20.276839+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-22T12:05:00+00:00 EmrJobFlowSensor 2021-04-22T13:06:48.246453+00:00 2021-04-22T13:14:50.807329+00:00 0:08:02.560876 20024 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T13:06:46.005159+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-22T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-22T13:06:28.111198+00:00 2021-04-22T13:06:29.731180+00:00 0:00:01.619982 20023 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T13:06:25.986032+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-22T12:05:00+00:00 PythonOperator 2021-04-22T13:05:14.182867+00:00 2021-04-22T13:05:17.176764+00:00 0:00:02.993897 20022 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T13:05:11.846688+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T12:00:00+00:00 EmrJobFlowSensor 2021-04-22T13:01:11.617751+00:00 2021-04-22T13:11:14.513613+00:00 0:10:02.895862 20021 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T13:01:09.438490+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T13:00:40.103031+00:00 2021-04-22T13:00:41.801610+00:00 0:00:01.698579 20020 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T13:00:37.405798+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T12:00:00+00:00 PythonOperator 2021-04-22T13:00:18.389730+00:00 2021-04-22T13:00:21.421811+00:00 0:00:03.032081 20019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T13:00:15.452646+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-22T11:00:00+00:00 EmrJobFlowSensor 2021-04-22T12:12:25.479815+00:00 2021-04-22T12:21:28.083857+00:00 0:09:02.604042 20017 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T12:12:23.130683+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-22T11:00:00+00:00 EmrJobFlowSensor 2021-04-22T12:12:17.614529+00:00 2021-04-22T12:21:20.363059+00:00 0:09:02.748530 20016 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T12:12:15.130298+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-22T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T12:12:05.696421+00:00 2021-04-22T12:12:07.371433+00:00 0:00:01.675012 20015 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T12:12:03.114632+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-22T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T12:11:57.314654+00:00 2021-04-22T12:11:59.378733+00:00 0:00:02.064079 20014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T12:11:55.111239+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-22T11:00:00+00:00 PythonOperator 2021-04-22T12:11:43.420267+00:00 2021-04-22T12:11:46.752294+00:00 0:00:03.332027 20013 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T12:11:41.093821+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-22T11:00:00+00:00 PythonOperator 2021-04-22T12:11:35.703160+00:00 2021-04-22T12:11:39.159278+00:00 0:00:03.456118 20012 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T12:11:33.084717+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T11:00:00+00:00 TriggerDagRunOperator 2021-04-22T12:11:27.593537+00:00 2021-04-22T12:11:28.138308+00:00 0:00:00.544771 20011 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T12:11:25.140701+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T11:00:00+00:00 TriggerDagRunOperator 2021-04-22T12:11:27.525886+00:00 2021-04-22T12:11:27.958774+00:00 0:00:00.432888 20010 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T12:11:25.140735+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-22T11:05:00+00:00 EmrJobFlowSensor 2021-04-22T12:05:54.605093+00:00 2021-04-22T12:13:56.975866+00:00 0:08:02.370773 20009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T12:05:52.422203+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-22T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-22T12:05:32.550090+00:00 2021-04-22T12:05:34.206913+00:00 0:00:01.656823 20008 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T12:05:30.396398+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-22T11:05:00+00:00 PythonOperator 2021-04-22T12:05:10.564855+00:00 2021-04-22T12:05:13.745840+00:00 0:00:03.180985 20007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T12:05:08.394181+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T11:00:00+00:00 EmrJobFlowSensor 2021-04-22T12:01:12.414285+00:00 2021-04-22T12:11:15.273040+00:00 0:10:02.858755 20006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T12:01:10.067572+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T12:00:40.330816+00:00 2021-04-22T12:00:42.148688+00:00 0:00:01.817872 20005 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T12:00:37.998714+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T11:00:00+00:00 PythonOperator 2021-04-22T12:00:18.848189+00:00 2021-04-22T12:00:21.823267+00:00 0:00:02.975078 20004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T12:00:15.933524+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-22T10:00:00+00:00 EmrJobFlowSensor 2021-04-22T11:13:04.975017+00:00 2021-04-22T11:23:07.885250+00:00 0:10:02.910233 20002 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T11:13:02.482828+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-22T10:00:00+00:00 EmrJobFlowSensor 2021-04-22T11:13:02.823151+00:00 2021-04-22T11:22:05.465036+00:00 0:09:02.641885 20001 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T11:13:00.487679+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-22T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T11:12:43.085891+00:00 2021-04-22T11:12:44.766037+00:00 0:00:01.680146 20000 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T11:12:40.443394+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-22T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T11:12:40.827586+00:00 2021-04-22T11:12:43.013818+00:00 0:00:02.186232 19999 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T11:12:38.445856+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-22T10:00:00+00:00 PythonOperator 2021-04-22T11:12:19.046606+00:00 2021-04-22T11:12:22.460006+00:00 0:00:03.413400 19998 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T11:12:16.420197+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-22T10:00:00+00:00 PythonOperator 2021-04-22T11:12:16.681674+00:00 2021-04-22T11:12:19.898576+00:00 0:00:03.216902 19997 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T11:12:14.418766+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T10:00:00+00:00 TriggerDagRunOperator 2021-04-22T11:12:01.716659+00:00 2021-04-22T11:12:02.132669+00:00 0:00:00.416010 19996 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T11:11:58.444529+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T10:00:00+00:00 TriggerDagRunOperator 2021-04-22T11:12:01.240780+00:00 2021-04-22T11:12:01.850160+00:00 0:00:00.609380 19995 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T11:11:58.444586+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-22T10:05:00+00:00 EmrJobFlowSensor 2021-04-22T11:05:50.126722+00:00 2021-04-22T11:14:52.694097+00:00 0:09:02.567375 19994 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T11:05:47.652896+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-22T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-22T11:05:30.271060+00:00 2021-04-22T11:05:31.906598+00:00 0:00:01.635538 19993 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T11:05:27.744421+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-22T10:05:00+00:00 PythonOperator 2021-04-22T11:05:07.671948+00:00 2021-04-22T11:05:10.823634+00:00 0:00:03.151686 19992 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T11:05:05.515919+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T10:00:00+00:00 EmrJobFlowSensor 2021-04-22T11:00:49.356057+00:00 2021-04-22T11:11:52.353034+00:00 0:11:02.996977 19991 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T11:00:47.123116+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T11:00:27.658256+00:00 2021-04-22T11:00:29.478789+00:00 0:00:01.820533 19990 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T11:00:25.166163+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T10:00:00+00:00 PythonOperator 2021-04-22T11:00:05.889903+00:00 2021-04-22T11:00:08.973090+00:00 0:00:03.083187 19989 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T11:00:03.087960+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-22T09:00:00+00:00 EmrJobFlowSensor 2021-04-22T10:12:23.606908+00:00 2021-04-22T10:21:26.336224+00:00 0:09:02.729316 19987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T10:12:21.358788+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-22T09:00:00+00:00 EmrJobFlowSensor 2021-04-22T10:12:20.108912+00:00 2021-04-22T10:21:22.927065+00:00 0:09:02.818153 19986 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T10:12:17.347870+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-22T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T10:11:57.523785+00:00 2021-04-22T10:11:59.517314+00:00 0:00:01.993529 19985 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T10:11:55.328081+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-22T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T10:11:55.647144+00:00 2021-04-22T10:11:57.467777+00:00 0:00:01.820633 19984 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-22T10:11:53.329382+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-22T09:00:00+00:00 PythonOperator 2021-04-22T10:11:31.754479+00:00 2021-04-22T10:11:34.804105+00:00 0:00:03.049626 19983 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T10:11:29.310317+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-22T09:00:00+00:00 PythonOperator 2021-04-22T10:11:31.648614+00:00 2021-04-22T10:11:35.232152+00:00 0:00:03.583538 19982 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T10:11:29.310282+00:00 2 default_pool