Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T12:05:42.598931+00:00 2021-04-08T12:05:44.274880+00:00 0:00:01.675949 14916 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T12:05:40.436583+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T11:05:00+00:00 PythonOperator 2021-04-08T12:05:22.542761+00:00 2021-04-08T12:05:25.225534+00:00 0:00:02.682773 14915 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T12:05:20.416626+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T11:00:00+00:00 EmrJobFlowSensor 2021-04-08T12:00:56.229623+00:00 2021-04-08T12:10:59.218211+00:00 0:10:02.988588 14914 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T12:00:54.042973+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T12:00:36.300949+00:00 2021-04-08T12:00:38.051553+00:00 0:00:01.750604 14913 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T12:00:34.019225+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T11:00:00+00:00 PythonOperator 2021-04-08T12:00:12.828398+00:00 2021-04-08T12:00:15.681294+00:00 0:00:02.852896 14912 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T12:00:10.055944+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T10:00:00+00:00 EmrJobFlowSensor 2021-04-08T11:12:16.033002+00:00 2021-04-08T11:22:18.995095+00:00 0:10:02.962093 14910 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T11:12:13.647498+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T10:00:00+00:00 EmrJobFlowSensor 2021-04-08T11:11:59.900888+00:00 2021-04-08T11:22:02.699456+00:00 0:10:02.798568 14909 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T11:11:57.584282+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T11:11:53.689253+00:00 2021-04-08T11:11:55.491242+00:00 0:00:01.801989 14908 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T11:11:51.518113+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T11:11:39.920333+00:00 2021-04-08T11:11:41.716073+00:00 0:00:01.795740 14907 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T11:11:37.516483+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T10:00:00+00:00 PythonOperator 2021-04-08T11:11:33.854367+00:00 2021-04-08T11:11:36.888964+00:00 0:00:03.034597 14906 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T11:11:31.497929+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T10:00:00+00:00 PythonOperator 2021-04-08T11:11:17.752411+00:00 2021-04-08T11:11:20.498976+00:00 0:00:02.746565 14905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T11:11:15.426643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T10:00:00+00:00 TriggerDagRunOperator 2021-04-08T11:11:11.939332+00:00 2021-04-08T11:11:12.346651+00:00 0:00:00.407319 14904 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T11:11:09.541092+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T10:00:00+00:00 TriggerDagRunOperator 2021-04-08T11:11:11.878617+00:00 2021-04-08T11:11:12.431123+00:00 0:00:00.552506 14903 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T11:11:09.541146+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T10:05:00+00:00 EmrJobFlowSensor 2021-04-08T11:05:47.163050+00:00 2021-04-08T11:13:49.719436+00:00 0:08:02.556386 14902 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T11:05:44.764488+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T11:05:27.010505+00:00 2021-04-08T11:05:28.693653+00:00 0:00:01.683148 14901 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T11:05:24.707448+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T10:05:00+00:00 PythonOperator 2021-04-08T11:05:05.178817+00:00 2021-04-08T11:05:08.100345+00:00 0:00:02.921528 14900 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T11:05:02.686266+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T10:00:00+00:00 EmrJobFlowSensor 2021-04-08T11:00:46.418777+00:00 2021-04-08T11:10:49.324217+00:00 0:10:02.905440 14899 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T11:00:44.160692+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T11:00:26.326841+00:00 2021-04-08T11:00:28.183202+00:00 0:00:01.856361 14898 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T11:00:24.060927+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T10:00:00+00:00 PythonOperator 2021-04-08T11:00:04.898195+00:00 2021-04-08T11:00:07.628822+00:00 0:00:02.730627 14897 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T11:00:02.038991+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T09:00:00+00:00 EmrJobFlowSensor 2021-04-08T10:13:17.909685+00:00 2021-04-08T10:23:20.632907+00:00 0:10:02.723222 14895 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T10:13:15.749846+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T09:00:00+00:00 EmrJobFlowSensor 2021-04-08T10:13:08.572825+00:00 2021-04-08T10:25:11.850813+00:00 0:12:03.277988 14894 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T10:13:05.737500+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T10:12:56.030554+00:00 2021-04-08T10:12:57.866562+00:00 0:00:01.836008 14893 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T10:12:53.731251+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T10:12:46.398582+00:00 2021-04-08T10:12:48.083552+00:00 0:00:01.684970 14892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T10:12:43.741502+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T09:00:00+00:00 PythonOperator 2021-04-08T10:12:33.934809+00:00 2021-04-08T10:12:36.650410+00:00 0:00:02.715601 14891 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T10:12:31.707719+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T09:00:00+00:00 PythonOperator 2021-04-08T10:12:26.308787+00:00 2021-04-08T10:12:29.395524+00:00 0:00:03.086737 14890 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T10:12:23.789187+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T09:00:00+00:00 TriggerDagRunOperator 2021-04-08T10:12:20.159105+00:00 2021-04-08T10:12:20.704261+00:00 0:00:00.545156 14889 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T10:12:17.696508+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T09:00:00+00:00 TriggerDagRunOperator 2021-04-08T10:12:20.041757+00:00 2021-04-08T10:12:20.610431+00:00 0:00:00.568674 14888 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T10:12:17.696540+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T09:05:00+00:00 EmrJobFlowSensor 2021-04-08T10:05:57.467114+00:00 2021-04-08T10:14:00.073373+00:00 0:08:02.606259 14887 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T10:05:55.060629+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T10:05:37.144932+00:00 2021-04-08T10:05:38.933049+00:00 0:00:01.788117 14886 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T10:05:34.957289+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T09:05:00+00:00 PythonOperator 2021-04-08T10:05:15.259648+00:00 2021-04-08T10:05:18.075392+00:00 0:00:02.815744 14885 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T10:05:12.937594+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T09:00:00+00:00 EmrJobFlowSensor 2021-04-08T10:01:06.606849+00:00 2021-04-08T10:12:09.620545+00:00 0:11:03.013696 14884 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T10:01:04.450525+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T10:00:46.484457+00:00 2021-04-08T10:00:48.289968+00:00 0:00:01.805511 14883 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T10:00:44.348341+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T09:00:00+00:00 PythonOperator 2021-04-08T10:00:25.186508+00:00 2021-04-08T10:00:28.032683+00:00 0:00:02.846175 14882 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T10:00:22.330862+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T08:00:00+00:00 EmrJobFlowSensor 2021-04-08T09:12:30.984860+00:00 2021-04-08T09:20:33.552526+00:00 0:08:02.567666 14880 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T09:12:28.671583+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T08:00:00+00:00 EmrJobFlowSensor 2021-04-08T09:12:19.110316+00:00 2021-04-08T09:22:21.821459+00:00 0:10:02.711143 14879 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T09:12:16.599047+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T09:12:06.810641+00:00 2021-04-08T09:12:08.520433+00:00 0:00:01.709792 14878 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T09:12:04.588132+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T09:11:58.961899+00:00 2021-04-08T09:12:00.703251+00:00 0:00:01.741352 14877 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T09:11:56.649254+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T08:00:00+00:00 PythonOperator 2021-04-08T09:11:44.892164+00:00 2021-04-08T09:11:47.632054+00:00 0:00:02.739890 14876 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T09:11:42.559023+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T08:00:00+00:00 PythonOperator 2021-04-08T09:11:36.709626+00:00 2021-04-08T09:11:39.670569+00:00 0:00:02.960943 14875 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T09:11:34.549359+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T08:00:00+00:00 TriggerDagRunOperator 2021-04-08T09:11:23.171563+00:00 2021-04-08T09:11:23.898363+00:00 0:00:00.726800 14874 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T09:11:20.534666+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T08:00:00+00:00 TriggerDagRunOperator 2021-04-08T09:11:22.851328+00:00 2021-04-08T09:11:23.272225+00:00 0:00:00.420897 14873 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T09:11:20.534693+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T08:05:00+00:00 EmrJobFlowSensor 2021-04-08T09:05:47.890793+00:00 2021-04-08T09:14:50.480198+00:00 0:09:02.589405 14872 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T09:05:45.763409+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T09:05:28.042854+00:00 2021-04-08T09:05:29.777606+00:00 0:00:01.734752 14871 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T09:05:25.744006+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T08:05:00+00:00 PythonOperator 2021-04-08T09:05:05.857025+00:00 2021-04-08T09:05:08.520967+00:00 0:00:02.663942 14870 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T09:05:03.728818+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T08:00:00+00:00 EmrJobFlowSensor 2021-04-08T09:00:57.640184+00:00 2021-04-08T09:11:00.487703+00:00 0:10:02.847519 14869 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T09:00:55.391104+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T09:00:35.839839+00:00 2021-04-08T09:00:37.542318+00:00 0:00:01.702479 14868 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T09:00:33.383933+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T08:00:00+00:00 PythonOperator 2021-04-08T09:00:16.162686+00:00 2021-04-08T09:00:19.030737+00:00 0:00:02.868051 14867 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T09:00:13.363952+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T07:00:00+00:00 EmrJobFlowSensor 2021-04-08T08:13:00.613915+00:00 2021-04-08T08:24:03.522480+00:00 0:11:02.908565 14865 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T08:12:58.307009+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T08:12:38.641010+00:00 2021-04-08T08:12:40.334430+00:00 0:00:01.693420 14864 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T08:12:36.288081+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T07:00:00+00:00 EmrJobFlowSensor 2021-04-08T08:12:26.453854+00:00 2021-04-08T08:21:29.093432+00:00 0:09:02.639578 14863 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T08:12:24.256684+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T08:12:02.610923+00:00 2021-04-08T08:12:04.308415+00:00 0:00:01.697492 14862 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T08:12:00.234917+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T07:00:00+00:00 PythonOperator 2021-04-08T08:11:32.739638+00:00 2021-04-08T08:11:35.444059+00:00 0:00:02.704421 14861 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T08:11:30.249954+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T07:00:00+00:00 PythonOperator 2021-04-08T08:11:24.711504+00:00 2021-04-08T08:11:27.819612+00:00 0:00:03.108108 14860 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T08:11:22.255811+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T07:00:00+00:00 TriggerDagRunOperator 2021-04-08T08:11:10.539893+00:00 2021-04-08T08:11:11.098472+00:00 0:00:00.558579 14859 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T08:11:08.192641+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T07:00:00+00:00 TriggerDagRunOperator 2021-04-08T08:11:10.513173+00:00 2021-04-08T08:11:10.924099+00:00 0:00:00.410926 14858 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T08:11:08.192674+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T07:05:00+00:00 EmrJobFlowSensor 2021-04-08T08:05:50.179971+00:00 2021-04-08T08:14:52.762264+00:00 0:09:02.582293 14857 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T08:05:47.859742+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T08:05:30.413798+00:00 2021-04-08T08:05:32.116033+00:00 0:00:01.702235 14856 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T08:05:27.862086+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T07:05:00+00:00 PythonOperator 2021-04-08T08:05:07.852778+00:00 2021-04-08T08:05:10.528597+00:00 0:00:02.675819 14855 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T08:05:05.711724+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T07:00:00+00:00 EmrJobFlowSensor 2021-04-08T08:00:49.699891+00:00 2021-04-08T08:10:52.650156+00:00 0:10:02.950265 14854 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T08:00:47.257211+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T08:00:29.464003+00:00 2021-04-08T08:00:31.166649+00:00 0:00:01.702646 14853 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T08:00:27.114545+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T07:00:00+00:00 PythonOperator 2021-04-08T08:00:07.657977+00:00 2021-04-08T08:00:10.578107+00:00 0:00:02.920130 14852 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T08:00:05.087675+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T06:00:00+00:00 EmrJobFlowSensor 2021-04-08T07:13:39.900422+00:00 2021-04-08T07:21:42.445798+00:00 0:08:02.545376 14850 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T07:13:36.997785+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T06:00:00+00:00 EmrJobFlowSensor 2021-04-08T07:13:37.358751+00:00 2021-04-08T07:23:40.675997+00:00 0:10:03.317246 14849 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T07:13:34.988648+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T07:13:11.169380+00:00 2021-04-08T07:13:12.925609+00:00 0:00:01.756229 14848 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T07:13:08.946230+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T07:13:09.405686+00:00 2021-04-08T07:13:11.205363+00:00 0:00:01.799677 14847 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T07:13:06.956875+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T06:00:00+00:00 PythonOperator 2021-04-08T07:12:49.211431+00:00 2021-04-08T07:12:52.005709+00:00 0:00:02.794278 14846 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T07:12:46.853012+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T06:00:00+00:00 PythonOperator 2021-04-08T07:12:47.394858+00:00 2021-04-08T07:12:50.369733+00:00 0:00:02.974875 14845 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T07:12:44.870776+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T06:00:00+00:00 TriggerDagRunOperator 2021-04-08T07:12:35.121543+00:00 2021-04-08T07:12:35.657370+00:00 0:00:00.535827 14844 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T07:12:32.806656+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T06:00:00+00:00 TriggerDagRunOperator 2021-04-08T07:12:34.995032+00:00 2021-04-08T07:12:35.444453+00:00 0:00:00.449421 14843 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T07:12:32.806688+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T06:05:00+00:00 EmrJobFlowSensor 2021-04-08T07:05:56.386653+00:00 2021-04-08T07:13:58.845130+00:00 0:08:02.458477 14842 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T07:05:54.164812+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T07:05:34.415185+00:00 2021-04-08T07:05:36.327148+00:00 0:00:01.911963 14841 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T07:05:32.041740+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T06:05:00+00:00 PythonOperator 2021-04-08T07:05:12.093469+00:00 2021-04-08T07:05:14.759850+00:00 0:00:02.666381 14840 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T07:05:09.960867+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T06:00:00+00:00 EmrJobFlowSensor 2021-04-08T07:01:09.928140+00:00 2021-04-08T07:12:12.992092+00:00 0:11:03.063952 14839 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T07:01:07.538751+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T07:00:35.817836+00:00 2021-04-08T07:00:37.662403+00:00 0:00:01.844567 14838 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T07:00:33.504026+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T06:00:00+00:00 PythonOperator 2021-04-08T07:00:11.934258+00:00 2021-04-08T07:00:14.637584+00:00 0:00:02.703326 14837 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T07:00:09.494139+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T05:00:00+00:00 EmrJobFlowSensor 2021-04-08T06:12:17.559181+00:00 2021-04-08T06:20:20.045287+00:00 0:08:02.486106 14835 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T06:12:14.923767+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T05:00:00+00:00 EmrJobFlowSensor 2021-04-08T06:12:15.306756+00:00 2021-04-08T06:22:18.464380+00:00 0:10:03.157624 14834 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T06:12:12.924154+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T06:11:55.217400+00:00 2021-04-08T06:11:56.993066+00:00 0:00:01.775666 14833 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T06:11:52.902847+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T06:11:53.165303+00:00 2021-04-08T06:11:54.873644+00:00 0:00:01.708341 14832 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T06:11:50.955313+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T05:00:00+00:00 PythonOperator 2021-04-08T06:11:33.217013+00:00 2021-04-08T06:11:36.580926+00:00 0:00:03.363913 14831 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T06:11:30.883372+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T05:00:00+00:00 PythonOperator 2021-04-08T06:11:31.220028+00:00 2021-04-08T06:11:34.208738+00:00 0:00:02.988710 14830 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T06:11:28.947944+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T05:00:00+00:00 TriggerDagRunOperator 2021-04-08T06:11:13.150696+00:00 2021-04-08T06:11:13.700076+00:00 0:00:00.549380 14829 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T06:11:10.793868+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T05:00:00+00:00 TriggerDagRunOperator 2021-04-08T06:11:13.015966+00:00 2021-04-08T06:11:13.433772+00:00 0:00:00.417806 14828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T06:11:10.793832+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T05:05:00+00:00 EmrJobFlowSensor 2021-04-08T06:05:46.640801+00:00 2021-04-08T06:14:49.419955+00:00 0:09:02.779154 14827 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T06:05:44.261740+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T06:05:26.357858+00:00 2021-04-08T06:05:28.013618+00:00 0:00:01.655760 14826 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T06:05:24.205524+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T05:05:00+00:00 PythonOperator 2021-04-08T06:05:04.588323+00:00 2021-04-08T06:05:07.315242+00:00 0:00:02.726919 14825 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T06:05:02.253792+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-08T05:00:00+00:00 EmrJobFlowSensor 2021-04-08T06:00:48.290229+00:00 2021-04-08T06:10:51.181650+00:00 0:10:02.891421 14824 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T06:00:45.809004+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-08T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T06:00:26.055870+00:00 2021-04-08T06:00:27.810385+00:00 0:00:01.754515 14823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-08T06:00:23.796157+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-08T05:00:00+00:00 PythonOperator 2021-04-08T06:00:06.282762+00:00 2021-04-08T06:00:09.154444+00:00 0:00:02.871682 14822 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-08T06:00:03.781449+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-08T04:00:00+00:00 EmrJobFlowSensor 2021-04-08T05:12:47.801684+00:00 2021-04-08T05:20:50.281193+00:00 0:08:02.479509 14820 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T05:12:45.631397+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-08T04:00:00+00:00 EmrJobFlowSensor 2021-04-08T05:12:37.937107+00:00 2021-04-08T05:23:41.066115+00:00 0:11:03.129008 14819 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T05:12:35.614730+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-08T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T05:12:11.815184+00:00 2021-04-08T05:12:13.510428+00:00 0:00:01.695244 14818 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T05:12:09.591042+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-08T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-08T05:12:08.008686+00:00 2021-04-08T05:12:09.723936+00:00 0:00:01.715250 14817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T05:12:05.651522+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-08T04:00:00+00:00 PythonOperator 2021-04-08T05:11:48.497550+00:00 2021-04-08T05:11:51.224722+00:00 0:00:02.727172 14816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T05:11:45.586754+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-08T04:00:00+00:00 PythonOperator 2021-04-08T05:11:45.994121+00:00 2021-04-08T05:11:49.302220+00:00 0:00:03.308099 14815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T05:11:43.577591+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-08T04:00:00+00:00 TriggerDagRunOperator 2021-04-08T05:11:27.817554+00:00 2021-04-08T05:11:28.325893+00:00 0:00:00.508339 14814 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T05:11:25.496549+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-08T04:00:00+00:00 TriggerDagRunOperator 2021-04-08T05:11:27.704929+00:00 2021-04-08T05:11:28.112722+00:00 0:00:00.407793 14813 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T05:11:25.496515+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-08T04:05:00+00:00 EmrJobFlowSensor 2021-04-08T05:05:53.438340+00:00 2021-04-08T05:14:56.147596+00:00 0:09:02.709256 14812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-08T05:05:50.959720+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-08T04:05:00+00:00 EmrCreateJobFlowOperator 2021-04-08T05:05:33.345563+00:00 2021-04-08T05:05:35.080337+00:00 0:00:01.734774 14811 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-08T05:05:30.886719+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-08T04:05:00+00:00 PythonOperator 2021-04-08T05:05:10.921912+00:00 2021-04-08T05:05:13.597205+00:00 0:00:02.675293 14810 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-08T05:05:08.761489+00:00 2 default_pool