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 check_cluster_status 2021-04-24T17:00:00+00:00 EmrJobFlowSensor 2021-04-24T18:11:19.415607+00:00 2021-04-24T18:21:22.235431+00:00 0:10:02.819824 20829 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T18:11:17.065110+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T18:11:05.504461+00:00 2021-04-24T18:11:07.275621+00:00 0:00:01.771160 20828 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T18:11:03.050714+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T18:10:59.391067+00:00 2021-04-24T18:11:01.082184+00:00 0:00:01.691117 20827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T18:10:57.040940+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T17:00:00+00:00 PythonOperator 2021-04-24T18:10:41.315261+00:00 2021-04-24T18:10:44.316211+00:00 0:00:03.000950 20826 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T18:10:38.988878+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T17:00:00+00:00 PythonOperator 2021-04-24T18:10:37.336910+00:00 2021-04-24T18:10:40.528767+00:00 0:00:03.191857 20825 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T18:10:34.998283+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T17:00:00+00:00 TriggerDagRunOperator 2021-04-24T18:10:17.380501+00:00 2021-04-24T18:10:17.946105+00:00 0:00:00.565604 20824 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T18:10:14.959674+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T17:00:00+00:00 TriggerDagRunOperator 2021-04-24T18:10:17.140781+00:00 2021-04-24T18:10:17.538638+00:00 0:00:00.397857 20823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T18:10:14.959724+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T17:05:00+00:00 EmrJobFlowSensor 2021-04-24T18:05:52.937503+00:00 2021-04-24T18:13:55.287646+00:00 0:08:02.350143 20822 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T18:05:50.576810+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T18:05:30.900562+00:00 2021-04-24T18:05:32.618847+00:00 0:00:01.718285 20821 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T18:05:28.569602+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T17:05:00+00:00 PythonOperator 2021-04-24T18:05:08.868104+00:00 2021-04-24T18:05:11.780982+00:00 0:00:02.912878 20820 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T18:05:06.554020+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T17:00:00+00:00 EmrJobFlowSensor 2021-04-24T18:01:04.917433+00:00 2021-04-24T18:10:07.782257+00:00 0:09:02.864824 20819 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T18:01:02.167161+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T18:00:42.229219+00:00 2021-04-24T18:00:43.884489+00:00 0:00:01.655270 20818 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T18:00:40.077959+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T17:00:00+00:00 PythonOperator 2021-04-24T18:00:22.317527+00:00 2021-04-24T18:00:25.317262+00:00 0:00:02.999735 20817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T18:00:20.060043+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T16:00:00+00:00 EmrJobFlowSensor 2021-04-24T17:11:29.158291+00:00 2021-04-24T17:20:31.819760+00:00 0:09:02.661469 20815 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T17:11:26.755799+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T16:00:00+00:00 EmrJobFlowSensor 2021-04-24T17:11:13.076412+00:00 2021-04-24T17:20:15.629142+00:00 0:09:02.552730 20814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T17:11:10.741604+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T17:11:09.060413+00:00 2021-04-24T17:11:10.832244+00:00 0:00:01.771831 20813 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T17:11:06.737033+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T17:10:52.895314+00:00 2021-04-24T17:10:54.650702+00:00 0:00:01.755388 20812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T17:10:50.722327+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T16:00:00+00:00 PythonOperator 2021-04-24T17:10:47.080304+00:00 2021-04-24T17:10:50.015338+00:00 0:00:02.935034 20811 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T17:10:44.715979+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T16:00:00+00:00 PythonOperator 2021-04-24T17:10:31.512176+00:00 2021-04-24T17:10:34.679336+00:00 0:00:03.167160 20810 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T17:10:28.845394+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T16:00:00+00:00 TriggerDagRunOperator 2021-04-24T17:10:23.101721+00:00 2021-04-24T17:10:23.617470+00:00 0:00:00.515749 20809 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T17:10:20.686867+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T16:00:00+00:00 TriggerDagRunOperator 2021-04-24T17:10:22.994308+00:00 2021-04-24T17:10:23.395735+00:00 0:00:00.401427 20808 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T17:10:20.686837+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T16:05:00+00:00 EmrJobFlowSensor 2021-04-24T17:06:12.454957+00:00 2021-04-24T17:15:15.118516+00:00 0:09:02.663559 20807 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T17:06:10.217775+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T17:05:52.507608+00:00 2021-04-24T17:05:54.181694+00:00 0:00:01.674086 20806 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T17:05:50.202247+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T16:05:00+00:00 PythonOperator 2021-04-24T17:05:30.558822+00:00 2021-04-24T17:05:33.497309+00:00 0:00:02.938487 20805 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T17:05:28.340531+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T16:00:00+00:00 EmrJobFlowSensor 2021-04-24T17:01:00.420832+00:00 2021-04-24T17:10:03.372902+00:00 0:09:02.952070 20804 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T17:00:57.850947+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T17:00:38.087973+00:00 2021-04-24T17:00:39.774070+00:00 0:00:01.686097 20803 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T17:00:35.846433+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T16:00:00+00:00 PythonOperator 2021-04-24T17:00:18.451776+00:00 2021-04-24T17:00:21.475766+00:00 0:00:03.023990 20802 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T17:00:15.805514+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T15:00:00+00:00 EmrJobFlowSensor 2021-04-24T16:11:16.778148+00:00 2021-04-24T16:21:19.514371+00:00 0:10:02.736223 20800 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T16:11:14.444073+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T15:00:00+00:00 EmrJobFlowSensor 2021-04-24T16:11:10.785105+00:00 2021-04-24T16:19:13.278968+00:00 0:08:02.493863 20799 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T16:11:08.459504+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T16:10:54.589863+00:00 2021-04-24T16:10:56.416297+00:00 0:00:01.826434 20798 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T16:10:52.330488+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T16:10:48.600333+00:00 2021-04-24T16:10:50.290650+00:00 0:00:01.690317 20797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T16:10:46.324640+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T15:00:00+00:00 PythonOperator 2021-04-24T16:10:34.478552+00:00 2021-04-24T16:10:37.726918+00:00 0:00:03.248366 20796 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T16:10:32.310394+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T15:00:00+00:00 PythonOperator 2021-04-24T16:10:29.163393+00:00 2021-04-24T16:10:32.167349+00:00 0:00:03.003956 20795 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T16:10:26.306903+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T15:00:00+00:00 TriggerDagRunOperator 2021-04-24T16:10:20.482954+00:00 2021-04-24T16:10:20.900403+00:00 0:00:00.417449 20794 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T16:10:18.295919+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T15:00:00+00:00 TriggerDagRunOperator 2021-04-24T16:10:20.488643+00:00 2021-04-24T16:10:21.045865+00:00 0:00:00.557222 20793 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T16:10:18.295953+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T15:05:00+00:00 EmrJobFlowSensor 2021-04-24T16:05:58.262208+00:00 2021-04-24T16:15:00.967489+00:00 0:09:02.705281 20792 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T16:05:55.831822+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T16:05:36.215153+00:00 2021-04-24T16:05:37.968736+00:00 0:00:01.753583 20791 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T16:05:33.870428+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T15:05:00+00:00 PythonOperator 2021-04-24T16:05:16.155169+00:00 2021-04-24T16:05:19.064732+00:00 0:00:02.909563 20790 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T16:05:13.859946+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T15:00:00+00:00 EmrJobFlowSensor 2021-04-24T16:01:00.051999+00:00 2021-04-24T16:10:02.959414+00:00 0:09:02.907415 20789 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T16:00:57.565600+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T16:00:31.709161+00:00 2021-04-24T16:00:33.409012+00:00 0:00:01.699851 20788 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T16:00:29.407032+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T15:00:00+00:00 PythonOperator 2021-04-24T16:00:05.695319+00:00 2021-04-24T16:00:08.734576+00:00 0:00:03.039257 20787 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T16:00:03.386671+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T14:00:00+00:00 EmrJobFlowSensor 2021-04-24T15:13:35.161705+00:00 2021-04-24T15:22:37.794893+00:00 0:09:02.633188 20786 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T15:13:32.573065+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T14:00:00+00:00 EmrJobFlowSensor 2021-04-24T15:13:18.922192+00:00 2021-04-24T15:23:21.687761+00:00 0:10:02.765569 20785 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T15:13:16.543733+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T15:13:12.734353+00:00 2021-04-24T15:13:14.391274+00:00 0:00:01.656921 20784 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T15:13:10.483975+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T15:12:56.763743+00:00 2021-04-24T15:12:58.595632+00:00 0:00:01.831889 20783 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T15:12:54.484878+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T14:00:00+00:00 PythonOperator 2021-04-24T15:12:52.682466+00:00 2021-04-24T15:12:55.625049+00:00 0:00:02.942583 20782 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T15:12:50.445396+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T14:00:00+00:00 PythonOperator 2021-04-24T15:12:36.711850+00:00 2021-04-24T15:12:39.871774+00:00 0:00:03.159924 20781 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T15:12:34.431039+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T14:00:00+00:00 TriggerDagRunOperator 2021-04-24T15:12:27.270260+00:00 2021-04-24T15:12:27.810742+00:00 0:00:00.540482 20780 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T15:12:24.437965+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T14:00:00+00:00 TriggerDagRunOperator 2021-04-24T15:12:27.162332+00:00 2021-04-24T15:12:27.572169+00:00 0:00:00.409837 20779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T15:12:24.437933+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T14:05:00+00:00 EmrJobFlowSensor 2021-04-24T15:05:48.791051+00:00 2021-04-24T15:13:51.221579+00:00 0:08:02.430528 20777 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T15:05:46.654205+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T15:05:26.976906+00:00 2021-04-24T15:05:28.813155+00:00 0:00:01.836249 20776 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T15:05:24.676080+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T14:05:00+00:00 PythonOperator 2021-04-24T15:05:07.124143+00:00 2021-04-24T15:05:10.051954+00:00 0:00:02.927811 20775 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T15:05:04.761081+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T14:00:00+00:00 EmrJobFlowSensor 2021-04-24T15:00:58.750941+00:00 2021-04-24T15:11:01.535512+00:00 0:10:02.784571 20774 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T15:00:56.262705+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T15:00:38.416879+00:00 2021-04-24T15:00:40.175493+00:00 0:00:01.758614 20773 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T15:00:36.191652+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T14:00:00+00:00 PythonOperator 2021-04-24T15:00:16.686716+00:00 2021-04-24T15:00:19.667363+00:00 0:00:02.980647 20772 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T15:00:14.178176+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T13:00:00+00:00 EmrJobFlowSensor 2021-04-24T14:11:21.233396+00:00 2021-04-24T14:20:23.867065+00:00 0:09:02.633669 20771 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T14:11:19.042591+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T13:00:00+00:00 EmrJobFlowSensor 2021-04-24T14:11:19.455318+00:00 2021-04-24T14:20:22.151047+00:00 0:09:02.695729 20770 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T14:11:16.983784+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T14:10:59.548591+00:00 2021-04-24T14:11:01.258044+00:00 0:00:01.709453 20769 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T14:10:56.927883+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T14:10:57.121388+00:00 2021-04-24T14:10:59.193780+00:00 0:00:02.072392 20768 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T14:10:54.922977+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T13:00:00+00:00 PythonOperator 2021-04-24T14:10:39.230768+00:00 2021-04-24T14:10:42.582650+00:00 0:00:03.351882 20767 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T14:10:36.911224+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T13:00:00+00:00 PythonOperator 2021-04-24T14:10:37.115992+00:00 2021-04-24T14:10:40.062047+00:00 0:00:02.946055 20766 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T14:10:34.913171+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T13:00:00+00:00 TriggerDagRunOperator 2021-04-24T14:10:17.620084+00:00 2021-04-24T14:10:18.176439+00:00 0:00:00.556355 20765 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T14:10:14.705799+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T13:00:00+00:00 TriggerDagRunOperator 2021-04-24T14:10:17.575101+00:00 2021-04-24T14:10:18.041820+00:00 0:00:00.466719 20764 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T14:10:14.705833+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T13:05:00+00:00 EmrJobFlowSensor 2021-04-24T14:06:02.179322+00:00 2021-04-24T14:15:04.853472+00:00 0:09:02.674150 20762 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T14:06:00.025382+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T14:05:40.333110+00:00 2021-04-24T14:05:42.037966+00:00 0:00:01.704856 20761 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T14:05:37.992408+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T13:05:00+00:00 PythonOperator 2021-04-24T14:05:18.093641+00:00 2021-04-24T14:05:20.995711+00:00 0:00:02.902070 20760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T14:05:15.926309+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T13:00:00+00:00 EmrJobFlowSensor 2021-04-24T14:01:02.059760+00:00 2021-04-24T14:10:04.791238+00:00 0:09:02.731478 20759 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T14:00:59.657178+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T14:00:37.686105+00:00 2021-04-24T14:00:39.382293+00:00 0:00:01.696188 20758 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T14:00:35.486602+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T13:00:00+00:00 PythonOperator 2021-04-24T14:00:17.526162+00:00 2021-04-24T14:00:20.526024+00:00 0:00:02.999862 20757 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T14:00:15.347429+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T12:00:00+00:00 EmrJobFlowSensor 2021-04-24T13:12:28.799672+00:00 2021-04-24T13:20:31.306657+00:00 0:08:02.506985 20756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T13:12:26.496532+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T12:00:00+00:00 EmrJobFlowSensor 2021-04-24T13:12:24.688561+00:00 2021-04-24T13:22:27.421758+00:00 0:10:02.733197 20755 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T13:12:22.494755+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T13:12:06.835862+00:00 2021-04-24T13:12:08.551986+00:00 0:00:01.716124 20754 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T13:12:04.554140+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T13:12:04.995943+00:00 2021-04-24T13:12:06.864482+00:00 0:00:01.868539 20753 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T13:12:02.544010+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T12:00:00+00:00 PythonOperator 2021-04-24T13:11:46.668481+00:00 2021-04-24T13:11:49.649449+00:00 0:00:02.980968 20752 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T13:11:44.419025+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T12:00:00+00:00 PythonOperator 2021-04-24T13:11:42.665175+00:00 2021-04-24T13:11:45.826023+00:00 0:00:03.160848 20751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T13:11:40.419772+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T12:00:00+00:00 TriggerDagRunOperator 2021-04-24T13:11:24.994406+00:00 2021-04-24T13:11:25.511808+00:00 0:00:00.517402 20750 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T13:11:22.464644+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T12:00:00+00:00 TriggerDagRunOperator 2021-04-24T13:11:24.953946+00:00 2021-04-24T13:11:25.364862+00:00 0:00:00.410916 20749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T13:11:22.464681+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T12:05:00+00:00 EmrJobFlowSensor 2021-04-24T13:09:12.388522+00:00 2021-04-24T13:18:15.079152+00:00 0:09:02.690630 20748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T13:09:10.195845+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T13:08:52.351233+00:00 2021-04-24T13:08:54.126335+00:00 0:00:01.775102 20747 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T13:08:50.178482+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T12:05:00+00:00 PythonOperator 2021-04-24T13:08:30.892517+00:00 2021-04-24T13:08:33.864023+00:00 0:00:02.971506 20746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T13:08:28.160643+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T12:00:00+00:00 EmrJobFlowSensor 2021-04-24T13:00:58.323647+00:00 2021-04-24T13:11:01.325849+00:00 0:10:03.002202 20744 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T13:00:55.900533+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T13:00:36.223819+00:00 2021-04-24T13:00:37.897390+00:00 0:00:01.673571 20743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T13:00:33.946532+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T12:00:00+00:00 PythonOperator 2021-04-24T13:00:16.212266+00:00 2021-04-24T13:00:19.214677+00:00 0:00:03.002411 20742 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T13:00:13.872011+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T11:00:00+00:00 EmrJobFlowSensor 2021-04-24T12:11:11.756467+00:00 2021-04-24T12:21:14.627482+00:00 0:10:02.871015 20741 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T12:11:09.060983+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T11:00:00+00:00 EmrJobFlowSensor 2021-04-24T12:11:09.282962+00:00 2021-04-24T12:20:12.196649+00:00 0:09:02.913687 20740 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T12:11:06.986718+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T12:10:51.215470+00:00 2021-04-24T12:10:52.931632+00:00 0:00:01.716162 20739 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T12:10:48.925946+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T12:10:49.293615+00:00 2021-04-24T12:10:51.090279+00:00 0:00:01.796664 20738 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T12:10:46.924527+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T11:00:00+00:00 PythonOperator 2021-04-24T12:10:29.265514+00:00 2021-04-24T12:10:32.428570+00:00 0:00:03.163056 20737 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T12:10:26.918269+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T11:00:00+00:00 PythonOperator 2021-04-24T12:10:27.338608+00:00 2021-04-24T12:10:30.297431+00:00 0:00:02.958823 20736 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T12:10:24.950289+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T11:00:00+00:00 TriggerDagRunOperator 2021-04-24T12:10:05.603973+00:00 2021-04-24T12:10:06.115578+00:00 0:00:00.511605 20735 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T12:10:02.953609+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T11:00:00+00:00 TriggerDagRunOperator 2021-04-24T12:10:05.403440+00:00 2021-04-24T12:10:05.847245+00:00 0:00:00.443805 20734 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T12:10:02.953656+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T11:05:00+00:00 EmrJobFlowSensor 2021-04-24T12:05:52.887351+00:00 2021-04-24T12:14:55.391711+00:00 0:09:02.504360 20733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T12:05:50.544047+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T12:05:32.562624+00:00 2021-04-24T12:05:34.219918+00:00 0:00:01.657294 20732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T12:05:30.386691+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T11:05:00+00:00 PythonOperator 2021-04-24T12:05:10.791575+00:00 2021-04-24T12:05:13.724080+00:00 0:00:02.932505 20731 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T12:05:08.387208+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T11:00:00+00:00 EmrJobFlowSensor 2021-04-24T12:00:55.077452+00:00 2021-04-24T12:09:57.803156+00:00 0:09:02.725704 20729 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T12:00:52.766866+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T12:00:33.105408+00:00 2021-04-24T12:00:35.004144+00:00 0:00:01.898736 20728 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T12:00:30.740225+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T11:00:00+00:00 PythonOperator 2021-04-24T12:00:10.928738+00:00 2021-04-24T12:00:14.030151+00:00 0:00:03.101413 20727 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T12:00:08.694885+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T10:00:00+00:00 EmrJobFlowSensor 2021-04-24T11:16:41.339100+00:00 2021-04-24T11:26:44.074044+00:00 0:10:02.734944 20726 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T11:16:39.198236+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T10:00:00+00:00 EmrJobFlowSensor 2021-04-24T11:16:37.430614+00:00 2021-04-24T11:25:39.923072+00:00 0:09:02.492458 20725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T11:16:35.196184+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T11:16:19.390518+00:00 2021-04-24T11:16:21.106281+00:00 0:00:01.715763 20724 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T11:16:17.145056+00:00 2 default_pool