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-05-15T19:00:00+00:00 PythonOperator 2021-05-15T20:11:47.834526+00:00 2021-05-15T20:11:51.261874+00:00 0:00:03.427348 28476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T20:11:45.511578+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T19:00:00+00:00 TriggerDagRunOperator 2021-05-15T20:11:42.287539+00:00 2021-05-15T20:11:42.822791+00:00 0:00:00.535252 28475 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T20:11:39.353467+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T19:00:00+00:00 TriggerDagRunOperator 2021-05-15T20:11:42.125602+00:00 2021-05-15T20:11:42.591987+00:00 0:00:00.466385 28474 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T20:11:39.353504+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-15T19:05:00+00:00 EmrJobFlowSensor 2021-05-15T20:05:57.968053+00:00 2021-05-15T20:15:00.591994+00:00 0:09:02.623941 28472 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T20:05:55.907270+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-15T19:05:00+00:00 EmrCreateJobFlowOperator 2021-05-15T20:05:36.064170+00:00 2021-05-15T20:05:37.689003+00:00 0:00:01.624833 28471 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T20:05:33.856718+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-15T19:05:00+00:00 PythonOperator 2021-05-15T20:05:13.932311+00:00 2021-05-15T20:05:17.090937+00:00 0:00:03.158626 28470 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T20:05:11.746634+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T19:00:00+00:00 EmrJobFlowSensor 2021-05-15T20:00:47.468148+00:00 2021-05-15T20:10:50.245763+00:00 0:10:02.777615 28469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T20:00:45.331954+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T20:00:27.561277+00:00 2021-05-15T20:00:29.337786+00:00 0:00:01.776509 28468 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T20:00:25.311583+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T19:00:00+00:00 PythonOperator 2021-05-15T20:00:05.655364+00:00 2021-05-15T20:00:08.775010+00:00 0:00:03.119646 28467 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T20:00:03.294804+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-15T18:00:00+00:00 EmrJobFlowSensor 2021-05-15T19:21:11.449928+00:00 2021-05-15T19:38:15.502134+00:00 0:17:04.052206 28466 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T19:21:09.062051+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-15T18:00:00+00:00 EmrJobFlowSensor 2021-05-15T19:21:03.742211+00:00 2021-05-15T19:31:06.820014+00:00 0:10:03.077803 28465 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T19:21:01.054351+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-15T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T19:20:49.558139+00:00 2021-05-15T19:20:51.276861+00:00 0:00:01.718722 28464 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T19:20:46.960776+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-15T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T19:20:40.990932+00:00 2021-05-15T19:20:42.735025+00:00 0:00:01.744093 28463 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T19:20:38.892236+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-15T18:00:00+00:00 PythonOperator 2021-05-15T19:20:28.940774+00:00 2021-05-15T19:20:32.074523+00:00 0:00:03.133749 28462 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T19:20:26.842136+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-15T18:00:00+00:00 PythonOperator 2021-05-15T19:20:19.130918+00:00 2021-05-15T19:20:22.508928+00:00 0:00:03.378010 28461 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T19:20:16.823236+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T18:00:00+00:00 TriggerDagRunOperator 2021-05-15T19:20:09.427872+00:00 2021-05-15T19:20:09.960270+00:00 0:00:00.532398 28460 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T19:20:06.821307+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T18:00:00+00:00 TriggerDagRunOperator 2021-05-15T19:20:09.313168+00:00 2021-05-15T19:20:09.727651+00:00 0:00:00.414483 28459 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T19:20:06.821218+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-15T18:05:00+00:00 EmrJobFlowSensor 2021-05-15T19:06:03.553387+00:00 2021-05-15T19:15:06.347527+00:00 0:09:02.794140 28457 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T19:06:01.275217+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-15T18:05:00+00:00 EmrCreateJobFlowOperator 2021-05-15T19:05:41.355522+00:00 2021-05-15T19:05:43.031226+00:00 0:00:01.675704 28456 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T19:05:39.244104+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-15T18:05:00+00:00 PythonOperator 2021-05-15T19:05:19.407678+00:00 2021-05-15T19:05:22.514700+00:00 0:00:03.107022 28455 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T19:05:17.194455+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T18:00:00+00:00 EmrJobFlowSensor 2021-05-15T19:00:56.743182+00:00 2021-05-15T19:20:00.847861+00:00 0:19:04.104679 28454 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T19:00:54.625605+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T19:00:36.697707+00:00 2021-05-15T19:00:38.393846+00:00 0:00:01.696139 28453 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T19:00:34.608343+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T18:00:00+00:00 PythonOperator 2021-05-15T19:00:14.889147+00:00 2021-05-15T19:00:18.071914+00:00 0:00:03.182767 28452 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T19:00:12.592464+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-15T17:00:00+00:00 EmrJobFlowSensor 2021-05-15T18:10:49.424297+00:00 2021-05-15T18:21:52.309024+00:00 0:11:02.884727 28451 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T18:10:47.296475+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-15T17:00:00+00:00 EmrJobFlowSensor 2021-05-15T18:10:45.666705+00:00 2021-05-15T18:18:48.093735+00:00 0:08:02.427030 28450 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T18:10:43.351682+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-15T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T18:10:28.135515+00:00 2021-05-15T18:10:29.856527+00:00 0:00:01.721012 28449 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T18:10:25.282167+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-15T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T18:10:25.840452+00:00 2021-05-15T18:10:27.987145+00:00 0:00:02.146693 28448 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T18:10:23.270331+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-15T17:00:00+00:00 PythonOperator 2021-05-15T18:10:07.419461+00:00 2021-05-15T18:10:10.736037+00:00 0:00:03.316576 28447 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T18:10:05.213227+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-15T17:00:00+00:00 PythonOperator 2021-05-15T18:10:03.437912+00:00 2021-05-15T18:10:06.567187+00:00 0:00:03.129275 28446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T18:10:01.210546+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T17:00:00+00:00 TriggerDagRunOperator 2021-05-15T18:09:45.702065+00:00 2021-05-15T18:09:46.233349+00:00 0:00:00.531284 28445 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T18:09:43.198097+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T17:00:00+00:00 TriggerDagRunOperator 2021-05-15T18:09:45.469486+00:00 2021-05-15T18:09:45.869594+00:00 0:00:00.400108 28444 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T18:09:43.198139+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-15T17:05:00+00:00 EmrJobFlowSensor 2021-05-15T18:06:06.161484+00:00 2021-05-15T18:14:08.632453+00:00 0:08:02.470969 28442 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T18:06:04.117042+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-15T17:05:00+00:00 EmrCreateJobFlowOperator 2021-05-15T18:05:44.261095+00:00 2021-05-15T18:05:45.901783+00:00 0:00:01.640688 28441 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T18:05:42.097667+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-15T17:05:00+00:00 PythonOperator 2021-05-15T18:05:22.196549+00:00 2021-05-15T18:05:25.373794+00:00 0:00:03.177245 28440 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T18:05:20.023184+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T17:00:00+00:00 EmrJobFlowSensor 2021-05-15T18:01:14.036491+00:00 2021-05-15T18:09:16.784763+00:00 0:08:02.748272 28439 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T18:01:11.723943+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T18:00:44.094355+00:00 2021-05-15T18:00:45.907989+00:00 0:00:01.813634 28438 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T18:00:41.693857+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T17:00:00+00:00 PythonOperator 2021-05-15T18:00:21.950320+00:00 2021-05-15T18:00:25.090619+00:00 0:00:03.140299 28437 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T18:00:19.659512+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-15T16:00:00+00:00 EmrJobFlowSensor 2021-05-15T17:12:20.498074+00:00 2021-05-15T17:22:23.349516+00:00 0:10:02.851442 28436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T17:12:18.343566+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-15T16:00:00+00:00 EmrJobFlowSensor 2021-05-15T17:12:06.766399+00:00 2021-05-15T17:20:09.237085+00:00 0:08:02.470686 28435 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T17:12:04.326274+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-15T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T17:11:58.697525+00:00 2021-05-15T17:12:00.389945+00:00 0:00:01.692420 28434 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T17:11:56.384676+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-15T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T17:11:44.732895+00:00 2021-05-15T17:11:46.562940+00:00 0:00:01.830045 28433 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T17:11:42.355806+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-15T16:00:00+00:00 PythonOperator 2021-05-15T17:11:36.741233+00:00 2021-05-15T17:11:40.119737+00:00 0:00:03.378504 28432 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T17:11:34.367334+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-15T16:00:00+00:00 PythonOperator 2021-05-15T17:11:22.726302+00:00 2021-05-15T17:11:25.893841+00:00 0:00:03.167539 28431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T17:11:20.358872+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T16:00:00+00:00 TriggerDagRunOperator 2021-05-15T17:11:16.966848+00:00 2021-05-15T17:11:17.535241+00:00 0:00:00.568393 28430 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T17:11:14.354008+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T16:00:00+00:00 TriggerDagRunOperator 2021-05-15T17:11:16.915457+00:00 2021-05-15T17:11:17.418214+00:00 0:00:00.502757 28429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T17:11:14.353967+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-15T16:05:00+00:00 EmrJobFlowSensor 2021-05-15T17:05:46.368451+00:00 2021-05-15T17:14:48.928689+00:00 0:09:02.560238 28427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T17:05:44.307395+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-15T16:05:00+00:00 EmrCreateJobFlowOperator 2021-05-15T17:05:26.604716+00:00 2021-05-15T17:05:28.382643+00:00 0:00:01.777927 28426 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T17:05:24.282108+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-15T16:05:00+00:00 PythonOperator 2021-05-15T17:05:04.403895+00:00 2021-05-15T17:05:07.533645+00:00 0:00:03.129750 28425 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T17:05:02.267692+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T16:00:00+00:00 EmrJobFlowSensor 2021-05-15T17:00:57.895865+00:00 2021-05-15T17:11:00.656150+00:00 0:10:02.760285 28424 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T17:00:55.809512+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T17:00:36.104253+00:00 2021-05-15T17:00:37.803337+00:00 0:00:01.699084 28423 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T17:00:33.800799+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T16:00:00+00:00 PythonOperator 2021-05-15T17:00:09.978824+00:00 2021-05-15T17:00:13.187945+00:00 0:00:03.209121 28422 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T17:00:07.742068+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-15T15:00:00+00:00 EmrJobFlowSensor 2021-05-15T16:12:17.334567+00:00 2021-05-15T16:21:20.167801+00:00 0:09:02.833234 28421 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T16:12:15.049569+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-15T15:00:00+00:00 EmrJobFlowSensor 2021-05-15T16:12:13.203604+00:00 2021-05-15T16:20:15.746121+00:00 0:08:02.542517 28420 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T16:12:11.048149+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-15T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T16:11:49.559015+00:00 2021-05-15T16:11:51.223156+00:00 0:00:01.664141 28419 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T16:11:47.021994+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-15T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T16:11:47.213026+00:00 2021-05-15T16:11:49.216294+00:00 0:00:02.003268 28418 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T16:11:45.057004+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-15T15:00:00+00:00 PythonOperator 2021-05-15T16:11:27.400701+00:00 2021-05-15T16:11:30.518784+00:00 0:00:03.118083 28417 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T16:11:25.059432+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-15T15:00:00+00:00 PythonOperator 2021-05-15T16:11:25.525329+00:00 2021-05-15T16:11:28.946558+00:00 0:00:03.421229 28416 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T16:11:23.065997+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T15:00:00+00:00 TriggerDagRunOperator 2021-05-15T16:11:11.708751+00:00 2021-05-15T16:11:12.134982+00:00 0:00:00.426231 28415 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T16:11:08.994126+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T15:00:00+00:00 TriggerDagRunOperator 2021-05-15T16:11:11.515324+00:00 2021-05-15T16:11:12.048121+00:00 0:00:00.532797 28414 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T16:11:08.994169+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-15T15:05:00+00:00 EmrJobFlowSensor 2021-05-15T16:08:43.051286+00:00 2021-05-15T16:14:45.339992+00:00 0:06:02.288706 28413 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T16:08:40.673877+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-15T15:05:00+00:00 EmrCreateJobFlowOperator 2021-05-15T16:05:30.310242+00:00 2021-05-15T16:05:32.060005+00:00 0:00:01.749763 28411 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T16:05:27.964947+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-15T15:05:00+00:00 PythonOperator 2021-05-15T16:05:06.125230+00:00 2021-05-15T16:05:09.236794+00:00 0:00:03.111564 28410 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T16:05:03.890997+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T15:00:00+00:00 EmrJobFlowSensor 2021-05-15T16:00:59.815294+00:00 2021-05-15T16:11:02.835988+00:00 0:10:03.020694 28409 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T16:00:57.495056+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T16:00:39.723231+00:00 2021-05-15T16:00:41.396634+00:00 0:00:01.673403 28408 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T16:00:37.467009+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T15:00:00+00:00 PythonOperator 2021-05-15T16:00:15.604715+00:00 2021-05-15T16:00:18.876126+00:00 0:00:03.271411 28407 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T16:00:13.410574+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-15T14:00:00+00:00 EmrJobFlowSensor 2021-05-15T15:17:07.431558+00:00 2021-05-15T15:26:10.157876+00:00 0:09:02.726318 28406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T15:17:05.287654+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-15T14:00:00+00:00 EmrJobFlowSensor 2021-05-15T15:17:05.713597+00:00 2021-05-15T15:26:08.557285+00:00 0:09:02.843688 28405 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T15:17:03.357909+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-15T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T15:16:45.510105+00:00 2021-05-15T15:16:47.333511+00:00 0:00:01.823406 28404 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T15:16:43.272828+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-15T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T15:16:43.381146+00:00 2021-05-15T15:16:45.106964+00:00 0:00:01.725818 28403 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T15:16:41.268279+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-15T14:00:00+00:00 PythonOperator 2021-05-15T15:16:25.558763+00:00 2021-05-15T15:16:28.880502+00:00 0:00:03.321739 28402 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T15:16:23.231209+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-15T14:00:00+00:00 PythonOperator 2021-05-15T15:16:23.347631+00:00 2021-05-15T15:16:26.471367+00:00 0:00:03.123736 28401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T15:16:21.226130+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T14:00:00+00:00 TriggerDagRunOperator 2021-05-15T15:16:01.622543+00:00 2021-05-15T15:16:02.147534+00:00 0:00:00.524991 28400 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T15:15:59.215097+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T14:00:00+00:00 TriggerDagRunOperator 2021-05-15T15:16:01.378524+00:00 2021-05-15T15:16:01.793915+00:00 0:00:00.415391 28399 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T15:15:59.215049+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-15T14:05:00+00:00 EmrJobFlowSensor 2021-05-15T15:06:46.683742+00:00 2021-05-15T15:15:49.432611+00:00 0:09:02.748869 28398 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T15:06:44.383696+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T14:00:00+00:00 EmrJobFlowSensor 2021-05-15T15:06:38.684090+00:00 2021-05-15T15:15:41.414602+00:00 0:09:02.730512 28397 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T15:06:36.307256+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-15T14:05:00+00:00 EmrCreateJobFlowOperator 2021-05-15T15:06:26.456576+00:00 2021-05-15T15:06:28.114759+00:00 0:00:01.658183 28396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T15:06:24.293084+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T15:06:16.388459+00:00 2021-05-15T15:06:18.107440+00:00 0:00:01.718981 28395 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T15:06:14.280770+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-15T14:05:00+00:00 PythonOperator 2021-05-15T15:06:04.943365+00:00 2021-05-15T15:06:08.033696+00:00 0:00:03.090331 28394 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T15:06:02.271204+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T14:00:00+00:00 PythonOperator 2021-05-15T15:05:56.794366+00:00 2021-05-15T15:05:59.957505+00:00 0:00:03.163139 28393 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T15:05:54.321457+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-15T13:00:00+00:00 EmrJobFlowSensor 2021-05-15T14:11:31.145163+00:00 2021-05-15T14:21:33.832075+00:00 0:10:02.686912 28391 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T14:11:28.741210+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-15T13:00:00+00:00 EmrJobFlowSensor 2021-05-15T14:11:16.726203+00:00 2021-05-15T14:21:19.554360+00:00 0:10:02.828157 28390 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T14:11:14.551992+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-15T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T14:11:02.749521+00:00 2021-05-15T14:11:04.492970+00:00 0:00:01.743449 28389 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T14:11:00.539242+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-15T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T14:10:48.815565+00:00 2021-05-15T14:10:50.489303+00:00 0:00:01.673738 28388 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T14:10:46.525374+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-15T13:00:00+00:00 PythonOperator 2021-05-15T14:10:38.693144+00:00 2021-05-15T14:10:41.803568+00:00 0:00:03.110424 28387 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T14:10:36.517412+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-15T13:00:00+00:00 PythonOperator 2021-05-15T14:10:26.709393+00:00 2021-05-15T14:10:30.105643+00:00 0:00:03.396250 28386 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T14:10:24.506870+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T13:00:00+00:00 TriggerDagRunOperator 2021-05-15T14:10:17.114958+00:00 2021-05-15T14:10:17.653255+00:00 0:00:00.538297 28385 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T14:10:14.572621+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-15T13:00:00+00:00 TriggerDagRunOperator 2021-05-15T14:10:16.993356+00:00 2021-05-15T14:10:17.431497+00:00 0:00:00.438141 28384 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T14:10:14.572564+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-15T13:05:00+00:00 EmrJobFlowSensor 2021-05-15T14:05:58.357262+00:00 2021-05-15T14:15:00.991709+00:00 0:09:02.634447 28383 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T14:05:55.991597+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-15T13:05:00+00:00 EmrCreateJobFlowOperator 2021-05-15T14:05:38.404161+00:00 2021-05-15T14:05:40.126118+00:00 0:00:01.721957 28382 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T14:05:35.973670+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-15T13:05:00+00:00 PythonOperator 2021-05-15T14:05:16.078495+00:00 2021-05-15T14:05:19.217896+00:00 0:00:03.139401 28381 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T14:05:13.961195+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-15T13:00:00+00:00 EmrJobFlowSensor 2021-05-15T14:00:49.935162+00:00 2021-05-15T14:09:52.740108+00:00 0:09:02.804946 28380 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T14:00:47.600093+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-15T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T14:00:27.753108+00:00 2021-05-15T14:00:29.459550+00:00 0:00:01.706442 28379 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-15T14:00:25.580331+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-15T13:00:00+00:00 PythonOperator 2021-05-15T14:00:08.417805+00:00 2021-05-15T14:00:11.562661+00:00 0:00:03.144856 28378 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-15T14:00:05.547106+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-15T12:00:00+00:00 EmrJobFlowSensor 2021-05-15T13:11:28.095127+00:00 2021-05-15T13:19:30.701682+00:00 0:08:02.606555 28376 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T13:11:25.825887+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-15T12:00:00+00:00 EmrJobFlowSensor 2021-05-15T13:11:24.017187+00:00 2021-05-15T13:21:26.894661+00:00 0:10:02.877474 28375 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T13:11:21.822289+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-15T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T13:11:07.989277+00:00 2021-05-15T13:11:09.693158+00:00 0:00:01.703881 28374 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T13:11:05.808506+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-15T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-15T13:11:04.192764+00:00 2021-05-15T13:11:05.967931+00:00 0:00:01.775167 28373 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-15T13:11:01.810598+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-15T12:00:00+00:00 PythonOperator 2021-05-15T13:10:46.419448+00:00 2021-05-15T13:10:49.525528+00:00 0:00:03.106080 28372 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T13:10:43.860169+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-15T12:00:00+00:00 PythonOperator 2021-05-15T13:10:40.954893+00:00 2021-05-15T13:10:44.638732+00:00 0:00:03.683839 28371 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-15T13:10:37.852842+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-15T12:00:00+00:00 TriggerDagRunOperator 2021-05-15T13:10:32.447535+00:00 2021-05-15T13:10:32.953460+00:00 0:00:00.505925 28370 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-15T13:10:29.864142+00:00 2 default_pool