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_cluster_and_add_emr_steps 2021-04-27T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T21:11:52.649542+00:00 2021-04-27T21:11:54.435370+00:00 0:00:01.785828 21965 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T21:11:50.392646+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T20:00:00+00:00 PythonOperator 2021-04-27T21:11:33.094520+00:00 2021-04-27T21:11:36.040453+00:00 0:00:02.945933 21964 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T21:11:30.371278+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T20:00:00+00:00 PythonOperator 2021-04-27T21:11:29.064457+00:00 2021-04-27T21:11:32.844071+00:00 0:00:03.779614 21963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T21:11:26.369410+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T20:00:00+00:00 TriggerDagRunOperator 2021-04-27T21:11:20.785799+00:00 2021-04-27T21:11:21.202241+00:00 0:00:00.416442 21962 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T21:11:18.367163+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T20:00:00+00:00 TriggerDagRunOperator 2021-04-27T21:11:20.730901+00:00 2021-04-27T21:11:21.251671+00:00 0:00:00.520770 21961 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T21:11:18.367127+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T20:05:00+00:00 EmrJobFlowSensor 2021-04-27T21:06:05.951566+00:00 2021-04-27T21:16:08.673206+00:00 0:10:02.721640 21960 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T21:06:03.808130+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T21:05:44.145177+00:00 2021-04-27T21:05:45.789782+00:00 0:00:01.644605 21959 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T21:05:41.788825+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T20:05:00+00:00 PythonOperator 2021-04-27T21:05:21.866588+00:00 2021-04-27T21:05:24.835531+00:00 0:00:02.968943 21958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T21:05:19.722170+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T20:00:00+00:00 EmrJobFlowSensor 2021-04-27T21:00:57.699604+00:00 2021-04-27T21:11:00.448849+00:00 0:10:02.749245 21957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T21:00:55.360886+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T21:00:37.582340+00:00 2021-04-27T21:00:39.393565+00:00 0:00:01.811225 21956 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T21:00:35.260816+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T20:00:00+00:00 PythonOperator 2021-04-27T21:00:05.968007+00:00 2021-04-27T21:00:09.050492+00:00 0:00:03.082485 21955 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T21:00:03.221615+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T19:00:00+00:00 EmrJobFlowSensor 2021-04-27T20:24:15.975740+00:00 2021-04-27T20:24:17.452814+00:00 0:00:01.477074 21953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T20:24:13.818575+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T19:00:00+00:00 EmrJobFlowSensor 2021-04-27T20:12:28.808366+00:00 2021-04-27T20:21:31.310073+00:00 0:09:02.501707 21951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T20:12:26.643946+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T20:12:25.219580+00:00 2021-04-27T20:12:27.108156+00:00 0:00:01.888576 21950 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T20:12:22.645456+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T20:12:07.124106+00:00 2021-04-27T20:12:09.043251+00:00 0:00:01.919145 21949 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T20:12:04.749252+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T19:00:00+00:00 PythonOperator 2021-04-27T20:11:53.073045+00:00 2021-04-27T20:11:56.121904+00:00 0:00:03.048859 21948 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T20:11:50.611482+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T19:00:00+00:00 PythonOperator 2021-04-27T20:11:38.974494+00:00 2021-04-27T20:11:41.991758+00:00 0:00:03.017264 21947 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T20:11:36.665158+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T19:00:00+00:00 TriggerDagRunOperator 2021-04-27T20:11:31.421393+00:00 2021-04-27T20:11:31.976374+00:00 0:00:00.554981 21946 airflow-worker-2.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T20:11:28.476778+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T19:00:00+00:00 TriggerDagRunOperator 2021-04-27T20:11:31.122523+00:00 2021-04-27T20:11:31.634920+00:00 0:00:00.512397 21945 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T20:11:28.476810+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T19:05:00+00:00 EmrJobFlowSensor 2021-04-27T20:06:10.178841+00:00 2021-04-27T20:15:12.773869+00:00 0:09:02.595028 21944 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T20:06:07.888453+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T20:05:40.084955+00:00 2021-04-27T20:05:41.815096+00:00 0:00:01.730141 21943 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T20:05:37.848671+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T19:05:00+00:00 PythonOperator 2021-04-27T20:05:20.116866+00:00 2021-04-27T20:05:23.067551+00:00 0:00:02.950685 21942 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T20:05:17.800690+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T19:00:00+00:00 EmrJobFlowSensor 2021-04-27T20:01:03.835691+00:00 2021-04-27T20:11:06.644598+00:00 0:10:02.808907 21941 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T20:01:01.460382+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T20:00:41.603854+00:00 2021-04-27T20:00:43.381060+00:00 0:00:01.777206 21940 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T20:00:39.390400+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T19:00:00+00:00 PythonOperator 2021-04-27T20:00:21.721407+00:00 2021-04-27T20:00:24.751615+00:00 0:00:03.030208 21939 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T20:00:19.288807+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T18:00:00+00:00 EmrJobFlowSensor 2021-04-27T19:23:55.620748+00:00 2021-04-27T19:23:57.089113+00:00 0:00:01.468365 21937 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T19:23:53.460810+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T18:00:00+00:00 EmrJobFlowSensor 2021-04-27T19:23:47.684584+00:00 2021-04-27T19:23:49.291472+00:00 0:00:01.606888 21936 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T19:23:45.451982+00:00 3 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T19:12:08.438043+00:00 2021-04-27T19:12:10.173084+00:00 0:00:01.735041 21933 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T19:12:06.215266+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T19:12:02.460089+00:00 2021-04-27T19:12:04.507406+00:00 0:00:02.047317 21932 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T19:12:00.220371+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T18:00:00+00:00 PythonOperator 2021-04-27T19:11:46.312308+00:00 2021-04-27T19:11:49.314211+00:00 0:00:03.001903 21931 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T19:11:44.188640+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T18:00:00+00:00 PythonOperator 2021-04-27T19:11:40.558319+00:00 2021-04-27T19:11:43.865231+00:00 0:00:03.306912 21930 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T19:11:38.257815+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T18:00:00+00:00 TriggerDagRunOperator 2021-04-27T19:11:26.694000+00:00 2021-04-27T19:11:27.181868+00:00 0:00:00.487868 21929 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T19:11:24.246803+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T18:00:00+00:00 TriggerDagRunOperator 2021-04-27T19:11:26.712297+00:00 2021-04-27T19:11:27.290337+00:00 0:00:00.578040 21928 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T19:11:24.246856+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T18:05:00+00:00 EmrJobFlowSensor 2021-04-27T19:06:06.131680+00:00 2021-04-27T19:15:08.744640+00:00 0:09:02.612960 21927 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T19:06:03.745264+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T19:05:43.971508+00:00 2021-04-27T19:05:45.727402+00:00 0:00:01.755894 21926 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T19:05:41.630529+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T18:05:00+00:00 PythonOperator 2021-04-27T19:05:19.977317+00:00 2021-04-27T19:05:22.943346+00:00 0:00:02.966029 21925 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T19:05:17.601921+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T18:00:00+00:00 EmrJobFlowSensor 2021-04-27T19:00:59.607126+00:00 2021-04-27T19:11:02.566544+00:00 0:10:02.959418 21924 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T19:00:57.114220+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T19:00:37.489892+00:00 2021-04-27T19:00:39.189203+00:00 0:00:01.699311 21923 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T19:00:35.102041+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T18:00:00+00:00 PythonOperator 2021-04-27T19:00:17.651418+00:00 2021-04-27T19:00:20.706470+00:00 0:00:03.055052 21922 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T19:00:15.075772+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T17:00:00+00:00 EmrJobFlowSensor 2021-04-27T18:10:08.155731+00:00 2021-04-27T18:20:10.928635+00:00 0:10:02.772904 21920 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T18:10:05.913769+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T17:00:00+00:00 EmrJobFlowSensor 2021-04-27T18:10:04.265567+00:00 2021-04-27T18:19:06.982625+00:00 0:09:02.717058 21919 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T18:10:01.953189+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T18:09:46.395396+00:00 2021-04-27T18:09:48.096082+00:00 0:00:01.700686 21918 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T18:09:43.966127+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T18:09:42.369075+00:00 2021-04-27T18:09:44.219483+00:00 0:00:01.850408 21917 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T18:09:39.896692+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T17:00:00+00:00 PythonOperator 2021-04-27T18:09:24.268932+00:00 2021-04-27T18:09:27.521825+00:00 0:00:03.252893 21916 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T18:09:21.854982+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T17:00:00+00:00 PythonOperator 2021-04-27T18:09:19.984235+00:00 2021-04-27T18:09:22.981213+00:00 0:00:02.996978 21915 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T18:09:17.853106+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T17:00:00+00:00 TriggerDagRunOperator 2021-04-27T18:09:10.200086+00:00 2021-04-27T18:09:10.740039+00:00 0:00:00.539953 21914 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T18:09:07.845792+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T17:00:00+00:00 TriggerDagRunOperator 2021-04-27T18:09:10.096142+00:00 2021-04-27T18:09:10.494761+00:00 0:00:00.398619 21913 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T18:09:07.845828+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T17:05:00+00:00 EmrJobFlowSensor 2021-04-27T18:05:55.763446+00:00 2021-04-27T18:15:58.506224+00:00 0:10:02.742778 21912 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T18:05:53.505593+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T18:05:33.676781+00:00 2021-04-27T18:05:35.370715+00:00 0:00:01.693934 21911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T18:05:31.491004+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T17:05:00+00:00 PythonOperator 2021-04-27T18:05:13.700652+00:00 2021-04-27T18:05:16.761665+00:00 0:00:03.061013 21910 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T18:05:11.466818+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T17:00:00+00:00 EmrJobFlowSensor 2021-04-27T18:00:49.211741+00:00 2021-04-27T18:08:51.698994+00:00 0:08:02.487253 21909 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T18:00:47.018583+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T18:00:29.218174+00:00 2021-04-27T18:00:30.894099+00:00 0:00:01.675925 21908 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T18:00:27.003092+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T17:00:00+00:00 PythonOperator 2021-04-27T18:00:07.772718+00:00 2021-04-27T18:00:10.762204+00:00 0:00:02.989486 21907 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T18:00:05.044984+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T16:00:00+00:00 EmrJobFlowSensor 2021-04-27T17:11:12.104890+00:00 2021-04-27T17:21:14.908162+00:00 0:10:02.803272 21905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T17:11:09.889034+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T16:00:00+00:00 EmrJobFlowSensor 2021-04-27T17:11:02.292818+00:00 2021-04-27T17:19:04.984460+00:00 0:08:02.691642 21904 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T17:10:59.944776+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T17:10:49.982221+00:00 2021-04-27T17:10:51.674648+00:00 0:00:01.692427 21903 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T17:10:47.828932+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T17:10:40.209936+00:00 2021-04-27T17:10:41.988755+00:00 0:00:01.778819 21902 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T17:10:37.822180+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T16:00:00+00:00 PythonOperator 2021-04-27T17:10:30.113889+00:00 2021-04-27T17:10:33.332491+00:00 0:00:03.218602 21901 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T17:10:27.810238+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T16:00:00+00:00 PythonOperator 2021-04-27T17:10:19.992561+00:00 2021-04-27T17:10:22.976462+00:00 0:00:02.983901 21900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T17:10:17.802978+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T16:00:00+00:00 TriggerDagRunOperator 2021-04-27T17:10:06.337694+00:00 2021-04-27T17:10:06.775142+00:00 0:00:00.437448 21899 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T17:10:03.790278+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T16:00:00+00:00 TriggerDagRunOperator 2021-04-27T17:10:06.345572+00:00 2021-04-27T17:10:06.888766+00:00 0:00:00.543194 21898 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T17:10:03.790245+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T16:05:00+00:00 EmrJobFlowSensor 2021-04-27T17:05:51.710360+00:00 2021-04-27T17:15:54.387719+00:00 0:10:02.677359 21897 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T17:05:49.486144+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T17:05:31.717146+00:00 2021-04-27T17:05:33.438465+00:00 0:00:01.721319 21896 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T17:05:29.468240+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T16:05:00+00:00 PythonOperator 2021-04-27T17:05:09.614115+00:00 2021-04-27T17:05:12.570872+00:00 0:00:02.956757 21895 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T17:05:07.453449+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T16:00:00+00:00 EmrJobFlowSensor 2021-04-27T17:00:57.110055+00:00 2021-04-27T17:09:59.728539+00:00 0:09:02.618484 21894 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T17:00:54.930278+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T17:00:35.298950+00:00 2021-04-27T17:00:37.000532+00:00 0:00:01.701582 21893 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T17:00:32.908994+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T16:00:00+00:00 PythonOperator 2021-04-27T17:00:13.198314+00:00 2021-04-27T17:00:16.217685+00:00 0:00:03.019371 21892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T17:00:10.895324+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T15:00:00+00:00 EmrJobFlowSensor 2021-04-27T16:11:50.897001+00:00 2021-04-27T16:20:53.410464+00:00 0:09:02.513463 21890 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T16:11:48.699766+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T15:00:00+00:00 EmrJobFlowSensor 2021-04-27T16:11:49.135669+00:00 2021-04-27T16:21:51.991025+00:00 0:10:02.855356 21889 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T16:11:46.700451+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T16:11:28.993681+00:00 2021-04-27T16:11:30.787923+00:00 0:00:01.794242 21888 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T16:11:26.683811+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T16:11:26.931566+00:00 2021-04-27T16:11:28.664844+00:00 0:00:01.733278 21887 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T16:11:24.686393+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T15:00:00+00:00 PythonOperator 2021-04-27T16:11:09.931979+00:00 2021-04-27T16:11:13.112230+00:00 0:00:03.180251 21886 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T16:11:06.639280+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T15:00:00+00:00 PythonOperator 2021-04-27T16:11:07.178044+00:00 2021-04-27T16:11:10.907273+00:00 0:00:03.729229 21885 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T16:11:04.765558+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T15:00:00+00:00 TriggerDagRunOperator 2021-04-27T16:11:01.121538+00:00 2021-04-27T16:11:01.703205+00:00 0:00:00.581667 21884 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T16:10:58.675479+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T15:00:00+00:00 TriggerDagRunOperator 2021-04-27T16:11:00.885470+00:00 2021-04-27T16:11:01.320934+00:00 0:00:00.435464 21883 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T16:10:58.675441+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T15:05:00+00:00 EmrJobFlowSensor 2021-04-27T16:06:04.496556+00:00 2021-04-27T16:15:07.372304+00:00 0:09:02.875748 21882 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T16:06:02.155729+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T16:05:42.523351+00:00 2021-04-27T16:05:44.272313+00:00 0:00:01.748962 21881 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T16:05:40.148543+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T15:05:00+00:00 PythonOperator 2021-04-27T16:05:22.168443+00:00 2021-04-27T16:05:25.138215+00:00 0:00:02.969772 21880 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T16:05:20.061821+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T15:00:00+00:00 EmrJobFlowSensor 2021-04-27T16:00:47.883039+00:00 2021-04-27T16:10:50.783579+00:00 0:10:02.900540 21879 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T16:00:45.631859+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T16:00:25.962387+00:00 2021-04-27T16:00:27.799479+00:00 0:00:01.837092 21878 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T16:00:23.604870+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T15:00:00+00:00 PythonOperator 2021-04-27T16:00:06.157184+00:00 2021-04-27T16:00:09.157395+00:00 0:00:03.000211 21877 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T16:00:03.658001+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T14:00:00+00:00 EmrJobFlowSensor 2021-04-27T15:11:31.400443+00:00 2021-04-27T15:20:34.097070+00:00 0:09:02.696627 21875 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T15:11:29.069920+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T14:00:00+00:00 EmrJobFlowSensor 2021-04-27T15:11:25.094042+00:00 2021-04-27T15:21:27.759130+00:00 0:10:02.665088 21874 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T15:11:22.935062+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T15:11:09.319150+00:00 2021-04-27T15:11:11.185856+00:00 0:00:01.866706 21873 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T15:11:06.920163+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T15:11:05.312787+00:00 2021-04-27T15:11:07.062776+00:00 0:00:01.749989 21872 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T15:11:02.917124+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T14:00:00+00:00 PythonOperator 2021-04-27T15:10:47.203369+00:00 2021-04-27T15:10:50.144912+00:00 0:00:02.941543 21871 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T15:10:44.944251+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-27T14:00:00+00:00 PythonOperator 2021-04-27T15:10:41.491232+00:00 2021-04-27T15:10:44.759397+00:00 0:00:03.268165 21870 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T15:10:38.959147+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-27T14:00:00+00:00 TriggerDagRunOperator 2021-04-27T15:10:33.171842+00:00 2021-04-27T15:10:33.700376+00:00 0:00:00.528534 21869 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T15:10:30.888485+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-27T14:00:00+00:00 TriggerDagRunOperator 2021-04-27T15:10:33.073104+00:00 2021-04-27T15:10:33.480461+00:00 0:00:00.407357 21868 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T15:10:30.888520+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-27T14:05:00+00:00 EmrJobFlowSensor 2021-04-27T15:06:00.949686+00:00 2021-04-27T15:16:03.645603+00:00 0:10:02.695917 21867 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T15:05:58.565370+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-27T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-27T15:05:38.727865+00:00 2021-04-27T15:05:40.522448+00:00 0:00:01.794583 21866 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T15:05:36.391637+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-27T14:05:00+00:00 PythonOperator 2021-04-27T15:05:18.784743+00:00 2021-04-27T15:05:21.725387+00:00 0:00:02.940644 21865 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T15:05:16.326119+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-27T14:00:00+00:00 EmrJobFlowSensor 2021-04-27T15:00:56.338370+00:00 2021-04-27T15:09:59.009660+00:00 0:09:02.671290 21864 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T15:00:54.073473+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-27T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T15:00:34.520645+00:00 2021-04-27T15:00:36.336230+00:00 0:00:01.815585 21863 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-27T15:00:31.990558+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-27T14:00:00+00:00 PythonOperator 2021-04-27T15:00:12.331933+00:00 2021-04-27T15:00:15.418010+00:00 0:00:03.086077 21862 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-27T15:00:09.970629+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-27T13:00:00+00:00 EmrJobFlowSensor 2021-04-27T14:12:11.725374+00:00 2021-04-27T14:21:14.395352+00:00 0:09:02.669978 21860 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T14:12:09.485373+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-27T13:00:00+00:00 EmrJobFlowSensor 2021-04-27T14:12:07.934503+00:00 2021-04-27T14:23:10.925477+00:00 0:11:02.990974 21859 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-27T14:12:05.480614+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-27T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T14:11:51.634427+00:00 2021-04-27T14:11:53.444477+00:00 0:00:01.810050 21858 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T14:11:49.399162+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-27T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-27T14:11:45.796836+00:00 2021-04-27T14:11:47.466659+00:00 0:00:01.669823 21857 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-27T14:11:43.462170+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-27T13:00:00+00:00 PythonOperator 2021-04-27T14:11:30.286695+00:00 2021-04-27T14:11:33.494769+00:00 0:00:03.208074 21856 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-27T14:11:27.385115+00:00 2 default_pool