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 create_cluster_and_add_emr_steps 2021-04-08T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T01:05:44.343515+00:00 2021-04-08T01:05:46.021682+00:00 0:00:01.678167 14751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T01:05:41.837226+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T00:05:00+00:00 PythonOperator 2021-04-08T01:05:22.033571+00:00 2021-04-08T01:05:24.818285+00:00 0:00:02.784714 14750 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T01:05:19.816885+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T00:00:00+00:00 EmrJobFlowSensor 2021-04-08T01:01:01.747149+00:00 2021-04-08T01:10:04.475623+00:00 0:09:02.728474 14749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T01:00:59.473659+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T01:00:37.693638+00:00 2021-04-08T01:00:39.377031+00:00 0:00:01.683393 14748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T01:00:35.404663+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T00:00:00+00:00 PythonOperator 2021-04-08T01:00:16.020460+00:00 2021-04-08T01:00:18.752730+00:00 0:00:02.732270 14747 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T01:00:13.340732+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T23:00:00+00:00 EmrJobFlowSensor 2021-04-08T00:11:23.733717+00:00 2021-04-08T00:19:26.373033+00:00 0:08:02.639316 14745 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T00:11:21.151742+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T23:00:00+00:00 EmrJobFlowSensor 2021-04-08T00:11:13.321552+00:00 2021-04-08T00:20:16.209252+00:00 0:09:02.887700 14744 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T00:11:11.092939+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T00:11:03.903204+00:00 2021-04-08T00:11:05.638216+00:00 0:00:01.735012 14743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T00:11:01.063006+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T00:10:51.219606+00:00 2021-04-08T00:10:52.957021+00:00 0:00:01.737415 14742 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T00:10:49.054376+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T23:00:00+00:00 PythonOperator 2021-04-08T00:10:27.720246+00:00 2021-04-08T00:10:30.414762+00:00 0:00:02.694516 14741 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T00:10:25.046154+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T23:00:00+00:00 PythonOperator 2021-04-08T00:10:23.775487+00:00 2021-04-08T00:10:27.152786+00:00 0:00:03.377299 14740 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T00:10:21.144177+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T23:00:00+00:00 TriggerDagRunOperator 2021-04-08T00:10:17.710542+00:00 2021-04-08T00:10:18.245700+00:00 0:00:00.535158 14739 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T00:10:15.072196+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T23:00:00+00:00 TriggerDagRunOperator 2021-04-08T00:10:17.539391+00:00 2021-04-08T00:10:17.944407+00:00 0:00:00.405016 14738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T00:10:15.072235+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T23:05:00+00:00 EmrJobFlowSensor 2021-04-08T00:05:51.139227+00:00 2021-04-08T00:14:53.650028+00:00 0:09:02.510801 14737 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T00:05:48.753772+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T00:05:31.187441+00:00 2021-04-08T00:05:32.830850+00:00 0:00:01.643409 14736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T00:05:28.744080+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T23:05:00+00:00 PythonOperator 2021-04-08T00:05:08.890413+00:00 2021-04-08T00:05:11.657580+00:00 0:00:02.767167 14735 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T00:05:06.518259+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T23:00:00+00:00 EmrJobFlowSensor 2021-04-08T00:00:54.576508+00:00 2021-04-08T00:09:57.415698+00:00 0:09:02.839190 14734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T00:00:52.099732+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T00:00:32.299414+00:00 2021-04-08T00:00:34.046353+00:00 0:00:01.746939 14733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T00:00:30.082625+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T23:00:00+00:00 PythonOperator 2021-04-08T00:00:04.714600+00:00 2021-04-08T00:00:07.455527+00:00 0:00:02.740927 14732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T00:00:02.077902+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T22:00:00+00:00 EmrJobFlowSensor 2021-04-07T23:11:41.336643+00:00 2021-04-07T23:21:44.038648+00:00 0:10:02.702005 14730 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T23:11:38.424420+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T22:00:00+00:00 EmrJobFlowSensor 2021-04-07T23:11:39.243875+00:00 2021-04-07T23:20:42.096311+00:00 0:09:02.852436 14729 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T23:11:36.425154+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T23:11:19.348995+00:00 2021-04-07T23:11:21.034276+00:00 0:00:01.685281 14728 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T23:11:16.465799+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T23:11:17.047413+00:00 2021-04-07T23:11:19.157648+00:00 0:00:02.110235 14727 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T23:11:14.475977+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T22:00:00+00:00 PythonOperator 2021-04-07T23:10:57.135317+00:00 2021-04-07T23:10:59.830025+00:00 0:00:02.694708 14726 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T23:10:54.387875+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T22:00:00+00:00 PythonOperator 2021-04-07T23:10:54.657149+00:00 2021-04-07T23:10:58.017268+00:00 0:00:03.360119 14725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T23:10:52.387856+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T22:00:00+00:00 TriggerDagRunOperator 2021-04-07T23:10:34.630654+00:00 2021-04-07T23:10:35.091523+00:00 0:00:00.460869 14724 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T23:10:32.368493+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T22:00:00+00:00 TriggerDagRunOperator 2021-04-07T23:10:34.627738+00:00 2021-04-07T23:10:35.191776+00:00 0:00:00.564038 14723 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T23:10:32.368531+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T22:05:00+00:00 EmrJobFlowSensor 2021-04-07T23:06:04.696049+00:00 2021-04-07T23:15:07.365788+00:00 0:09:02.669739 14722 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T23:06:01.931130+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T23:05:42.172512+00:00 2021-04-07T23:05:43.815591+00:00 0:00:01.643079 14721 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T23:05:39.905876+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T22:05:00+00:00 PythonOperator 2021-04-07T23:05:20.236506+00:00 2021-04-07T23:05:22.953887+00:00 0:00:02.717381 14720 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T23:05:17.956125+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T22:00:00+00:00 EmrJobFlowSensor 2021-04-07T23:01:07.522893+00:00 2021-04-07T23:10:10.353374+00:00 0:09:02.830481 14719 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T23:01:05.210021+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T23:00:45.417531+00:00 2021-04-07T23:00:47.145592+00:00 0:00:01.728061 14718 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T23:00:43.192369+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T22:00:00+00:00 PythonOperator 2021-04-07T23:00:25.401283+00:00 2021-04-07T23:00:28.202873+00:00 0:00:02.801590 14717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T23:00:23.085870+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T21:00:00+00:00 EmrJobFlowSensor 2021-04-07T22:10:13.623451+00:00 2021-04-07T22:19:16.251810+00:00 0:09:02.628359 14715 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T22:10:11.357397+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T21:00:00+00:00 EmrJobFlowSensor 2021-04-07T22:10:07.643409+00:00 2021-04-07T22:19:10.358200+00:00 0:09:02.714791 14714 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T22:10:05.282338+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T22:09:51.410132+00:00 2021-04-07T22:09:53.084951+00:00 0:00:01.674819 14713 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T22:09:49.262591+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T22:09:47.508726+00:00 2021-04-07T22:09:49.299205+00:00 0:00:01.790479 14712 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T22:09:45.261410+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T21:00:00+00:00 PythonOperator 2021-04-07T22:09:31.810144+00:00 2021-04-07T22:09:34.866130+00:00 0:00:03.055986 14711 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T22:09:29.257896+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T21:00:00+00:00 PythonOperator 2021-04-07T22:09:25.492903+00:00 2021-04-07T22:09:28.375290+00:00 0:00:02.882387 14710 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T22:09:23.201959+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T21:00:00+00:00 TriggerDagRunOperator 2021-04-07T22:09:11.643471+00:00 2021-04-07T22:09:12.193643+00:00 0:00:00.550172 14709 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T22:09:09.192921+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T21:00:00+00:00 TriggerDagRunOperator 2021-04-07T22:09:11.593429+00:00 2021-04-07T22:09:12.006216+00:00 0:00:00.412787 14708 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T22:09:09.192985+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T21:05:00+00:00 EmrJobFlowSensor 2021-04-07T22:06:07.088204+00:00 2021-04-07T22:14:09.500766+00:00 0:08:02.412562 14707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T22:06:04.957676+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T22:05:43.175454+00:00 2021-04-07T22:05:44.873846+00:00 0:00:01.698392 14706 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T22:05:40.895137+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T21:05:00+00:00 PythonOperator 2021-04-07T22:05:21.114392+00:00 2021-04-07T22:05:23.817242+00:00 0:00:02.702850 14705 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T22:05:18.822647+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T21:00:00+00:00 EmrJobFlowSensor 2021-04-07T22:01:01.041002+00:00 2021-04-07T22:09:03.843829+00:00 0:08:02.802827 14704 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T22:00:58.578737+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T22:00:38.979827+00:00 2021-04-07T22:00:40.686889+00:00 0:00:01.707062 14703 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T22:00:36.440828+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T21:00:00+00:00 PythonOperator 2021-04-07T22:00:19.137978+00:00 2021-04-07T22:00:21.913055+00:00 0:00:02.775077 14702 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T22:00:16.369494+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T20:00:00+00:00 EmrJobFlowSensor 2021-04-07T21:12:06.424616+00:00 2021-04-07T21:22:09.254491+00:00 0:10:02.829875 14700 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T21:12:04.238082+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T20:00:00+00:00 EmrJobFlowSensor 2021-04-07T21:11:58.464134+00:00 2021-04-07T21:21:01.201840+00:00 0:09:02.737706 14699 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T21:11:56.159070+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T21:11:46.630294+00:00 2021-04-07T21:11:48.308742+00:00 0:00:01.678448 14698 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T21:11:44.163991+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T21:11:36.645856+00:00 2021-04-07T21:11:38.444260+00:00 0:00:01.798404 14697 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T21:11:34.174288+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T20:00:00+00:00 PythonOperator 2021-04-07T21:11:24.624484+00:00 2021-04-07T21:11:27.553116+00:00 0:00:02.928632 14696 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T21:11:22.159637+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T20:00:00+00:00 PythonOperator 2021-04-07T21:11:16.417898+00:00 2021-04-07T21:11:19.273992+00:00 0:00:02.856094 14695 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T21:11:14.095692+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T20:00:00+00:00 TriggerDagRunOperator 2021-04-07T21:11:00.853827+00:00 2021-04-07T21:11:01.311484+00:00 0:00:00.457657 14694 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T21:10:58.072125+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T20:00:00+00:00 TriggerDagRunOperator 2021-04-07T21:11:00.714154+00:00 2021-04-07T21:11:01.264214+00:00 0:00:00.550060 14693 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T21:10:58.072091+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T20:05:00+00:00 EmrJobFlowSensor 2021-04-07T21:05:54.017907+00:00 2021-04-07T21:14:56.507398+00:00 0:09:02.489491 14692 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T21:05:51.555504+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T20:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T21:05:31.859282+00:00 2021-04-07T21:05:33.521869+00:00 0:00:01.662587 14691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T21:05:29.551253+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T20:05:00+00:00 PythonOperator 2021-04-07T21:05:09.629695+00:00 2021-04-07T21:05:12.278978+00:00 0:00:02.649283 14690 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T21:05:07.436670+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T20:00:00+00:00 EmrJobFlowSensor 2021-04-07T21:01:51.323155+00:00 2021-04-07T21:10:54.000808+00:00 0:09:02.677653 14689 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T21:01:49.112667+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T21:01:29.780138+00:00 2021-04-07T21:01:31.549016+00:00 0:00:01.768878 14688 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T21:01:27.159823+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T20:00:00+00:00 PythonOperator 2021-04-07T21:01:09.653983+00:00 2021-04-07T21:01:12.545536+00:00 0:00:02.891553 14687 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T21:01:07.084024+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T19:00:00+00:00 EmrJobFlowSensor 2021-04-07T20:11:18.646722+00:00 2021-04-07T20:19:21.201984+00:00 0:08:02.555262 14685 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T20:11:16.174076+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T19:00:00+00:00 EmrJobFlowSensor 2021-04-07T20:11:12.493010+00:00 2021-04-07T20:22:15.695114+00:00 0:11:03.202104 14684 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T20:11:10.133860+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T20:10:58.472970+00:00 2021-04-07T20:11:00.194687+00:00 0:00:01.721717 14683 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T20:10:56.090986+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T20:10:52.314521+00:00 2021-04-07T20:10:54.241425+00:00 0:00:01.926904 14682 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T20:10:50.081262+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T19:00:00+00:00 PythonOperator 2021-04-07T20:10:36.273801+00:00 2021-04-07T20:10:38.968095+00:00 0:00:02.694294 14681 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T20:10:34.066766+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T19:00:00+00:00 PythonOperator 2021-04-07T20:10:30.552074+00:00 2021-04-07T20:10:33.528903+00:00 0:00:02.976829 14680 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T20:10:28.065226+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T19:00:00+00:00 TriggerDagRunOperator 2021-04-07T20:10:16.677943+00:00 2021-04-07T20:10:17.257546+00:00 0:00:00.579603 14679 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T20:10:14.061865+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T19:00:00+00:00 TriggerDagRunOperator 2021-04-07T20:10:16.476226+00:00 2021-04-07T20:10:16.903857+00:00 0:00:00.427631 14678 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T20:10:14.061813+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T19:05:00+00:00 EmrJobFlowSensor 2021-04-07T20:05:48.131261+00:00 2021-04-07T20:14:50.784345+00:00 0:09:02.653084 14677 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T20:05:45.744862+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T20:05:27.809265+00:00 2021-04-07T20:05:29.517573+00:00 0:00:01.708308 14676 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T20:05:25.651562+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T19:05:00+00:00 PythonOperator 2021-04-07T20:05:05.773936+00:00 2021-04-07T20:05:08.423472+00:00 0:00:02.649536 14675 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T20:05:03.584142+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T19:00:00+00:00 EmrJobFlowSensor 2021-04-07T20:00:59.515432+00:00 2021-04-07T20:10:02.155427+00:00 0:09:02.639995 14674 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T20:00:57.186833+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T20:00:39.655001+00:00 2021-04-07T20:00:41.466646+00:00 0:00:01.811645 14673 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T20:00:37.164904+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T19:00:00+00:00 PythonOperator 2021-04-07T20:00:15.552077+00:00 2021-04-07T20:00:18.300577+00:00 0:00:02.748500 14672 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T20:00:13.143100+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T18:00:00+00:00 EmrJobFlowSensor 2021-04-07T19:10:33.383672+00:00 2021-04-07T19:20:36.269503+00:00 0:10:02.885831 14670 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T19:10:31.152781+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T18:00:00+00:00 EmrJobFlowSensor 2021-04-07T19:10:31.411679+00:00 2021-04-07T19:19:34.136448+00:00 0:09:02.724769 14669 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T19:10:29.174872+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T19:10:11.308114+00:00 2021-04-07T19:10:13.116788+00:00 0:00:01.808674 14668 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T19:10:09.114313+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T19:10:09.387489+00:00 2021-04-07T19:10:11.114913+00:00 0:00:01.727424 14667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T19:10:07.116825+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T18:00:00+00:00 PythonOperator 2021-04-07T19:09:49.816494+00:00 2021-04-07T19:09:52.876142+00:00 0:00:03.059648 14666 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T19:09:47.102092+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T18:00:00+00:00 PythonOperator 2021-04-07T19:09:49.622129+00:00 2021-04-07T19:09:52.359347+00:00 0:00:02.737218 14665 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T19:09:47.102143+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T18:00:00+00:00 TriggerDagRunOperator 2021-04-07T19:09:35.579268+00:00 2021-04-07T19:09:36.094768+00:00 0:00:00.515500 14664 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T19:09:33.144106+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T18:00:00+00:00 TriggerDagRunOperator 2021-04-07T19:09:35.412941+00:00 2021-04-07T19:09:35.859532+00:00 0:00:00.446591 14663 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T19:09:33.144076+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T18:05:00+00:00 EmrJobFlowSensor 2021-04-07T19:06:16.882261+00:00 2021-04-07T19:15:19.496963+00:00 0:09:02.614702 14662 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T19:06:14.752870+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T19:05:49.022268+00:00 2021-04-07T19:05:50.747967+00:00 0:00:01.725699 14661 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T19:05:46.636734+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T18:05:00+00:00 PythonOperator 2021-04-07T19:05:24.754121+00:00 2021-04-07T19:05:27.459951+00:00 0:00:02.705830 14660 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T19:05:22.615898+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-07T18:00:00+00:00 EmrJobFlowSensor 2021-04-07T19:01:10.311730+00:00 2021-04-07T19:09:12.844726+00:00 0:08:02.532996 14659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T19:01:08.159847+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-07T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T19:00:44.564817+00:00 2021-04-07T19:00:46.372692+00:00 0:00:01.807875 14658 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-07T19:00:42.133849+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-07T18:00:00+00:00 PythonOperator 2021-04-07T19:00:14.495989+00:00 2021-04-07T19:00:17.246514+00:00 0:00:02.750525 14657 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-07T19:00:12.109685+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-07T17:00:00+00:00 EmrJobFlowSensor 2021-04-07T18:11:09.893582+00:00 2021-04-07T18:22:12.827109+00:00 0:11:02.933527 14655 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T18:11:07.675043+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-07T17:00:00+00:00 EmrJobFlowSensor 2021-04-07T18:10:55.862311+00:00 2021-04-07T18:19:58.443358+00:00 0:09:02.581047 14654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T18:10:53.602656+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-07T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T18:10:50.148475+00:00 2021-04-07T18:10:51.934596+00:00 0:00:01.786121 14653 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T18:10:47.597099+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-07T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-07T18:10:33.930004+00:00 2021-04-07T18:10:35.695533+00:00 0:00:01.765529 14652 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T18:10:31.585915+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-07T17:00:00+00:00 PythonOperator 2021-04-07T18:10:27.856334+00:00 2021-04-07T18:10:30.947672+00:00 0:00:03.091338 14651 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T18:10:25.545790+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-07T17:00:00+00:00 PythonOperator 2021-04-07T18:10:13.851731+00:00 2021-04-07T18:10:16.573404+00:00 0:00:02.721673 14650 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T18:10:11.535302+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-07T17:00:00+00:00 TriggerDagRunOperator 2021-04-07T18:10:08.255226+00:00 2021-04-07T18:10:08.819947+00:00 0:00:00.564721 14649 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T18:10:05.583622+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-07T17:00:00+00:00 TriggerDagRunOperator 2021-04-07T18:10:08.017473+00:00 2021-04-07T18:10:08.432552+00:00 0:00:00.415079 14648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T18:10:05.583593+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-07T17:05:00+00:00 EmrJobFlowSensor 2021-04-07T18:05:49.677285+00:00 2021-04-07T18:14:52.244951+00:00 0:09:02.567666 14647 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-07T18:05:47.344266+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-07T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-07T18:05:29.777645+00:00 2021-04-07T18:05:31.527467+00:00 0:00:01.749822 14646 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-07T18:05:27.270049+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-07T17:05:00+00:00 PythonOperator 2021-04-07T18:05:07.278024+00:00 2021-04-07T18:05:09.951342+00:00 0:00:02.673318 14645 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-07T18:05:05.168534+00:00 2 default_pool