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 vc-asset-import_v002 create_emr_steps 2021-03-25T07:05:00+00:00 PythonOperator 2021-03-25T08:05:22.807324+00:00 2021-03-25T08:05:25.515071+00:00 0:00:02.707747 11523 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T08:05:20.702633+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T07:00:00+00:00 EmrJobFlowSensor 2021-03-25T08:00:48.391874+00:00 2021-03-25T08:10:51.173511+00:00 0:10:02.781637 11522 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T08:00:46.303901+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T08:00:26.590399+00:00 2021-03-25T08:00:28.290160+00:00 0:00:01.699761 11521 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T08:00:24.369692+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T07:00:00+00:00 PythonOperator 2021-03-25T08:00:04.697355+00:00 2021-03-25T08:00:07.565744+00:00 0:00:02.868389 11520 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T08:00:02.211415+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T06:00:00+00:00 EmrJobFlowSensor 2021-03-25T07:11:14.501270+00:00 2021-03-25T07:20:17.062985+00:00 0:09:02.561715 11518 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T07:11:12.151094+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T07:10:54.523383+00:00 2021-03-25T07:10:56.302806+00:00 0:00:01.779423 11517 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T07:10:52.059133+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T06:00:00+00:00 PythonOperator 2021-03-25T07:10:32.630217+00:00 2021-03-25T07:10:35.628065+00:00 0:00:02.997848 11516 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T07:10:29.988206+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T06:00:00+00:00 TriggerDagRunOperator 2021-03-25T07:10:28.315264+00:00 2021-03-25T07:10:28.721426+00:00 0:00:00.406162 11515 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T07:10:25.971520+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T06:00:00+00:00 TriggerDagRunOperator 2021-03-25T07:10:28.299031+00:00 2021-03-25T07:10:28.865202+00:00 0:00:00.566171 11514 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T07:10:25.971476+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T06:05:00+00:00 EmrJobFlowSensor 2021-03-25T07:06:03.651232+00:00 2021-03-25T07:14:06.202644+00:00 0:08:02.551412 11513 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T07:06:01.463372+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T06:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T07:05:37.649666+00:00 2021-03-25T07:05:39.326177+00:00 0:00:01.676511 11512 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T07:05:35.504522+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T06:05:00+00:00 PythonOperator 2021-03-25T07:05:15.965930+00:00 2021-03-25T07:05:18.796267+00:00 0:00:02.830337 11511 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T07:05:13.475893+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T06:00:00+00:00 EmrJobFlowSensor 2021-03-25T07:01:07.266548+00:00 2021-03-25T07:10:09.910960+00:00 0:09:02.644412 11510 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T07:01:05.057749+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T07:00:43.203514+00:00 2021-03-25T07:00:44.902252+00:00 0:00:01.698738 11509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T07:00:41.011230+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T06:00:00+00:00 PythonOperator 2021-03-25T07:00:23.789360+00:00 2021-03-25T07:00:26.619095+00:00 0:00:02.829735 11508 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T07:00:21.051669+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T05:00:00+00:00 EmrJobFlowSensor 2021-03-25T06:11:54.798185+00:00 2021-03-25T06:21:57.623682+00:00 0:10:02.825497 11506 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T06:11:52.658316+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T06:11:32.824902+00:00 2021-03-25T06:11:34.502976+00:00 0:00:01.678074 11505 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T06:11:30.616268+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T05:00:00+00:00 PythonOperator 2021-03-25T06:11:11.129473+00:00 2021-03-25T06:11:14.118093+00:00 0:00:02.988620 11504 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T06:11:08.595156+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T05:00:00+00:00 TriggerDagRunOperator 2021-03-25T06:10:58.980321+00:00 2021-03-25T06:10:59.379400+00:00 0:00:00.399079 11503 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T06:10:56.535924+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T05:00:00+00:00 TriggerDagRunOperator 2021-03-25T06:10:58.878341+00:00 2021-03-25T06:10:59.407856+00:00 0:00:00.529515 11502 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T06:10:56.535898+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T05:05:00+00:00 EmrJobFlowSensor 2021-03-25T06:06:04.389812+00:00 2021-03-25T06:15:06.827965+00:00 0:09:02.438153 11501 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T06:06:02.156161+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T05:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T06:05:42.481443+00:00 2021-03-25T06:05:44.134261+00:00 0:00:01.652818 11500 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T06:05:40.156754+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T05:05:00+00:00 PythonOperator 2021-03-25T06:05:22.280611+00:00 2021-03-25T06:05:24.976121+00:00 0:00:02.695510 11499 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T06:05:20.033007+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T05:00:00+00:00 EmrJobFlowSensor 2021-03-25T06:00:49.690906+00:00 2021-03-25T06:10:52.515239+00:00 0:10:02.824333 11498 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T06:00:47.543477+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T06:00:27.781007+00:00 2021-03-25T06:00:29.543501+00:00 0:00:01.762494 11497 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T06:00:25.521366+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T05:00:00+00:00 PythonOperator 2021-03-25T06:00:06.316329+00:00 2021-03-25T06:00:09.151424+00:00 0:00:02.835095 11496 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T06:00:03.552239+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T04:00:00+00:00 EmrJobFlowSensor 2021-03-25T05:10:09.221696+00:00 2021-03-25T05:20:11.923056+00:00 0:10:02.701360 11494 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T05:10:06.949059+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T05:09:47.161739+00:00 2021-03-25T05:09:48.978519+00:00 0:00:01.816780 11493 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T05:09:44.772702+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T04:00:00+00:00 PythonOperator 2021-03-25T05:09:26.989926+00:00 2021-03-25T05:09:29.982812+00:00 0:00:02.992886 11492 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T05:09:24.706332+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T04:00:00+00:00 TriggerDagRunOperator 2021-03-25T05:09:19.030114+00:00 2021-03-25T05:09:19.731775+00:00 0:00:00.701661 11491 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T05:09:16.697921+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T04:00:00+00:00 TriggerDagRunOperator 2021-03-25T05:09:18.956392+00:00 2021-03-25T05:09:19.348917+00:00 0:00:00.392525 11490 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T05:09:16.697952+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T04:05:00+00:00 EmrJobFlowSensor 2021-03-25T05:05:54.784296+00:00 2021-03-25T05:13:57.253715+00:00 0:08:02.469419 11489 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T05:05:52.368756+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T04:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T05:05:32.452821+00:00 2021-03-25T05:05:34.105851+00:00 0:00:01.653030 11488 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T05:05:30.303933+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T04:05:00+00:00 PythonOperator 2021-03-25T05:05:12.353888+00:00 2021-03-25T05:05:15.099611+00:00 0:00:02.745723 11487 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T05:05:10.287543+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T04:00:00+00:00 EmrJobFlowSensor 2021-03-25T05:01:06.355083+00:00 2021-03-25T05:09:08.980833+00:00 0:08:02.625750 11486 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T05:01:03.882275+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T05:00:38.071051+00:00 2021-03-25T05:00:39.842927+00:00 0:00:01.771876 11485 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T05:00:35.810540+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T04:00:00+00:00 PythonOperator 2021-03-25T05:00:12.424847+00:00 2021-03-25T05:00:15.326644+00:00 0:00:02.901797 11484 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T05:00:09.792237+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T03:00:00+00:00 EmrJobFlowSensor 2021-03-25T04:11:20.724463+00:00 2021-03-25T04:21:23.603684+00:00 0:10:02.879221 11482 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T04:11:18.531406+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T03:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T04:10:58.814462+00:00 2021-03-25T04:11:00.745910+00:00 0:00:01.931448 11481 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T04:10:56.517118+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-25T03:00:00+00:00 PythonOperator 2021-03-25T04:10:48.843812+00:00 2021-03-25T04:10:51.526583+00:00 0:00:02.682771 11480 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T04:10:46.505404+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T03:00:00+00:00 PythonOperator 2021-03-25T04:10:37.088033+00:00 2021-03-25T04:10:40.177332+00:00 0:00:03.089299 11479 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T04:10:34.505238+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T03:00:00+00:00 TriggerDagRunOperator 2021-03-25T04:10:25.145689+00:00 2021-03-25T04:10:25.692154+00:00 0:00:00.546465 11478 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T04:10:22.643631+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T03:00:00+00:00 TriggerDagRunOperator 2021-03-25T04:10:25.105723+00:00 2021-03-25T04:10:25.515221+00:00 0:00:00.409498 11477 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T04:10:22.643581+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T03:05:00+00:00 EmrJobFlowSensor 2021-03-25T04:06:02.483005+00:00 2021-03-25T04:15:05.118889+00:00 0:09:02.635884 11476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T04:06:00.075281+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T03:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T04:05:40.480083+00:00 2021-03-25T04:05:42.142536+00:00 0:00:01.662453 11475 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T04:05:38.047255+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T03:05:00+00:00 PythonOperator 2021-03-25T04:05:20.166043+00:00 2021-03-25T04:05:22.953981+00:00 0:00:02.787938 11474 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T04:05:17.925228+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T03:00:00+00:00 EmrJobFlowSensor 2021-03-25T04:01:07.678813+00:00 2021-03-25T04:10:10.299552+00:00 0:09:02.620739 11473 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T04:01:05.560782+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T03:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T04:00:45.743174+00:00 2021-03-25T04:00:47.429953+00:00 0:00:01.686779 11472 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T04:00:43.516846+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T03:00:00+00:00 PythonOperator 2021-03-25T04:00:24.350961+00:00 2021-03-25T04:00:27.239606+00:00 0:00:02.888645 11471 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T04:00:21.558176+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T02:00:00+00:00 EmrJobFlowSensor 2021-03-25T03:11:22.692413+00:00 2021-03-25T03:20:25.377094+00:00 0:09:02.684681 11469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T03:11:20.500620+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-25T02:00:00+00:00 EmrJobFlowSensor 2021-03-25T03:11:19.393994+00:00 2021-03-25T03:23:05.454721+00:00 0:11:46.060727 11468 airflow 1 default 2021-03-25T03:11:16.492073+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T02:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T03:11:00.792608+00:00 2021-03-25T03:11:02.564194+00:00 0:00:01.771586 11467 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T03:10:58.470782+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-25T02:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T03:10:56.622107+00:00 2021-03-25T03:10:58.360591+00:00 0:00:01.738484 11466 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T03:10:54.444453+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T02:00:00+00:00 PythonOperator 2021-03-25T03:10:38.675397+00:00 2021-03-25T03:10:41.633164+00:00 0:00:02.957767 11465 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T03:10:36.469075+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-25T02:00:00+00:00 PythonOperator 2021-03-25T03:10:34.813373+00:00 2021-03-25T03:10:37.618531+00:00 0:00:02.805158 11464 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T03:10:32.487152+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T02:00:00+00:00 TriggerDagRunOperator 2021-03-25T03:10:31.215400+00:00 2021-03-25T03:10:31.678271+00:00 0:00:00.462871 11463 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T03:10:28.465601+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T02:00:00+00:00 TriggerDagRunOperator 2021-03-25T03:10:31.014112+00:00 2021-03-25T03:10:31.595816+00:00 0:00:00.581704 11462 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T03:10:28.465560+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T02:05:00+00:00 EmrJobFlowSensor 2021-03-25T03:05:56.115933+00:00 2021-03-25T03:14:58.611475+00:00 0:09:02.495542 11461 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T03:05:53.994742+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T02:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T03:05:36.183583+00:00 2021-03-25T03:05:37.850395+00:00 0:00:01.666812 11460 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T03:05:33.959224+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T02:05:00+00:00 PythonOperator 2021-03-25T03:05:10.152469+00:00 2021-03-25T03:05:12.930617+00:00 0:00:02.778148 11459 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T03:05:07.935840+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T02:00:00+00:00 EmrJobFlowSensor 2021-03-25T03:01:05.817797+00:00 2021-03-25T03:10:08.599206+00:00 0:09:02.781409 11458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T03:01:03.581062+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T02:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T03:00:43.810616+00:00 2021-03-25T03:00:45.613044+00:00 0:00:01.802428 11457 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T03:00:41.540298+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T02:00:00+00:00 PythonOperator 2021-03-25T03:00:22.112860+00:00 2021-03-25T03:00:24.989017+00:00 0:00:02.876157 11456 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T03:00:19.500908+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-25T01:00:00+00:00 EmrJobFlowSensor 2021-03-25T02:10:59.669103+00:00 2021-03-25T02:19:02.273785+00:00 0:08:02.604682 11454 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T02:10:57.362153+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T01:00:00+00:00 EmrJobFlowSensor 2021-03-25T02:10:55.499085+00:00 2021-03-25T02:20:58.195616+00:00 0:10:02.696531 11453 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T02:10:53.355514+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-25T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T02:10:39.614280+00:00 2021-03-25T02:10:41.309927+00:00 0:00:01.695647 11452 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T02:10:37.341009+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T02:10:35.510595+00:00 2021-03-25T02:10:37.183293+00:00 0:00:01.672698 11451 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T02:10:33.338197+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-25T01:00:00+00:00 PythonOperator 2021-03-25T02:10:17.858793+00:00 2021-03-25T02:10:20.550046+00:00 0:00:02.691253 11450 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T02:10:15.322207+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T01:00:00+00:00 PythonOperator 2021-03-25T02:10:13.920194+00:00 2021-03-25T02:10:17.193810+00:00 0:00:03.273616 11449 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T02:10:11.321770+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T01:00:00+00:00 TriggerDagRunOperator 2021-03-25T02:10:02.121297+00:00 2021-03-25T02:10:02.513363+00:00 0:00:00.392066 11448 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T02:09:59.265985+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T01:00:00+00:00 TriggerDagRunOperator 2021-03-25T02:10:01.807018+00:00 2021-03-25T02:10:02.313490+00:00 0:00:00.506472 11447 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T02:09:59.265942+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T01:05:00+00:00 EmrJobFlowSensor 2021-03-25T02:05:50.863293+00:00 2021-03-25T02:13:53.239552+00:00 0:08:02.376259 11446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T02:05:48.729016+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T01:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T02:05:28.981222+00:00 2021-03-25T02:05:30.712665+00:00 0:00:01.731443 11445 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T02:05:26.709547+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T01:05:00+00:00 PythonOperator 2021-03-25T02:05:06.863827+00:00 2021-03-25T02:05:09.565183+00:00 0:00:02.701356 11444 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T02:05:04.684718+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T01:00:00+00:00 EmrJobFlowSensor 2021-03-25T02:00:48.344804+00:00 2021-03-25T02:09:50.950398+00:00 0:09:02.605594 11443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T02:00:46.195329+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T02:00:24.349423+00:00 2021-03-25T02:00:26.073633+00:00 0:00:01.724210 11442 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T02:00:22.134720+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T01:00:00+00:00 PythonOperator 2021-03-25T02:00:04.604306+00:00 2021-03-25T02:00:07.316375+00:00 0:00:02.712069 11441 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T02:00:02.117430+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-25T00:00:00+00:00 EmrJobFlowSensor 2021-03-25T01:12:15.501029+00:00 2021-03-25T01:21:18.131476+00:00 0:09:02.630447 11439 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T01:12:13.093505+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-25T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T01:11:55.227345+00:00 2021-03-25T01:11:57.036456+00:00 0:00:01.809111 11438 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T01:11:53.001277+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-25T00:00:00+00:00 PythonOperator 2021-03-25T01:11:33.318774+00:00 2021-03-25T01:11:36.182283+00:00 0:00:02.863509 11437 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T01:11:31.055688+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T00:00:00+00:00 EmrJobFlowSensor 2021-03-25T01:11:21.121271+00:00 2021-03-25T01:21:23.828533+00:00 0:10:02.707262 11436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T01:11:18.930085+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T01:10:59.139003+00:00 2021-03-25T01:11:00.850074+00:00 0:00:01.711071 11435 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T01:10:56.909406+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T00:00:00+00:00 PythonOperator 2021-03-25T01:10:35.282597+00:00 2021-03-25T01:10:38.246150+00:00 0:00:02.963553 11434 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T01:10:32.895754+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T00:00:00+00:00 TriggerDagRunOperator 2021-03-25T01:10:15.386982+00:00 2021-03-25T01:10:15.816539+00:00 0:00:00.429557 11433 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T01:10:12.858935+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T00:00:00+00:00 TriggerDagRunOperator 2021-03-25T01:10:15.196956+00:00 2021-03-25T01:10:15.737481+00:00 0:00:00.540525 11432 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T01:10:12.858889+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T00:05:00+00:00 EmrJobFlowSensor 2021-03-25T01:05:52.723180+00:00 2021-03-25T01:13:55.158989+00:00 0:08:02.435809 11431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T01:05:50.351855+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T00:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T01:05:30.873381+00:00 2021-03-25T01:05:32.500186+00:00 0:00:01.626805 11430 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T01:05:28.448862+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T00:05:00+00:00 PythonOperator 2021-03-25T01:05:10.433457+00:00 2021-03-25T01:05:13.121448+00:00 0:00:02.687991 11429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T01:05:08.259957+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T00:00:00+00:00 EmrJobFlowSensor 2021-03-25T01:00:56.070907+00:00 2021-03-25T01:09:58.659716+00:00 0:09:02.588809 11428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T01:00:53.864703+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T01:00:34.303996+00:00 2021-03-25T01:00:36.162970+00:00 0:00:01.858974 11427 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T01:00:31.843131+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T00:00:00+00:00 PythonOperator 2021-03-25T01:00:12.163893+00:00 2021-03-25T01:00:14.988834+00:00 0:00:02.824941 11426 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T01:00:09.795295+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-24T23:00:00+00:00 EmrJobFlowSensor 2021-03-25T00:12:30.855116+00:00 2021-03-25T00:22:33.650803+00:00 0:10:02.795687 11424 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T00:12:28.058800+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-24T23:00:00+00:00 EmrJobFlowSensor 2021-03-25T00:12:30.697080+00:00 2021-03-25T00:21:33.241177+00:00 0:09:02.544097 11423 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T00:12:28.058753+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-24T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T00:12:10.491485+00:00 2021-03-25T00:12:12.274540+00:00 0:00:01.783055 11422 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T00:12:07.962179+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-24T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T00:12:10.408849+00:00 2021-03-25T00:12:12.343325+00:00 0:00:01.934476 11421 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T00:12:07.962150+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-24T23:00:00+00:00 PythonOperator 2021-03-25T00:11:48.146743+00:00 2021-03-25T00:11:50.945560+00:00 0:00:02.798817 11420 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T00:11:45.839605+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-24T23:00:00+00:00 PythonOperator 2021-03-25T00:11:48.117577+00:00 2021-03-25T00:11:51.276165+00:00 0:00:03.158588 11419 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T00:11:45.839567+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-24T23:00:00+00:00 TriggerDagRunOperator 2021-03-25T00:11:26.111795+00:00 2021-03-25T00:11:26.699599+00:00 0:00:00.587804 11418 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T00:11:23.824104+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-24T23:00:00+00:00 TriggerDagRunOperator 2021-03-25T00:11:26.085015+00:00 2021-03-25T00:11:26.486247+00:00 0:00:00.401232 11417 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T00:11:23.824071+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-24T23:05:00+00:00 EmrJobFlowSensor 2021-03-25T00:06:03.617646+00:00 2021-03-25T00:14:06.117881+00:00 0:08:02.500235 11416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T00:06:01.482263+00:00 2 default_pool