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-03-25T09:00:00+00:00 PythonOperator 2021-03-25T10:11:34.208313+00:00 2021-03-25T10:11:37.189018+00:00 0:00:02.980705 11552 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T10:11:31.993894+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T09:00:00+00:00 TriggerDagRunOperator 2021-03-25T10:11:16.247751+00:00 2021-03-25T10:11:16.667547+00:00 0:00:00.419796 11551 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T10:11:13.945140+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T09:00:00+00:00 TriggerDagRunOperator 2021-03-25T10:11:16.210494+00:00 2021-03-25T10:11:16.740736+00:00 0:00:00.530242 11550 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T10:11:13.945105+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T09:05:00+00:00 EmrJobFlowSensor 2021-03-25T10:05:57.695956+00:00 2021-03-25T10:15:00.290047+00:00 0:09:02.594091 11549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T10:05:55.503806+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T09:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T10:05:37.645200+00:00 2021-03-25T10:05:39.235434+00:00 0:00:01.590234 11548 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T10:05:35.435810+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T09:05:00+00:00 PythonOperator 2021-03-25T10:05:15.628017+00:00 2021-03-25T10:05:18.402718+00:00 0:00:02.774701 11547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T10:05:13.381891+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T09:00:00+00:00 EmrJobFlowSensor 2021-03-25T10:01:05.072783+00:00 2021-03-25T10:11:07.937862+00:00 0:10:02.865079 11546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T10:01:02.912807+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T10:00:43.130032+00:00 2021-03-25T10:00:44.955749+00:00 0:00:01.825717 11545 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T10:00:40.891037+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T09:00:00+00:00 PythonOperator 2021-03-25T10:00:21.502964+00:00 2021-03-25T10:00:24.233654+00:00 0:00:02.730690 11544 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T10:00:18.872932+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T08:00:00+00:00 EmrJobFlowSensor 2021-03-25T09:11:18.004302+00:00 2021-03-25T09:21:20.890605+00:00 0:10:02.886303 11542 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T09:11:15.791973+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T09:10:56.212813+00:00 2021-03-25T09:10:57.932868+00:00 0:00:01.720055 11541 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T09:10:53.859376+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T08:00:00+00:00 PythonOperator 2021-03-25T09:10:34.207141+00:00 2021-03-25T09:10:37.252826+00:00 0:00:03.045685 11540 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T09:10:31.741019+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T08:00:00+00:00 TriggerDagRunOperator 2021-03-25T09:10:08.177839+00:00 2021-03-25T09:10:08.673844+00:00 0:00:00.496005 11539 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T09:10:05.653010+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T08:00:00+00:00 TriggerDagRunOperator 2021-03-25T09:10:08.135616+00:00 2021-03-25T09:10:08.686148+00:00 0:00:00.550532 11538 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T09:10:05.653052+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T08:05:00+00:00 EmrJobFlowSensor 2021-03-25T09:05:55.459749+00:00 2021-03-25T09:13:57.864578+00:00 0:08:02.404829 11537 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T09:05:53.279889+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T08:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T09:05:33.570395+00:00 2021-03-25T09:05:35.212530+00:00 0:00:01.642135 11536 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T09:05:31.262284+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T08:05:00+00:00 PythonOperator 2021-03-25T09:05:11.365474+00:00 2021-03-25T09:05:14.071324+00:00 0:00:02.705850 11535 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T09:05:09.244976+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T08:00:00+00:00 EmrJobFlowSensor 2021-03-25T09:00:58.843655+00:00 2021-03-25T09:10:01.519494+00:00 0:09:02.675839 11534 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T09:00:56.631968+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T09:00:38.916993+00:00 2021-03-25T09:00:40.590359+00:00 0:00:01.673366 11533 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T09:00:36.611991+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T08:00:00+00:00 PythonOperator 2021-03-25T09:00:17.273525+00:00 2021-03-25T09:00:20.031495+00:00 0:00:02.757970 11532 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T09:00:14.662881+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T07:00:00+00:00 EmrJobFlowSensor 2021-03-25T08:11:57.595976+00:00 2021-03-25T08:23:00.486939+00:00 0:11:02.890963 11530 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T08:11:55.420996+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T08:11:35.780488+00:00 2021-03-25T08:11:37.503443+00:00 0:00:01.722955 11529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T08:11:33.469494+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T07:00:00+00:00 PythonOperator 2021-03-25T08:11:13.681135+00:00 2021-03-25T08:11:16.745198+00:00 0:00:03.064063 11528 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T08:11:11.384693+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T07:00:00+00:00 TriggerDagRunOperator 2021-03-25T08:10:57.673105+00:00 2021-03-25T08:10:58.067104+00:00 0:00:00.393999 11527 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T08:10:55.324353+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T07:00:00+00:00 TriggerDagRunOperator 2021-03-25T08:10:57.626414+00:00 2021-03-25T08:10:58.127822+00:00 0:00:00.501408 11526 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T08:10:55.324324+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T07:05:00+00:00 EmrJobFlowSensor 2021-03-25T08:06:04.963748+00:00 2021-03-25T08:14:07.384910+00:00 0:08:02.421162 11525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T08:06:02.775165+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T07:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T08:05:43.083748+00:00 2021-03-25T08:05:44.758121+00:00 0:00:01.674373 11524 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T08:05:40.718616+00:00 2 default_pool
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