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 create_cluster_and_add_emr_steps 2021-04-01T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T16:00:42.177087+00:00 2021-04-01T16:00:44.005050+00:00 0:00:01.827963 12449 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T16:00:40.011944+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T15:00:00+00:00 PythonOperator 2021-04-01T16:00:20.297333+00:00 2021-04-01T16:00:23.012639+00:00 0:00:02.715306 12448 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T16:00:17.994733+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T14:00:00+00:00 EmrJobFlowSensor 2021-04-01T15:12:26.898661+00:00 2021-04-01T15:21:29.536119+00:00 0:09:02.637458 12446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T15:12:24.552355+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T14:00:00+00:00 EmrJobFlowSensor 2021-04-01T15:12:25.066052+00:00 2021-04-01T15:21:27.649545+00:00 0:09:02.583493 12445 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T15:12:22.642126+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T15:12:06.602372+00:00 2021-04-01T15:12:08.321389+00:00 0:00:01.719017 12444 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T15:12:04.398499+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T15:12:02.644178+00:00 2021-04-01T15:12:04.364220+00:00 0:00:01.720042 12443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T15:12:00.381962+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T14:00:00+00:00 PythonOperator 2021-04-01T15:11:44.709844+00:00 2021-04-01T15:11:47.680970+00:00 0:00:02.971126 12442 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T15:11:42.256577+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T14:00:00+00:00 PythonOperator 2021-04-01T15:11:40.531187+00:00 2021-04-01T15:11:43.355742+00:00 0:00:02.824555 12441 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T15:11:38.253889+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T14:00:00+00:00 TriggerDagRunOperator 2021-04-01T15:11:18.824887+00:00 2021-04-01T15:11:19.354302+00:00 0:00:00.529415 12440 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T15:11:16.234401+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T14:00:00+00:00 TriggerDagRunOperator 2021-04-01T15:11:18.696824+00:00 2021-04-01T15:11:19.119119+00:00 0:00:00.422295 12439 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T15:11:16.234432+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T14:05:00+00:00 EmrJobFlowSensor 2021-04-01T15:05:57.982446+00:00 2021-04-01T15:15:00.735862+00:00 0:09:02.753416 12438 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T15:05:55.789233+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T15:05:36.092495+00:00 2021-04-01T15:05:37.841666+00:00 0:00:01.749171 12437 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T15:05:33.727664+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T14:05:00+00:00 PythonOperator 2021-04-01T15:05:14.117314+00:00 2021-04-01T15:05:16.892941+00:00 0:00:02.775627 12436 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T15:05:11.751221+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T14:00:00+00:00 EmrJobFlowSensor 2021-04-01T15:00:59.503258+00:00 2021-04-01T15:11:02.394667+00:00 0:10:02.891409 12435 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T15:00:57.111371+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T15:00:37.321488+00:00 2021-04-01T15:00:39.110182+00:00 0:00:01.788694 12434 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T15:00:35.085979+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T14:00:00+00:00 PythonOperator 2021-04-01T15:00:17.449253+00:00 2021-04-01T15:00:20.302947+00:00 0:00:02.853694 12433 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T15:00:15.011662+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T13:00:00+00:00 EmrJobFlowSensor 2021-04-01T14:12:24.322999+00:00 2021-04-01T14:20:26.805187+00:00 0:08:02.482188 12431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T14:12:21.963873+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T13:00:00+00:00 EmrJobFlowSensor 2021-04-01T14:12:08.484070+00:00 2021-04-01T14:23:11.605377+00:00 0:11:03.121307 12430 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T14:12:05.958317+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T14:12:04.315523+00:00 2021-04-01T14:12:06.001254+00:00 0:00:01.685731 12429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T14:12:01.945874+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T14:11:48.177484+00:00 2021-04-01T14:11:49.997361+00:00 0:00:01.819877 12428 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T14:11:45.844735+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T13:00:00+00:00 PythonOperator 2021-04-01T14:11:42.074276+00:00 2021-04-01T14:11:44.897010+00:00 0:00:02.822734 12427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T14:11:39.840105+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T13:00:00+00:00 PythonOperator 2021-04-01T14:11:26.081499+00:00 2021-04-01T14:11:29.029730+00:00 0:00:02.948231 12426 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T14:11:23.825711+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T13:00:00+00:00 TriggerDagRunOperator 2021-04-01T14:11:20.231327+00:00 2021-04-01T14:11:20.762993+00:00 0:00:00.531666 12425 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T14:11:17.822796+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T13:00:00+00:00 TriggerDagRunOperator 2021-04-01T14:11:20.034925+00:00 2021-04-01T14:11:20.459459+00:00 0:00:00.424534 12424 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T14:11:17.822762+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T13:05:00+00:00 EmrJobFlowSensor 2021-04-01T14:06:05.579545+00:00 2021-04-01T14:14:08.130773+00:00 0:08:02.551228 12423 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T14:06:03.290693+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T14:05:45.670537+00:00 2021-04-01T14:05:47.383531+00:00 0:00:01.712994 12422 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T14:05:43.236368+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T13:05:00+00:00 PythonOperator 2021-04-01T14:05:23.367536+00:00 2021-04-01T14:05:26.138936+00:00 0:00:02.771400 12421 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T14:05:21.217753+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T13:00:00+00:00 EmrJobFlowSensor 2021-04-01T14:00:53.587444+00:00 2021-04-01T14:10:56.540986+00:00 0:10:02.953542 12420 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T14:00:50.808850+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T14:00:31.355619+00:00 2021-04-01T14:00:33.090568+00:00 0:00:01.734949 12419 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T14:00:28.867647+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T13:00:00+00:00 PythonOperator 2021-04-01T14:00:09.189853+00:00 2021-04-01T14:00:11.931412+00:00 0:00:02.741559 12418 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T14:00:06.743017+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T12:00:00+00:00 EmrJobFlowSensor 2021-04-01T13:11:13.506861+00:00 2021-04-01T13:28:17.149649+00:00 0:17:03.642788 12416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T13:11:11.292990+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T12:00:00+00:00 EmrJobFlowSensor 2021-04-01T13:11:09.629469+00:00 2021-04-01T13:19:12.150971+00:00 0:08:02.521502 12415 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T13:11:07.298787+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T13:10:53.619186+00:00 2021-04-01T13:10:55.459752+00:00 0:00:01.840566 12414 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T13:10:51.260248+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T13:10:49.636884+00:00 2021-04-01T13:10:51.414962+00:00 0:00:01.778078 12413 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T13:10:47.257114+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T12:00:00+00:00 PythonOperator 2021-04-01T13:10:31.620718+00:00 2021-04-01T13:10:34.604014+00:00 0:00:02.983296 12412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T13:10:29.245636+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T12:00:00+00:00 PythonOperator 2021-04-01T13:10:27.404798+00:00 2021-04-01T13:10:30.216663+00:00 0:00:02.811865 12411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T13:10:25.240356+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T12:00:00+00:00 TriggerDagRunOperator 2021-04-01T13:10:07.762268+00:00 2021-04-01T13:10:08.181959+00:00 0:00:00.419691 12410 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T13:10:05.271701+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T12:00:00+00:00 TriggerDagRunOperator 2021-04-01T13:10:07.774630+00:00 2021-04-01T13:10:08.334627+00:00 0:00:00.559997 12409 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T13:10:05.271744+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T12:05:00+00:00 EmrJobFlowSensor 2021-04-01T13:05:55.144177+00:00 2021-04-01T13:14:57.729072+00:00 0:09:02.584895 12408 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T13:05:52.823950+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T13:05:33.284402+00:00 2021-04-01T13:05:34.910977+00:00 0:00:01.626575 12407 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T13:05:30.863250+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T12:05:00+00:00 PythonOperator 2021-04-01T13:05:10.970056+00:00 2021-04-01T13:05:13.653966+00:00 0:00:02.683910 12406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T13:05:08.776713+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T12:00:00+00:00 EmrJobFlowSensor 2021-04-01T13:00:46.661684+00:00 2021-04-01T13:09:49.506042+00:00 0:09:02.844358 12405 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T13:00:44.286616+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T13:00:26.419977+00:00 2021-04-01T13:00:28.147306+00:00 0:00:01.727329 12404 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T13:00:24.260821+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T12:00:00+00:00 PythonOperator 2021-04-01T13:00:04.704856+00:00 2021-04-01T13:00:07.478682+00:00 0:00:02.773826 12403 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T13:00:02.203530+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T11:00:00+00:00 EmrJobFlowSensor 2021-04-01T12:12:37.713404+00:00 2021-04-01T12:24:40.978214+00:00 0:12:03.264810 12401 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T12:12:35.068306+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T11:00:00+00:00 EmrJobFlowSensor 2021-04-01T12:12:37.410270+00:00 2021-04-01T12:20:39.951397+00:00 0:08:02.541127 12400 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T12:12:35.068255+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T12:12:15.727088+00:00 2021-04-01T12:12:17.560930+00:00 0:00:01.833842 12399 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T12:12:13.058875+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T12:12:15.596575+00:00 2021-04-01T12:12:17.329539+00:00 0:00:01.732964 12398 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T12:12:13.058826+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T11:00:00+00:00 PythonOperator 2021-04-01T12:11:55.317538+00:00 2021-04-01T12:11:58.191893+00:00 0:00:02.874355 12397 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T12:11:52.944470+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T11:00:00+00:00 PythonOperator 2021-04-01T12:11:55.225828+00:00 2021-04-01T12:11:58.223425+00:00 0:00:02.997597 12396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T12:11:52.944505+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T11:00:00+00:00 TriggerDagRunOperator 2021-04-01T12:11:37.330750+00:00 2021-04-01T12:11:37.859843+00:00 0:00:00.529093 12395 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T12:11:34.930157+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T11:00:00+00:00 TriggerDagRunOperator 2021-04-01T12:11:37.246206+00:00 2021-04-01T12:11:37.660640+00:00 0:00:00.414434 12394 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T12:11:34.930123+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T11:05:00+00:00 EmrJobFlowSensor 2021-04-01T12:06:08.665271+00:00 2021-04-01T12:15:11.244140+00:00 0:09:02.578869 12393 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T12:06:06.433832+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T12:05:48.714646+00:00 2021-04-01T12:05:50.369670+00:00 0:00:01.655024 12392 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T12:05:46.406626+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T11:05:00+00:00 PythonOperator 2021-04-01T12:05:26.760118+00:00 2021-04-01T12:05:29.437793+00:00 0:00:02.677675 12391 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T12:05:24.467848+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T11:00:00+00:00 EmrJobFlowSensor 2021-04-01T12:01:10.150317+00:00 2021-04-01T12:11:13.160671+00:00 0:10:03.010354 12390 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T12:01:07.826493+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T12:00:42.134775+00:00 2021-04-01T12:00:43.828609+00:00 0:00:01.693834 12389 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T12:00:39.865787+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T11:00:00+00:00 PythonOperator 2021-04-01T12:00:22.099391+00:00 2021-04-01T12:00:24.889601+00:00 0:00:02.790210 12388 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T12:00:19.783951+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T10:00:00+00:00 EmrJobFlowSensor 2021-04-01T11:12:34.526329+00:00 2021-04-01T11:21:37.002600+00:00 0:09:02.476271 12386 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T11:12:32.183583+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T10:00:00+00:00 EmrJobFlowSensor 2021-04-01T11:12:28.414493+00:00 2021-04-01T11:22:31.279895+00:00 0:10:02.865402 12385 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T11:12:26.164392+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T11:12:10.311112+00:00 2021-04-01T11:12:12.056878+00:00 0:00:01.745766 12384 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T11:12:08.148315+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T11:12:06.311702+00:00 2021-04-01T11:12:08.074390+00:00 0:00:01.762688 12383 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T11:12:04.142541+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T10:00:00+00:00 PythonOperator 2021-04-01T11:11:50.754538+00:00 2021-04-01T11:11:54.026180+00:00 0:00:03.271642 12382 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T11:11:48.130068+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T10:00:00+00:00 PythonOperator 2021-04-01T11:11:46.756716+00:00 2021-04-01T11:11:50.037448+00:00 0:00:03.280732 12381 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T11:11:44.123560+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T10:00:00+00:00 TriggerDagRunOperator 2021-04-01T11:11:34.624196+00:00 2021-04-01T11:11:35.195141+00:00 0:00:00.570945 12380 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T11:11:32.113304+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T10:00:00+00:00 TriggerDagRunOperator 2021-04-01T11:11:34.423483+00:00 2021-04-01T11:11:34.870202+00:00 0:00:00.446719 12379 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T11:11:32.113273+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T10:05:00+00:00 EmrJobFlowSensor 2021-04-01T11:06:04.007762+00:00 2021-04-01T11:15:06.635566+00:00 0:09:02.627804 12378 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T11:06:01.701698+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T11:05:42.000714+00:00 2021-04-01T11:05:43.643395+00:00 0:00:01.642681 12377 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T11:05:39.744059+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T10:05:00+00:00 PythonOperator 2021-04-01T11:05:21.820004+00:00 2021-04-01T11:05:24.498884+00:00 0:00:02.678880 12376 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T11:05:19.655118+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T10:00:00+00:00 EmrJobFlowSensor 2021-04-01T11:01:09.888907+00:00 2021-04-01T11:11:12.758761+00:00 0:10:02.869854 12375 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T11:01:07.279039+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T11:00:47.414007+00:00 2021-04-01T11:00:49.127735+00:00 0:00:01.713728 12374 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T11:00:45.189350+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T10:00:00+00:00 PythonOperator 2021-04-01T11:00:21.548792+00:00 2021-04-01T11:00:24.257195+00:00 0:00:02.708403 12373 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T11:00:19.126588+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T09:00:00+00:00 EmrJobFlowSensor 2021-04-01T10:11:28.920231+00:00 2021-04-01T10:21:31.701658+00:00 0:10:02.781427 12371 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T10:11:26.787337+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T09:00:00+00:00 EmrJobFlowSensor 2021-04-01T10:11:23.187923+00:00 2021-04-01T10:28:27.013439+00:00 0:17:03.825516 12370 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T10:11:20.855409+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T10:11:09.293658+00:00 2021-04-01T10:11:11.216683+00:00 0:00:01.923025 12369 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T10:11:06.770426+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T10:11:03.192120+00:00 2021-04-01T10:11:05.047773+00:00 0:00:01.855653 12368 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T10:11:00.759093+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T09:00:00+00:00 PythonOperator 2021-04-01T10:10:46.888433+00:00 2021-04-01T10:10:49.886665+00:00 0:00:02.998232 12367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T10:10:44.690199+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T09:00:00+00:00 PythonOperator 2021-04-01T10:10:40.983317+00:00 2021-04-01T10:10:43.668587+00:00 0:00:02.685270 12366 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T10:10:38.752291+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T09:00:00+00:00 TriggerDagRunOperator 2021-04-01T10:10:23.011850+00:00 2021-04-01T10:10:23.689301+00:00 0:00:00.677451 12365 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T10:10:20.664280+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T09:00:00+00:00 TriggerDagRunOperator 2021-04-01T10:10:22.931966+00:00 2021-04-01T10:10:23.379518+00:00 0:00:00.447552 12364 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T10:10:20.664307+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T09:05:00+00:00 EmrJobFlowSensor 2021-04-01T10:05:46.604993+00:00 2021-04-01T10:16:49.649406+00:00 0:11:03.044413 12363 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T10:05:44.225202+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T10:05:24.399747+00:00 2021-04-01T10:05:26.064773+00:00 0:00:01.665026 12362 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T10:05:22.240855+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T09:05:00+00:00 PythonOperator 2021-04-01T10:05:04.644706+00:00 2021-04-01T10:05:07.530875+00:00 0:00:02.886169 12361 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T10:05:02.186644+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T09:00:00+00:00 EmrJobFlowSensor 2021-04-01T10:01:00.458125+00:00 2021-04-01T10:10:03.259011+00:00 0:09:02.800886 12360 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T10:00:57.963177+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T10:00:40.081698+00:00 2021-04-01T10:00:41.781964+00:00 0:00:01.700266 12359 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T10:00:37.846007+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T09:00:00+00:00 PythonOperator 2021-04-01T10:00:18.466506+00:00 2021-04-01T10:00:21.302408+00:00 0:00:02.835902 12358 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T10:00:15.882955+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-01T08:00:00+00:00 EmrJobFlowSensor 2021-04-01T09:19:04.609106+00:00 2021-04-01T09:29:07.431863+00:00 0:10:02.822757 12357 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T09:19:02.169047+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-01T08:00:00+00:00 EmrJobFlowSensor 2021-04-01T09:18:48.270356+00:00 2021-04-01T09:27:51.008467+00:00 0:09:02.738111 12356 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T09:18:46.022987+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-01T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T09:18:42.374822+00:00 2021-04-01T09:18:44.119288+00:00 0:00:01.744466 12355 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T09:18:40.075282+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-01T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T09:18:28.394708+00:00 2021-04-01T09:18:30.208779+00:00 0:00:01.814071 12354 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T09:18:26.007291+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-01T08:00:00+00:00 PythonOperator 2021-04-01T09:18:22.230527+00:00 2021-04-01T09:18:25.343353+00:00 0:00:03.112826 12353 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T09:18:20.003139+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-01T08:00:00+00:00 PythonOperator 2021-04-01T09:18:06.263009+00:00 2021-04-01T09:18:08.978303+00:00 0:00:02.715294 12352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T09:18:03.987713+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-01T08:00:00+00:00 TriggerDagRunOperator 2021-04-01T09:18:00.670337+00:00 2021-04-01T09:18:01.096632+00:00 0:00:00.426295 12351 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T09:17:57.983193+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-01T08:00:00+00:00 TriggerDagRunOperator 2021-04-01T09:18:00.679113+00:00 2021-04-01T09:18:01.203499+00:00 0:00:00.524386 12350 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T09:17:57.983220+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-01T08:05:00+00:00 EmrJobFlowSensor 2021-04-01T09:05:46.263712+00:00 2021-04-01T09:14:48.944140+00:00 0:09:02.680428 12348 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-01T09:05:44.056240+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-01T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-01T09:05:24.457841+00:00 2021-04-01T09:05:26.099384+00:00 0:00:01.641543 12347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-01T09:05:21.967059+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-01T08:05:00+00:00 PythonOperator 2021-04-01T09:05:04.453509+00:00 2021-04-01T09:05:07.249122+00:00 0:00:02.795613 12346 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T09:05:01.948047+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-01T08:00:00+00:00 EmrJobFlowSensor 2021-04-01T09:01:03.918941+00:00 2021-04-01T09:15:07.350870+00:00 0:14:03.431929 12345 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-01T09:01:01.591451+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-01T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-01T09:00:41.709460+00:00 2021-04-01T09:00:43.423402+00:00 0:00:01.713942 12344 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-01T09:00:39.549774+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-01T08:00:00+00:00 PythonOperator 2021-04-01T09:00:19.673721+00:00 2021-04-01T09:00:22.383540+00:00 0:00:02.709819 12343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-01T09:00:17.477691+00:00 2 default_pool