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 create_cluster_and_add_emr_steps 2021-03-20T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T07:11:45.466119+00:00 2021-03-20T07:11:47.347840+00:00 0:00:01.881721 10028 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-20T07:11:43.026232+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-20T06:00:00+00:00 PythonOperator 2021-03-20T07:11:17.207261+00:00 2021-03-20T07:11:20.093850+00:00 0:00:02.886589 10027 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T07:11:14.911152+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T06:00:00+00:00 TriggerDagRunOperator 2021-03-20T07:11:11.249985+00:00 2021-03-20T07:11:11.777387+00:00 0:00:00.527402 10026 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T07:11:08.907046+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T06:00:00+00:00 TriggerDagRunOperator 2021-03-20T07:11:11.187096+00:00 2021-03-20T07:11:11.635850+00:00 0:00:00.448754 10025 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T07:11:08.907079+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T06:00:00+00:00 EmrJobFlowSensor 2021-03-20T07:01:00.034892+00:00 2021-03-20T07:11:02.903658+00:00 0:10:02.868766 10024 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T07:00:57.815485+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T07:00:33.863688+00:00 2021-03-20T07:00:35.600380+00:00 0:00:01.736692 10023 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T07:00:31.694788+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T06:00:00+00:00 PythonOperator 2021-03-20T07:00:08.280885+00:00 2021-03-20T07:00:10.990106+00:00 0:00:02.709221 10022 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T07:00:05.672426+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-20T05:00:00+00:00 EmrJobFlowSensor 2021-03-20T06:11:17.369459+00:00 2021-03-20T06:20:20.156372+00:00 0:09:02.786913 10020 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T06:11:15.101970+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-20T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T06:10:55.394599+00:00 2021-03-20T06:10:57.115687+00:00 0:00:01.721088 10019 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-20T06:10:53.085017+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-20T05:00:00+00:00 PythonOperator 2021-03-20T06:10:31.348662+00:00 2021-03-20T06:10:34.195105+00:00 0:00:02.846443 10018 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T06:10:29.066104+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T05:00:00+00:00 TriggerDagRunOperator 2021-03-20T06:10:22.054666+00:00 2021-03-20T06:10:22.592172+00:00 0:00:00.537506 10017 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T06:10:19.044197+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T05:00:00+00:00 TriggerDagRunOperator 2021-03-20T06:10:21.524098+00:00 2021-03-20T06:10:21.896948+00:00 0:00:00.372850 10016 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T06:10:19.044228+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T05:00:00+00:00 EmrJobFlowSensor 2021-03-20T06:01:12.177189+00:00 2021-03-20T06:10:14.979915+00:00 0:09:02.802726 10015 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T06:01:09.873407+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T06:00:48.052422+00:00 2021-03-20T06:00:49.778306+00:00 0:00:01.725884 10014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T06:00:45.859500+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T05:00:00+00:00 PythonOperator 2021-03-20T06:00:30.522006+00:00 2021-03-20T06:00:33.416366+00:00 0:00:02.894360 10013 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T06:00:27.814943+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-20T04:00:00+00:00 EmrJobFlowSensor 2021-03-20T05:12:27.230161+00:00 2021-03-20T05:20:29.723475+00:00 0:08:02.493314 10011 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T05:12:24.755407+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-20T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T05:12:10.803655+00:00 2021-03-20T05:12:12.534725+00:00 0:00:01.731070 10010 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-20T05:12:08.687119+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-20T04:00:00+00:00 PythonOperator 2021-03-20T05:11:55.111566+00:00 2021-03-20T05:11:57.856468+00:00 0:00:02.744902 10009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T05:11:52.680478+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T04:00:00+00:00 TriggerDagRunOperator 2021-03-20T05:11:49.359506+00:00 2021-03-20T05:11:49.895809+00:00 0:00:00.536303 10008 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T05:11:46.668483+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T04:00:00+00:00 TriggerDagRunOperator 2021-03-20T05:11:49.229876+00:00 2021-03-20T05:11:49.656419+00:00 0:00:00.426543 10007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T05:11:46.668449+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T04:00:00+00:00 EmrJobFlowSensor 2021-03-20T05:01:39.438139+00:00 2021-03-20T05:11:42.239734+00:00 0:10:02.801595 10006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T05:01:37.237132+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T05:01:23.839626+00:00 2021-03-20T05:01:25.819521+00:00 0:00:01.979895 10005 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T05:01:21.213657+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T04:00:00+00:00 PythonOperator 2021-03-20T05:00:17.434032+00:00 2021-03-20T05:00:20.176562+00:00 0:00:02.742530 10004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T05:00:15.085167+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-20T03:00:00+00:00 EmrJobFlowSensor 2021-03-20T04:12:00.636977+00:00 2021-03-20T04:21:03.300260+00:00 0:09:02.663283 10002 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T04:11:58.422646+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-20T03:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T04:11:44.822795+00:00 2021-03-20T04:11:46.744000+00:00 0:00:01.921205 10001 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-20T04:11:42.407040+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-20T03:00:00+00:00 PythonOperator 2021-03-20T04:11:28.615621+00:00 2021-03-20T04:11:31.330536+00:00 0:00:02.714915 10000 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T04:11:26.389453+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T03:00:00+00:00 TriggerDagRunOperator 2021-03-20T04:11:10.706944+00:00 2021-03-20T04:11:11.237030+00:00 0:00:00.530086 9999 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T04:11:08.369735+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T03:00:00+00:00 TriggerDagRunOperator 2021-03-20T04:11:10.619411+00:00 2021-03-20T04:11:11.006359+00:00 0:00:00.386948 9998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T04:11:08.369708+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T03:00:00+00:00 EmrJobFlowSensor 2021-03-20T04:00:49.677448+00:00 2021-03-20T04:10:52.351153+00:00 0:10:02.673705 9997 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T04:00:47.442119+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T03:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T04:00:33.879616+00:00 2021-03-20T04:00:35.776836+00:00 0:00:01.897220 9996 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T04:00:31.375581+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T03:00:00+00:00 PythonOperator 2021-03-20T04:00:17.719133+00:00 2021-03-20T04:00:20.473861+00:00 0:00:02.754728 9995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T04:00:15.426590+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-20T02:00:00+00:00 EmrJobFlowSensor 2021-03-20T03:16:26.470921+00:00 2021-03-20T03:24:29.075557+00:00 0:08:02.604636 9994 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T03:16:24.286890+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-20T02:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T03:16:00.479171+00:00 2021-03-20T03:16:02.217410+00:00 0:00:01.738239 9993 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-20T03:15:58.272721+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-20T02:00:00+00:00 PythonOperator 2021-03-20T03:15:44.523767+00:00 2021-03-20T03:15:47.349022+00:00 0:00:02.825255 9992 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T03:15:42.216747+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T02:00:00+00:00 TriggerDagRunOperator 2021-03-20T03:15:24.796079+00:00 2021-03-20T03:15:25.336460+00:00 0:00:00.540381 9991 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T03:15:22.203581+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T02:00:00+00:00 TriggerDagRunOperator 2021-03-20T03:15:24.735724+00:00 2021-03-20T03:15:25.156896+00:00 0:00:00.421172 9990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T03:15:22.203609+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T02:00:00+00:00 EmrJobFlowSensor 2021-03-20T03:01:10.173299+00:00 2021-03-20T03:11:13.165188+00:00 0:10:02.991889 9988 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T03:01:07.694205+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T02:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T03:00:48.077099+00:00 2021-03-20T03:00:49.935454+00:00 0:00:01.858355 9987 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T03:00:45.676745+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T02:00:00+00:00 PythonOperator 2021-03-20T03:00:20.111438+00:00 2021-03-20T03:00:22.910161+00:00 0:00:02.798723 9986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T03:00:17.718461+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-20T01:00:00+00:00 EmrJobFlowSensor 2021-03-20T02:11:51.159876+00:00 2021-03-20T02:20:54.005886+00:00 0:09:02.846010 9985 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T02:11:48.668615+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-20T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T02:11:35.124811+00:00 2021-03-20T02:11:36.810041+00:00 0:00:01.685230 9984 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-20T02:11:32.729264+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-20T01:00:00+00:00 PythonOperator 2021-03-20T02:11:18.942252+00:00 2021-03-20T02:11:21.784632+00:00 0:00:02.842380 9983 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T02:11:16.606734+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T01:00:00+00:00 TriggerDagRunOperator 2021-03-20T02:11:15.177819+00:00 2021-03-20T02:11:15.742541+00:00 0:00:00.564722 9982 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T02:11:12.604405+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T01:00:00+00:00 TriggerDagRunOperator 2021-03-20T02:11:14.985531+00:00 2021-03-20T02:11:15.401381+00:00 0:00:00.415850 9981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T02:11:12.604378+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T01:00:00+00:00 EmrJobFlowSensor 2021-03-20T02:00:58.055210+00:00 2021-03-20T02:11:00.854234+00:00 0:10:02.799024 9979 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T02:00:55.759485+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T02:00:42.015585+00:00 2021-03-20T02:00:43.854812+00:00 0:00:01.839227 9978 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T02:00:39.696573+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T01:00:00+00:00 PythonOperator 2021-03-20T02:00:13.926182+00:00 2021-03-20T02:00:16.637173+00:00 0:00:02.710991 9977 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T02:00:11.681638+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-20T00:00:00+00:00 EmrJobFlowSensor 2021-03-20T01:10:58.962004+00:00 2021-03-20T01:19:01.618044+00:00 0:08:02.656040 9976 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T01:10:56.445483+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-20T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T01:10:42.518034+00:00 2021-03-20T01:10:44.247321+00:00 0:00:01.729287 9975 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-20T01:10:40.398732+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-20T00:00:00+00:00 PythonOperator 2021-03-20T01:10:26.568759+00:00 2021-03-20T01:10:29.280827+00:00 0:00:02.712068 9974 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T01:10:24.381550+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T00:00:00+00:00 TriggerDagRunOperator 2021-03-20T01:10:13.139281+00:00 2021-03-20T01:10:13.571660+00:00 0:00:00.432379 9973 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T01:10:10.375439+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T00:00:00+00:00 TriggerDagRunOperator 2021-03-20T01:10:13.126433+00:00 2021-03-20T01:10:13.723999+00:00 0:00:00.597566 9972 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T01:10:10.375482+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T00:00:00+00:00 EmrJobFlowSensor 2021-03-20T01:00:51.323016+00:00 2021-03-20T01:09:53.953886+00:00 0:09:02.630870 9970 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T01:00:49.135600+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T01:00:27.389627+00:00 2021-03-20T01:00:29.230380+00:00 0:00:01.840753 9969 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T01:00:25.116831+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T00:00:00+00:00 PythonOperator 2021-03-20T01:00:11.340877+00:00 2021-03-20T01:00:14.109103+00:00 0:00:02.768226 9968 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T01:00:09.092562+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-19T23:00:00+00:00 EmrJobFlowSensor 2021-03-20T00:10:31.906824+00:00 2021-03-20T00:20:34.835261+00:00 0:10:02.928437 9967 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T00:10:29.670306+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-19T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T00:10:15.988697+00:00 2021-03-20T00:10:17.696114+00:00 0:00:01.707417 9966 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-20T00:10:13.720883+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-19T23:00:00+00:00 PythonOperator 2021-03-20T00:09:59.752710+00:00 2021-03-20T00:10:02.559763+00:00 0:00:02.807053 9965 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T00:09:57.585450+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-19T23:00:00+00:00 TriggerDagRunOperator 2021-03-20T00:09:50.710498+00:00 2021-03-20T00:09:51.230563+00:00 0:00:00.520065 9964 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T00:09:47.336659+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-19T23:00:00+00:00 TriggerDagRunOperator 2021-03-20T00:09:50.068040+00:00 2021-03-20T00:09:50.481258+00:00 0:00:00.413218 9963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T00:09:47.336686+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-19T23:00:00+00:00 EmrJobFlowSensor 2021-03-20T00:00:40.684194+00:00 2021-03-20T00:09:43.491959+00:00 0:09:02.807765 9961 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T00:00:38.319095+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-19T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T00:00:24.434989+00:00 2021-03-20T00:00:26.175601+00:00 0:00:01.740612 9960 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T00:00:22.282904+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-19T23:00:00+00:00 PythonOperator 2021-03-20T00:00:06.710122+00:00 2021-03-20T00:00:09.453951+00:00 0:00:02.743829 9959 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T00:00:04.324552+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-19T22:00:00+00:00 EmrJobFlowSensor 2021-03-19T23:11:11.026416+00:00 2021-03-19T23:21:13.937281+00:00 0:10:02.910865 9958 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T23:11:08.671085+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-19T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-19T23:10:54.867709+00:00 2021-03-19T23:10:56.552745+00:00 0:00:01.685036 9957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-19T23:10:52.654645+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-19T22:00:00+00:00 PythonOperator 2021-03-19T23:10:22.907671+00:00 2021-03-19T23:10:25.612405+00:00 0:00:02.704734 9956 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-19T23:10:20.595533+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-19T22:00:00+00:00 TriggerDagRunOperator 2021-03-19T23:10:06.928329+00:00 2021-03-19T23:10:07.483801+00:00 0:00:00.555472 9955 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T23:10:04.581306+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-19T22:00:00+00:00 TriggerDagRunOperator 2021-03-19T23:10:06.911617+00:00 2021-03-19T23:10:07.305357+00:00 0:00:00.393740 9954 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T23:10:04.581334+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-19T22:00:00+00:00 EmrJobFlowSensor 2021-03-19T23:01:46.212613+00:00 2021-03-19T23:09:48.830283+00:00 0:08:02.617670 9953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-19T23:01:43.832969+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-19T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-19T23:01:30.021473+00:00 2021-03-19T23:01:31.734554+00:00 0:00:01.713081 9952 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-19T23:01:27.723024+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-19T22:00:00+00:00 PythonOperator 2021-03-19T23:01:14.461149+00:00 2021-03-19T23:01:17.166067+00:00 0:00:02.704918 9951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-19T23:01:11.764306+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-19T21:00:00+00:00 EmrJobFlowSensor 2021-03-19T22:12:04.639490+00:00 2021-03-19T22:22:07.393914+00:00 0:10:02.754424 9949 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T22:12:02.283625+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-19T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-19T22:11:48.712075+00:00 2021-03-19T22:11:50.540853+00:00 0:00:01.828778 9948 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-19T22:11:46.270130+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-19T21:00:00+00:00 PythonOperator 2021-03-19T22:11:32.708680+00:00 2021-03-19T22:11:35.418207+00:00 0:00:02.709527 9947 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-19T22:11:30.330909+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-19T21:00:00+00:00 TriggerDagRunOperator 2021-03-19T22:11:22.834411+00:00 2021-03-19T22:11:23.362633+00:00 0:00:00.528222 9946 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T22:11:20.251541+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-19T21:00:00+00:00 TriggerDagRunOperator 2021-03-19T22:11:22.604341+00:00 2021-03-19T22:11:23.009310+00:00 0:00:00.404969 9945 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T22:11:20.251500+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-19T21:00:00+00:00 EmrJobFlowSensor 2021-03-19T22:00:59.131371+00:00 2021-03-19T22:11:02.000792+00:00 0:10:02.869421 9944 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-19T22:00:56.977063+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-19T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-19T22:00:37.317667+00:00 2021-03-19T22:00:39.198521+00:00 0:00:01.880854 9943 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-19T22:00:34.960096+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-19T21:00:00+00:00 PythonOperator 2021-03-19T22:00:19.331372+00:00 2021-03-19T22:00:22.049578+00:00 0:00:02.718206 9942 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-19T22:00:16.887940+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-19T20:00:00+00:00 EmrJobFlowSensor 2021-03-19T21:10:36.805371+00:00 2021-03-19T21:32:41.158083+00:00 0:22:04.352712 9940 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T21:10:34.498618+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-19T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-19T21:10:20.694719+00:00 2021-03-19T21:10:22.406031+00:00 0:00:01.711312 9939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-19T21:10:18.486483+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-19T20:00:00+00:00 PythonOperator 2021-03-19T21:10:05.137478+00:00 2021-03-19T21:10:08.226908+00:00 0:00:03.089430 9938 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-19T21:10:02.470515+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-19T20:00:00+00:00 TriggerDagRunOperator 2021-03-19T21:09:55.203303+00:00 2021-03-19T21:09:55.740683+00:00 0:00:00.537380 9937 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T21:09:52.530148+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-19T20:00:00+00:00 TriggerDagRunOperator 2021-03-19T21:09:54.811326+00:00 2021-03-19T21:09:55.221230+00:00 0:00:00.409904 9936 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T21:09:52.530119+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-19T20:00:00+00:00 EmrJobFlowSensor 2021-03-19T21:00:43.840207+00:00 2021-03-19T21:09:46.756923+00:00 0:09:02.916716 9935 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-19T21:00:41.338710+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-19T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-19T21:00:27.417459+00:00 2021-03-19T21:00:29.179838+00:00 0:00:01.762379 9934 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-19T21:00:25.267310+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-19T20:00:00+00:00 PythonOperator 2021-03-19T21:00:10.075700+00:00 2021-03-19T21:00:12.947016+00:00 0:00:02.871316 9933 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-19T21:00:07.256559+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-19T19:00:00+00:00 EmrJobFlowSensor 2021-03-19T20:12:03.566498+00:00 2021-03-19T20:21:06.212696+00:00 0:09:02.646198 9931 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T20:12:01.241923+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-19T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-19T20:11:47.455809+00:00 2021-03-19T20:11:49.134214+00:00 0:00:01.678405 9930 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-19T20:11:45.147218+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-19T19:00:00+00:00 PythonOperator 2021-03-19T20:11:19.411196+00:00 2021-03-19T20:11:22.281128+00:00 0:00:02.869932 9929 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-19T20:11:16.996476+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-19T19:00:00+00:00 TriggerDagRunOperator 2021-03-19T20:11:05.290670+00:00 2021-03-19T20:11:05.838774+00:00 0:00:00.548104 9928 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T20:11:02.986792+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-19T19:00:00+00:00 TriggerDagRunOperator 2021-03-19T20:11:05.204182+00:00 2021-03-19T20:11:05.647865+00:00 0:00:00.443683 9927 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T20:11:02.986760+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-19T19:00:00+00:00 EmrJobFlowSensor 2021-03-19T20:00:48.032216+00:00 2021-03-19T20:10:50.740368+00:00 0:10:02.708152 9926 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-19T20:00:45.876683+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-19T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-19T20:00:30.468015+00:00 2021-03-19T20:00:32.348503+00:00 0:00:01.880488 9925 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-19T20:00:27.937410+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-19T19:00:00+00:00 PythonOperator 2021-03-19T20:00:14.365345+00:00 2021-03-19T20:00:17.068869+00:00 0:00:02.703524 9924 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-19T20:00:11.843078+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-03-19T18:00:00+00:00 EmrJobFlowSensor 2021-03-19T19:12:04.167504+00:00 2021-03-19T19:31:08.261062+00:00 0:19:04.093558 9922 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T19:12:01.798264+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-03-19T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-19T19:11:47.988709+00:00 2021-03-19T19:11:49.749022+00:00 0:00:01.760313 9921 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-19T19:11:45.776354+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-19T18:00:00+00:00 PythonOperator 2021-03-19T19:11:29.990579+00:00 2021-03-19T19:11:32.740191+00:00 0:00:02.749612 9920 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-19T19:11:27.766403+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-19T18:00:00+00:00 TriggerDagRunOperator 2021-03-19T19:11:11.902251+00:00 2021-03-19T19:11:12.470067+00:00 0:00:00.567816 9919 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T19:11:09.686733+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-19T18:00:00+00:00 TriggerDagRunOperator 2021-03-19T19:11:11.818189+00:00 2021-03-19T19:11:12.211153+00:00 0:00:00.392964 9918 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T19:11:09.686704+00:00 2 default_pool