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-04-24T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T16:00:31.709161+00:00 2021-04-24T16:00:33.409012+00:00 0:00:01.699851 20788 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T16:00:29.407032+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T15:00:00+00:00 PythonOperator 2021-04-24T16:00:05.695319+00:00 2021-04-24T16:00:08.734576+00:00 0:00:03.039257 20787 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T16:00:03.386671+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T14:00:00+00:00 EmrJobFlowSensor 2021-04-24T15:13:35.161705+00:00 2021-04-24T15:22:37.794893+00:00 0:09:02.633188 20786 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T15:13:32.573065+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T14:00:00+00:00 EmrJobFlowSensor 2021-04-24T15:13:18.922192+00:00 2021-04-24T15:23:21.687761+00:00 0:10:02.765569 20785 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T15:13:16.543733+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T15:13:12.734353+00:00 2021-04-24T15:13:14.391274+00:00 0:00:01.656921 20784 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T15:13:10.483975+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T15:12:56.763743+00:00 2021-04-24T15:12:58.595632+00:00 0:00:01.831889 20783 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T15:12:54.484878+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T14:00:00+00:00 PythonOperator 2021-04-24T15:12:52.682466+00:00 2021-04-24T15:12:55.625049+00:00 0:00:02.942583 20782 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T15:12:50.445396+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T14:00:00+00:00 PythonOperator 2021-04-24T15:12:36.711850+00:00 2021-04-24T15:12:39.871774+00:00 0:00:03.159924 20781 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T15:12:34.431039+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T14:00:00+00:00 TriggerDagRunOperator 2021-04-24T15:12:27.270260+00:00 2021-04-24T15:12:27.810742+00:00 0:00:00.540482 20780 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T15:12:24.437965+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T14:00:00+00:00 TriggerDagRunOperator 2021-04-24T15:12:27.162332+00:00 2021-04-24T15:12:27.572169+00:00 0:00:00.409837 20779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T15:12:24.437933+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T14:05:00+00:00 EmrJobFlowSensor 2021-04-24T15:05:48.791051+00:00 2021-04-24T15:13:51.221579+00:00 0:08:02.430528 20777 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T15:05:46.654205+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T15:05:26.976906+00:00 2021-04-24T15:05:28.813155+00:00 0:00:01.836249 20776 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T15:05:24.676080+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T14:05:00+00:00 PythonOperator 2021-04-24T15:05:07.124143+00:00 2021-04-24T15:05:10.051954+00:00 0:00:02.927811 20775 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T15:05:04.761081+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T14:00:00+00:00 EmrJobFlowSensor 2021-04-24T15:00:58.750941+00:00 2021-04-24T15:11:01.535512+00:00 0:10:02.784571 20774 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T15:00:56.262705+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T15:00:38.416879+00:00 2021-04-24T15:00:40.175493+00:00 0:00:01.758614 20773 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T15:00:36.191652+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T14:00:00+00:00 PythonOperator 2021-04-24T15:00:16.686716+00:00 2021-04-24T15:00:19.667363+00:00 0:00:02.980647 20772 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T15:00:14.178176+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T13:00:00+00:00 EmrJobFlowSensor 2021-04-24T14:11:21.233396+00:00 2021-04-24T14:20:23.867065+00:00 0:09:02.633669 20771 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T14:11:19.042591+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T13:00:00+00:00 EmrJobFlowSensor 2021-04-24T14:11:19.455318+00:00 2021-04-24T14:20:22.151047+00:00 0:09:02.695729 20770 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T14:11:16.983784+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T14:10:59.548591+00:00 2021-04-24T14:11:01.258044+00:00 0:00:01.709453 20769 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T14:10:56.927883+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T14:10:57.121388+00:00 2021-04-24T14:10:59.193780+00:00 0:00:02.072392 20768 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T14:10:54.922977+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T13:00:00+00:00 PythonOperator 2021-04-24T14:10:39.230768+00:00 2021-04-24T14:10:42.582650+00:00 0:00:03.351882 20767 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T14:10:36.911224+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T13:00:00+00:00 PythonOperator 2021-04-24T14:10:37.115992+00:00 2021-04-24T14:10:40.062047+00:00 0:00:02.946055 20766 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T14:10:34.913171+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T13:00:00+00:00 TriggerDagRunOperator 2021-04-24T14:10:17.620084+00:00 2021-04-24T14:10:18.176439+00:00 0:00:00.556355 20765 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T14:10:14.705799+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T13:00:00+00:00 TriggerDagRunOperator 2021-04-24T14:10:17.575101+00:00 2021-04-24T14:10:18.041820+00:00 0:00:00.466719 20764 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T14:10:14.705833+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T13:05:00+00:00 EmrJobFlowSensor 2021-04-24T14:06:02.179322+00:00 2021-04-24T14:15:04.853472+00:00 0:09:02.674150 20762 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T14:06:00.025382+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T14:05:40.333110+00:00 2021-04-24T14:05:42.037966+00:00 0:00:01.704856 20761 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T14:05:37.992408+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T13:05:00+00:00 PythonOperator 2021-04-24T14:05:18.093641+00:00 2021-04-24T14:05:20.995711+00:00 0:00:02.902070 20760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T14:05:15.926309+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T13:00:00+00:00 EmrJobFlowSensor 2021-04-24T14:01:02.059760+00:00 2021-04-24T14:10:04.791238+00:00 0:09:02.731478 20759 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T14:00:59.657178+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T14:00:37.686105+00:00 2021-04-24T14:00:39.382293+00:00 0:00:01.696188 20758 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T14:00:35.486602+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T13:00:00+00:00 PythonOperator 2021-04-24T14:00:17.526162+00:00 2021-04-24T14:00:20.526024+00:00 0:00:02.999862 20757 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T14:00:15.347429+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T12:00:00+00:00 EmrJobFlowSensor 2021-04-24T13:12:28.799672+00:00 2021-04-24T13:20:31.306657+00:00 0:08:02.506985 20756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T13:12:26.496532+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T12:00:00+00:00 EmrJobFlowSensor 2021-04-24T13:12:24.688561+00:00 2021-04-24T13:22:27.421758+00:00 0:10:02.733197 20755 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T13:12:22.494755+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T13:12:06.835862+00:00 2021-04-24T13:12:08.551986+00:00 0:00:01.716124 20754 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T13:12:04.554140+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T13:12:04.995943+00:00 2021-04-24T13:12:06.864482+00:00 0:00:01.868539 20753 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T13:12:02.544010+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T12:00:00+00:00 PythonOperator 2021-04-24T13:11:46.668481+00:00 2021-04-24T13:11:49.649449+00:00 0:00:02.980968 20752 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T13:11:44.419025+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T12:00:00+00:00 PythonOperator 2021-04-24T13:11:42.665175+00:00 2021-04-24T13:11:45.826023+00:00 0:00:03.160848 20751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T13:11:40.419772+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T12:00:00+00:00 TriggerDagRunOperator 2021-04-24T13:11:24.994406+00:00 2021-04-24T13:11:25.511808+00:00 0:00:00.517402 20750 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T13:11:22.464644+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T12:00:00+00:00 TriggerDagRunOperator 2021-04-24T13:11:24.953946+00:00 2021-04-24T13:11:25.364862+00:00 0:00:00.410916 20749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T13:11:22.464681+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T12:05:00+00:00 EmrJobFlowSensor 2021-04-24T13:09:12.388522+00:00 2021-04-24T13:18:15.079152+00:00 0:09:02.690630 20748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T13:09:10.195845+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T13:08:52.351233+00:00 2021-04-24T13:08:54.126335+00:00 0:00:01.775102 20747 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T13:08:50.178482+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T12:05:00+00:00 PythonOperator 2021-04-24T13:08:30.892517+00:00 2021-04-24T13:08:33.864023+00:00 0:00:02.971506 20746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T13:08:28.160643+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T12:00:00+00:00 EmrJobFlowSensor 2021-04-24T13:00:58.323647+00:00 2021-04-24T13:11:01.325849+00:00 0:10:03.002202 20744 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T13:00:55.900533+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T13:00:36.223819+00:00 2021-04-24T13:00:37.897390+00:00 0:00:01.673571 20743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T13:00:33.946532+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T12:00:00+00:00 PythonOperator 2021-04-24T13:00:16.212266+00:00 2021-04-24T13:00:19.214677+00:00 0:00:03.002411 20742 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T13:00:13.872011+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T11:00:00+00:00 EmrJobFlowSensor 2021-04-24T12:11:11.756467+00:00 2021-04-24T12:21:14.627482+00:00 0:10:02.871015 20741 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T12:11:09.060983+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T11:00:00+00:00 EmrJobFlowSensor 2021-04-24T12:11:09.282962+00:00 2021-04-24T12:20:12.196649+00:00 0:09:02.913687 20740 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T12:11:06.986718+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T12:10:51.215470+00:00 2021-04-24T12:10:52.931632+00:00 0:00:01.716162 20739 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T12:10:48.925946+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T12:10:49.293615+00:00 2021-04-24T12:10:51.090279+00:00 0:00:01.796664 20738 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T12:10:46.924527+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T11:00:00+00:00 PythonOperator 2021-04-24T12:10:29.265514+00:00 2021-04-24T12:10:32.428570+00:00 0:00:03.163056 20737 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T12:10:26.918269+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T11:00:00+00:00 PythonOperator 2021-04-24T12:10:27.338608+00:00 2021-04-24T12:10:30.297431+00:00 0:00:02.958823 20736 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T12:10:24.950289+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T11:00:00+00:00 TriggerDagRunOperator 2021-04-24T12:10:05.603973+00:00 2021-04-24T12:10:06.115578+00:00 0:00:00.511605 20735 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T12:10:02.953609+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T11:00:00+00:00 TriggerDagRunOperator 2021-04-24T12:10:05.403440+00:00 2021-04-24T12:10:05.847245+00:00 0:00:00.443805 20734 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T12:10:02.953656+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T11:05:00+00:00 EmrJobFlowSensor 2021-04-24T12:05:52.887351+00:00 2021-04-24T12:14:55.391711+00:00 0:09:02.504360 20733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T12:05:50.544047+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T12:05:32.562624+00:00 2021-04-24T12:05:34.219918+00:00 0:00:01.657294 20732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T12:05:30.386691+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T11:05:00+00:00 PythonOperator 2021-04-24T12:05:10.791575+00:00 2021-04-24T12:05:13.724080+00:00 0:00:02.932505 20731 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T12:05:08.387208+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T11:00:00+00:00 EmrJobFlowSensor 2021-04-24T12:00:55.077452+00:00 2021-04-24T12:09:57.803156+00:00 0:09:02.725704 20729 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T12:00:52.766866+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T12:00:33.105408+00:00 2021-04-24T12:00:35.004144+00:00 0:00:01.898736 20728 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T12:00:30.740225+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T11:00:00+00:00 PythonOperator 2021-04-24T12:00:10.928738+00:00 2021-04-24T12:00:14.030151+00:00 0:00:03.101413 20727 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T12:00:08.694885+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T10:00:00+00:00 EmrJobFlowSensor 2021-04-24T11:16:41.339100+00:00 2021-04-24T11:26:44.074044+00:00 0:10:02.734944 20726 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T11:16:39.198236+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T10:00:00+00:00 EmrJobFlowSensor 2021-04-24T11:16:37.430614+00:00 2021-04-24T11:25:39.923072+00:00 0:09:02.492458 20725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T11:16:35.196184+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T11:16:19.390518+00:00 2021-04-24T11:16:21.106281+00:00 0:00:01.715763 20724 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T11:16:17.145056+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T11:16:15.614686+00:00 2021-04-24T11:16:17.466268+00:00 0:00:01.851582 20723 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T11:16:13.115739+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T10:00:00+00:00 PythonOperator 2021-04-24T11:15:59.706887+00:00 2021-04-24T11:16:03.085087+00:00 0:00:03.378200 20722 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T11:15:57.096766+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T10:00:00+00:00 PythonOperator 2021-04-24T11:15:55.265261+00:00 2021-04-24T11:15:58.573185+00:00 0:00:03.307924 20721 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T11:15:53.085911+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T10:00:00+00:00 TriggerDagRunOperator 2021-04-24T11:15:35.433617+00:00 2021-04-24T11:15:35.952950+00:00 0:00:00.519333 20720 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T11:15:33.071169+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T10:00:00+00:00 TriggerDagRunOperator 2021-04-24T11:15:35.351916+00:00 2021-04-24T11:15:35.766725+00:00 0:00:00.414809 20719 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T11:15:33.071139+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T10:05:00+00:00 EmrJobFlowSensor 2021-04-24T11:05:56.153719+00:00 2021-04-24T11:14:58.868282+00:00 0:09:02.714563 20718 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T11:05:53.699493+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T11:05:33.957582+00:00 2021-04-24T11:05:35.588084+00:00 0:00:01.630502 20717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T11:05:31.666824+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T10:05:00+00:00 PythonOperator 2021-04-24T11:05:11.900047+00:00 2021-04-24T11:05:14.847775+00:00 0:00:02.947728 20716 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T11:05:09.557519+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T10:00:00+00:00 EmrJobFlowSensor 2021-04-24T11:05:07.891680+00:00 2021-04-24T11:15:10.638568+00:00 0:10:02.746888 20715 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T11:05:05.559464+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T11:04:45.740987+00:00 2021-04-24T11:04:47.472435+00:00 0:00:01.731448 20714 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T11:04:43.467462+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T10:00:00+00:00 PythonOperator 2021-04-24T11:04:25.804236+00:00 2021-04-24T11:04:28.854345+00:00 0:00:03.050109 20713 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T11:04:23.401059+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T09:00:00+00:00 EmrJobFlowSensor 2021-04-24T10:12:21.851724+00:00 2021-04-24T10:21:24.624723+00:00 0:09:02.772999 20711 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T10:12:19.600481+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T09:00:00+00:00 EmrJobFlowSensor 2021-04-24T10:12:05.843278+00:00 2021-04-24T10:22:08.699794+00:00 0:10:02.856516 20710 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T10:12:03.586581+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T10:11:59.995695+00:00 2021-04-24T10:12:01.760052+00:00 0:00:01.764357 20709 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T10:11:57.665502+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T10:11:42.249070+00:00 2021-04-24T10:11:44.123509+00:00 0:00:01.874439 20708 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T10:11:39.567302+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T09:00:00+00:00 PythonOperator 2021-04-24T10:11:38.092882+00:00 2021-04-24T10:11:41.292795+00:00 0:00:03.199913 20707 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T10:11:35.573558+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T09:00:00+00:00 PythonOperator 2021-04-24T10:11:21.720213+00:00 2021-04-24T10:11:24.967117+00:00 0:00:03.246904 20706 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T10:11:19.489869+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T09:00:00+00:00 TriggerDagRunOperator 2021-04-24T10:11:16.108247+00:00 2021-04-24T10:11:16.550578+00:00 0:00:00.442331 20705 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T10:11:13.544370+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T09:00:00+00:00 TriggerDagRunOperator 2021-04-24T10:11:16.126226+00:00 2021-04-24T10:11:16.712920+00:00 0:00:00.586694 20704 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T10:11:13.544416+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T09:05:00+00:00 EmrJobFlowSensor 2021-04-24T10:06:00.951025+00:00 2021-04-24T10:14:03.388108+00:00 0:08:02.437083 20703 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T10:05:58.763096+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T10:05:34.862337+00:00 2021-04-24T10:05:36.588515+00:00 0:00:01.726178 20702 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T10:05:32.729290+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T09:05:00+00:00 PythonOperator 2021-04-24T10:05:13.017922+00:00 2021-04-24T10:05:15.958125+00:00 0:00:02.940203 20701 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T10:05:10.667689+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T09:00:00+00:00 EmrJobFlowSensor 2021-04-24T10:00:58.789886+00:00 2021-04-24T10:11:01.605063+00:00 0:10:02.815177 20700 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T10:00:56.337003+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T10:00:36.715324+00:00 2021-04-24T10:00:38.425280+00:00 0:00:01.709956 20699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T10:00:34.364151+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T09:00:00+00:00 PythonOperator 2021-04-24T10:00:14.887834+00:00 2021-04-24T10:00:17.898722+00:00 0:00:03.010888 20698 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T10:00:12.260357+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-24T08:00:00+00:00 EmrJobFlowSensor 2021-04-24T09:11:06.010606+00:00 2021-04-24T09:19:08.483160+00:00 0:08:02.472554 20696 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T09:11:03.779024+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-24T08:00:00+00:00 EmrJobFlowSensor 2021-04-24T09:11:02.430931+00:00 2021-04-24T09:20:05.148971+00:00 0:09:02.718040 20695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T09:10:59.853236+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-24T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T09:10:42.837934+00:00 2021-04-24T09:10:44.532323+00:00 0:00:01.694389 20694 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T09:10:39.700911+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-24T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T09:10:40.650454+00:00 2021-04-24T09:10:42.732588+00:00 0:00:02.082134 20693 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T09:10:37.753615+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-24T08:00:00+00:00 PythonOperator 2021-04-24T09:10:20.278530+00:00 2021-04-24T09:10:23.262265+00:00 0:00:02.983735 20692 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T09:10:17.664400+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-24T08:00:00+00:00 PythonOperator 2021-04-24T09:10:18.120851+00:00 2021-04-24T09:10:21.339950+00:00 0:00:03.219099 20691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T09:10:15.670598+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T08:00:00+00:00 TriggerDagRunOperator 2021-04-24T09:10:08.120529+00:00 2021-04-24T09:10:08.584736+00:00 0:00:00.464207 20690 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T09:10:05.669360+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T08:00:00+00:00 TriggerDagRunOperator 2021-04-24T09:10:08.035941+00:00 2021-04-24T09:10:08.700201+00:00 0:00:00.664260 20689 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T09:10:05.669401+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-24T08:05:00+00:00 EmrJobFlowSensor 2021-04-24T09:05:47.509533+00:00 2021-04-24T09:14:50.117956+00:00 0:09:02.608423 20688 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T09:05:45.247840+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-24T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-24T09:05:25.267082+00:00 2021-04-24T09:05:26.935590+00:00 0:00:01.668508 20687 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-24T09:05:23.096030+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-24T08:05:00+00:00 PythonOperator 2021-04-24T09:05:05.375353+00:00 2021-04-24T09:05:08.407944+00:00 0:00:03.032591 20686 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T09:05:03.079130+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T08:00:00+00:00 EmrJobFlowSensor 2021-04-24T09:00:52.654759+00:00 2021-04-24T09:09:55.157352+00:00 0:09:02.502593 20685 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T09:00:50.413682+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T09:00:31.035171+00:00 2021-04-24T09:00:32.752497+00:00 0:00:01.717326 20684 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T09:00:28.457160+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T08:00:00+00:00 PythonOperator 2021-04-24T09:00:08.879286+00:00 2021-04-24T09:00:11.891218+00:00 0:00:03.011932 20683 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T09:00:06.283835+00:00 2 default_pool