Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T14:00:30.909070+00:00 2021-03-22T14:00:32.594054+00:00 0:00:01.684984 10552 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T14:00:28.373202+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T13:00:00+00:00 PythonOperator 2021-03-22T14:00:08.583858+00:00 2021-03-22T14:00:11.455505+00:00 0:00:02.871647 10551 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T14:00:06.246899+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-22T12:00:00+00:00 EmrJobFlowSensor 2021-03-22T13:13:04.855332+00:00 2021-03-22T13:17:06.775025+00:00 0:04:01.919693 10549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T13:13:02.684831+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T12:00:00+00:00 EmrJobFlowSensor 2021-03-22T13:12:40.913069+00:00 2021-03-22T13:22:43.653991+00:00 0:10:02.740922 10548 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T13:12:38.650680+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-22T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T13:12:38.919465+00:00 2021-03-22T13:12:40.596594+00:00 0:00:01.677129 10547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T13:12:36.674618+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T13:12:21.341782+00:00 2021-03-22T13:12:23.325037+00:00 0:00:01.983255 10546 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T13:12:18.603432+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T12:00:00+00:00 PythonOperator 2021-03-22T13:12:19.091316+00:00 2021-03-22T13:12:22.492122+00:00 0:00:03.400806 10545 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:12:16.658302+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T12:00:00+00:00 PythonOperator 2021-03-22T13:11:59.352287+00:00 2021-03-22T13:12:02.168841+00:00 0:00:02.816554 10544 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:11:56.556573+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T10:00:00+00:00 PythonOperator 2021-03-22T13:11:56.963158+00:00 2021-03-22T13:12:00.368337+00:00 0:00:03.405179 10543 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:11:54.557232+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T08:00:00+00:00 PythonOperator 2021-03-22T13:11:56.807648+00:00 2021-03-22T13:11:59.741363+00:00 0:00:02.933715 10542 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:11:54.557265+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T12:00:00+00:00 TriggerDagRunOperator 2021-03-22T13:11:41.090361+00:00 2021-03-22T13:11:41.622775+00:00 0:00:00.532414 10541 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T13:11:38.552556+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T12:00:00+00:00 TriggerDagRunOperator 2021-03-22T13:11:40.964678+00:00 2021-03-22T13:11:41.388581+00:00 0:00:00.423903 10540 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T13:11:38.552513+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-22T07:00:00+00:00 PythonOperator 2021-03-22T13:11:35.080222+00:00 2021-03-22T13:11:38.159433+00:00 0:00:03.079211 10539 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:11:32.558758+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-21T12:00:00+00:00 PythonOperator 2021-03-22T13:09:12.437694+00:00 2021-03-22T13:09:15.461129+00:00 0:00:03.023435 10536 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:09:10.239849+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-21T06:00:00+00:00 PythonOperator 2021-03-22T13:08:26.645012+00:00 2021-03-22T13:08:29.660354+00:00 0:00:03.015342 10535 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:08:24.289948+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-21T05:00:00+00:00 PythonOperator 2021-03-22T13:08:02.635350+00:00 2021-03-22T13:08:05.661233+00:00 0:00:03.025883 10534 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:08:00.245748+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-20T17:00:00+00:00 PythonOperator 2021-03-22T13:06:30.739012+00:00 2021-03-22T13:06:33.670342+00:00 0:00:02.931330 10531 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:06:28.144570+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-20T14:00:00+00:00 PythonOperator 2021-03-22T13:06:08.220183+00:00 2021-03-22T13:06:11.240658+00:00 0:00:03.020475 10530 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:06:05.932680+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-22T12:05:00+00:00 EmrJobFlowSensor 2021-03-22T13:05:48.701852+00:00 2021-03-22T13:14:51.161535+00:00 0:09:02.459683 10529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T13:05:45.921263+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-20T12:00:00+00:00 PythonOperator 2021-03-22T13:05:46.319378+00:00 2021-03-22T13:05:50.251940+00:00 0:00:03.932562 10528 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:05:43.915453+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-22T12:05:00+00:00 EmrCreateJobFlowOperator 2021-03-22T13:05:26.263678+00:00 2021-03-22T13:05:27.916238+00:00 0:00:01.652560 10527 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T13:05:23.969483+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-22T12:05:00+00:00 PythonOperator 2021-03-22T13:05:04.149722+00:00 2021-03-22T13:05:06.932288+00:00 0:00:02.782566 10526 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:05:01.888856+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-20T05:00:00+00:00 PythonOperator 2021-03-22T13:05:00.177887+00:00 2021-03-22T13:05:03.165314+00:00 0:00:02.987427 10525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:04:57.863445+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-20T03:00:00+00:00 PythonOperator 2021-03-22T13:04:38.244082+00:00 2021-03-22T13:04:41.173442+00:00 0:00:02.929360 10524 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:04:35.814719+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-20T02:00:00+00:00 PythonOperator 2021-03-22T13:04:09.976613+00:00 2021-03-22T13:04:12.948114+00:00 0:00:02.971501 10523 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:04:07.795140+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-19T17:00:00+00:00 PythonOperator 2021-03-22T13:01:39.890579+00:00 2021-03-22T13:01:42.910335+00:00 0:00:03.019756 10522 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:01:37.593507+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-19T16:00:00+00:00 EmrJobFlowSensor 2021-03-22T13:01:39.880597+00:00 2021-03-22T13:31:45.303826+00:00 0:30:05.423229 10521 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T13:01:37.593538+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-19T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T13:01:17.769042+00:00 2021-03-22T13:01:19.597604+00:00 0:00:01.828562 10520 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T13:01:15.528205+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T12:00:00+00:00 EmrJobFlowSensor 2021-03-22T13:01:13.877979+00:00 2021-03-22T13:11:16.731482+00:00 0:10:02.853503 10519 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:01:11.578717+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-19T16:00:00+00:00 PythonOperator 2021-03-22T13:00:53.948469+00:00 2021-03-22T13:00:57.050649+00:00 0:00:03.102180 10518 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T13:00:51.505287+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T13:00:53.761350+00:00 2021-03-22T13:00:55.716424+00:00 0:00:01.955074 10517 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T13:00:51.505315+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T12:00:00+00:00 PythonOperator 2021-03-22T13:00:32.188613+00:00 2021-03-22T13:00:35.046414+00:00 0:00:02.857801 10516 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T13:00:29.559785+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-22T11:05:00+00:00 EmrJobFlowSensor 2021-03-22T12:18:30.676142+00:00 2021-03-22T12:27:33.360394+00:00 0:09:02.684252 10514 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T12:18:28.258063+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-22T11:05:00+00:00 EmrCreateJobFlowOperator 2021-03-22T12:18:00.434649+00:00 2021-03-22T12:18:02.182756+00:00 0:00:01.748107 10513 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T12:17:58.174638+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-22T11:05:00+00:00 PythonOperator 2021-03-22T12:17:38.481658+00:00 2021-03-22T12:17:41.184259+00:00 0:00:02.702601 10512 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T12:17:36.165712+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T11:00:00+00:00 EmrJobFlowSensor 2021-03-22T12:12:08.109408+00:00 2021-03-22T12:21:10.911786+00:00 0:09:02.802378 10511 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T12:12:05.621417+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T12:11:33.777918+00:00 2021-03-22T12:11:35.500450+00:00 0:00:01.722532 10510 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T12:11:31.588624+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T11:00:00+00:00 PythonOperator 2021-03-22T12:11:11.741361+00:00 2021-03-22T12:11:14.531840+00:00 0:00:02.790479 10509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T12:11:09.549654+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T11:00:00+00:00 TriggerDagRunOperator 2021-03-22T12:11:06.114711+00:00 2021-03-22T12:11:06.621258+00:00 0:00:00.506547 10508 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T12:11:03.560865+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T11:00:00+00:00 TriggerDagRunOperator 2021-03-22T12:11:05.867996+00:00 2021-03-22T12:11:06.256655+00:00 0:00:00.388659 10507 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T12:11:03.560829+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T11:00:00+00:00 EmrJobFlowSensor 2021-03-22T12:00:53.021475+00:00 2021-03-22T12:10:55.926430+00:00 0:10:02.904955 10506 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T12:00:50.651694+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T12:00:31.205093+00:00 2021-03-22T12:00:32.918650+00:00 0:00:01.713557 10505 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T12:00:28.843212+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T11:00:00+00:00 PythonOperator 2021-03-22T12:00:09.008214+00:00 2021-03-22T12:00:11.757483+00:00 0:00:02.749269 10504 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T12:00:06.603122+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T10:00:00+00:00 EmrJobFlowSensor 2021-03-22T11:10:51.215432+00:00 2021-03-22T11:19:53.769931+00:00 0:09:02.554499 10502 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T11:10:48.996914+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T11:10:29.161229+00:00 2021-03-22T11:10:30.963712+00:00 0:00:01.802483 10501 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T11:10:26.959410+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T10:00:00+00:00 PythonOperator 2021-03-22T11:10:07.204140+00:00 2021-03-22T11:10:09.928655+00:00 0:00:02.724515 10500 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T11:10:04.917392+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T10:00:00+00:00 TriggerDagRunOperator 2021-03-22T11:09:57.248241+00:00 2021-03-22T11:09:57.662552+00:00 0:00:00.414311 10499 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T11:09:54.916021+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T10:00:00+00:00 TriggerDagRunOperator 2021-03-22T11:09:57.195953+00:00 2021-03-22T11:09:57.753350+00:00 0:00:00.557397 10498 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T11:09:54.915979+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T10:00:00+00:00 EmrJobFlowSensor 2021-03-22T11:00:48.478256+00:00 2021-03-22T11:09:51.248483+00:00 0:09:02.770227 10497 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T11:00:46.119802+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T11:00:26.665293+00:00 2021-03-22T11:00:28.499333+00:00 0:00:01.834040 10496 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T11:00:24.158024+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T10:00:00+00:00 PythonOperator 2021-03-22T11:00:06.589460+00:00 2021-03-22T11:00:09.484445+00:00 0:00:02.894985 10495 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T11:00:04.086721+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T09:00:00+00:00 EmrJobFlowSensor 2021-03-22T10:11:12.663633+00:00 2021-03-22T10:20:15.369209+00:00 0:09:02.705576 10493 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T10:11:10.239426+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T10:10:56.285973+00:00 2021-03-22T10:10:57.965790+00:00 0:00:01.679817 10492 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T10:10:54.165399+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T09:00:00+00:00 PythonOperator 2021-03-22T10:10:40.351395+00:00 2021-03-22T10:10:43.201457+00:00 0:00:02.850062 10491 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T10:10:38.098612+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T09:00:00+00:00 TriggerDagRunOperator 2021-03-22T10:10:23.023256+00:00 2021-03-22T10:10:23.742718+00:00 0:00:00.719462 10490 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T10:10:20.136821+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T09:00:00+00:00 TriggerDagRunOperator 2021-03-22T10:10:22.634182+00:00 2021-03-22T10:10:23.054005+00:00 0:00:00.419823 10489 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T10:10:20.136775+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T09:00:00+00:00 EmrJobFlowSensor 2021-03-22T10:02:07.693694+00:00 2021-03-22T10:10:10.362649+00:00 0:08:02.668955 10488 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T10:02:05.228152+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T10:01:51.216974+00:00 2021-03-22T10:01:52.920962+00:00 0:00:01.703988 10487 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T10:01:49.081192+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T09:00:00+00:00 PythonOperator 2021-03-22T10:01:35.339091+00:00 2021-03-22T10:01:38.068946+00:00 0:00:02.729855 10486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T10:01:33.066750+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T08:00:00+00:00 EmrJobFlowSensor 2021-03-22T09:12:02.206387+00:00 2021-03-22T09:22:05.088209+00:00 0:10:02.881822 10484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T09:12:00.096348+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T09:11:46.280399+00:00 2021-03-22T09:11:47.945314+00:00 0:00:01.664915 10483 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T09:11:44.074928+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T08:00:00+00:00 PythonOperator 2021-03-22T09:11:30.598080+00:00 2021-03-22T09:11:33.344800+00:00 0:00:02.746720 10482 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T09:11:28.130009+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T08:00:00+00:00 TriggerDagRunOperator 2021-03-22T09:11:24.548409+00:00 2021-03-22T09:11:25.087441+00:00 0:00:00.539032 10481 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T09:11:22.056509+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T08:00:00+00:00 TriggerDagRunOperator 2021-03-22T09:11:24.294048+00:00 2021-03-22T09:11:24.721398+00:00 0:00:00.427350 10480 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T09:11:22.056480+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T08:00:00+00:00 EmrJobFlowSensor 2021-03-22T09:00:41.074570+00:00 2021-03-22T09:10:43.890607+00:00 0:10:02.816037 10479 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T09:00:38.918484+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T09:00:21.333999+00:00 2021-03-22T09:00:23.037133+00:00 0:00:01.703134 10478 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T09:00:18.947776+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T08:00:00+00:00 PythonOperator 2021-03-22T09:00:05.694429+00:00 2021-03-22T09:00:08.646505+00:00 0:00:02.952076 10477 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T09:00:03.015301+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T07:00:00+00:00 EmrJobFlowSensor 2021-03-22T08:11:03.887853+00:00 2021-03-22T08:21:06.808352+00:00 0:10:02.920499 10475 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T08:11:01.528316+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T08:10:47.642886+00:00 2021-03-22T08:10:49.316692+00:00 0:00:01.673806 10474 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T08:10:45.482419+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T07:00:00+00:00 PythonOperator 2021-03-22T08:10:31.920356+00:00 2021-03-22T08:10:34.809116+00:00 0:00:02.888760 10473 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T08:10:29.518270+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T07:00:00+00:00 TriggerDagRunOperator 2021-03-22T08:10:13.767230+00:00 2021-03-22T08:10:14.292710+00:00 0:00:00.525480 10472 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T08:10:11.401064+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T07:00:00+00:00 TriggerDagRunOperator 2021-03-22T08:10:13.765158+00:00 2021-03-22T08:10:14.292674+00:00 0:00:00.527516 10471 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T08:10:11.401033+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T07:00:00+00:00 EmrJobFlowSensor 2021-03-22T08:00:50.708480+00:00 2021-03-22T08:09:53.390147+00:00 0:09:02.681667 10470 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T08:00:48.459921+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T08:00:34.826340+00:00 2021-03-22T08:00:36.668320+00:00 0:00:01.841980 10469 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T08:00:32.409451+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T07:00:00+00:00 PythonOperator 2021-03-22T08:00:18.928446+00:00 2021-03-22T08:00:21.822829+00:00 0:00:02.894383 10468 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T08:00:16.394198+00:00 2 default_pool
success Custom-EMR-cluster_v001 create_cluster_n_add_steps 2021-03-22T07:19:14.382187+00:00 PythonOperator 2021-03-22T07:19:27.445222+00:00 2021-03-22T07:19:30.222057+00:00 0:00:02.776835 10466 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T07:19:25.285542+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T06:00:00+00:00 EmrJobFlowSensor 2021-03-22T07:12:10.737165+00:00 2021-03-22T07:22:13.709167+00:00 0:10:02.972002 10465 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T07:12:08.460136+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T07:11:48.866579+00:00 2021-03-22T07:11:50.679532+00:00 0:00:01.812953 10464 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T07:11:46.434352+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T06:00:00+00:00 PythonOperator 2021-03-22T07:11:30.814367+00:00 2021-03-22T07:11:33.686783+00:00 0:00:02.872416 10463 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T07:11:28.427106+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T06:00:00+00:00 TriggerDagRunOperator 2021-03-22T07:11:13.085468+00:00 2021-03-22T07:11:13.531429+00:00 0:00:00.445961 10462 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T07:11:10.439361+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T06:00:00+00:00 TriggerDagRunOperator 2021-03-22T07:11:12.812743+00:00 2021-03-22T07:11:13.353511+00:00 0:00:00.540768 10461 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T07:11:10.439323+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T06:00:00+00:00 EmrJobFlowSensor 2021-03-22T07:00:57.611998+00:00 2021-03-22T07:11:00.380876+00:00 0:10:02.768878 10460 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T07:00:55.320602+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T07:00:41.543668+00:00 2021-03-22T07:00:43.229118+00:00 0:00:01.685450 10459 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T07:00:39.259481+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T06:00:00+00:00 PythonOperator 2021-03-22T07:00:25.609097+00:00 2021-03-22T07:00:28.324927+00:00 0:00:02.715830 10458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T07:00:23.222929+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T05:00:00+00:00 EmrJobFlowSensor 2021-03-22T06:11:44.388661+00:00 2021-03-22T06:20:46.916183+00:00 0:09:02.527522 10456 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T06:11:41.985127+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T06:11:28.519245+00:00 2021-03-22T06:11:30.251915+00:00 0:00:01.732670 10455 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T06:11:26.036377+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T05:00:00+00:00 PythonOperator 2021-03-22T06:11:12.449896+00:00 2021-03-22T06:11:15.309522+00:00 0:00:02.859626 10454 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T06:11:10.028052+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T05:00:00+00:00 TriggerDagRunOperator 2021-03-22T06:10:58.266815+00:00 2021-03-22T06:10:58.806556+00:00 0:00:00.539741 10453 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T06:10:55.889396+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T05:00:00+00:00 TriggerDagRunOperator 2021-03-22T06:10:58.070590+00:00 2021-03-22T06:10:58.463842+00:00 0:00:00.393252 10452 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T06:10:55.889426+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T05:00:00+00:00 EmrJobFlowSensor 2021-03-22T06:00:36.886841+00:00 2021-03-22T06:10:39.654447+00:00 0:10:02.767606 10451 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T06:00:34.783054+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T06:00:21.302710+00:00 2021-03-22T06:00:23.020600+00:00 0:00:01.717890 10450 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T06:00:18.843940+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T05:00:00+00:00 PythonOperator 2021-03-22T06:00:05.712930+00:00 2021-03-22T06:00:08.595848+00:00 0:00:02.882918 10449 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T06:00:02.763115+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-22T04:00:00+00:00 EmrJobFlowSensor 2021-03-22T05:11:34.962588+00:00 2021-03-22T05:21:37.889159+00:00 0:10:02.926571 10447 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T05:11:32.496631+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-22T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T05:11:18.908453+00:00 2021-03-22T05:11:20.710269+00:00 0:00:01.801816 10446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-22T05:11:16.540356+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-22T04:00:00+00:00 PythonOperator 2021-03-22T05:11:02.734530+00:00 2021-03-22T05:11:05.443490+00:00 0:00:02.708960 10445 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T05:11:00.473210+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-22T04:00:00+00:00 TriggerDagRunOperator 2021-03-22T05:10:46.775644+00:00 2021-03-22T05:10:47.312784+00:00 0:00:00.537140 10444 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T05:10:44.433280+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-22T04:00:00+00:00 TriggerDagRunOperator 2021-03-22T05:10:46.698023+00:00 2021-03-22T05:10:47.093819+00:00 0:00:00.395796 10443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-22T05:10:44.433237+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-22T04:00:00+00:00 EmrJobFlowSensor 2021-03-22T05:00:35.881863+00:00 2021-03-22T05:10:38.594377+00:00 0:10:02.712514 10442 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-22T05:00:33.532412+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-22T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-22T05:00:19.986352+00:00 2021-03-22T05:00:21.891215+00:00 0:00:01.904863 10441 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-22T05:00:17.429801+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-22T04:00:00+00:00 PythonOperator 2021-03-22T05:00:03.812537+00:00 2021-03-22T05:00:06.667898+00:00 0:00:02.855361 10440 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-22T05:00:01.386840+00:00 2 default_pool