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-history-job_v002 check_cluster_status 2021-04-02T17:00:00+00:00 EmrJobFlowSensor 2021-04-02T18:12:31.570615+00:00 2021-04-02T18:21:34.352236+00:00 0:09:02.781621 12850 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T18:12:29.244126+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T18:12:13.367319+00:00 2021-04-02T18:12:15.226331+00:00 0:00:01.859012 12849 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T18:12:11.091553+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T18:12:09.515548+00:00 2021-04-02T18:12:11.255636+00:00 0:00:01.740088 12848 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T18:12:07.157848+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T17:00:00+00:00 PythonOperator 2021-04-02T18:11:53.197037+00:00 2021-04-02T18:11:56.103973+00:00 0:00:02.906936 12847 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T18:11:51.036384+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T17:00:00+00:00 PythonOperator 2021-04-02T18:11:47.282708+00:00 2021-04-02T18:11:50.145029+00:00 0:00:02.862321 12846 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T18:11:45.077476+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T17:00:00+00:00 TriggerDagRunOperator 2021-04-02T18:11:29.483618+00:00 2021-04-02T18:11:30.024138+00:00 0:00:00.540520 12845 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T18:11:27.010492+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T17:00:00+00:00 TriggerDagRunOperator 2021-04-02T18:11:29.205336+00:00 2021-04-02T18:11:29.683369+00:00 0:00:00.478033 12844 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T18:11:27.010519+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T17:05:00+00:00 EmrJobFlowSensor 2021-04-02T18:05:54.904096+00:00 2021-04-02T18:14:57.492399+00:00 0:09:02.588303 12843 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T18:05:52.543836+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T18:05:35.127867+00:00 2021-04-02T18:05:36.842812+00:00 0:00:01.714945 12842 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T18:05:32.491719+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T17:05:00+00:00 PythonOperator 2021-04-02T18:05:10.888203+00:00 2021-04-02T18:05:13.589710+00:00 0:00:02.701507 12841 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T18:05:08.490464+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T17:00:00+00:00 EmrJobFlowSensor 2021-04-02T18:01:04.536764+00:00 2021-04-02T18:11:07.389877+00:00 0:10:02.853113 12840 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T18:01:02.185583+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T18:00:42.447669+00:00 2021-04-02T18:00:44.264936+00:00 0:00:01.817267 12839 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T18:00:40.143616+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T17:00:00+00:00 PythonOperator 2021-04-02T18:00:22.660492+00:00 2021-04-02T18:00:25.532310+00:00 0:00:02.871818 12838 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T18:00:20.035276+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T16:00:00+00:00 EmrJobFlowSensor 2021-04-02T17:12:48.816612+00:00 2021-04-02T17:21:51.488628+00:00 0:09:02.672016 12836 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T17:12:46.640811+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T16:00:00+00:00 EmrJobFlowSensor 2021-04-02T17:12:46.910228+00:00 2021-04-02T17:21:49.635253+00:00 0:09:02.725025 12835 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T17:12:44.641409+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T17:12:26.856290+00:00 2021-04-02T17:12:28.620948+00:00 0:00:01.764658 12834 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T17:12:24.622378+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T17:12:24.785835+00:00 2021-04-02T17:12:26.470760+00:00 0:00:01.684925 12833 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T17:12:22.621639+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T16:00:00+00:00 PythonOperator 2021-04-02T17:12:05.138555+00:00 2021-04-02T17:12:07.965024+00:00 0:00:02.826469 12832 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T17:12:02.676258+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T16:00:00+00:00 PythonOperator 2021-04-02T17:12:03.011228+00:00 2021-04-02T17:12:05.973881+00:00 0:00:02.962653 12831 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T17:12:00.662388+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T16:00:00+00:00 TriggerDagRunOperator 2021-04-02T17:11:40.866091+00:00 2021-04-02T17:11:41.393569+00:00 0:00:00.527478 12830 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T17:11:38.593507+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T16:00:00+00:00 TriggerDagRunOperator 2021-04-02T17:11:40.853763+00:00 2021-04-02T17:11:41.255276+00:00 0:00:00.401513 12829 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T17:11:38.593539+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T16:05:00+00:00 EmrJobFlowSensor 2021-04-02T17:05:54.234174+00:00 2021-04-02T17:14:56.726254+00:00 0:09:02.492080 12828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T17:05:51.984605+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T17:05:34.094718+00:00 2021-04-02T17:05:35.707681+00:00 0:00:01.612963 12827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T17:05:31.925216+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T16:05:00+00:00 PythonOperator 2021-04-02T17:05:11.999255+00:00 2021-04-02T17:05:14.675910+00:00 0:00:02.676655 12826 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T17:05:09.903794+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T16:00:00+00:00 EmrJobFlowSensor 2021-04-02T17:01:07.818691+00:00 2021-04-02T17:11:10.893781+00:00 0:10:03.075090 12825 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T17:01:05.618694+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T17:00:45.835118+00:00 2021-04-02T17:00:47.580065+00:00 0:00:01.744947 12824 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T17:00:43.596017+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T16:00:00+00:00 PythonOperator 2021-04-02T17:00:24.370566+00:00 2021-04-02T17:00:27.258741+00:00 0:00:02.888175 12823 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T17:00:21.584024+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T15:00:00+00:00 EmrJobFlowSensor 2021-04-02T16:12:03.634511+00:00 2021-04-02T16:20:06.166589+00:00 0:08:02.532078 12821 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T16:12:01.418942+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T15:00:00+00:00 EmrJobFlowSensor 2021-04-02T16:12:00.037050+00:00 2021-04-02T16:22:02.976195+00:00 0:10:02.939145 12820 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T16:11:57.453274+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T16:11:39.897900+00:00 2021-04-02T16:11:41.600472+00:00 0:00:01.702572 12819 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T16:11:37.483205+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T16:11:38.025479+00:00 2021-04-02T16:11:39.883734+00:00 0:00:01.858255 12818 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T16:11:35.468240+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T15:00:00+00:00 PythonOperator 2021-04-02T16:11:19.908402+00:00 2021-04-02T16:11:22.864248+00:00 0:00:02.955846 12817 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T16:11:17.379085+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T15:00:00+00:00 PythonOperator 2021-04-02T16:11:15.854402+00:00 2021-04-02T16:11:18.757348+00:00 0:00:02.902946 12816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T16:11:13.449505+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T15:00:00+00:00 TriggerDagRunOperator 2021-04-02T16:10:59.874190+00:00 2021-04-02T16:11:00.384339+00:00 0:00:00.510149 12815 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T16:10:57.309479+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T15:00:00+00:00 TriggerDagRunOperator 2021-04-02T16:10:59.484879+00:00 2021-04-02T16:10:59.890548+00:00 0:00:00.405669 12814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T16:10:57.309452+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T15:05:00+00:00 EmrJobFlowSensor 2021-04-02T16:05:47.027193+00:00 2021-04-02T16:13:49.611370+00:00 0:08:02.584177 12813 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T16:05:44.820686+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T16:05:24.989632+00:00 2021-04-02T16:05:26.645160+00:00 0:00:01.655528 12812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T16:05:22.805949+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T15:05:00+00:00 PythonOperator 2021-04-02T16:05:05.069234+00:00 2021-04-02T16:05:07.802556+00:00 0:00:02.733322 12811 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T16:05:02.791399+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T15:00:00+00:00 EmrJobFlowSensor 2021-04-02T16:00:46.697294+00:00 2021-04-02T16:10:49.544609+00:00 0:10:02.847315 12810 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T16:00:44.421251+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T16:00:26.614369+00:00 2021-04-02T16:00:28.336483+00:00 0:00:01.722114 12809 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T16:00:24.402097+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T15:00:00+00:00 PythonOperator 2021-04-02T16:00:05.107472+00:00 2021-04-02T16:00:07.995766+00:00 0:00:02.888294 12808 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T16:00:02.385758+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T14:00:00+00:00 EmrJobFlowSensor 2021-04-02T15:10:33.636322+00:00 2021-04-02T15:19:36.194177+00:00 0:09:02.557855 12806 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T15:10:31.447719+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T14:00:00+00:00 EmrJobFlowSensor 2021-04-02T15:10:15.730744+00:00 2021-04-02T15:20:18.680632+00:00 0:10:02.949888 12805 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T15:10:13.430292+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T15:10:01.884151+00:00 2021-04-02T15:10:03.546494+00:00 0:00:01.662343 12804 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T15:09:59.414511+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T15:09:50.264579+00:00 2021-04-02T15:09:51.913892+00:00 0:00:01.649313 12803 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T15:09:47.488783+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T14:00:00+00:00 PythonOperator 2021-04-02T15:09:37.701396+00:00 2021-04-02T15:09:40.534881+00:00 0:00:02.833485 12802 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T15:09:35.393861+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T14:00:00+00:00 PythonOperator 2021-04-02T15:09:28.139309+00:00 2021-04-02T15:09:31.111919+00:00 0:00:02.972610 12801 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T15:09:25.388692+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T14:00:00+00:00 TriggerDagRunOperator 2021-04-02T15:09:15.732656+00:00 2021-04-02T15:09:16.244342+00:00 0:00:00.511686 12800 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T15:09:13.346760+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T14:00:00+00:00 TriggerDagRunOperator 2021-04-02T15:09:15.725679+00:00 2021-04-02T15:09:16.379065+00:00 0:00:00.653386 12799 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T15:09:13.346727+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T14:05:00+00:00 EmrJobFlowSensor 2021-04-02T15:05:57.027312+00:00 2021-04-02T15:14:59.622601+00:00 0:09:02.595289 12798 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T15:05:54.903052+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T15:05:35.115876+00:00 2021-04-02T15:05:36.840420+00:00 0:00:01.724544 12797 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T15:05:32.884546+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T14:05:00+00:00 PythonOperator 2021-04-02T15:05:13.053476+00:00 2021-04-02T15:05:15.758257+00:00 0:00:02.704781 12796 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T15:05:10.831470+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T14:00:00+00:00 EmrJobFlowSensor 2021-04-02T15:00:58.621024+00:00 2021-04-02T15:09:01.257629+00:00 0:08:02.636605 12795 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T15:00:56.427880+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T15:00:38.894777+00:00 2021-04-02T15:00:40.720580+00:00 0:00:01.825803 12794 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T15:00:36.407657+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T14:00:00+00:00 PythonOperator 2021-04-02T15:00:16.910955+00:00 2021-04-02T15:00:19.791853+00:00 0:00:02.880898 12793 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T15:00:14.456112+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T13:00:00+00:00 EmrJobFlowSensor 2021-04-02T14:14:40.316608+00:00 2021-04-02T14:22:42.816445+00:00 0:08:02.499837 12792 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T14:14:37.955988+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T13:00:00+00:00 EmrJobFlowSensor 2021-04-02T14:14:30.218211+00:00 2021-04-02T14:24:33.037663+00:00 0:10:02.819452 12791 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T14:14:27.843312+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T14:14:18.020734+00:00 2021-04-02T14:14:19.772704+00:00 0:00:01.751970 12790 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T14:14:15.821810+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T14:14:08.262936+00:00 2021-04-02T14:14:10.086851+00:00 0:00:01.823915 12789 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T14:14:05.809474+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T13:00:00+00:00 PythonOperator 2021-04-02T14:13:58.100595+00:00 2021-04-02T14:14:00.774893+00:00 0:00:02.674298 12788 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T14:13:55.799440+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T13:00:00+00:00 PythonOperator 2021-04-02T14:13:48.134805+00:00 2021-04-02T14:13:51.092864+00:00 0:00:02.958059 12787 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T14:13:45.789573+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T13:00:00+00:00 TriggerDagRunOperator 2021-04-02T14:13:40.544413+00:00 2021-04-02T14:13:41.068122+00:00 0:00:00.523709 12786 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T14:13:37.696784+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T13:00:00+00:00 TriggerDagRunOperator 2021-04-02T14:13:40.428379+00:00 2021-04-02T14:13:40.891127+00:00 0:00:00.462748 12785 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T14:13:37.696816+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T13:05:00+00:00 EmrJobFlowSensor 2021-04-02T14:05:46.886601+00:00 2021-04-02T14:14:49.562961+00:00 0:09:02.676360 12783 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T14:05:44.645354+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T14:05:26.841957+00:00 2021-04-02T14:05:28.574271+00:00 0:00:01.732314 12782 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T14:05:24.538064+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T13:05:00+00:00 PythonOperator 2021-04-02T14:05:04.913764+00:00 2021-04-02T14:05:07.575146+00:00 0:00:02.661382 12781 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T14:05:02.572683+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T13:00:00+00:00 EmrJobFlowSensor 2021-04-02T14:00:50.385122+00:00 2021-04-02T14:10:53.370776+00:00 0:10:02.985654 12780 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T14:00:48.157528+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T14:00:28.602753+00:00 2021-04-02T14:00:30.427232+00:00 0:00:01.824479 12779 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T14:00:26.173297+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T13:00:00+00:00 PythonOperator 2021-04-02T14:00:08.397686+00:00 2021-04-02T14:00:11.154235+00:00 0:00:02.756549 12778 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T14:00:06.149043+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T12:00:00+00:00 EmrJobFlowSensor 2021-04-02T13:12:19.170408+00:00 2021-04-02T13:22:21.943968+00:00 0:10:02.773560 12777 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T13:12:16.506176+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T12:00:00+00:00 EmrJobFlowSensor 2021-04-02T13:12:16.718247+00:00 2021-04-02T13:21:19.737383+00:00 0:09:03.019136 12776 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T13:12:14.508903+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T13:11:57.021311+00:00 2021-04-02T13:11:58.792769+00:00 0:00:01.771458 12775 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T13:11:54.546731+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T13:11:55.099650+00:00 2021-04-02T13:11:56.793575+00:00 0:00:01.693925 12774 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T13:11:52.490538+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T12:00:00+00:00 PythonOperator 2021-04-02T13:11:37.454082+00:00 2021-04-02T13:11:40.362552+00:00 0:00:02.908470 12773 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T13:11:34.477398+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T12:00:00+00:00 PythonOperator 2021-04-02T13:11:32.785186+00:00 2021-04-02T13:11:36.178337+00:00 0:00:03.393151 12772 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T13:11:30.475552+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T12:00:00+00:00 TriggerDagRunOperator 2021-04-02T13:11:27.328018+00:00 2021-04-02T13:11:27.841904+00:00 0:00:00.513886 12771 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T13:11:24.250815+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T12:00:00+00:00 TriggerDagRunOperator 2021-04-02T13:11:27.112662+00:00 2021-04-02T13:11:27.544956+00:00 0:00:00.432294 12770 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T13:11:24.250859+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T12:05:00+00:00 EmrJobFlowSensor 2021-04-02T13:06:04.862674+00:00 2021-04-02T13:14:07.434846+00:00 0:08:02.572172 12768 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T13:06:02.459255+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T13:05:42.530629+00:00 2021-04-02T13:05:44.284438+00:00 0:00:01.753809 12767 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T13:05:40.316100+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T12:05:00+00:00 PythonOperator 2021-04-02T13:05:22.484969+00:00 2021-04-02T13:05:25.154582+00:00 0:00:02.669613 12766 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T13:05:20.299305+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T12:00:00+00:00 EmrJobFlowSensor 2021-04-02T13:01:06.130918+00:00 2021-04-02T13:11:09.022565+00:00 0:10:02.891647 12765 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T13:01:03.891095+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T13:00:44.389820+00:00 2021-04-02T13:00:46.212868+00:00 0:00:01.823048 12764 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T13:00:41.846724+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T12:00:00+00:00 PythonOperator 2021-04-02T13:00:24.269985+00:00 2021-04-02T13:00:27.014844+00:00 0:00:02.744859 12763 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T13:00:21.828320+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T11:00:00+00:00 EmrJobFlowSensor 2021-04-02T12:11:26.921367+00:00 2021-04-02T12:19:29.579157+00:00 0:08:02.657790 12762 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T12:11:24.709032+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T11:00:00+00:00 EmrJobFlowSensor 2021-04-02T12:11:23.045606+00:00 2021-04-02T12:21:26.119976+00:00 0:10:03.074370 12761 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T12:11:20.705396+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-02T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T12:11:04.987732+00:00 2021-04-02T12:11:06.688871+00:00 0:00:01.701139 12760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T12:11:02.687975+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T12:11:01.140821+00:00 2021-04-02T12:11:02.999189+00:00 0:00:01.858368 12759 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T12:10:58.756657+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-02T11:00:00+00:00 PythonOperator 2021-04-02T12:10:43.029611+00:00 2021-04-02T12:10:45.896559+00:00 0:00:02.866948 12758 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T12:10:40.671786+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-02T11:00:00+00:00 PythonOperator 2021-04-02T12:10:38.903303+00:00 2021-04-02T12:10:41.851726+00:00 0:00:02.948423 12757 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T12:10:36.686654+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-02T11:00:00+00:00 TriggerDagRunOperator 2021-04-02T12:10:23.014831+00:00 2021-04-02T12:10:23.611397+00:00 0:00:00.596566 12756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T12:10:20.648208+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-02T11:00:00+00:00 TriggerDagRunOperator 2021-04-02T12:10:22.961913+00:00 2021-04-02T12:10:23.717311+00:00 0:00:00.755398 12755 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T12:10:20.648172+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-02T11:05:00+00:00 EmrJobFlowSensor 2021-04-02T12:07:03.089641+00:00 2021-04-02T12:15:05.565625+00:00 0:08:02.475984 12754 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T12:07:00.463472+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-02T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-02T12:05:42.185741+00:00 2021-04-02T12:05:43.888031+00:00 0:00:01.702290 12752 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T12:05:39.925482+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-02T11:05:00+00:00 PythonOperator 2021-04-02T12:05:22.334776+00:00 2021-04-02T12:05:25.120156+00:00 0:00:02.785380 12751 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T12:05:19.960258+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-02T11:00:00+00:00 EmrJobFlowSensor 2021-04-02T12:00:55.835701+00:00 2021-04-02T12:09:58.483537+00:00 0:09:02.647836 12750 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-02T12:00:53.497831+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-02T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T12:00:33.748113+00:00 2021-04-02T12:00:35.619507+00:00 0:00:01.871394 12749 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-02T12:00:31.467926+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-02T11:00:00+00:00 PythonOperator 2021-04-02T12:00:13.711940+00:00 2021-04-02T12:00:16.552626+00:00 0:00:02.840686 12748 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-02T12:00:11.446146+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-02T10:00:00+00:00 EmrJobFlowSensor 2021-04-02T11:18:04.009608+00:00 2021-04-02T11:30:07.086151+00:00 0:12:03.076543 12747 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T11:18:01.610556+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-02T10:00:00+00:00 EmrJobFlowSensor 2021-04-02T11:17:59.910409+00:00 2021-04-02T11:26:02.464646+00:00 0:08:02.554237 12746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-02T11:17:57.657254+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-02T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-02T11:17:41.891033+00:00 2021-04-02T11:17:43.572600+00:00 0:00:01.681567 12745 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-02T11:17:39.593759+00:00 2 default_pool