Task Instances

Reset Filters
  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_emr_steps 2021-04-13T21:00:00+00:00 PythonOperator 2021-04-13T22:00:17.613388+00:00 2021-04-13T22:00:20.503122+00:00 0:00:02.889734 16874 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T22:00:15.325603+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T20:00:00+00:00 TriggerDagRunOperator 2021-04-13T21:09:21.902883+00:00 2021-04-13T21:09:22.502029+00:00 0:00:00.599146 16866 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T21:09:19.464432+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T20:00:00+00:00 TriggerDagRunOperator 2021-04-13T21:09:21.728120+00:00 2021-04-13T21:09:22.191085+00:00 0:00:00.462965 16865 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T21:09:19.464401+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T20:00:00+00:00 EmrJobFlowSensor 2021-04-13T21:01:00.924833+00:00 2021-04-13T21:09:03.501163+00:00 0:08:02.576330 16861 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T21:00:58.656882+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T21:00:39.079907+00:00 2021-04-13T21:00:40.901293+00:00 0:00:01.821386 16860 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T21:00:36.562129+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T20:00:00+00:00 PythonOperator 2021-04-13T21:00:19.308381+00:00 2021-04-13T21:00:22.166808+00:00 0:00:02.858427 16859 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T21:00:16.546303+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T19:00:00+00:00 TriggerDagRunOperator 2021-04-13T20:09:59.748329+00:00 2021-04-13T20:10:00.378740+00:00 0:00:00.630411 16851 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T20:09:57.247504+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T19:00:00+00:00 TriggerDagRunOperator 2021-04-13T20:09:59.574414+00:00 2021-04-13T20:10:00.006447+00:00 0:00:00.432033 16850 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T20:09:57.247463+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T19:00:00+00:00 EmrJobFlowSensor 2021-04-13T20:00:52.667732+00:00 2021-04-13T20:09:55.434705+00:00 0:09:02.766973 16844 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T20:00:50.396636+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T20:00:30.813155+00:00 2021-04-13T20:00:32.514841+00:00 0:00:01.701686 16843 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T20:00:28.440862+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T19:00:00+00:00 PythonOperator 2021-04-13T20:00:08.617819+00:00 2021-04-13T20:00:11.559576+00:00 0:00:02.941757 16842 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T20:00:06.206515+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T18:00:00+00:00 TriggerDagRunOperator 2021-04-13T19:09:20.367603+00:00 2021-04-13T19:09:20.914632+00:00 0:00:00.547029 16834 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T19:09:18.084131+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T18:00:00+00:00 TriggerDagRunOperator 2021-04-13T19:09:20.275336+00:00 2021-04-13T19:09:20.713745+00:00 0:00:00.438409 16833 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T19:09:18.084158+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T18:00:00+00:00 EmrJobFlowSensor 2021-04-13T19:01:05.336252+00:00 2021-04-13T19:09:07.874128+00:00 0:08:02.537876 16829 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T19:01:03.047756+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T19:00:35.327652+00:00 2021-04-13T19:00:37.082721+00:00 0:00:01.755069 16828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T19:00:33.008174+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T18:00:00+00:00 PythonOperator 2021-04-13T19:00:13.646849+00:00 2021-04-13T19:00:16.581679+00:00 0:00:02.934830 16827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T19:00:10.989747+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T17:00:00+00:00 TriggerDagRunOperator 2021-04-13T18:10:20.390838+00:00 2021-04-13T18:10:20.822224+00:00 0:00:00.431386 16819 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T18:10:17.985989+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T17:00:00+00:00 TriggerDagRunOperator 2021-04-13T18:10:20.420566+00:00 2021-04-13T18:10:20.955495+00:00 0:00:00.534929 16818 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T18:10:17.986016+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T17:00:00+00:00 EmrJobFlowSensor 2021-04-13T18:01:03.430187+00:00 2021-04-13T18:10:06.073677+00:00 0:09:02.643490 16814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T18:01:01.033796+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T18:00:43.340043+00:00 2021-04-13T18:00:45.001131+00:00 0:00:01.661088 16813 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T18:00:41.012372+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T17:00:00+00:00 PythonOperator 2021-04-13T18:00:21.250760+00:00 2021-04-13T18:00:24.260353+00:00 0:00:03.009593 16812 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T18:00:18.999526+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T16:00:00+00:00 TriggerDagRunOperator 2021-04-13T17:27:23.855984+00:00 2021-04-13T17:27:24.753413+00:00 0:00:00.897429 16803 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T17:27:21.545728+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T16:00:00+00:00 TriggerDagRunOperator 2021-04-13T17:27:23.730863+00:00 2021-04-13T17:27:24.160777+00:00 0:00:00.429914 16802 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T17:27:21.545754+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T16:00:00+00:00 EmrJobFlowSensor 2021-04-13T17:00:55.287552+00:00 2021-04-13T17:27:00.069560+00:00 0:26:04.782008 16795 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T17:00:52.952364+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T17:00:33.065628+00:00 2021-04-13T17:00:34.753257+00:00 0:00:01.687629 16794 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T17:00:30.825323+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T16:00:00+00:00 PythonOperator 2021-04-13T17:00:13.097936+00:00 2021-04-13T17:00:16.922674+00:00 0:00:03.824738 16793 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T17:00:10.806670+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T15:00:00+00:00 TriggerDagRunOperator 2021-04-13T16:18:28.980873+00:00 2021-04-13T16:18:29.468751+00:00 0:00:00.487878 16786 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T16:18:26.533003+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T15:00:00+00:00 TriggerDagRunOperator 2021-04-13T16:18:28.788043+00:00 2021-04-13T16:18:29.181649+00:00 0:00:00.393606 16785 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T16:18:26.533040+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T15:00:00+00:00 EmrJobFlowSensor 2021-04-13T16:09:01.924468+00:00 2021-04-13T16:18:04.739745+00:00 0:09:02.815277 16784 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T16:08:59.716252+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T16:08:40.124560+00:00 2021-04-13T16:08:42.338608+00:00 0:00:02.214048 16782 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T16:08:37.743675+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T15:00:00+00:00 PythonOperator 2021-04-13T16:08:20.012917+00:00 2021-04-13T16:08:22.925882+00:00 0:00:02.912965 16780 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T16:08:17.635541+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T14:00:00+00:00 TriggerDagRunOperator 2021-04-13T15:10:05.323050+00:00 2021-04-13T15:10:05.864247+00:00 0:00:00.541197 16771 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T15:10:02.691503+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T14:00:00+00:00 TriggerDagRunOperator 2021-04-13T15:10:05.043524+00:00 2021-04-13T15:10:05.613019+00:00 0:00:00.569495 16770 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T15:10:02.691536+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T14:00:00+00:00 EmrJobFlowSensor 2021-04-13T15:00:56.117771+00:00 2021-04-13T15:09:58.692298+00:00 0:09:02.574527 16766 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T15:00:53.887363+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T15:00:34.193774+00:00 2021-04-13T15:00:35.897894+00:00 0:00:01.704120 16765 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T15:00:31.847157+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T14:00:00+00:00 PythonOperator 2021-04-13T15:00:12.298305+00:00 2021-04-13T15:00:15.284801+00:00 0:00:02.986496 16764 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T15:00:09.830735+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T13:00:00+00:00 TriggerDagRunOperator 2021-04-13T14:11:21.593916+00:00 2021-04-13T14:11:22.080932+00:00 0:00:00.487016 16756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T14:11:19.372672+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T13:00:00+00:00 TriggerDagRunOperator 2021-04-13T14:11:21.627741+00:00 2021-04-13T14:11:22.220665+00:00 0:00:00.592924 16755 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T14:11:19.372708+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T13:00:00+00:00 EmrJobFlowSensor 2021-04-13T14:01:08.711726+00:00 2021-04-13T14:11:11.463267+00:00 0:10:02.751541 16751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T14:01:06.489439+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T14:00:38.733456+00:00 2021-04-13T14:00:40.546004+00:00 0:00:01.812548 16750 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T14:00:36.418369+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T13:00:00+00:00 PythonOperator 2021-04-13T14:00:11.002038+00:00 2021-04-13T14:00:13.982608+00:00 0:00:02.980570 16749 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T14:00:08.402061+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T12:00:00+00:00 TriggerDagRunOperator 2021-04-13T13:10:25.738440+00:00 2021-04-13T13:10:26.281599+00:00 0:00:00.543159 16739 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T13:10:23.351531+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T12:00:00+00:00 TriggerDagRunOperator 2021-04-13T13:10:25.580305+00:00 2021-04-13T13:10:26.007867+00:00 0:00:00.427562 16738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T13:10:23.351558+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T12:00:00+00:00 EmrJobFlowSensor 2021-04-13T13:01:02.921373+00:00 2021-04-13T13:10:05.786012+00:00 0:09:02.864639 16734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T13:01:00.384836+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T13:00:40.528233+00:00 2021-04-13T13:00:42.236766+00:00 0:00:01.708533 16733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T13:00:38.298606+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T12:00:00+00:00 PythonOperator 2021-04-13T13:00:18.609347+00:00 2021-04-13T13:00:21.486889+00:00 0:00:02.877542 16732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T13:00:16.262871+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T11:00:00+00:00 TriggerDagRunOperator 2021-04-13T12:11:09.243590+00:00 2021-04-13T12:11:09.754778+00:00 0:00:00.511188 16724 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T12:11:06.617761+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T11:00:00+00:00 TriggerDagRunOperator 2021-04-13T12:11:08.998657+00:00 2021-04-13T12:11:09.417557+00:00 0:00:00.418900 16723 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T12:11:06.617792+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T11:00:00+00:00 EmrJobFlowSensor 2021-04-13T12:01:02.005525+00:00 2021-04-13T12:11:04.766695+00:00 0:10:02.761170 16719 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T12:00:59.553781+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T12:00:39.510193+00:00 2021-04-13T12:00:41.245595+00:00 0:00:01.735402 16718 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T12:00:37.352472+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T11:00:00+00:00 PythonOperator 2021-04-13T12:00:19.607812+00:00 2021-04-13T12:00:22.563236+00:00 0:00:02.955424 16717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T12:00:17.336072+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T10:00:00+00:00 TriggerDagRunOperator 2021-04-13T11:11:12.799827+00:00 2021-04-13T11:11:13.233524+00:00 0:00:00.433697 16709 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T11:11:10.462103+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T10:00:00+00:00 TriggerDagRunOperator 2021-04-13T11:11:12.759892+00:00 2021-04-13T11:11:13.355510+00:00 0:00:00.595618 16708 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T11:11:10.462073+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T10:00:00+00:00 EmrJobFlowSensor 2021-04-13T11:01:03.870633+00:00 2021-04-13T11:11:06.880627+00:00 0:10:03.009994 16704 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T11:01:01.360287+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T11:00:41.520946+00:00 2021-04-13T11:00:43.254261+00:00 0:00:01.733315 16703 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T11:00:39.201653+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T10:00:00+00:00 PythonOperator 2021-04-13T11:00:21.578219+00:00 2021-04-13T11:00:24.546974+00:00 0:00:02.968755 16702 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T11:00:19.189343+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T09:00:00+00:00 TriggerDagRunOperator 2021-04-13T10:11:19.499452+00:00 2021-04-13T10:11:20.031735+00:00 0:00:00.532283 16692 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T10:11:16.875367+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T09:00:00+00:00 TriggerDagRunOperator 2021-04-13T10:11:19.245682+00:00 2021-04-13T10:11:19.670873+00:00 0:00:00.425191 16691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T10:11:16.875397+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T09:00:00+00:00 EmrJobFlowSensor 2021-04-13T10:01:00.286433+00:00 2021-04-13T10:11:03.117944+00:00 0:10:02.831511 16687 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T10:00:57.958791+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T10:00:38.325824+00:00 2021-04-13T10:00:40.126164+00:00 0:00:01.800340 16686 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T10:00:35.974548+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T09:00:00+00:00 PythonOperator 2021-04-13T10:00:18.508416+00:00 2021-04-13T10:00:21.312834+00:00 0:00:02.804418 16685 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T10:00:15.964316+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T08:00:00+00:00 TriggerDagRunOperator 2021-04-13T09:11:20.426757+00:00 2021-04-13T09:11:21.355834+00:00 0:00:00.929077 16675 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T09:11:17.331667+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T08:00:00+00:00 TriggerDagRunOperator 2021-04-13T09:11:20.141052+00:00 2021-04-13T09:11:21.109754+00:00 0:00:00.968702 16674 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T09:11:17.331640+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T08:00:00+00:00 EmrJobFlowSensor 2021-04-13T09:01:08.951171+00:00 2021-04-13T09:11:11.865483+00:00 0:10:02.914312 16670 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T09:01:06.188516+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T09:00:46.424083+00:00 2021-04-13T09:00:48.238826+00:00 0:00:01.814743 16669 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T09:00:44.146704+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T08:00:00+00:00 PythonOperator 2021-04-13T09:00:24.712251+00:00 2021-04-13T09:00:27.535839+00:00 0:00:02.823588 16668 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T09:00:22.125742+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T07:00:00+00:00 TriggerDagRunOperator 2021-04-13T08:10:25.834016+00:00 2021-04-13T08:10:26.343602+00:00 0:00:00.509586 16660 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T08:10:23.394108+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T07:00:00+00:00 TriggerDagRunOperator 2021-04-13T08:10:25.727553+00:00 2021-04-13T08:10:26.139091+00:00 0:00:00.411538 16659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T08:10:23.394081+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T07:00:00+00:00 EmrJobFlowSensor 2021-04-13T08:01:01.101414+00:00 2021-04-13T08:10:03.954008+00:00 0:09:02.852594 16655 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T08:00:58.474415+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T08:00:40.524170+00:00 2021-04-13T08:00:42.199539+00:00 0:00:01.675369 16654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T08:00:38.345213+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T07:00:00+00:00 PythonOperator 2021-04-13T08:00:19.130243+00:00 2021-04-13T08:00:21.982296+00:00 0:00:02.852053 16653 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T08:00:16.329406+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T06:00:00+00:00 TriggerDagRunOperator 2021-04-13T07:11:08.567489+00:00 2021-04-13T07:11:09.082911+00:00 0:00:00.515422 16645 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T07:11:05.843617+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T06:00:00+00:00 TriggerDagRunOperator 2021-04-13T07:11:08.361213+00:00 2021-04-13T07:11:08.795225+00:00 0:00:00.434012 16644 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T07:11:05.843581+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T06:00:00+00:00 EmrJobFlowSensor 2021-04-13T07:00:55.257989+00:00 2021-04-13T07:10:58.135081+00:00 0:10:02.877092 16640 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T07:00:52.846527+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T07:00:33.102571+00:00 2021-04-13T07:00:34.778432+00:00 0:00:01.675861 16639 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T07:00:30.755771+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T06:00:00+00:00 PythonOperator 2021-04-13T07:00:13.023366+00:00 2021-04-13T07:00:15.975954+00:00 0:00:02.952588 16638 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T07:00:10.684066+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T05:00:00+00:00 TriggerDagRunOperator 2021-04-13T06:10:05.536196+00:00 2021-04-13T06:10:06.050060+00:00 0:00:00.513864 16628 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T06:10:02.713335+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T05:00:00+00:00 TriggerDagRunOperator 2021-04-13T06:10:04.878798+00:00 2021-04-13T06:10:05.259518+00:00 0:00:00.380720 16627 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T06:10:02.713368+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T05:00:00+00:00 EmrJobFlowSensor 2021-04-13T06:00:54.334545+00:00 2021-04-13T06:09:57.196330+00:00 0:09:02.861785 16623 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T06:00:51.907950+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T06:00:33.088137+00:00 2021-04-13T06:00:34.766853+00:00 0:00:01.678716 16622 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T06:00:29.886204+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T05:00:00+00:00 PythonOperator 2021-04-13T06:00:10.403954+00:00 2021-04-13T06:00:13.176974+00:00 0:00:02.773020 16621 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T06:00:07.882206+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T04:00:00+00:00 TriggerDagRunOperator 2021-04-13T05:11:05.842632+00:00 2021-04-13T05:11:06.370871+00:00 0:00:00.528239 16613 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T05:11:02.507264+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T04:00:00+00:00 TriggerDagRunOperator 2021-04-13T05:11:05.753299+00:00 2021-04-13T05:11:06.156505+00:00 0:00:00.403206 16612 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T05:11:02.507303+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T04:00:00+00:00 EmrJobFlowSensor 2021-04-13T05:00:48.811413+00:00 2021-04-13T05:10:51.704575+00:00 0:10:02.893162 16608 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T05:00:45.625119+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T05:00:25.890453+00:00 2021-04-13T05:00:27.900097+00:00 0:00:02.009644 16607 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T05:00:23.620169+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T04:00:00+00:00 PythonOperator 2021-04-13T05:00:04.822655+00:00 2021-04-13T05:00:07.860384+00:00 0:00:03.037729 16606 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T05:00:01.650463+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T03:00:00+00:00 TriggerDagRunOperator 2021-04-13T04:10:24.331862+00:00 2021-04-13T04:10:24.898049+00:00 0:00:00.566187 16598 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T04:10:21.487875+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T03:00:00+00:00 TriggerDagRunOperator 2021-04-13T04:10:23.872058+00:00 2021-04-13T04:10:24.417510+00:00 0:00:00.545452 16597 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T04:10:21.487835+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T03:00:00+00:00 EmrJobFlowSensor 2021-04-13T04:01:01.135454+00:00 2021-04-13T04:10:04.006763+00:00 0:09:02.871309 16593 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T04:00:58.641291+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T04:00:40.651965+00:00 2021-04-13T04:00:42.353699+00:00 0:00:01.701734 16592 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T04:00:38.429945+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T03:00:00+00:00 PythonOperator 2021-04-13T04:00:19.387546+00:00 2021-04-13T04:00:22.233159+00:00 0:00:02.845613 16591 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T04:00:16.472355+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T02:00:00+00:00 TriggerDagRunOperator 2021-04-13T03:10:21.751954+00:00 2021-04-13T03:10:22.263757+00:00 0:00:00.511803 16583 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T03:10:18.797270+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T02:00:00+00:00 TriggerDagRunOperator 2021-04-13T03:10:21.191713+00:00 2021-04-13T03:10:21.611076+00:00 0:00:00.419363 16582 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T03:10:18.797217+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T02:00:00+00:00 EmrJobFlowSensor 2021-04-13T03:00:54.103114+00:00 2021-04-13T03:09:56.890310+00:00 0:09:02.787196 16578 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T03:00:51.730627+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T03:00:32.215650+00:00 2021-04-13T03:00:33.960083+00:00 0:00:01.744433 16577 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T03:00:29.772432+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T02:00:00+00:00 PythonOperator 2021-04-13T03:00:10.028554+00:00 2021-04-13T03:00:12.928620+00:00 0:00:02.900066 16576 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T03:00:07.689112+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T01:00:00+00:00 TriggerDagRunOperator 2021-04-13T02:20:43.894400+00:00 2021-04-13T02:20:44.362854+00:00 0:00:00.468454 16569 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T02:20:41.320839+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T01:00:00+00:00 TriggerDagRunOperator 2021-04-13T02:20:43.814956+00:00 2021-04-13T02:20:44.377999+00:00 0:00:00.563043 16568 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T02:20:41.320868+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T01:00:00+00:00 EmrJobFlowSensor 2021-04-13T02:00:53.645445+00:00 2021-04-13T02:08:56.237354+00:00 0:08:02.591909 16563 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T02:00:51.435659+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T02:00:33.789604+00:00 2021-04-13T02:00:35.656030+00:00 0:00:01.866426 16562 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T02:00:31.415370+00:00 2 default_pool