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-20T01:00:00+00:00 EmrJobFlowSensor 2021-04-20T02:12:20.719195+00:00 2021-04-20T02:21:23.479848+00:00 0:09:02.760653 19116 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T02:12:17.757955+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-20T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T02:12:08.318682+00:00 2021-04-20T02:12:10.142995+00:00 0:00:01.824313 19115 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T02:12:05.844254+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-20T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T02:11:57.931090+00:00 2021-04-20T02:11:59.666483+00:00 0:00:01.735393 19114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T02:11:55.737272+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-20T01:00:00+00:00 PythonOperator 2021-04-20T02:11:48.062120+00:00 2021-04-20T02:11:51.034627+00:00 0:00:02.972507 19113 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T02:11:45.784374+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-20T01:00:00+00:00 PythonOperator 2021-04-20T02:11:36.028471+00:00 2021-04-20T02:11:39.187704+00:00 0:00:03.159233 19112 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T02:11:33.708505+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T01:00:00+00:00 TriggerDagRunOperator 2021-04-20T02:11:30.290199+00:00 2021-04-20T02:11:30.835594+00:00 0:00:00.545395 19111 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T02:11:27.553838+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T01:00:00+00:00 TriggerDagRunOperator 2021-04-20T02:11:30.097805+00:00 2021-04-20T02:11:30.502229+00:00 0:00:00.404424 19110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T02:11:27.553871+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-20T01:05:00+00:00 EmrJobFlowSensor 2021-04-20T02:05:48.991331+00:00 2021-04-20T02:13:51.528891+00:00 0:08:02.537560 19109 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T02:05:46.660627+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-20T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-20T02:05:26.896051+00:00 2021-04-20T02:05:28.667216+00:00 0:00:01.771165 19108 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T02:05:24.562967+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-20T01:05:00+00:00 PythonOperator 2021-04-20T02:05:06.628812+00:00 2021-04-20T02:05:09.488911+00:00 0:00:02.860099 19107 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T02:05:04.488579+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T01:00:00+00:00 EmrJobFlowSensor 2021-04-20T02:01:04.424458+00:00 2021-04-20T02:11:07.432856+00:00 0:10:03.008398 19106 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T02:01:02.012826+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T02:00:44.368232+00:00 2021-04-20T02:00:46.069777+00:00 0:00:01.701545 19105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T02:00:41.992572+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T01:00:00+00:00 PythonOperator 2021-04-20T02:00:22.568382+00:00 2021-04-20T02:00:25.606079+00:00 0:00:03.037697 19104 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T02:00:19.952825+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-20T00:00:00+00:00 EmrJobFlowSensor 2021-04-20T01:12:31.313694+00:00 2021-04-20T01:22:34.103514+00:00 0:10:02.789820 19102 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T01:12:28.956888+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-20T00:00:00+00:00 EmrJobFlowSensor 2021-04-20T01:12:13.286363+00:00 2021-04-20T01:21:15.870773+00:00 0:09:02.584410 19101 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T01:12:10.860611+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-20T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T01:12:09.247989+00:00 2021-04-20T01:12:10.952184+00:00 0:00:01.704195 19100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T01:12:06.855665+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-20T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T01:11:49.731696+00:00 2021-04-20T01:11:51.445385+00:00 0:00:01.713689 19099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T01:11:46.852234+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-20T00:00:00+00:00 PythonOperator 2021-04-20T01:11:45.219228+00:00 2021-04-20T01:11:49.194099+00:00 0:00:03.974871 19098 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T01:11:42.787151+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-20T00:00:00+00:00 PythonOperator 2021-04-20T01:11:26.918319+00:00 2021-04-20T01:11:29.843472+00:00 0:00:02.925153 19097 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T01:11:24.735855+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-20T00:00:00+00:00 TriggerDagRunOperator 2021-04-20T01:11:17.006032+00:00 2021-04-20T01:11:17.594141+00:00 0:00:00.588109 19096 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T01:11:14.730866+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-20T00:00:00+00:00 TriggerDagRunOperator 2021-04-20T01:11:16.979705+00:00 2021-04-20T01:11:17.409800+00:00 0:00:00.430095 19095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T01:11:14.730896+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-20T00:05:00+00:00 EmrJobFlowSensor 2021-04-20T01:05:56.504938+00:00 2021-04-20T01:14:59.042903+00:00 0:09:02.537965 19094 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T01:05:54.405653+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-20T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-20T01:05:28.598895+00:00 2021-04-20T01:05:30.288252+00:00 0:00:01.689357 19093 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T01:05:26.383879+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-20T00:05:00+00:00 PythonOperator 2021-04-20T01:05:06.695920+00:00 2021-04-20T01:05:09.626312+00:00 0:00:02.930392 19092 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T01:05:04.365967+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-20T00:00:00+00:00 EmrJobFlowSensor 2021-04-20T01:01:04.128268+00:00 2021-04-20T01:11:06.925983+00:00 0:10:02.797715 19091 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T01:01:01.950919+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-20T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T01:00:42.096559+00:00 2021-04-20T01:00:43.804141+00:00 0:00:01.707582 19090 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T01:00:39.930335+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-20T00:00:00+00:00 PythonOperator 2021-04-20T01:00:20.936169+00:00 2021-04-20T01:00:23.894221+00:00 0:00:02.958052 19089 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T01:00:17.903169+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T23:00:00+00:00 EmrJobFlowSensor 2021-04-20T00:12:43.905851+00:00 2021-04-20T00:20:46.452703+00:00 0:08:02.546852 19087 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T00:12:41.696105+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T23:00:00+00:00 EmrJobFlowSensor 2021-04-20T00:12:25.806664+00:00 2021-04-20T00:21:28.345352+00:00 0:09:02.538688 19086 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T00:12:23.633582+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T00:12:13.814587+00:00 2021-04-20T00:12:15.568130+00:00 0:00:01.753543 19085 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T00:12:11.643638+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T00:12:04.438277+00:00 2021-04-20T00:12:06.473578+00:00 0:00:02.035301 19084 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T00:12:01.615593+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T23:00:00+00:00 PythonOperator 2021-04-20T00:11:42.316006+00:00 2021-04-20T00:11:45.250346+00:00 0:00:02.934340 19083 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T00:11:39.640920+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T23:00:00+00:00 PythonOperator 2021-04-20T00:11:38.168561+00:00 2021-04-20T00:11:42.054714+00:00 0:00:03.886153 19082 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T00:11:35.597313+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T23:00:00+00:00 TriggerDagRunOperator 2021-04-20T00:11:24.231272+00:00 2021-04-20T00:11:24.857907+00:00 0:00:00.626635 19081 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T00:11:21.581135+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T23:00:00+00:00 TriggerDagRunOperator 2021-04-20T00:11:24.213200+00:00 2021-04-20T00:11:24.626724+00:00 0:00:00.413524 19080 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T00:11:21.581185+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T23:05:00+00:00 EmrJobFlowSensor 2021-04-20T00:06:03.279271+00:00 2021-04-20T00:14:05.776209+00:00 0:08:02.496938 19079 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-20T00:06:00.931052+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-20T00:05:41.403606+00:00 2021-04-20T00:05:43.159952+00:00 0:00:01.756346 19078 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-20T00:05:38.968420+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T23:05:00+00:00 PythonOperator 2021-04-20T00:05:19.100981+00:00 2021-04-20T00:05:22.170600+00:00 0:00:03.069619 19077 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T00:05:16.897348+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T23:00:00+00:00 EmrJobFlowSensor 2021-04-20T00:01:04.981492+00:00 2021-04-20T00:11:07.836437+00:00 0:10:02.854945 19076 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-20T00:01:02.374088+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-20T00:00:42.680556+00:00 2021-04-20T00:00:44.352852+00:00 0:00:01.672296 19075 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-20T00:00:40.362545+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T23:00:00+00:00 PythonOperator 2021-04-20T00:00:22.665736+00:00 2021-04-20T00:00:25.649786+00:00 0:00:02.984050 19074 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-20T00:00:20.226807+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T22:00:00+00:00 EmrJobFlowSensor 2021-04-19T23:10:04.486926+00:00 2021-04-19T23:20:08.163781+00:00 0:10:03.676855 19072 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T23:10:02.318639+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T22:00:00+00:00 EmrJobFlowSensor 2021-04-19T23:09:56.796067+00:00 2021-04-19T23:30:00.728790+00:00 0:20:03.932723 19071 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T23:09:54.307222+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T23:09:42.497959+00:00 2021-04-19T23:09:44.199882+00:00 0:00:01.701923 19070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T23:09:40.291659+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T23:09:34.555836+00:00 2021-04-19T23:09:36.730425+00:00 0:00:02.174589 19069 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T23:09:32.287123+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T22:00:00+00:00 PythonOperator 2021-04-19T23:09:20.726059+00:00 2021-04-19T23:09:24.019610+00:00 0:00:03.293551 19068 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T23:09:18.264358+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T22:00:00+00:00 PythonOperator 2021-04-19T23:09:12.473658+00:00 2021-04-19T23:09:15.418619+00:00 0:00:02.944961 19067 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T23:09:10.186963+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T22:00:00+00:00 TriggerDagRunOperator 2021-04-19T23:09:06.872388+00:00 2021-04-19T23:09:07.417475+00:00 0:00:00.545087 19066 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T23:09:04.252979+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T22:00:00+00:00 TriggerDagRunOperator 2021-04-19T23:09:06.679289+00:00 2021-04-19T23:09:07.111923+00:00 0:00:00.432634 19065 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T23:09:04.253016+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T22:05:00+00:00 EmrJobFlowSensor 2021-04-19T23:05:54.180881+00:00 2021-04-19T23:14:56.707275+00:00 0:09:02.526394 19064 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T23:05:51.987604+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T23:05:32.076177+00:00 2021-04-19T23:05:33.989016+00:00 0:00:01.912839 19063 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T23:05:29.958218+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T22:05:00+00:00 PythonOperator 2021-04-19T23:05:06.050453+00:00 2021-04-19T23:05:08.937015+00:00 0:00:02.886562 19062 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T23:05:03.934832+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T22:00:00+00:00 EmrJobFlowSensor 2021-04-19T23:00:56.021079+00:00 2021-04-19T23:08:58.759592+00:00 0:08:02.738513 19061 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T23:00:53.603233+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T23:00:34.084868+00:00 2021-04-19T23:00:35.768490+00:00 0:00:01.683622 19060 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T23:00:31.643524+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T22:00:00+00:00 PythonOperator 2021-04-19T23:00:14.459058+00:00 2021-04-19T23:00:17.512031+00:00 0:00:03.052973 19059 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T23:00:11.567679+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T21:00:00+00:00 EmrJobFlowSensor 2021-04-19T22:23:12.676852+00:00 2021-04-19T22:31:15.214628+00:00 0:08:02.537776 19057 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T22:23:10.491270+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T21:00:00+00:00 EmrJobFlowSensor 2021-04-19T22:23:00.921021+00:00 2021-04-19T22:32:03.582816+00:00 0:09:02.661795 19056 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T22:22:58.570033+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T22:22:47.062506+00:00 2021-04-19T22:22:48.814166+00:00 0:00:01.751660 19055 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T22:22:44.468197+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T22:22:38.657414+00:00 2021-04-19T22:22:40.394740+00:00 0:00:01.737326 19054 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T22:22:36.459844+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T21:00:00+00:00 PythonOperator 2021-04-19T22:22:25.034523+00:00 2021-04-19T22:22:28.098720+00:00 0:00:03.064197 19053 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T22:22:22.544213+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T21:00:00+00:00 PythonOperator 2021-04-19T22:22:16.857607+00:00 2021-04-19T22:22:20.119296+00:00 0:00:03.261689 19052 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T22:22:14.451476+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T21:00:00+00:00 TriggerDagRunOperator 2021-04-19T22:22:09.289446+00:00 2021-04-19T22:22:09.744987+00:00 0:00:00.455541 19051 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T22:22:06.487483+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T21:00:00+00:00 TriggerDagRunOperator 2021-04-19T22:22:09.174251+00:00 2021-04-19T22:22:09.750249+00:00 0:00:00.575998 19050 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T22:22:06.487519+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T21:05:00+00:00 EmrJobFlowSensor 2021-04-19T22:06:03.502145+00:00 2021-04-19T22:15:06.154586+00:00 0:09:02.652441 19049 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T22:06:01.052802+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T22:05:41.304430+00:00 2021-04-19T22:05:43.062793+00:00 0:00:01.758363 19048 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T22:05:39.045867+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T21:05:00+00:00 PythonOperator 2021-04-19T22:05:15.145073+00:00 2021-04-19T22:05:18.324962+00:00 0:00:03.179889 19047 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T22:05:12.909943+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T21:00:00+00:00 EmrJobFlowSensor 2021-04-19T22:00:56.760100+00:00 2021-04-19T22:22:01.135373+00:00 0:21:04.375273 19046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T22:00:54.503426+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T22:00:34.970495+00:00 2021-04-19T22:00:36.807104+00:00 0:00:01.836609 19045 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T22:00:32.482755+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T21:00:00+00:00 PythonOperator 2021-04-19T22:00:12.769754+00:00 2021-04-19T22:00:15.972792+00:00 0:00:03.203038 19044 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T22:00:10.448055+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T20:00:00+00:00 EmrJobFlowSensor 2021-04-19T21:12:50.673324+00:00 2021-04-19T21:21:53.290279+00:00 0:09:02.616955 19042 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T21:12:48.391633+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T20:00:00+00:00 EmrJobFlowSensor 2021-04-19T21:12:42.709156+00:00 2021-04-19T21:21:45.228914+00:00 0:09:02.519758 19041 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T21:12:40.390250+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T21:12:28.604052+00:00 2021-04-19T21:12:30.315587+00:00 0:00:01.711535 19040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T21:12:26.375946+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T21:12:22.657956+00:00 2021-04-19T21:12:24.474163+00:00 0:00:01.816207 19039 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T21:12:20.326612+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T20:00:00+00:00 PythonOperator 2021-04-19T21:12:06.576139+00:00 2021-04-19T21:12:09.787977+00:00 0:00:03.211838 19038 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T21:12:04.315032+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T20:00:00+00:00 PythonOperator 2021-04-19T21:11:56.628319+00:00 2021-04-19T21:12:00.220496+00:00 0:00:03.592177 19037 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T21:11:54.305768+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T20:00:00+00:00 TriggerDagRunOperator 2021-04-19T21:11:38.957037+00:00 2021-04-19T21:11:39.465407+00:00 0:00:00.508370 19036 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T21:11:36.361330+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T20:00:00+00:00 TriggerDagRunOperator 2021-04-19T21:11:38.797550+00:00 2021-04-19T21:11:39.224248+00:00 0:00:00.426698 19035 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T21:11:36.361287+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T20:05:00+00:00 EmrJobFlowSensor 2021-04-19T21:06:02.294740+00:00 2021-04-19T21:15:05.064691+00:00 0:09:02.769951 19034 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T21:05:59.951932+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T21:05:40.145315+00:00 2021-04-19T21:05:42.142235+00:00 0:00:01.996920 19033 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T21:05:37.850932+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T20:05:00+00:00 PythonOperator 2021-04-19T21:05:19.998164+00:00 2021-04-19T21:05:22.903159+00:00 0:00:02.904995 19032 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T21:05:17.788281+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T20:00:00+00:00 EmrJobFlowSensor 2021-04-19T21:01:11.833517+00:00 2021-04-19T21:11:14.818857+00:00 0:10:02.985340 19031 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T21:01:09.447668+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T21:00:45.722914+00:00 2021-04-19T21:00:47.522449+00:00 0:00:01.799535 19030 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T21:00:43.417480+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T20:00:00+00:00 PythonOperator 2021-04-19T21:00:25.792032+00:00 2021-04-19T21:00:28.831742+00:00 0:00:03.039710 19029 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T21:00:23.401827+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T19:00:00+00:00 EmrJobFlowSensor 2021-04-19T20:11:16.372121+00:00 2021-04-19T20:21:19.178972+00:00 0:10:02.806851 19027 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T20:11:14.182579+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T19:00:00+00:00 EmrJobFlowSensor 2021-04-19T20:11:06.432909+00:00 2021-04-19T20:30:10.564296+00:00 0:19:04.131387 19026 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T20:11:04.164053+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T20:10:54.320898+00:00 2021-04-19T20:10:56.763935+00:00 0:00:02.443037 19025 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T20:10:52.156982+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-19T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T20:10:44.619202+00:00 2021-04-19T20:10:46.452352+00:00 0:00:01.833150 19024 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T20:10:42.149073+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-19T19:00:00+00:00 PythonOperator 2021-04-19T20:10:34.563225+00:00 2021-04-19T20:10:37.776036+00:00 0:00:03.212811 19023 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T20:10:32.101361+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-19T19:00:00+00:00 PythonOperator 2021-04-19T20:10:22.552019+00:00 2021-04-19T20:10:25.620566+00:00 0:00:03.068547 19022 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T20:10:20.150075+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T19:00:00+00:00 TriggerDagRunOperator 2021-04-19T20:10:16.695580+00:00 2021-04-19T20:10:17.218094+00:00 0:00:00.522514 19021 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T20:10:14.160177+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T19:00:00+00:00 TriggerDagRunOperator 2021-04-19T20:10:16.525454+00:00 2021-04-19T20:10:16.957900+00:00 0:00:00.432446 19020 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T20:10:14.160124+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-19T19:05:00+00:00 EmrJobFlowSensor 2021-04-19T20:06:02.043333+00:00 2021-04-19T20:15:04.800690+00:00 0:09:02.757357 19019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T20:05:59.662478+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-19T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-19T20:05:39.959930+00:00 2021-04-19T20:05:41.736671+00:00 0:00:01.776741 19018 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T20:05:37.655916+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-19T19:05:00+00:00 PythonOperator 2021-04-19T20:05:09.783639+00:00 2021-04-19T20:05:12.893955+00:00 0:00:03.110316 19017 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T20:05:07.531803+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T19:00:00+00:00 EmrJobFlowSensor 2021-04-19T20:00:55.569992+00:00 2021-04-19T20:09:58.137533+00:00 0:09:02.567541 19016 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T20:00:53.160326+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T20:00:33.326206+00:00 2021-04-19T20:00:35.190965+00:00 0:00:01.864759 19015 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T20:00:31.074240+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T19:00:00+00:00 PythonOperator 2021-04-19T20:00:11.658509+00:00 2021-04-19T20:00:14.837246+00:00 0:00:03.178737 19014 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T20:00:09.046567+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-19T18:00:00+00:00 EmrJobFlowSensor 2021-04-19T19:11:00.805866+00:00 2021-04-19T19:19:03.474364+00:00 0:08:02.668498 19012 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T19:10:57.660570+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-19T18:00:00+00:00 EmrJobFlowSensor 2021-04-19T19:11:00.712502+00:00 2021-04-19T19:20:03.504687+00:00 0:09:02.792185 19011 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T19:10:57.660620+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-19T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T19:10:38.138610+00:00 2021-04-19T19:10:39.888638+00:00 0:00:01.750028 19010 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-19T19:10:35.563761+00:00 2 default_pool