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-02-27T16:00:00+00:00 EmrJobFlowSensor 2023-02-27T17:01:03.820771+00:00 2023-02-27T17:11:05.525004+00:00 0:10:01.704233 346056 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-27T17:01:01.110390+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-27T16:00:00+00:00 EmrCreateJobFlowOperator 2023-02-27T17:00:41.679030+00:00 2023-02-27T17:00:42.554016+00:00 0:00:00.874986 346054 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-27T17:00:39.095907+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-27T16:00:00+00:00 PythonOperator 2023-02-27T17:00:19.771082+00:00 2023-02-27T17:00:25.356637+00:00 0:00:05.585555 346052 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-27T17:00:16.822673+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-27T15:00:00+00:00 TriggerDagRunOperator 2023-02-27T16:35:31.444237+00:00 2023-02-27T16:35:31.973770+00:00 0:00:00.529533 346045 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T16:35:28.801079+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-27T15:00:00+00:00 TriggerDagRunOperator 2023-02-27T16:35:31.368880+00:00 2023-02-27T16:35:31.895212+00:00 0:00:00.526332 346044 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T16:35:28.801107+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-27T15:00:00+00:00 EmrJobFlowSensor 2023-02-27T16:14:11.214282+00:00 2023-02-27T16:24:13.112212+00:00 0:10:01.897930 346039 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-27T16:14:08.730253+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-27T15:00:00+00:00 EmrCreateJobFlowOperator 2023-02-27T16:13:49.110425+00:00 2023-02-27T16:13:49.923951+00:00 0:00:00.813526 346036 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-27T16:13:46.691468+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-27T15:00:00+00:00 PythonOperator 2023-02-27T16:13:29.509877+00:00 2023-02-27T16:13:32.760669+00:00 0:00:03.250792 346033 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-27T16:13:26.723772+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-27T14:00:00+00:00 TriggerDagRunOperator 2023-02-27T15:22:50.201555+00:00 2023-02-27T15:22:50.708723+00:00 0:00:00.507168 346027 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T15:22:47.224619+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-27T14:00:00+00:00 TriggerDagRunOperator 2023-02-27T15:22:50.027640+00:00 2023-02-27T15:22:50.521821+00:00 0:00:00.494181 346026 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T15:22:47.224649+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-27T14:00:00+00:00 EmrJobFlowSensor 2023-02-27T15:08:21.576546+00:00 2023-02-27T15:18:23.501016+00:00 0:10:01.924470 346019 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-27T15:08:15.636058+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-27T14:00:00+00:00 EmrCreateJobFlowOperator 2023-02-27T15:07:59.498225+00:00 2023-02-27T15:08:01.202948+00:00 0:00:01.704723 346015 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-27T15:07:55.564021+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-27T12:00:00+00:00 TriggerDagRunOperator 2023-02-27T15:07:37.839388+00:00 2023-02-27T15:07:38.571818+00:00 0:00:00.732430 346010 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T15:07:31.604136+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-27T14:00:00+00:00 PythonOperator 2023-02-27T15:07:37.670952+00:00 2023-02-27T15:07:40.884815+00:00 0:00:03.213863 346009 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-27T15:07:31.604217+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-27T12:00:00+00:00 TriggerDagRunOperator 2023-02-27T15:07:37.063050+00:00 2023-02-27T15:07:37.733302+00:00 0:00:00.670252 346008 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T15:07:31.604183+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-27T12:00:00+00:00 EmrJobFlowSensor 2023-02-27T13:38:44.789416+00:00 2023-02-27T13:48:46.828500+00:00 0:10:02.039084 346000 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-27T13:38:42.468955+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-27T12:00:00+00:00 EmrCreateJobFlowOperator 2023-02-27T13:38:24.658309+00:00 2023-02-27T13:38:25.542882+00:00 0:00:00.884573 345996 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-27T13:38:22.449123+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-27T11:00:00+00:00 TriggerDagRunOperator 2023-02-27T13:38:07.658618+00:00 2023-02-27T13:38:08.341264+00:00 0:00:00.682646 345992 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T13:38:01.701045+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-27T12:00:00+00:00 PythonOperator 2023-02-27T13:38:07.030048+00:00 2023-02-27T13:38:11.800163+00:00 0:00:04.770115 345991 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-27T13:38:01.701071+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-27T11:00:00+00:00 TriggerDagRunOperator 2023-02-27T13:38:06.742959+00:00 2023-02-27T13:38:07.298781+00:00 0:00:00.555822 345990 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T13:38:01.701011+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-27T11:00:00+00:00 EmrJobFlowSensor 2023-02-27T12:42:14.355391+00:00 2023-02-27T12:52:16.492947+00:00 0:10:02.137556 345982 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-27T12:42:12.080310+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-27T11:00:00+00:00 EmrCreateJobFlowOperator 2023-02-27T12:41:56.357361+00:00 2023-02-27T12:41:57.427570+00:00 0:00:01.070209 345979 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-27T12:41:52.052405+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-27T11:00:00+00:00 PythonOperator 2023-02-27T12:41:32.850212+00:00 2023-02-27T12:41:38.972610+00:00 0:00:06.122398 345975 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-27T12:41:30.098258+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-27T09:00:00+00:00 TriggerDagRunOperator 2023-02-27T10:15:28.271022+00:00 2023-02-27T10:15:28.788184+00:00 0:00:00.517162 345969 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T10:15:25.456705+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-27T09:00:00+00:00 TriggerDagRunOperator 2023-02-27T10:15:27.933718+00:00 2023-02-27T10:15:28.518945+00:00 0:00:00.585227 345968 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T10:15:25.456734+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-27T09:00:00+00:00 EmrJobFlowSensor 2023-02-27T10:05:16.693675+00:00 2023-02-27T10:15:18.577904+00:00 0:10:01.884229 345960 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-27T10:05:14.209760+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-27T09:00:00+00:00 EmrCreateJobFlowOperator 2023-02-27T10:04:58.189882+00:00 2023-02-27T10:04:59.368909+00:00 0:00:01.179027 345957 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-27T10:04:54.178270+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-27T08:00:00+00:00 TriggerDagRunOperator 2023-02-27T10:04:37.923936+00:00 2023-02-27T10:04:39.096627+00:00 0:00:01.172691 345955 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T10:04:32.152215+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-27T09:00:00+00:00 PythonOperator 2023-02-27T10:04:37.711344+00:00 2023-02-27T10:04:42.472327+00:00 0:00:04.760983 345954 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-27T10:04:32.152261+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-27T08:00:00+00:00 TriggerDagRunOperator 2023-02-27T10:04:34.704341+00:00 2023-02-27T10:04:35.157961+00:00 0:00:00.453620 345953 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T10:04:32.152247+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-27T08:00:00+00:00 EmrJobFlowSensor 2023-02-27T09:04:40.876290+00:00 2023-02-27T09:15:42.954443+00:00 0:11:02.078153 345944 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-27T09:04:38.461295+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-27T08:00:00+00:00 EmrCreateJobFlowOperator 2023-02-27T09:04:18.913236+00:00 2023-02-27T09:04:19.849532+00:00 0:00:00.936296 345941 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-27T09:04:16.439827+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-27T08:00:00+00:00 PythonOperator 2023-02-27T09:04:02.054171+00:00 2023-02-27T09:04:06.294782+00:00 0:00:04.240611 345939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-27T09:03:56.197392+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-27T07:00:00+00:00 TriggerDagRunOperator 2023-02-27T09:04:01.922905+00:00 2023-02-27T09:04:02.672814+00:00 0:00:00.749909 345937 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T09:03:56.197370+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-27T07:00:00+00:00 TriggerDagRunOperator 2023-02-27T09:04:00.022843+00:00 2023-02-27T09:04:00.947967+00:00 0:00:00.925124 345936 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T09:03:56.197327+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-27T07:00:00+00:00 EmrJobFlowSensor 2023-02-27T08:50:05.284506+00:00 2023-02-27T09:00:07.161456+00:00 0:10:01.876950 345931 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-27T08:50:02.926396+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-27T07:00:00+00:00 EmrCreateJobFlowOperator 2023-02-27T08:49:43.167075+00:00 2023-02-27T08:49:44.079433+00:00 0:00:00.912358 345928 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-27T08:49:40.904670+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-27T07:00:00+00:00 PythonOperator 2023-02-27T08:49:23.254276+00:00 2023-02-27T08:49:29.452509+00:00 0:00:06.198233 345925 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-27T08:49:20.886505+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-27T06:00:00+00:00 TriggerDagRunOperator 2023-02-27T07:48:16.494760+00:00 2023-02-27T07:48:17.094981+00:00 0:00:00.600221 345920 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T07:48:13.398988+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-27T06:00:00+00:00 TriggerDagRunOperator 2023-02-27T07:48:16.215940+00:00 2023-02-27T07:48:16.687241+00:00 0:00:00.471301 345919 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T07:48:13.399043+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-27T06:00:00+00:00 EmrJobFlowSensor 2023-02-27T07:35:29.154051+00:00 2023-02-27T07:45:31.035502+00:00 0:10:01.881451 345915 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-27T07:35:26.848998+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-27T06:00:00+00:00 EmrCreateJobFlowOperator 2023-02-27T07:35:07.253134+00:00 2023-02-27T07:35:08.166403+00:00 0:00:00.913269 345911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-27T07:35:04.831527+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-27T05:00:00+00:00 TriggerDagRunOperator 2023-02-27T07:34:47.225343+00:00 2023-02-27T07:34:48.356385+00:00 0:00:01.131042 345907 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T07:34:40.793605+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-27T05:00:00+00:00 TriggerDagRunOperator 2023-02-27T07:34:46.899910+00:00 2023-02-27T07:34:48.115843+00:00 0:00:01.215933 345906 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T07:34:40.793636+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-27T06:00:00+00:00 PythonOperator 2023-02-27T07:34:43.147949+00:00 2023-02-27T07:34:47.499365+00:00 0:00:04.351416 345905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-27T07:34:40.793649+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-27T05:00:00+00:00 EmrJobFlowSensor 2023-02-27T06:29:21.329523+00:00 2023-02-27T06:39:23.127639+00:00 0:10:01.798116 345896 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-27T06:29:18.226391+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-27T05:00:00+00:00 EmrCreateJobFlowOperator 2023-02-27T06:28:59.083015+00:00 2023-02-27T06:28:59.994412+00:00 0:00:00.911397 345891 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-27T06:28:56.156143+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-27T05:00:00+00:00 PythonOperator 2023-02-27T06:28:42.431645+00:00 2023-02-27T06:28:46.475492+00:00 0:00:04.043847 345887 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-27T06:28:34.091423+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-27T03:00:00+00:00 TriggerDagRunOperator 2023-02-27T06:28:42.330135+00:00 2023-02-27T06:28:42.893065+00:00 0:00:00.562930 345886 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T06:28:34.091410+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-27T03:00:00+00:00 TriggerDagRunOperator 2023-02-27T06:28:36.595456+00:00 2023-02-27T06:28:37.082469+00:00 0:00:00.487013 345885 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T06:28:34.091377+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-27T03:00:00+00:00 EmrJobFlowSensor 2023-02-27T04:25:21.937917+00:00 2023-02-27T04:35:23.746241+00:00 0:10:01.808324 345874 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-27T04:25:19.189006+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-27T03:00:00+00:00 EmrCreateJobFlowOperator 2023-02-27T04:25:02.005578+00:00 2023-02-27T04:25:02.994741+00:00 0:00:00.989163 345869 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-27T04:24:59.173609+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-27T01:00:00+00:00 TriggerDagRunOperator 2023-02-27T04:24:45.295688+00:00 2023-02-27T04:24:46.439911+00:00 0:00:01.144223 345865 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T04:24:37.008714+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-27T01:00:00+00:00 TriggerDagRunOperator 2023-02-27T04:24:45.107353+00:00 2023-02-27T04:24:46.439956+00:00 0:00:01.332603 345864 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T04:24:37.008678+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-27T03:00:00+00:00 PythonOperator 2023-02-27T04:24:39.988493+00:00 2023-02-27T04:24:44.011512+00:00 0:00:04.023019 345863 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-27T04:24:37.008728+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-27T01:00:00+00:00 EmrJobFlowSensor 2023-02-27T02:35:11.611206+00:00 2023-02-27T02:45:13.400930+00:00 0:10:01.789724 345858 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-27T02:35:09.272607+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-27T01:00:00+00:00 EmrCreateJobFlowOperator 2023-02-27T02:34:51.578546+00:00 2023-02-27T02:34:52.372789+00:00 0:00:00.794243 345854 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-27T02:34:49.258504+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-27T01:00:00+00:00 PythonOperator 2023-02-27T02:34:36.124206+00:00 2023-02-27T02:34:40.366322+00:00 0:00:04.242116 345851 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-27T02:34:27.298283+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-27T00:00:00+00:00 TriggerDagRunOperator 2023-02-27T02:34:35.821116+00:00 2023-02-27T02:34:36.808398+00:00 0:00:00.987282 345850 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T02:34:27.298205+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-27T00:00:00+00:00 TriggerDagRunOperator 2023-02-27T02:34:29.975691+00:00 2023-02-27T02:34:30.500212+00:00 0:00:00.524521 345849 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T02:34:27.298260+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-27T00:00:00+00:00 EmrJobFlowSensor 2023-02-27T01:38:15.529517+00:00 2023-02-27T01:48:18.586188+00:00 0:10:03.056671 345838 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-27T01:38:09.634666+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-27T00:00:00+00:00 EmrCreateJobFlowOperator 2023-02-27T01:37:56.630025+00:00 2023-02-27T01:37:58.333243+00:00 0:00:01.703218 345834 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-27T01:37:47.583370+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-26T23:00:00+00:00 TriggerDagRunOperator 2023-02-27T01:37:36.822956+00:00 2023-02-27T01:37:38.184773+00:00 0:00:01.361817 345830 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T01:37:25.261563+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-27T00:00:00+00:00 PythonOperator 2023-02-27T01:37:32.945711+00:00 2023-02-27T01:37:40.587298+00:00 0:00:07.641587 345826 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-27T01:37:25.261601+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-26T23:00:00+00:00 TriggerDagRunOperator 2023-02-27T01:37:32.648641+00:00 2023-02-27T01:37:34.039324+00:00 0:00:01.390683 345825 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-27T01:37:25.261536+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-26T23:00:00+00:00 EmrJobFlowSensor 2023-02-27T00:06:22.939841+00:00 2023-02-27T00:16:24.679166+00:00 0:10:01.739325 345820 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-27T00:06:20.631427+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-26T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-27T00:06:03.013132+00:00 2023-02-27T00:06:04.202744+00:00 0:00:01.189612 345817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-27T00:06:00.553139+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-26T23:00:00+00:00 PythonOperator 2023-02-27T00:05:42.616043+00:00 2023-02-27T00:05:52.193481+00:00 0:00:09.577438 345814 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-27T00:05:38.530389+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-26T22:00:00+00:00 TriggerDagRunOperator 2023-02-26T23:26:11.555001+00:00 2023-02-26T23:26:12.071155+00:00 0:00:00.516154 345807 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T23:26:08.702436+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-26T22:00:00+00:00 TriggerDagRunOperator 2023-02-26T23:26:11.487949+00:00 2023-02-26T23:26:11.991562+00:00 0:00:00.503613 345806 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T23:26:08.702399+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-26T22:00:00+00:00 EmrJobFlowSensor 2023-02-26T23:03:05.563313+00:00 2023-02-26T23:13:07.315980+00:00 0:10:01.752667 345799 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-26T23:03:03.208525+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-26T22:00:00+00:00 EmrCreateJobFlowOperator 2023-02-26T23:02:43.538093+00:00 2023-02-26T23:02:44.627853+00:00 0:00:01.089760 345796 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-26T23:02:41.188618+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-26T22:00:00+00:00 PythonOperator 2023-02-26T23:02:24.540631+00:00 2023-02-26T23:02:27.668255+00:00 0:00:03.127624 345793 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-26T23:02:19.166452+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-26T21:00:00+00:00 TriggerDagRunOperator 2023-02-26T22:11:08.118107+00:00 2023-02-26T22:11:08.631199+00:00 0:00:00.513092 345782 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T22:11:05.753895+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-26T21:00:00+00:00 TriggerDagRunOperator 2023-02-26T22:11:08.097798+00:00 2023-02-26T22:11:08.595736+00:00 0:00:00.497938 345781 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T22:11:05.753866+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-26T21:00:00+00:00 EmrJobFlowSensor 2023-02-26T22:01:00.586678+00:00 2023-02-26T22:11:02.439413+00:00 0:10:01.852735 345775 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-26T22:00:58.344582+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-26T21:00:00+00:00 EmrCreateJobFlowOperator 2023-02-26T22:00:38.546309+00:00 2023-02-26T22:00:39.561300+00:00 0:00:01.014991 345773 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-26T22:00:36.317599+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-26T21:00:00+00:00 PythonOperator 2023-02-26T22:00:16.868700+00:00 2023-02-26T22:00:19.878537+00:00 0:00:03.009837 345771 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-26T22:00:14.310429+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-26T20:00:00+00:00 TriggerDagRunOperator 2023-02-26T21:24:51.226640+00:00 2023-02-26T21:24:51.682820+00:00 0:00:00.456180 345763 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T21:24:48.298343+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-26T20:00:00+00:00 TriggerDagRunOperator 2023-02-26T21:24:50.821228+00:00 2023-02-26T21:24:51.376179+00:00 0:00:00.554951 345762 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T21:24:48.298315+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-26T20:00:00+00:00 EmrJobFlowSensor 2023-02-26T21:06:08.514141+00:00 2023-02-26T21:16:10.195527+00:00 0:10:01.681386 345759 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-26T21:06:04.918320+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-26T20:00:00+00:00 EmrCreateJobFlowOperator 2023-02-26T21:05:45.416382+00:00 2023-02-26T21:05:46.285564+00:00 0:00:00.869182 345755 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-26T21:05:42.891807+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-26T20:00:00+00:00 PythonOperator 2023-02-26T21:05:25.212283+00:00 2023-02-26T21:05:29.242166+00:00 0:00:04.029883 345752 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-26T21:05:22.874511+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-26T19:00:00+00:00 TriggerDagRunOperator 2023-02-26T20:18:21.545066+00:00 2023-02-26T20:18:22.019444+00:00 0:00:00.474378 345741 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T20:18:18.742614+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-26T19:00:00+00:00 TriggerDagRunOperator 2023-02-26T20:18:21.135584+00:00 2023-02-26T20:18:21.622489+00:00 0:00:00.486905 345740 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T20:18:18.742642+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-26T19:00:00+00:00 EmrJobFlowSensor 2023-02-26T20:08:02.203826+00:00 2023-02-26T20:18:04.016195+00:00 0:10:01.812369 345735 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-26T20:07:59.745806+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-26T19:00:00+00:00 EmrCreateJobFlowOperator 2023-02-26T20:07:41.986018+00:00 2023-02-26T20:07:42.831117+00:00 0:00:00.845099 345732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-26T20:07:39.725076+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-26T19:00:00+00:00 PythonOperator 2023-02-26T20:07:20.638497+00:00 2023-02-26T20:07:23.891696+00:00 0:00:03.253199 345729 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-26T20:07:17.704768+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-26T18:00:00+00:00 TriggerDagRunOperator 2023-02-26T19:11:09.187507+00:00 2023-02-26T19:11:09.642801+00:00 0:00:00.455294 345718 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T19:11:06.691277+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-26T18:00:00+00:00 TriggerDagRunOperator 2023-02-26T19:11:09.057675+00:00 2023-02-26T19:11:09.510288+00:00 0:00:00.452613 345717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T19:11:06.691325+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-26T18:00:00+00:00 EmrJobFlowSensor 2023-02-26T19:00:48.471675+00:00 2023-02-26T19:10:50.247178+00:00 0:10:01.775503 345710 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-26T19:00:46.271342+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-26T18:00:00+00:00 EmrCreateJobFlowOperator 2023-02-26T19:00:28.351482+00:00 2023-02-26T19:00:29.177639+00:00 0:00:00.826157 345708 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-26T19:00:26.134721+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-26T18:00:00+00:00 PythonOperator 2023-02-26T19:00:06.563501+00:00 2023-02-26T19:00:09.744695+00:00 0:00:03.181194 345706 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-26T19:00:04.071176+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-26T17:00:00+00:00 TriggerDagRunOperator 2023-02-26T18:35:24.992061+00:00 2023-02-26T18:35:25.576507+00:00 0:00:00.584446 345700 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T18:35:21.922278+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-26T17:00:00+00:00 TriggerDagRunOperator 2023-02-26T18:35:24.785462+00:00 2023-02-26T18:35:25.302617+00:00 0:00:00.517155 345699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T18:35:21.922315+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-26T17:00:00+00:00 EmrJobFlowSensor 2023-02-26T18:05:36.092619+00:00 2023-02-26T18:15:37.786245+00:00 0:10:01.693626 345693 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-26T18:05:33.870160+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-26T17:00:00+00:00 EmrCreateJobFlowOperator 2023-02-26T18:05:14.207842+00:00 2023-02-26T18:05:15.267161+00:00 0:00:01.059319 345690 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-26T18:05:11.852206+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-26T17:00:00+00:00 PythonOperator 2023-02-26T18:04:54.835954+00:00 2023-02-26T18:04:58.023358+00:00 0:00:03.187404 345688 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-26T18:04:51.845365+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-26T16:00:00+00:00 TriggerDagRunOperator 2023-02-26T17:22:30.479427+00:00 2023-02-26T17:22:31.036577+00:00 0:00:00.557150 345681 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T17:22:27.401226+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-26T16:00:00+00:00 TriggerDagRunOperator 2023-02-26T17:22:30.253631+00:00 2023-02-26T17:22:30.770336+00:00 0:00:00.516705 345680 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T17:22:27.401182+00:00 2 default_pool