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 campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T14:00:41.913613+00:00 2021-05-08T14:00:43.618601+00:00 0:00:01.704988 25841 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T14:00:39.817336+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T13:00:00+00:00 PythonOperator 2021-05-08T14:00:20.432517+00:00 2021-05-08T14:00:23.534752+00:00 0:00:03.102235 25840 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T14:00:17.862812+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-08T12:00:00+00:00 EmrJobFlowSensor 2021-05-08T13:11:19.136543+00:00 2021-05-08T13:22:22.409706+00:00 0:11:03.273163 25839 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T13:11:16.869203+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-08T12:00:00+00:00 EmrJobFlowSensor 2021-05-08T13:11:11.044967+00:00 2021-05-08T13:20:13.654447+00:00 0:09:02.609480 25838 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T13:11:08.881306+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T13:10:59.075252+00:00 2021-05-08T13:11:00.765862+00:00 0:00:01.690610 25837 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T13:10:56.840357+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T13:10:51.124148+00:00 2021-05-08T13:10:52.917352+00:00 0:00:01.793204 25836 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T13:10:48.833010+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T12:00:00+00:00 PythonOperator 2021-05-08T13:10:37.571906+00:00 2021-05-08T13:10:40.972961+00:00 0:00:03.401055 25835 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T13:10:34.820408+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T12:00:00+00:00 PythonOperator 2021-05-08T13:10:29.309527+00:00 2021-05-08T13:10:32.417705+00:00 0:00:03.108178 25834 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T13:10:26.818775+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T12:00:00+00:00 TriggerDagRunOperator 2021-05-08T13:10:17.210071+00:00 2021-05-08T13:10:17.749769+00:00 0:00:00.539698 25833 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T13:10:14.805667+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T12:00:00+00:00 TriggerDagRunOperator 2021-05-08T13:10:17.061732+00:00 2021-05-08T13:10:17.459046+00:00 0:00:00.397314 25832 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T13:10:14.805638+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T12:05:00+00:00 EmrJobFlowSensor 2021-05-08T13:06:04.697190+00:00 2021-05-08T13:14:07.215079+00:00 0:08:02.517889 25830 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T13:06:02.526862+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T12:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T13:05:40.750805+00:00 2021-05-08T13:05:42.424476+00:00 0:00:01.673671 25829 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T13:05:38.566260+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T12:05:00+00:00 PythonOperator 2021-05-08T13:05:20.611307+00:00 2021-05-08T13:05:23.643185+00:00 0:00:03.031878 25828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T13:05:18.488383+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T12:00:00+00:00 EmrJobFlowSensor 2021-05-08T13:00:54.334143+00:00 2021-05-08T13:09:56.980397+00:00 0:09:02.646254 25827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T13:00:51.954402+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T13:00:34.285297+00:00 2021-05-08T13:00:36.139197+00:00 0:00:01.853900 25826 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T13:00:31.861840+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T12:00:00+00:00 PythonOperator 2021-05-08T13:00:11.971339+00:00 2021-05-08T13:00:15.082289+00:00 0:00:03.110950 25825 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T13:00:09.803395+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-08T11:00:00+00:00 EmrJobFlowSensor 2021-05-08T12:10:12.808573+00:00 2021-05-08T12:18:15.290535+00:00 0:08:02.481962 25824 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T12:10:10.584821+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-08T11:00:00+00:00 EmrJobFlowSensor 2021-05-08T12:10:10.829764+00:00 2021-05-08T12:22:14.220248+00:00 0:12:03.390484 25823 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T12:10:08.583176+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T12:09:50.696527+00:00 2021-05-08T12:09:52.382766+00:00 0:00:01.686239 25822 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T12:09:48.537628+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T12:09:49.065091+00:00 2021-05-08T12:09:50.851009+00:00 0:00:01.785918 25821 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T12:09:46.543069+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T11:00:00+00:00 PythonOperator 2021-05-08T12:09:31.007776+00:00 2021-05-08T12:09:34.100505+00:00 0:00:03.092729 25820 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T12:09:28.524016+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T11:00:00+00:00 PythonOperator 2021-05-08T12:09:28.709958+00:00 2021-05-08T12:09:32.335325+00:00 0:00:03.625367 25819 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T12:09:26.527850+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T11:00:00+00:00 TriggerDagRunOperator 2021-05-08T12:09:06.903798+00:00 2021-05-08T12:09:07.428077+00:00 0:00:00.524279 25818 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T12:09:04.502611+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T11:00:00+00:00 TriggerDagRunOperator 2021-05-08T12:09:06.781553+00:00 2021-05-08T12:09:07.175161+00:00 0:00:00.393608 25817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T12:09:04.502647+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T11:05:00+00:00 EmrJobFlowSensor 2021-05-08T12:05:47.332702+00:00 2021-05-08T12:14:49.929628+00:00 0:09:02.596926 25815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T12:05:45.237634+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T11:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T12:05:25.644399+00:00 2021-05-08T12:05:27.275761+00:00 0:00:01.631362 25814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T12:05:23.277793+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T11:05:00+00:00 PythonOperator 2021-05-08T12:05:05.469512+00:00 2021-05-08T12:05:08.516233+00:00 0:00:03.046721 25813 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T12:05:03.272540+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T11:00:00+00:00 EmrJobFlowSensor 2021-05-08T12:00:46.990677+00:00 2021-05-08T12:08:49.572432+00:00 0:08:02.581755 25812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T12:00:44.758141+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T12:00:26.721725+00:00 2021-05-08T12:00:28.458405+00:00 0:00:01.736680 25811 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T12:00:24.604631+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T11:00:00+00:00 PythonOperator 2021-05-08T12:00:04.857680+00:00 2021-05-08T12:00:07.917500+00:00 0:00:03.059820 25810 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T12:00:02.589845+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-08T10:00:00+00:00 EmrJobFlowSensor 2021-05-08T11:11:12.055274+00:00 2021-05-08T11:21:14.901993+00:00 0:10:02.846719 25809 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T11:11:09.895367+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-08T10:00:00+00:00 EmrJobFlowSensor 2021-05-08T11:11:00.175813+00:00 2021-05-08T11:21:03.073143+00:00 0:10:02.897330 25808 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T11:10:57.956697+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T11:10:50.234600+00:00 2021-05-08T11:10:52.003363+00:00 0:00:01.768763 25807 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T11:10:47.879079+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T11:10:38.352545+00:00 2021-05-08T11:10:40.129467+00:00 0:00:01.776922 25806 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T11:10:35.871252+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T10:00:00+00:00 PythonOperator 2021-05-08T11:10:28.347320+00:00 2021-05-08T11:10:31.413902+00:00 0:00:03.066582 25805 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T11:10:25.871739+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T10:00:00+00:00 PythonOperator 2021-05-08T11:10:15.948144+00:00 2021-05-08T11:10:19.233357+00:00 0:00:03.285213 25804 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T11:10:13.810144+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T10:00:00+00:00 TriggerDagRunOperator 2021-05-08T11:10:04.314621+00:00 2021-05-08T11:10:04.847723+00:00 0:00:00.533102 25803 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T11:10:01.788041+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T10:00:00+00:00 TriggerDagRunOperator 2021-05-08T11:10:04.018034+00:00 2021-05-08T11:10:04.464583+00:00 0:00:00.446549 25802 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T11:10:01.788073+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T10:05:00+00:00 EmrJobFlowSensor 2021-05-08T11:08:43.801488+00:00 2021-05-08T11:16:46.235312+00:00 0:08:02.433824 25801 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T11:08:41.687339+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T10:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T11:08:23.685362+00:00 2021-05-08T11:08:25.467120+00:00 0:00:01.781758 25800 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T11:08:21.612277+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T10:05:00+00:00 PythonOperator 2021-05-08T11:08:01.916954+00:00 2021-05-08T11:08:04.996587+00:00 0:00:03.079633 25799 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T11:07:59.593592+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T10:00:00+00:00 EmrJobFlowSensor 2021-05-08T11:00:51.422783+00:00 2021-05-08T11:09:54.165243+00:00 0:09:02.742460 25797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T11:00:49.325258+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T11:00:29.880081+00:00 2021-05-08T11:00:31.678155+00:00 0:00:01.798074 25796 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T11:00:27.307395+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T10:00:00+00:00 PythonOperator 2021-05-08T11:00:07.424534+00:00 2021-05-08T11:00:10.495649+00:00 0:00:03.071115 25795 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T11:00:05.284886+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-08T09:00:00+00:00 EmrJobFlowSensor 2021-05-08T10:12:24.105573+00:00 2021-05-08T10:22:26.868770+00:00 0:10:02.763197 25794 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T10:12:21.976225+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-08T09:00:00+00:00 EmrJobFlowSensor 2021-05-08T10:12:16.206621+00:00 2021-05-08T10:21:19.086408+00:00 0:09:02.879787 25793 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T10:12:13.953677+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T10:11:54.133717+00:00 2021-05-08T10:11:55.852620+00:00 0:00:01.718903 25792 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T10:11:51.931794+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T10:11:50.161457+00:00 2021-05-08T10:11:51.842853+00:00 0:00:01.681396 25791 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T10:11:47.946508+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T09:00:00+00:00 PythonOperator 2021-05-08T10:11:28.653981+00:00 2021-05-08T10:11:31.685669+00:00 0:00:03.031688 25790 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T10:11:25.961587+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T09:00:00+00:00 PythonOperator 2021-05-08T10:11:28.295592+00:00 2021-05-08T10:11:31.564877+00:00 0:00:03.269285 25789 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T10:11:25.961517+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T09:00:00+00:00 TriggerDagRunOperator 2021-05-08T10:11:12.469174+00:00 2021-05-08T10:11:12.987810+00:00 0:00:00.518636 25788 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T10:11:09.954299+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T09:00:00+00:00 TriggerDagRunOperator 2021-05-08T10:11:12.404038+00:00 2021-05-08T10:11:12.800859+00:00 0:00:00.396821 25787 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T10:11:09.954268+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T09:05:00+00:00 EmrJobFlowSensor 2021-05-08T10:06:23.762848+00:00 2021-05-08T10:15:26.447153+00:00 0:09:02.684305 25786 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T10:06:21.502643+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T09:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T10:06:01.830025+00:00 2021-05-08T10:06:03.653213+00:00 0:00:01.823188 25785 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T10:05:59.543383+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T09:05:00+00:00 PythonOperator 2021-05-08T10:05:39.655104+00:00 2021-05-08T10:05:42.747610+00:00 0:00:03.092506 25784 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T10:05:37.439034+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T09:00:00+00:00 EmrJobFlowSensor 2021-05-08T10:01:04.357728+00:00 2021-05-08T10:11:07.222836+00:00 0:10:02.865108 25782 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T10:01:01.962436+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T10:00:42.092895+00:00 2021-05-08T10:00:43.749816+00:00 0:00:01.656921 25781 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T10:00:39.954103+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T09:00:00+00:00 PythonOperator 2021-05-08T10:00:20.114617+00:00 2021-05-08T10:00:23.171748+00:00 0:00:03.057131 25780 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T10:00:17.823962+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-08T08:00:00+00:00 EmrJobFlowSensor 2021-05-08T09:13:13.438743+00:00 2021-05-08T09:36:17.990643+00:00 0:23:04.551900 25779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T09:13:11.337283+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-08T08:00:00+00:00 EmrJobFlowSensor 2021-05-08T09:13:03.570737+00:00 2021-05-08T09:22:06.239821+00:00 0:09:02.669084 25778 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T09:13:01.329180+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T09:12:51.392505+00:00 2021-05-08T09:12:53.058779+00:00 0:00:01.666274 25777 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T09:12:49.301918+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T09:12:41.397340+00:00 2021-05-08T09:12:43.102647+00:00 0:00:01.705307 25776 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T09:12:39.295775+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T08:00:00+00:00 PythonOperator 2021-05-08T09:12:29.399894+00:00 2021-05-08T09:12:32.465737+00:00 0:00:03.065843 25775 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T09:12:27.203333+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T08:00:00+00:00 PythonOperator 2021-05-08T09:12:19.471855+00:00 2021-05-08T09:12:22.741960+00:00 0:00:03.270105 25774 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T09:12:17.265326+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T08:00:00+00:00 TriggerDagRunOperator 2021-05-08T09:12:13.489396+00:00 2021-05-08T09:12:14.037564+00:00 0:00:00.548168 25773 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T09:12:11.187215+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T08:00:00+00:00 TriggerDagRunOperator 2021-05-08T09:12:13.335323+00:00 2021-05-08T09:12:13.741872+00:00 0:00:00.406549 25772 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T09:12:11.187242+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T08:05:00+00:00 EmrJobFlowSensor 2021-05-08T09:06:12.749695+00:00 2021-05-08T09:15:15.357524+00:00 0:09:02.607829 25771 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T09:06:10.600746+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T08:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T09:05:50.683414+00:00 2021-05-08T09:05:52.316094+00:00 0:00:01.632680 25770 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T09:05:48.584227+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T08:05:00+00:00 PythonOperator 2021-05-08T09:05:24.910910+00:00 2021-05-08T09:05:27.929158+00:00 0:00:03.018248 25769 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T09:05:22.550052+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T08:00:00+00:00 EmrJobFlowSensor 2021-05-08T09:02:48.667166+00:00 2021-05-08T09:11:51.355571+00:00 0:09:02.688405 25768 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T09:02:46.381150+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T09:02:26.699661+00:00 2021-05-08T09:02:28.520560+00:00 0:00:01.820899 25767 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T09:02:24.307386+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T08:00:00+00:00 PythonOperator 2021-05-08T09:02:04.788290+00:00 2021-05-08T09:02:07.848892+00:00 0:00:03.060602 25766 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T09:02:02.286948+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-08T07:00:00+00:00 EmrJobFlowSensor 2021-05-08T08:12:04.669617+00:00 2021-05-08T08:21:07.395438+00:00 0:09:02.725821 25764 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T08:12:01.964892+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-08T07:00:00+00:00 EmrJobFlowSensor 2021-05-08T08:12:02.269355+00:00 2021-05-08T08:21:05.312199+00:00 0:09:03.042844 25763 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T08:11:59.963640+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T08:11:42.269473+00:00 2021-05-08T08:11:43.997468+00:00 0:00:01.727995 25762 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T08:11:39.893151+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T08:11:40.359251+00:00 2021-05-08T08:11:42.176130+00:00 0:00:01.816879 25761 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T08:11:37.964465+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T07:00:00+00:00 PythonOperator 2021-05-08T08:11:20.339298+00:00 2021-05-08T08:11:23.593128+00:00 0:00:03.253830 25760 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T08:11:17.878412+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T07:00:00+00:00 PythonOperator 2021-05-08T08:11:20.185304+00:00 2021-05-08T08:11:23.290815+00:00 0:00:03.105511 25759 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T08:11:17.878450+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T07:00:00+00:00 TriggerDagRunOperator 2021-05-08T08:11:04.947676+00:00 2021-05-08T08:11:05.461793+00:00 0:00:00.514117 25758 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T08:11:01.848225+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T07:00:00+00:00 TriggerDagRunOperator 2021-05-08T08:11:04.114747+00:00 2021-05-08T08:11:04.509567+00:00 0:00:00.394820 25757 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T08:11:01.848196+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T07:05:00+00:00 EmrJobFlowSensor 2021-05-08T08:06:05.737582+00:00 2021-05-08T08:14:08.166223+00:00 0:08:02.428641 25756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T08:06:03.549161+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T07:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T08:05:43.580473+00:00 2021-05-08T08:05:45.206438+00:00 0:00:01.625965 25755 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T08:05:41.466774+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T07:05:00+00:00 PythonOperator 2021-05-08T08:05:23.575349+00:00 2021-05-08T08:05:26.655430+00:00 0:00:03.080081 25754 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T08:05:21.448750+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T07:00:00+00:00 EmrJobFlowSensor 2021-05-08T08:00:57.416377+00:00 2021-05-08T08:11:00.457750+00:00 0:10:03.041373 25753 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T08:00:55.115969+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T08:00:35.712040+00:00 2021-05-08T08:00:37.532846+00:00 0:00:01.820806 25752 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T08:00:33.160680+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T07:00:00+00:00 PythonOperator 2021-05-08T08:00:16.038476+00:00 2021-05-08T08:00:19.170920+00:00 0:00:03.132444 25751 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T08:00:13.147682+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-08T06:00:00+00:00 EmrJobFlowSensor 2021-05-08T07:12:09.158569+00:00 2021-05-08T07:21:11.891756+00:00 0:09:02.733187 25749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T07:12:06.689376+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-08T06:00:00+00:00 EmrJobFlowSensor 2021-05-08T07:12:04.953412+00:00 2021-05-08T07:21:07.705284+00:00 0:09:02.751872 25748 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T07:12:02.686876+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-08T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T07:11:46.863746+00:00 2021-05-08T07:11:48.676373+00:00 0:00:01.812627 25747 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T07:11:44.613844+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-08T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T07:11:42.819002+00:00 2021-05-08T07:11:44.508495+00:00 0:00:01.689493 25746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T07:11:40.593947+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-08T06:00:00+00:00 PythonOperator 2021-05-08T07:11:25.216520+00:00 2021-05-08T07:11:28.313213+00:00 0:00:03.096693 25745 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T07:11:22.576397+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-08T06:00:00+00:00 PythonOperator 2021-05-08T07:11:21.064014+00:00 2021-05-08T07:11:24.401676+00:00 0:00:03.337662 25744 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T07:11:18.544050+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-08T06:00:00+00:00 TriggerDagRunOperator 2021-05-08T07:11:12.759871+00:00 2021-05-08T07:11:13.329233+00:00 0:00:00.569362 25743 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T07:11:10.435712+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-08T06:00:00+00:00 TriggerDagRunOperator 2021-05-08T07:11:12.708738+00:00 2021-05-08T07:11:13.102222+00:00 0:00:00.393484 25742 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T07:11:10.435739+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-08T06:05:00+00:00 EmrJobFlowSensor 2021-05-08T07:05:51.958462+00:00 2021-05-08T07:14:54.486479+00:00 0:09:02.528017 25741 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-08T07:05:49.895753+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-08T06:05:00+00:00 EmrCreateJobFlowOperator 2021-05-08T07:05:30.186461+00:00 2021-05-08T07:05:31.944131+00:00 0:00:01.757670 25740 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-08T07:05:27.882703+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-08T06:05:00+00:00 PythonOperator 2021-05-08T07:05:10.069329+00:00 2021-05-08T07:05:13.123608+00:00 0:00:03.054279 25739 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T07:05:07.856847+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-08T06:00:00+00:00 EmrJobFlowSensor 2021-05-08T07:00:51.349166+00:00 2021-05-08T07:10:54.122088+00:00 0:10:02.772922 25738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-08T07:00:49.188408+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-08T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-08T07:00:31.396485+00:00 2021-05-08T07:00:33.086893+00:00 0:00:01.690408 25737 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-08T07:00:29.146971+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-08T06:00:00+00:00 PythonOperator 2021-05-08T07:00:10.190848+00:00 2021-05-08T07:00:13.316062+00:00 0:00:03.125214 25736 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-08T07:00:07.066708+00:00 2 default_pool