Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success vc-asset-import_v002 check_cluster_status 2021-05-03T01:05:00+00:00 EmrJobFlowSensor 2021-05-03T02:05:58.361901+00:00 2021-05-03T02:15:01.082508+00:00 0:09:02.720607 23851 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T02:05:55.892411+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-03T01:05:00+00:00 EmrCreateJobFlowOperator 2021-05-03T02:05:38.166829+00:00 2021-05-03T02:05:39.822300+00:00 0:00:01.655471 23850 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T02:05:35.860398+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-03T01:05:00+00:00 PythonOperator 2021-05-03T02:05:16.068228+00:00 2021-05-03T02:05:19.126633+00:00 0:00:03.058405 23849 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T02:05:13.827824+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T01:00:00+00:00 EmrJobFlowSensor 2021-05-03T02:01:05.855195+00:00 2021-05-03T02:09:08.599934+00:00 0:08:02.744739 23848 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T02:01:03.383519+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T02:00:41.874531+00:00 2021-05-03T02:00:43.576678+00:00 0:00:01.702147 23847 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T02:00:39.362210+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T01:00:00+00:00 PythonOperator 2021-05-03T02:00:19.861236+00:00 2021-05-03T02:00:22.891707+00:00 0:00:03.030471 23846 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T02:00:17.297841+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-03T00:00:00+00:00 EmrJobFlowSensor 2021-05-03T01:10:05.782842+00:00 2021-05-03T01:20:08.708720+00:00 0:10:02.925878 23844 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T01:10:03.344997+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-03T00:00:00+00:00 EmrJobFlowSensor 2021-05-03T01:09:59.639298+00:00 2021-05-03T01:20:02.690186+00:00 0:10:03.050888 23843 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T01:09:57.316799+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-03T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T01:09:43.832295+00:00 2021-05-03T01:09:45.731476+00:00 0:00:01.899181 23842 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T01:09:41.309677+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-03T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T01:09:37.824506+00:00 2021-05-03T01:09:39.534357+00:00 0:00:01.709851 23841 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T01:09:35.363831+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-03T00:00:00+00:00 PythonOperator 2021-05-03T01:09:21.514095+00:00 2021-05-03T01:09:24.554817+00:00 0:00:03.040722 23840 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T01:09:19.286101+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-03T00:00:00+00:00 PythonOperator 2021-05-03T01:09:17.902235+00:00 2021-05-03T01:09:21.135160+00:00 0:00:03.232925 23839 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T01:09:15.269220+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-03T00:00:00+00:00 TriggerDagRunOperator 2021-05-03T01:09:09.594402+00:00 2021-05-03T01:09:10.130370+00:00 0:00:00.535968 23838 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T01:09:07.257105+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-03T00:00:00+00:00 TriggerDagRunOperator 2021-05-03T01:09:09.512402+00:00 2021-05-03T01:09:09.920697+00:00 0:00:00.408295 23837 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T01:09:07.257061+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-03T00:05:00+00:00 EmrJobFlowSensor 2021-05-03T01:05:49.200364+00:00 2021-05-03T01:13:51.704006+00:00 0:08:02.503642 23836 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T01:05:46.848190+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-03T00:05:00+00:00 EmrCreateJobFlowOperator 2021-05-03T01:05:26.965286+00:00 2021-05-03T01:05:28.706866+00:00 0:00:01.741580 23835 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T01:05:24.674198+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-03T00:05:00+00:00 PythonOperator 2021-05-03T01:05:07.249372+00:00 2021-05-03T01:05:10.287313+00:00 0:00:03.037941 23834 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T01:05:04.737294+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-03T00:00:00+00:00 EmrJobFlowSensor 2021-05-03T01:00:54.422632+00:00 2021-05-03T01:08:57.044993+00:00 0:08:02.622361 23833 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T01:00:52.036217+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-03T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T01:00:32.238497+00:00 2021-05-03T01:00:34.124127+00:00 0:00:01.885630 23832 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T01:00:30.020125+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-03T00:00:00+00:00 PythonOperator 2021-05-03T01:00:10.449015+00:00 2021-05-03T01:00:13.493437+00:00 0:00:03.044422 23831 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T01:00:07.992141+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-02T23:00:00+00:00 EmrJobFlowSensor 2021-05-03T00:11:36.764760+00:00 2021-05-03T00:21:39.671107+00:00 0:10:02.906347 23829 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T00:11:34.531666+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-02T23:00:00+00:00 EmrJobFlowSensor 2021-05-03T00:11:15.463271+00:00 2021-05-03T00:20:18.103074+00:00 0:09:02.639803 23828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T00:11:12.512177+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-02T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T00:11:13.024642+00:00 2021-05-03T00:11:15.130706+00:00 0:00:02.106064 23827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T00:11:10.517277+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-02T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T00:10:53.341600+00:00 2021-05-03T00:10:55.081329+00:00 0:00:01.739729 23826 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T00:10:50.556791+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-02T23:00:00+00:00 PythonOperator 2021-05-03T00:10:50.712351+00:00 2021-05-03T00:10:53.964003+00:00 0:00:03.251652 23825 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T00:10:48.490718+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-02T23:00:00+00:00 PythonOperator 2021-05-03T00:10:33.261757+00:00 2021-05-03T00:10:36.290314+00:00 0:00:03.028557 23824 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T00:10:30.471736+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T23:00:00+00:00 TriggerDagRunOperator 2021-05-03T00:10:26.825239+00:00 2021-05-03T00:10:27.353162+00:00 0:00:00.527923 23823 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T00:10:24.389454+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T23:00:00+00:00 TriggerDagRunOperator 2021-05-03T00:10:26.779668+00:00 2021-05-03T00:10:27.209941+00:00 0:00:00.430273 23822 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T00:10:24.389490+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-02T23:05:00+00:00 EmrJobFlowSensor 2021-05-03T00:05:56.512818+00:00 2021-05-03T00:13:59.023939+00:00 0:08:02.511121 23821 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-03T00:05:54.061238+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-02T23:05:00+00:00 EmrCreateJobFlowOperator 2021-05-03T00:05:36.328668+00:00 2021-05-03T00:05:38.053764+00:00 0:00:01.725096 23820 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-03T00:05:33.898271+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-02T23:05:00+00:00 PythonOperator 2021-05-03T00:05:14.171775+00:00 2021-05-03T00:05:17.185440+00:00 0:00:03.013665 23819 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T00:05:11.806237+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T23:00:00+00:00 EmrJobFlowSensor 2021-05-03T00:01:07.510353+00:00 2021-05-03T00:10:10.374508+00:00 0:09:02.864155 23818 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-03T00:01:05.187927+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-03T00:00:45.507140+00:00 2021-05-03T00:00:47.211300+00:00 0:00:01.704160 23817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-03T00:00:43.158205+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T23:00:00+00:00 PythonOperator 2021-05-03T00:00:25.993610+00:00 2021-05-03T00:00:29.131533+00:00 0:00:03.137923 23816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-03T00:00:23.104101+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-02T22:00:00+00:00 EmrJobFlowSensor 2021-05-02T23:10:11.310861+00:00 2021-05-02T23:20:14.095481+00:00 0:10:02.784620 23814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T23:10:09.072348+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-02T22:00:00+00:00 EmrJobFlowSensor 2021-05-02T23:10:09.338363+00:00 2021-05-02T23:18:11.990551+00:00 0:08:02.652188 23813 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T23:10:07.051322+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-02T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T23:09:51.247232+00:00 2021-05-02T23:09:52.961592+00:00 0:00:01.714360 23812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T23:09:49.009922+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-02T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T23:09:47.203286+00:00 2021-05-02T23:09:48.882542+00:00 0:00:01.679256 23811 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T23:09:44.983237+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-02T22:00:00+00:00 PythonOperator 2021-05-02T23:09:29.296652+00:00 2021-05-02T23:09:32.547873+00:00 0:00:03.251221 23810 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T23:09:26.928477+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-02T22:00:00+00:00 PythonOperator 2021-05-02T23:09:25.335562+00:00 2021-05-02T23:09:28.413498+00:00 0:00:03.077936 23809 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T23:09:22.979719+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T22:00:00+00:00 TriggerDagRunOperator 2021-05-02T23:09:11.856311+00:00 2021-05-02T23:09:12.262875+00:00 0:00:00.406564 23808 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T23:09:08.976680+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T22:00:00+00:00 TriggerDagRunOperator 2021-05-02T23:09:11.303589+00:00 2021-05-02T23:09:11.910359+00:00 0:00:00.606770 23807 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T23:09:08.976646+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-02T22:05:00+00:00 EmrJobFlowSensor 2021-05-02T23:06:01.187034+00:00 2021-05-02T23:14:03.743931+00:00 0:08:02.556897 23806 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T23:05:58.759704+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-02T22:05:00+00:00 EmrCreateJobFlowOperator 2021-05-02T23:05:39.045602+00:00 2021-05-02T23:05:40.687281+00:00 0:00:01.641679 23805 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T23:05:36.663154+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-02T22:05:00+00:00 PythonOperator 2021-05-02T23:05:16.818566+00:00 2021-05-02T23:05:19.813854+00:00 0:00:02.995288 23804 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T23:05:14.573603+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T22:00:00+00:00 EmrJobFlowSensor 2021-05-02T23:01:00.725378+00:00 2021-05-02T23:09:03.321311+00:00 0:08:02.595933 23803 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T23:00:58.260077+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-05-01T23:00:00+00:00 EmrJobFlowSensor 2021-05-02T23:00:48.926010+00:00 2021-05-02T23:09:51.551084+00:00 0:09:02.625074 23802 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T23:00:46.099503+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T23:00:40.621871+00:00 2021-05-02T23:00:42.370927+00:00 0:00:01.749056 23801 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T23:00:38.169996+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-05-01T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T23:00:26.316849+00:00 2021-05-02T23:00:28.001084+00:00 0:00:01.684235 23800 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T23:00:24.083979+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T22:00:00+00:00 PythonOperator 2021-05-02T23:00:18.325491+00:00 2021-05-02T23:00:21.349504+00:00 0:00:03.024013 23799 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T23:00:16.069950+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-05-01T23:00:00+00:00 PythonOperator 2021-05-02T23:00:06.508564+00:00 2021-05-02T23:00:09.628870+00:00 0:00:03.120306 23798 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T23:00:04.065450+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-02T21:00:00+00:00 EmrJobFlowSensor 2021-05-02T22:10:52.059506+00:00 2021-05-02T22:18:54.645227+00:00 0:08:02.585721 23796 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T22:10:49.703184+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-02T21:00:00+00:00 EmrJobFlowSensor 2021-05-02T22:10:52.033892+00:00 2021-05-02T22:20:54.952441+00:00 0:10:02.918549 23795 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T22:10:49.703231+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-02T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T22:10:30.135172+00:00 2021-05-02T22:10:31.841521+00:00 0:00:01.706349 23794 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T22:10:27.600166+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-02T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T22:10:30.138050+00:00 2021-05-02T22:10:31.923105+00:00 0:00:01.785055 23793 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T22:10:27.600213+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-02T21:00:00+00:00 PythonOperator 2021-05-02T22:10:10.205818+00:00 2021-05-02T22:10:13.503929+00:00 0:00:03.298111 23792 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T22:10:07.570083+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-02T21:00:00+00:00 PythonOperator 2021-05-02T22:10:10.044082+00:00 2021-05-02T22:10:13.111664+00:00 0:00:03.067582 23791 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T22:10:07.570048+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T21:00:00+00:00 TriggerDagRunOperator 2021-05-02T22:10:03.937697+00:00 2021-05-02T22:10:04.463970+00:00 0:00:00.526273 23790 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T22:10:01.509488+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T21:00:00+00:00 TriggerDagRunOperator 2021-05-02T22:10:03.793520+00:00 2021-05-02T22:10:04.314393+00:00 0:00:00.520873 23789 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T22:10:01.509455+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-02T21:05:00+00:00 EmrJobFlowSensor 2021-05-02T22:06:15.279879+00:00 2021-05-02T22:15:17.840565+00:00 0:09:02.560686 23788 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T22:06:12.999669+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-02T21:05:00+00:00 EmrCreateJobFlowOperator 2021-05-02T22:05:55.206045+00:00 2021-05-02T22:05:56.890972+00:00 0:00:01.684927 23787 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T22:05:52.941691+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-02T21:05:00+00:00 PythonOperator 2021-05-02T22:05:25.109086+00:00 2021-05-02T22:05:28.091976+00:00 0:00:02.982890 23786 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T22:05:22.899647+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T21:00:00+00:00 EmrJobFlowSensor 2021-05-02T22:00:48.814561+00:00 2021-05-02T22:09:51.642191+00:00 0:09:02.827630 23785 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T22:00:46.350081+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T22:00:26.595361+00:00 2021-05-02T22:00:28.338929+00:00 0:00:01.743568 23784 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T22:00:24.331639+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T21:00:00+00:00 PythonOperator 2021-05-02T22:00:04.851484+00:00 2021-05-02T22:00:07.976885+00:00 0:00:03.125401 23783 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T22:00:02.316053+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-02T20:00:00+00:00 EmrJobFlowSensor 2021-05-02T21:11:20.498844+00:00 2021-05-02T21:20:23.155652+00:00 0:09:02.656808 23781 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T21:11:18.075562+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-02T20:00:00+00:00 EmrJobFlowSensor 2021-05-02T21:11:20.511828+00:00 2021-05-02T21:20:23.311658+00:00 0:09:02.799830 23780 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T21:11:18.075608+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-02T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T21:11:00.535698+00:00 2021-05-02T21:11:02.392021+00:00 0:00:01.856323 23779 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T21:10:58.044237+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-02T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T21:11:00.439360+00:00 2021-05-02T21:11:02.190763+00:00 0:00:01.751403 23778 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T21:10:58.044200+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-02T20:00:00+00:00 PythonOperator 2021-05-02T21:10:38.469173+00:00 2021-05-02T21:10:41.506725+00:00 0:00:03.037552 23777 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T21:10:35.926266+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-02T20:00:00+00:00 PythonOperator 2021-05-02T21:10:38.332764+00:00 2021-05-02T21:10:41.667714+00:00 0:00:03.334950 23776 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T21:10:35.926227+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T20:00:00+00:00 TriggerDagRunOperator 2021-05-02T21:10:10.308955+00:00 2021-05-02T21:10:10.743104+00:00 0:00:00.434149 23775 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T21:10:07.889082+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T20:00:00+00:00 TriggerDagRunOperator 2021-05-02T21:10:10.178693+00:00 2021-05-02T21:10:10.760778+00:00 0:00:00.582085 23774 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T21:10:07.889042+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-02T20:05:00+00:00 EmrJobFlowSensor 2021-05-02T21:06:01.686188+00:00 2021-05-02T21:15:04.353883+00:00 0:09:02.667695 23773 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T21:05:59.273856+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-02T20:05:00+00:00 EmrCreateJobFlowOperator 2021-05-02T21:05:39.669753+00:00 2021-05-02T21:05:41.346345+00:00 0:00:01.676592 23772 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T21:05:37.166957+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-02T20:05:00+00:00 PythonOperator 2021-05-02T21:05:17.273399+00:00 2021-05-02T21:05:20.267174+00:00 0:00:02.993775 23771 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T21:05:15.064589+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T20:00:00+00:00 EmrJobFlowSensor 2021-05-02T21:00:48.365363+00:00 2021-05-02T21:09:51.179505+00:00 0:09:02.814142 23770 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T21:00:46.059506+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T21:00:28.253822+00:00 2021-05-02T21:00:29.960975+00:00 0:00:01.707153 23769 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T21:00:25.989662+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T20:00:00+00:00 PythonOperator 2021-05-02T21:00:06.658479+00:00 2021-05-02T21:00:09.673581+00:00 0:00:03.015102 23768 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T21:00:03.724356+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-02T19:00:00+00:00 EmrJobFlowSensor 2021-05-02T20:11:19.709329+00:00 2021-05-02T20:21:22.485849+00:00 0:10:02.776520 23766 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T20:11:17.277492+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-02T19:00:00+00:00 EmrJobFlowSensor 2021-05-02T20:11:11.741552+00:00 2021-05-02T20:21:14.686555+00:00 0:10:02.945003 23765 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T20:11:09.253891+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-02T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T20:10:59.326938+00:00 2021-05-02T20:11:01.026628+00:00 0:00:01.699690 23764 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T20:10:57.096950+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-02T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T20:10:51.305425+00:00 2021-05-02T20:10:53.113716+00:00 0:00:01.808291 23763 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T20:10:49.063607+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-02T19:00:00+00:00 PythonOperator 2021-05-02T20:10:37.299967+00:00 2021-05-02T20:10:40.544426+00:00 0:00:03.244459 23762 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T20:10:35.069417+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-02T19:00:00+00:00 PythonOperator 2021-05-02T20:10:29.671315+00:00 2021-05-02T20:10:32.787221+00:00 0:00:03.115906 23761 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T20:10:27.052765+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-02T19:00:00+00:00 TriggerDagRunOperator 2021-05-02T20:10:21.303306+00:00 2021-05-02T20:10:21.897500+00:00 0:00:00.594194 23760 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T20:10:19.044207+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T19:00:00+00:00 TriggerDagRunOperator 2021-05-02T20:10:21.219584+00:00 2021-05-02T20:10:21.638839+00:00 0:00:00.419255 23759 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T20:10:19.044253+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-02T19:05:00+00:00 EmrJobFlowSensor 2021-05-02T20:05:46.738034+00:00 2021-05-02T20:14:49.222436+00:00 0:09:02.484402 23758 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T20:05:44.492917+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-02T19:05:00+00:00 EmrCreateJobFlowOperator 2021-05-02T20:05:26.776758+00:00 2021-05-02T20:05:28.517517+00:00 0:00:01.740759 23757 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T20:05:24.477034+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-02T19:05:00+00:00 PythonOperator 2021-05-02T20:05:04.828845+00:00 2021-05-02T20:05:07.948448+00:00 0:00:03.119603 23756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T20:05:02.417717+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-02T19:00:00+00:00 EmrJobFlowSensor 2021-05-02T20:00:56.086203+00:00 2021-05-02T20:09:58.756915+00:00 0:09:02.670712 23755 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T20:00:53.958805+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-02T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T20:00:36.210225+00:00 2021-05-02T20:00:37.963836+00:00 0:00:01.753611 23754 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-02T20:00:33.926634+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-02T19:00:00+00:00 PythonOperator 2021-05-02T20:00:14.729719+00:00 2021-05-02T20:00:17.771555+00:00 0:00:03.041836 23753 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-02T20:00:11.960090+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-02T18:00:00+00:00 EmrJobFlowSensor 2021-05-02T19:11:20.306116+00:00 2021-05-02T19:20:23.009270+00:00 0:09:02.703154 23751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T19:11:17.976026+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-02T18:00:00+00:00 EmrJobFlowSensor 2021-05-02T19:11:18.479987+00:00 2021-05-02T19:21:21.345745+00:00 0:10:02.865758 23750 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T19:11:15.973164+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-02T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T19:10:58.254454+00:00 2021-05-02T19:11:00.099299+00:00 0:00:01.844845 23749 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T19:10:55.945130+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-02T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-02T19:10:56.247557+00:00 2021-05-02T19:10:57.941895+00:00 0:00:01.694338 23748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-02T19:10:53.954163+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-02T18:00:00+00:00 PythonOperator 2021-05-02T19:10:38.610838+00:00 2021-05-02T19:10:41.950178+00:00 0:00:03.339340 23747 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T19:10:35.944046+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-02T18:00:00+00:00 PythonOperator 2021-05-02T19:10:36.135649+00:00 2021-05-02T19:10:39.544479+00:00 0:00:03.408830 23746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-02T19:10:33.871382+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-02T18:00:00+00:00 TriggerDagRunOperator 2021-05-02T19:10:22.166900+00:00 2021-05-02T19:10:22.749818+00:00 0:00:00.582918 23745 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-02T19:10:19.857278+00:00 2 default_pool