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 check_cluster_status 2023-03-13T23:00:00+00:00 EmrJobFlowSensor 2023-03-14T00:00:57.469461+00:00 2023-03-14T00:10:59.349349+00:00 0:10:01.879888 353173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-14T00:00:54.833295+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-13T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-14T00:00:37.613480+00:00 2023-03-14T00:00:38.839328+00:00 0:00:01.225848 353171 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-14T00:00:34.813449+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-13T23:00:00+00:00 PythonOperator 2023-03-14T00:00:15.526197+00:00 2023-03-14T00:00:18.824866+00:00 0:00:03.298669 353169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-14T00:00:12.790769+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-13T22:00:00+00:00 TriggerDagRunOperator 2023-03-13T23:11:09.466456+00:00 2023-03-13T23:11:09.969221+00:00 0:00:00.502765 353158 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T23:11:06.949264+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-13T22:00:00+00:00 TriggerDagRunOperator 2023-03-13T23:11:09.415550+00:00 2023-03-13T23:11:09.876335+00:00 0:00:00.460785 353157 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T23:11:06.949292+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-13T22:00:00+00:00 EmrJobFlowSensor 2023-03-13T23:01:01.253731+00:00 2023-03-13T23:11:03.196648+00:00 0:10:01.942917 353151 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-13T23:00:58.967396+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-13T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-13T23:00:40.916860+00:00 2023-03-13T23:00:42.143618+00:00 0:00:01.226758 353148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-13T23:00:36.955441+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-13T22:00:00+00:00 PythonOperator 2023-03-13T23:00:17.716988+00:00 2023-03-13T23:00:20.860134+00:00 0:00:03.143146 353145 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-13T23:00:14.928045+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-13T21:00:00+00:00 TriggerDagRunOperator 2023-03-13T22:11:03.901534+00:00 2023-03-13T22:11:04.472630+00:00 0:00:00.571096 353132 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T22:11:01.029552+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-13T21:00:00+00:00 TriggerDagRunOperator 2023-03-13T22:11:03.838170+00:00 2023-03-13T22:11:04.353464+00:00 0:00:00.515294 353131 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T22:11:01.029581+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-13T21:00:00+00:00 EmrJobFlowSensor 2023-03-13T22:00:46.642615+00:00 2023-03-13T22:10:48.984887+00:00 0:10:02.342272 353124 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-13T22:00:44.026391+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-13T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-13T22:00:26.455019+00:00 2023-03-13T22:00:27.419551+00:00 0:00:00.964532 353123 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-13T22:00:23.798705+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-13T21:00:00+00:00 PythonOperator 2023-03-13T22:00:04.501207+00:00 2023-03-13T22:00:07.947555+00:00 0:00:03.446348 353121 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-13T22:00:01.709385+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-13T20:00:00+00:00 TriggerDagRunOperator 2023-03-13T21:11:31.987656+00:00 2023-03-13T21:11:32.491943+00:00 0:00:00.504287 353108 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T21:11:29.054887+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-13T20:00:00+00:00 TriggerDagRunOperator 2023-03-13T21:11:31.839506+00:00 2023-03-13T21:11:32.317880+00:00 0:00:00.478374 353107 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T21:11:29.054856+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-13T20:00:00+00:00 EmrJobFlowSensor 2023-03-13T21:01:06.578651+00:00 2023-03-13T21:11:08.432404+00:00 0:10:01.853753 353101 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-13T21:01:04.200714+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-13T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-13T21:00:44.808080+00:00 2023-03-13T21:00:45.844628+00:00 0:00:01.036548 353099 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-13T21:00:42.164357+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-13T20:00:00+00:00 PythonOperator 2023-03-13T21:00:24.865899+00:00 2023-03-13T21:00:28.169431+00:00 0:00:03.303532 353097 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-13T21:00:22.210673+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-13T19:00:00+00:00 TriggerDagRunOperator 2023-03-13T20:11:26.398628+00:00 2023-03-13T20:11:26.951189+00:00 0:00:00.552561 353085 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T20:11:23.723702+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-13T19:00:00+00:00 TriggerDagRunOperator 2023-03-13T20:11:26.382124+00:00 2023-03-13T20:11:26.847971+00:00 0:00:00.465847 353084 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T20:11:23.723659+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-13T19:00:00+00:00 EmrJobFlowSensor 2023-03-13T20:00:58.357853+00:00 2023-03-13T20:11:00.116570+00:00 0:10:01.758717 353077 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-13T20:00:56.007079+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-13T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-13T20:00:38.513200+00:00 2023-03-13T20:00:39.396345+00:00 0:00:00.883145 353075 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-13T20:00:35.995193+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-13T19:00:00+00:00 PythonOperator 2023-03-13T20:00:16.242249+00:00 2023-03-13T20:00:20.236080+00:00 0:00:03.993831 353073 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-13T20:00:13.828189+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-13T18:00:00+00:00 TriggerDagRunOperator 2023-03-13T19:10:05.258740+00:00 2023-03-13T19:10:05.749719+00:00 0:00:00.490979 353061 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T19:10:02.818499+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-13T18:00:00+00:00 TriggerDagRunOperator 2023-03-13T19:10:05.191047+00:00 2023-03-13T19:10:05.709872+00:00 0:00:00.518825 353060 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T19:10:02.818540+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-13T18:00:00+00:00 EmrJobFlowSensor 2023-03-13T19:00:54.063264+00:00 2023-03-13T19:09:55.704735+00:00 0:09:01.641471 353054 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-13T19:00:51.813688+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-13T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-13T19:00:32.281964+00:00 2023-03-13T19:00:33.173511+00:00 0:00:00.891547 353052 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-13T19:00:29.811687+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-13T18:00:00+00:00 PythonOperator 2023-03-13T19:00:12.373913+00:00 2023-03-13T19:00:15.944876+00:00 0:00:03.570963 353050 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-13T19:00:09.797845+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-13T17:00:00+00:00 TriggerDagRunOperator 2023-03-13T18:11:16.251828+00:00 2023-03-13T18:11:16.723446+00:00 0:00:00.471618 353038 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T18:11:13.800232+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-13T17:00:00+00:00 TriggerDagRunOperator 2023-03-13T18:11:16.113504+00:00 2023-03-13T18:11:16.594983+00:00 0:00:00.481479 353037 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T18:11:13.800202+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-13T17:00:00+00:00 EmrJobFlowSensor 2023-03-13T18:01:06.538686+00:00 2023-03-13T18:11:08.401880+00:00 0:10:01.863194 353028 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-13T18:01:04.234578+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-13T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-13T18:00:44.821516+00:00 2023-03-13T18:00:45.799256+00:00 0:00:00.977740 353027 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-13T18:00:42.287701+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-13T17:00:00+00:00 PythonOperator 2023-03-13T18:00:24.750953+00:00 2023-03-13T18:00:27.825770+00:00 0:00:03.074817 353026 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-13T18:00:22.299034+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-13T16:00:00+00:00 TriggerDagRunOperator 2023-03-13T17:11:01.581147+00:00 2023-03-13T17:11:02.069371+00:00 0:00:00.488224 353014 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T17:10:58.418098+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-13T16:00:00+00:00 TriggerDagRunOperator 2023-03-13T17:11:01.389614+00:00 2023-03-13T17:11:01.854648+00:00 0:00:00.465034 353013 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T17:10:58.418060+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-13T16:00:00+00:00 EmrJobFlowSensor 2023-03-13T17:00:49.861768+00:00 2023-03-13T17:10:51.650265+00:00 0:10:01.788497 353006 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-13T17:00:47.345969+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-13T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-13T17:00:27.776248+00:00 2023-03-13T17:00:28.799148+00:00 0:00:01.022900 353004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-13T17:00:25.390418+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-13T16:00:00+00:00 PythonOperator 2023-03-13T17:00:07.608979+00:00 2023-03-13T17:00:11.517037+00:00 0:00:03.908058 353002 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-13T17:00:05.296689+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-13T15:00:00+00:00 TriggerDagRunOperator 2023-03-13T16:31:20.485446+00:00 2023-03-13T16:31:21.114686+00:00 0:00:00.629240 352993 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T16:31:17.509048+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-13T15:00:00+00:00 TriggerDagRunOperator 2023-03-13T16:31:20.429479+00:00 2023-03-13T16:31:21.016591+00:00 0:00:00.587112 352992 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T16:31:17.509010+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-13T15:00:00+00:00 EmrJobFlowSensor 2023-03-13T16:01:05.783821+00:00 2023-03-13T16:11:07.750869+00:00 0:10:01.967048 352988 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-13T16:01:03.349054+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-13T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-13T16:00:43.587276+00:00 2023-03-13T16:00:44.715232+00:00 0:00:01.127956 352986 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-13T16:00:41.334900+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-13T15:00:00+00:00 PythonOperator 2023-03-13T16:00:23.583589+00:00 2023-03-13T16:00:27.623163+00:00 0:00:04.039574 352984 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-13T16:00:21.278304+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-13T14:00:00+00:00 TriggerDagRunOperator 2023-03-13T15:17:22.044870+00:00 2023-03-13T15:17:22.578131+00:00 0:00:00.533261 352973 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T15:17:19.421589+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-13T14:00:00+00:00 TriggerDagRunOperator 2023-03-13T15:17:21.814511+00:00 2023-03-13T15:17:22.284475+00:00 0:00:00.469964 352972 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T15:17:19.421618+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-13T14:00:00+00:00 EmrJobFlowSensor 2023-03-13T15:07:04.586084+00:00 2023-03-13T15:17:06.394312+00:00 0:10:01.808228 352968 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-13T15:07:02.393600+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-13T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-13T15:06:42.687693+00:00 2023-03-13T15:06:43.616583+00:00 0:00:00.928890 352965 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-13T15:06:40.358738+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-13T14:00:00+00:00 PythonOperator 2023-03-13T15:06:25.766938+00:00 2023-03-13T15:06:28.944182+00:00 0:00:03.177244 352962 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-13T15:06:20.340479+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-13T13:00:00+00:00 TriggerDagRunOperator 2023-03-13T14:16:51.745018+00:00 2023-03-13T14:16:52.239423+00:00 0:00:00.494405 352953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T14:16:49.335365+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-13T13:00:00+00:00 TriggerDagRunOperator 2023-03-13T14:16:51.739132+00:00 2023-03-13T14:16:52.245042+00:00 0:00:00.505910 352952 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T14:16:49.335338+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-13T13:00:00+00:00 EmrJobFlowSensor 2023-03-13T14:06:25.585535+00:00 2023-03-13T14:16:27.457409+00:00 0:10:01.871874 352949 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-13T14:06:23.308470+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-13T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-13T14:06:06.390339+00:00 2023-03-13T14:06:07.231860+00:00 0:00:00.841521 352946 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-13T14:06:03.236652+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-13T13:00:00+00:00 PythonOperator 2023-03-13T14:05:43.997952+00:00 2023-03-13T14:05:48.488940+00:00 0:00:04.490988 352943 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-13T14:05:41.230669+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-13T12:00:00+00:00 TriggerDagRunOperator 2023-03-13T13:11:59.544985+00:00 2023-03-13T13:12:00.190308+00:00 0:00:00.645323 352933 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T13:11:56.836157+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-13T12:00:00+00:00 TriggerDagRunOperator 2023-03-13T13:11:59.535087+00:00 2023-03-13T13:12:00.164967+00:00 0:00:00.629880 352932 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T13:11:56.836187+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-13T12:00:00+00:00 EmrJobFlowSensor 2023-03-13T13:01:05.524665+00:00 2023-03-13T13:11:07.501240+00:00 0:10:01.976575 352925 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-13T13:01:03.098600+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-13T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-13T13:00:43.968037+00:00 2023-03-13T13:00:44.979815+00:00 0:00:01.011778 352922 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-13T13:00:41.112522+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-13T12:00:00+00:00 PythonOperator 2023-03-13T13:00:23.782460+00:00 2023-03-13T13:00:27.086608+00:00 0:00:03.304148 352921 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-13T13:00:21.117111+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-13T11:00:00+00:00 TriggerDagRunOperator 2023-03-13T12:11:33.529788+00:00 2023-03-13T12:11:34.036225+00:00 0:00:00.506437 352912 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T12:11:30.787681+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-13T11:00:00+00:00 TriggerDagRunOperator 2023-03-13T12:11:33.305806+00:00 2023-03-13T12:11:33.778827+00:00 0:00:00.473021 352911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T12:11:30.787641+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-13T11:00:00+00:00 EmrJobFlowSensor 2023-03-13T12:03:18.255586+00:00 2023-03-13T12:11:19.892762+00:00 0:08:01.637176 352906 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-13T12:03:15.358504+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-13T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-13T12:00:46.382257+00:00 2023-03-13T12:00:47.252803+00:00 0:00:00.870546 352902 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-13T12:00:43.971780+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-13T11:00:00+00:00 PythonOperator 2023-03-13T12:00:23.921388+00:00 2023-03-13T12:00:27.890466+00:00 0:00:03.969078 352900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-13T12:00:21.771552+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-13T10:00:00+00:00 TriggerDagRunOperator 2023-03-13T11:11:17.766090+00:00 2023-03-13T11:11:18.270865+00:00 0:00:00.504775 352891 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T11:11:15.163430+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-13T10:00:00+00:00 TriggerDagRunOperator 2023-03-13T11:11:17.528308+00:00 2023-03-13T11:11:18.006020+00:00 0:00:00.477712 352890 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T11:11:15.163458+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-13T10:00:00+00:00 EmrJobFlowSensor 2023-03-13T11:01:06.365232+00:00 2023-03-13T11:11:08.311459+00:00 0:10:01.946227 352884 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-13T11:01:03.706543+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-13T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-13T11:00:46.227508+00:00 2023-03-13T11:00:47.093386+00:00 0:00:00.865878 352882 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-13T11:00:43.696953+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-13T10:00:00+00:00 PythonOperator 2023-03-13T11:00:24.123770+00:00 2023-03-13T11:00:27.373922+00:00 0:00:03.250152 352880 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-13T11:00:21.625396+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-13T09:00:00+00:00 TriggerDagRunOperator 2023-03-13T10:11:10.578042+00:00 2023-03-13T10:11:11.218426+00:00 0:00:00.640384 352869 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T10:11:08.162257+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-13T09:00:00+00:00 TriggerDagRunOperator 2023-03-13T10:11:10.462269+00:00 2023-03-13T10:11:10.955997+00:00 0:00:00.493728 352868 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T10:11:08.162289+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-13T09:00:00+00:00 EmrJobFlowSensor 2023-03-13T10:00:59.416907+00:00 2023-03-13T10:11:01.246601+00:00 0:10:01.829694 352861 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-13T10:00:57.160110+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-13T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-13T10:00:37.384798+00:00 2023-03-13T10:00:38.493320+00:00 0:00:01.108522 352859 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-13T10:00:35.144170+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-13T09:00:00+00:00 PythonOperator 2023-03-13T10:00:15.579763+00:00 2023-03-13T10:00:19.633383+00:00 0:00:04.053620 352857 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-13T10:00:13.111189+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-13T08:00:00+00:00 TriggerDagRunOperator 2023-03-13T09:12:07.990052+00:00 2023-03-13T09:12:08.489458+00:00 0:00:00.499406 352849 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T09:12:05.329387+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-13T08:00:00+00:00 TriggerDagRunOperator 2023-03-13T09:12:07.908101+00:00 2023-03-13T09:12:08.400574+00:00 0:00:00.492473 352848 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T09:12:05.329429+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-13T08:00:00+00:00 EmrJobFlowSensor 2023-03-13T09:02:00.438304+00:00 2023-03-13T09:12:02.270004+00:00 0:10:01.831700 352842 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-13T09:01:57.803873+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-13T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-13T09:01:39.966555+00:00 2023-03-13T09:01:40.836265+00:00 0:00:00.869710 352840 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-13T09:01:37.782734+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-13T08:00:00+00:00 PythonOperator 2023-03-13T09:01:17.963937+00:00 2023-03-13T09:01:20.989376+00:00 0:00:03.025439 352838 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-13T09:01:15.762609+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-13T07:00:00+00:00 TriggerDagRunOperator 2023-03-13T08:15:59.397361+00:00 2023-03-13T08:15:59.942915+00:00 0:00:00.545554 352829 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T08:15:56.967290+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-13T07:00:00+00:00 TriggerDagRunOperator 2023-03-13T08:15:59.347517+00:00 2023-03-13T08:15:59.832769+00:00 0:00:00.485252 352828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T08:15:56.967261+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-13T07:00:00+00:00 EmrJobFlowSensor 2023-03-13T08:05:52.136622+00:00 2023-03-13T08:15:54.073899+00:00 0:10:01.937277 352823 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-13T08:05:49.775322+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-13T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-13T08:05:30.175378+00:00 2023-03-13T08:05:31.075046+00:00 0:00:00.899668 352820 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-13T08:05:27.751149+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-13T07:00:00+00:00 PythonOperator 2023-03-13T08:05:08.410569+00:00 2023-03-13T08:05:14.204360+00:00 0:00:05.793791 352817 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-13T08:05:05.733068+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-13T06:00:00+00:00 TriggerDagRunOperator 2023-03-13T07:11:10.306777+00:00 2023-03-13T07:11:10.812980+00:00 0:00:00.506203 352808 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T07:11:07.718788+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-13T06:00:00+00:00 TriggerDagRunOperator 2023-03-13T07:11:10.151192+00:00 2023-03-13T07:11:10.621947+00:00 0:00:00.470755 352807 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T07:11:07.718760+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-13T06:00:00+00:00 EmrJobFlowSensor 2023-03-13T07:00:58.894367+00:00 2023-03-13T07:11:00.740650+00:00 0:10:01.846283 352799 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-13T07:00:56.650803+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-13T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-13T07:00:36.846097+00:00 2023-03-13T07:00:37.826264+00:00 0:00:00.980167 352797 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-13T07:00:34.629259+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-13T06:00:00+00:00 PythonOperator 2023-03-13T07:00:17.141018+00:00 2023-03-13T07:00:20.311533+00:00 0:00:03.170515 352795 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-13T07:00:14.603230+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-13T05:00:00+00:00 TriggerDagRunOperator 2023-03-13T06:11:04.478705+00:00 2023-03-13T06:11:04.998795+00:00 0:00:00.520090 352787 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T06:11:02.018256+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-13T05:00:00+00:00 TriggerDagRunOperator 2023-03-13T06:11:04.254806+00:00 2023-03-13T06:11:04.731279+00:00 0:00:00.476473 352786 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T06:11:02.018290+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-13T05:00:00+00:00 EmrJobFlowSensor 2023-03-13T06:00:53.639488+00:00 2023-03-13T06:10:55.478577+00:00 0:10:01.839089 352780 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-13T06:00:51.378608+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-13T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-13T06:00:31.579994+00:00 2023-03-13T06:00:32.403385+00:00 0:00:00.823391 352778 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-13T06:00:29.360515+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-13T05:00:00+00:00 PythonOperator 2023-03-13T06:00:12.131167+00:00 2023-03-13T06:00:16.706247+00:00 0:00:04.575080 352776 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-13T06:00:09.335277+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-13T04:00:00+00:00 TriggerDagRunOperator 2023-03-13T05:13:56.205624+00:00 2023-03-13T05:13:56.729679+00:00 0:00:00.524055 352766 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T05:13:53.615311+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-13T04:00:00+00:00 TriggerDagRunOperator 2023-03-13T05:13:55.939406+00:00 2023-03-13T05:13:56.434666+00:00 0:00:00.495260 352765 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T05:13:53.615340+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-13T04:00:00+00:00 EmrJobFlowSensor 2023-03-13T05:03:50.411353+00:00 2023-03-13T05:13:52.264791+00:00 0:10:01.853438 352758 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-13T05:03:48.010296+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-13T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-13T05:03:30.314025+00:00 2023-03-13T05:03:31.226471+00:00 0:00:00.912446 352756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-13T05:03:27.920785+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-13T04:00:00+00:00 PythonOperator 2023-03-13T05:03:08.809842+00:00 2023-03-13T05:03:12.165021+00:00 0:00:03.355179 352754 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-13T05:03:05.906236+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-13T03:00:00+00:00 TriggerDagRunOperator 2023-03-13T04:11:15.767113+00:00 2023-03-13T04:11:16.281398+00:00 0:00:00.514285 352744 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T04:11:13.439658+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-13T03:00:00+00:00 TriggerDagRunOperator 2023-03-13T04:11:15.640177+00:00 2023-03-13T04:11:16.177450+00:00 0:00:00.537273 352743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-13T04:11:13.439618+00:00 2 default_pool