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_emr_steps 2021-04-04T12:00:00+00:00 PythonOperator 2021-04-04T13:00:05.964176+00:00 2021-04-04T13:00:08.682362+00:00 0:00:02.718186 13484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T13:00:03.626304+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T11:00:00+00:00 EmrJobFlowSensor 2021-04-04T12:11:08.985588+00:00 2021-04-04T12:20:11.672550+00:00 0:09:02.686962 13483 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T12:11:06.745722+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T11:00:00+00:00 EmrJobFlowSensor 2021-04-04T12:11:05.161429+00:00 2021-04-04T12:20:07.920843+00:00 0:09:02.759414 13482 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T12:11:02.747219+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T12:10:46.855425+00:00 2021-04-04T12:10:48.636784+00:00 0:00:01.781359 13481 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T12:10:44.618262+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T12:10:42.801689+00:00 2021-04-04T12:10:44.475281+00:00 0:00:01.673592 13480 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T12:10:40.617030+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T11:00:00+00:00 PythonOperator 2021-04-04T12:10:25.106811+00:00 2021-04-04T12:10:28.243294+00:00 0:00:03.136483 13479 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T12:10:22.666098+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T11:00:00+00:00 PythonOperator 2021-04-04T12:10:20.897106+00:00 2021-04-04T12:10:23.691980+00:00 0:00:02.794874 13478 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T12:10:18.597093+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T11:00:00+00:00 TriggerDagRunOperator 2021-04-04T12:10:06.977972+00:00 2021-04-04T12:10:07.493044+00:00 0:00:00.515072 13477 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T12:10:04.586258+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T11:00:00+00:00 TriggerDagRunOperator 2021-04-04T12:10:06.789475+00:00 2021-04-04T12:10:07.196340+00:00 0:00:00.406865 13476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T12:10:04.586225+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T11:05:00+00:00 EmrJobFlowSensor 2021-04-04T12:06:04.697617+00:00 2021-04-04T12:15:07.312070+00:00 0:09:02.614453 13475 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T12:06:02.247621+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T12:05:44.583965+00:00 2021-04-04T12:05:46.317780+00:00 0:00:01.733815 13474 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T12:05:42.173790+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T11:05:00+00:00 PythonOperator 2021-04-04T12:05:22.488505+00:00 2021-04-04T12:05:25.161595+00:00 0:00:02.673090 13473 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T12:05:20.099972+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T11:00:00+00:00 EmrJobFlowSensor 2021-04-04T12:00:49.909403+00:00 2021-04-04T12:09:52.635361+00:00 0:09:02.725958 13471 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T12:00:47.622693+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T12:00:26.307259+00:00 2021-04-04T12:00:27.979414+00:00 0:00:01.672155 13470 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T12:00:23.680826+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T11:00:00+00:00 PythonOperator 2021-04-04T12:00:06.108440+00:00 2021-04-04T12:00:08.849909+00:00 0:00:02.741469 13469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T12:00:03.662635+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T10:00:00+00:00 EmrJobFlowSensor 2021-04-04T11:12:37.539582+00:00 2021-04-04T11:22:40.319906+00:00 0:10:02.780324 13468 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T11:12:34.967010+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T10:00:00+00:00 EmrJobFlowSensor 2021-04-04T11:12:31.136226+00:00 2021-04-04T11:21:33.692633+00:00 0:09:02.556407 13467 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T11:12:28.898314+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T11:12:15.521385+00:00 2021-04-04T11:12:17.408561+00:00 0:00:01.887176 13466 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T11:12:12.957795+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T11:12:09.312471+00:00 2021-04-04T11:12:11.143145+00:00 0:00:01.830674 13465 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T11:12:06.879091+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T10:00:00+00:00 PythonOperator 2021-04-04T11:11:53.315585+00:00 2021-04-04T11:11:56.208813+00:00 0:00:02.893228 13464 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T11:11:50.864754+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T10:00:00+00:00 PythonOperator 2021-04-04T11:11:49.067778+00:00 2021-04-04T11:11:52.002103+00:00 0:00:02.934325 13463 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T11:11:46.863230+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T10:00:00+00:00 TriggerDagRunOperator 2021-04-04T11:11:27.215319+00:00 2021-04-04T11:11:27.658391+00:00 0:00:00.443072 13462 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T11:11:24.816825+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T10:00:00+00:00 TriggerDagRunOperator 2021-04-04T11:11:27.125637+00:00 2021-04-04T11:11:27.683226+00:00 0:00:00.557589 13461 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T11:11:24.816853+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T10:05:00+00:00 EmrJobFlowSensor 2021-04-04T11:06:08.606634+00:00 2021-04-04T11:15:11.266567+00:00 0:09:02.659933 13460 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T11:06:06.317311+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T11:05:46.766121+00:00 2021-04-04T11:05:48.531415+00:00 0:00:01.765294 13459 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T11:05:44.363114+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T10:05:00+00:00 PythonOperator 2021-04-04T11:05:22.436429+00:00 2021-04-04T11:05:25.137008+00:00 0:00:02.700579 13458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T11:05:20.252234+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T10:00:00+00:00 EmrJobFlowSensor 2021-04-04T11:02:06.327398+00:00 2021-04-04T11:11:09.164528+00:00 0:09:02.837130 13457 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T11:02:03.957082+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T11:01:44.026062+00:00 2021-04-04T11:01:45.739923+00:00 0:00:01.713861 13456 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T11:01:41.857902+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T10:00:00+00:00 PythonOperator 2021-04-04T11:01:12.615693+00:00 2021-04-04T11:01:15.457791+00:00 0:00:02.842098 13455 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T11:01:09.874778+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T09:00:00+00:00 EmrJobFlowSensor 2021-04-04T10:11:24.109582+00:00 2021-04-04T10:21:27.023721+00:00 0:10:02.914139 13453 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T10:11:21.634613+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T09:00:00+00:00 EmrJobFlowSensor 2021-04-04T10:11:21.893042+00:00 2021-04-04T10:21:24.718195+00:00 0:10:02.825153 13452 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T10:11:19.632381+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T10:11:03.821994+00:00 2021-04-04T10:11:05.558398+00:00 0:00:01.736404 13451 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T10:11:01.617979+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T10:11:02.026956+00:00 2021-04-04T10:11:03.939901+00:00 0:00:01.912945 13450 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T10:10:59.663445+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T09:00:00+00:00 PythonOperator 2021-04-04T10:10:41.875010+00:00 2021-04-04T10:10:44.571687+00:00 0:00:02.696677 13449 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T10:10:39.602841+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T09:00:00+00:00 PythonOperator 2021-04-04T10:10:40.091859+00:00 2021-04-04T10:10:43.185132+00:00 0:00:03.093273 13448 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T10:10:37.654307+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T09:00:00+00:00 TriggerDagRunOperator 2021-04-04T10:10:26.087166+00:00 2021-04-04T10:10:26.538761+00:00 0:00:00.451595 13447 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T10:10:23.685384+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T09:00:00+00:00 TriggerDagRunOperator 2021-04-04T10:10:25.998394+00:00 2021-04-04T10:10:26.585282+00:00 0:00:00.586888 13446 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T10:10:23.685419+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T09:05:00+00:00 EmrJobFlowSensor 2021-04-04T10:05:57.497442+00:00 2021-04-04T10:15:00.109609+00:00 0:09:02.612167 13445 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T10:05:55.291410+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T10:05:35.587491+00:00 2021-04-04T10:05:37.314041+00:00 0:00:01.726550 13444 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T10:05:33.219525+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T09:05:00+00:00 PythonOperator 2021-04-04T10:05:13.389694+00:00 2021-04-04T10:05:16.079990+00:00 0:00:02.690296 13443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T10:05:11.193308+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T09:00:00+00:00 EmrJobFlowSensor 2021-04-04T10:01:14.847876+00:00 2021-04-04T10:10:17.620397+00:00 0:09:02.772521 13442 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T10:01:12.508789+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T10:00:54.799794+00:00 2021-04-04T10:00:56.581350+00:00 0:00:01.781556 13441 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T10:00:52.449908+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T09:00:00+00:00 PythonOperator 2021-04-04T10:00:22.815828+00:00 2021-04-04T10:00:25.590785+00:00 0:00:02.774957 13440 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T10:00:20.421534+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T08:00:00+00:00 EmrJobFlowSensor 2021-04-04T09:11:07.365009+00:00 2021-04-04T09:20:09.996243+00:00 0:09:02.631234 13438 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T09:11:05.113517+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T08:00:00+00:00 EmrJobFlowSensor 2021-04-04T09:10:53.586439+00:00 2021-04-04T09:20:56.267662+00:00 0:10:02.681223 13437 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T09:10:51.102321+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T09:10:45.313721+00:00 2021-04-04T09:10:46.973079+00:00 0:00:01.659358 13436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T09:10:43.098114+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T09:10:29.655529+00:00 2021-04-04T09:10:31.329546+00:00 0:00:01.674017 13435 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T09:10:27.153529+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T08:00:00+00:00 PythonOperator 2021-04-04T09:10:23.312322+00:00 2021-04-04T09:10:26.098052+00:00 0:00:02.785730 13434 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T09:10:21.038501+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T08:00:00+00:00 PythonOperator 2021-04-04T09:10:09.576118+00:00 2021-04-04T09:10:12.686232+00:00 0:00:03.110114 13433 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T09:10:07.058341+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T08:00:00+00:00 TriggerDagRunOperator 2021-04-04T09:09:59.537739+00:00 2021-04-04T09:10:00.156549+00:00 0:00:00.618810 13432 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T09:09:56.972171+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T08:00:00+00:00 TriggerDagRunOperator 2021-04-04T09:09:59.233914+00:00 2021-04-04T09:09:59.703864+00:00 0:00:00.469950 13431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T09:09:56.972206+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T08:05:00+00:00 EmrJobFlowSensor 2021-04-04T09:06:06.993908+00:00 2021-04-04T09:15:09.635426+00:00 0:09:02.641518 13430 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T09:06:04.570384+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T09:05:44.672611+00:00 2021-04-04T09:05:46.338086+00:00 0:00:01.665475 13429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T09:05:42.495380+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T08:05:00+00:00 PythonOperator 2021-04-04T09:05:14.652081+00:00 2021-04-04T09:05:17.369312+00:00 0:00:02.717231 13428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T09:05:12.464734+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T08:00:00+00:00 EmrJobFlowSensor 2021-04-04T09:00:50.302082+00:00 2021-04-04T09:09:53.002715+00:00 0:09:02.700633 13427 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T09:00:48.098629+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T09:00:30.551481+00:00 2021-04-04T09:00:32.366464+00:00 0:00:01.814983 13426 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T09:00:28.162253+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T08:00:00+00:00 PythonOperator 2021-04-04T09:00:08.720953+00:00 2021-04-04T09:00:11.554998+00:00 0:00:02.834045 13425 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T09:00:06.063625+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T07:00:00+00:00 EmrJobFlowSensor 2021-04-04T08:12:58.173263+00:00 2021-04-04T08:22:00.750760+00:00 0:09:02.577497 13423 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T08:12:55.989546+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T07:00:00+00:00 EmrJobFlowSensor 2021-04-04T08:12:48.290107+00:00 2021-04-04T08:22:51.127747+00:00 0:10:02.837640 13422 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T08:12:45.979290+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T08:12:32.322853+00:00 2021-04-04T08:12:34.160077+00:00 0:00:01.837224 13421 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T08:12:29.974263+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T08:12:24.298316+00:00 2021-04-04T08:12:25.995172+00:00 0:00:01.696856 13420 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T08:12:21.904749+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T07:00:00+00:00 PythonOperator 2021-04-04T08:12:10.533122+00:00 2021-04-04T08:12:13.331913+00:00 0:00:02.798791 13419 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T08:12:07.889573+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T07:00:00+00:00 PythonOperator 2021-04-04T08:12:04.459425+00:00 2021-04-04T08:12:07.433715+00:00 0:00:02.974290 13418 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T08:12:01.892330+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T07:00:00+00:00 TriggerDagRunOperator 2021-04-04T08:11:58.551752+00:00 2021-04-04T08:11:59.081946+00:00 0:00:00.530194 13417 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T08:11:55.952871+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T07:00:00+00:00 TriggerDagRunOperator 2021-04-04T08:11:58.402615+00:00 2021-04-04T08:11:58.840140+00:00 0:00:00.437525 13416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T08:11:55.952923+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T07:05:00+00:00 EmrJobFlowSensor 2021-04-04T08:06:01.855360+00:00 2021-04-04T08:15:04.467320+00:00 0:09:02.611960 13415 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T08:05:59.454683+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T08:05:41.639378+00:00 2021-04-04T08:05:43.382651+00:00 0:00:01.743273 13414 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T08:05:39.363025+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T07:05:00+00:00 PythonOperator 2021-04-04T08:05:19.726510+00:00 2021-04-04T08:05:22.406661+00:00 0:00:02.680151 13413 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T08:05:17.363088+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T07:00:00+00:00 EmrJobFlowSensor 2021-04-04T08:01:19.171818+00:00 2021-04-04T08:11:22.025393+00:00 0:10:02.853575 13412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T08:01:16.871976+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T08:00:45.417665+00:00 2021-04-04T08:00:47.143018+00:00 0:00:01.725353 13411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T08:00:42.824345+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T07:00:00+00:00 PythonOperator 2021-04-04T08:00:23.119192+00:00 2021-04-04T08:00:25.969827+00:00 0:00:02.850635 13410 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T08:00:20.807923+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T06:00:00+00:00 EmrJobFlowSensor 2021-04-04T07:13:27.737005+00:00 2021-04-04T07:23:30.573560+00:00 0:10:02.836555 13408 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T07:13:25.366021+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T07:13:05.576740+00:00 2021-04-04T07:13:07.261596+00:00 0:00:01.684856 13407 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T07:13:03.353234+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T06:00:00+00:00 PythonOperator 2021-04-04T07:12:45.621590+00:00 2021-04-04T07:12:48.576218+00:00 0:00:02.954628 13406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T07:12:43.258842+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T06:00:00+00:00 EmrJobFlowSensor 2021-04-04T07:12:33.592533+00:00 2021-04-04T07:21:36.198519+00:00 0:09:02.605986 13405 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T07:12:31.258434+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T07:12:09.564820+00:00 2021-04-04T07:12:11.247640+00:00 0:00:01.682820 13404 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T07:12:07.220526+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T06:00:00+00:00 PythonOperator 2021-04-04T07:11:43.412244+00:00 2021-04-04T07:11:46.148143+00:00 0:00:02.735899 13403 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T07:11:41.208691+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T06:00:00+00:00 TriggerDagRunOperator 2021-04-04T07:11:29.693685+00:00 2021-04-04T07:11:30.234429+00:00 0:00:00.540744 13402 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T07:11:27.189891+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T06:00:00+00:00 TriggerDagRunOperator 2021-04-04T07:11:29.573303+00:00 2021-04-04T07:11:29.978133+00:00 0:00:00.404830 13401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T07:11:27.189853+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T06:05:00+00:00 EmrJobFlowSensor 2021-04-04T07:06:06.815384+00:00 2021-04-04T07:15:09.422933+00:00 0:09:02.607549 13400 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T07:06:04.491021+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T07:05:45.069811+00:00 2021-04-04T07:05:46.721475+00:00 0:00:01.651664 13399 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T07:05:42.552946+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T06:05:00+00:00 PythonOperator 2021-04-04T07:05:24.744869+00:00 2021-04-04T07:05:27.547237+00:00 0:00:02.802368 13398 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T07:05:22.457463+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T06:00:00+00:00 EmrJobFlowSensor 2021-04-04T07:01:04.353311+00:00 2021-04-04T07:11:07.196185+00:00 0:10:02.842874 13397 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T07:01:01.866757+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T07:00:42.144008+00:00 2021-04-04T07:00:43.997189+00:00 0:00:01.853181 13396 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T07:00:39.850199+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T06:00:00+00:00 PythonOperator 2021-04-04T07:00:20.080810+00:00 2021-04-04T07:00:22.803712+00:00 0:00:02.722902 13395 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T07:00:17.691064+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T05:00:00+00:00 EmrJobFlowSensor 2021-04-04T06:11:25.420345+00:00 2021-04-04T06:20:28.071642+00:00 0:09:02.651297 13393 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T06:11:23.194591+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T05:00:00+00:00 EmrJobFlowSensor 2021-04-04T06:11:15.632502+00:00 2021-04-04T06:21:18.370326+00:00 0:10:02.737824 13392 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T06:11:13.262580+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T06:11:03.487500+00:00 2021-04-04T06:11:05.445760+00:00 0:00:01.958260 13391 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T06:11:01.084799+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T06:10:55.502466+00:00 2021-04-04T06:10:57.299047+00:00 0:00:01.796581 13390 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T06:10:53.087826+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T05:00:00+00:00 PythonOperator 2021-04-04T06:10:41.217894+00:00 2021-04-04T06:10:44.068449+00:00 0:00:02.850555 13389 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T06:10:39.017183+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T05:00:00+00:00 PythonOperator 2021-04-04T06:10:33.300375+00:00 2021-04-04T06:10:36.264366+00:00 0:00:02.963991 13388 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T06:10:31.011235+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T05:00:00+00:00 TriggerDagRunOperator 2021-04-04T06:10:25.462073+00:00 2021-04-04T06:10:26.014591+00:00 0:00:00.552518 13387 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T06:10:23.006710+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T05:00:00+00:00 TriggerDagRunOperator 2021-04-04T06:10:25.349939+00:00 2021-04-04T06:10:25.815898+00:00 0:00:00.465959 13386 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T06:10:23.006672+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T05:05:00+00:00 EmrJobFlowSensor 2021-04-04T06:05:50.683530+00:00 2021-04-04T06:14:53.249916+00:00 0:09:02.566386 13385 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T06:05:48.510206+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T06:05:28.858783+00:00 2021-04-04T06:05:30.604908+00:00 0:00:01.746125 13384 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T06:05:26.472876+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T05:05:00+00:00 PythonOperator 2021-04-04T06:05:06.785680+00:00 2021-04-04T06:05:09.506995+00:00 0:00:02.721315 13383 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T06:05:04.446862+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T05:00:00+00:00 EmrJobFlowSensor 2021-04-04T06:01:04.668682+00:00 2021-04-04T06:10:07.438137+00:00 0:09:02.769455 13382 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T06:01:02.055853+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T06:00:42.329187+00:00 2021-04-04T06:00:44.039118+00:00 0:00:01.709931 13381 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T06:00:39.996827+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T05:00:00+00:00 PythonOperator 2021-04-04T06:00:20.303693+00:00 2021-04-04T06:00:23.016879+00:00 0:00:02.713186 13380 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T06:00:17.969704+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T04:00:00+00:00 EmrJobFlowSensor 2021-04-04T05:12:36.305146+00:00 2021-04-04T05:22:39.087470+00:00 0:10:02.782324 13378 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T05:12:34.121883+00:00 2 default_pool