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 trigger_dagrun_booking-processing-job_v002 2023-03-21T11:00:00+00:00 TriggerDagRunOperator 2023-03-21T12:26:20.279853+00:00 2023-03-21T12:26:20.748459+00:00 0:00:00.468606 357000 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T12:26:17.523406+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-21T11:00:00+00:00 EmrJobFlowSensor 2023-03-21T12:02:14.246469+00:00 2023-03-21T12:12:16.040658+00:00 0:10:01.794189 356993 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-21T12:02:12.040421+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-21T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-21T12:01:52.413850+00:00 2023-03-21T12:01:53.306150+00:00 0:00:00.892300 356991 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-21T12:01:50.025417+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-21T11:00:00+00:00 PythonOperator 2023-03-21T12:01:32.946062+00:00 2023-03-21T12:01:36.407029+00:00 0:00:03.460967 356989 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-21T12:01:30.019947+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-21T10:00:00+00:00 TriggerDagRunOperator 2023-03-21T11:12:34.790806+00:00 2023-03-21T11:12:35.297095+00:00 0:00:00.506289 356980 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T11:12:32.072744+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-21T10:00:00+00:00 TriggerDagRunOperator 2023-03-21T11:12:34.607555+00:00 2023-03-21T11:12:35.097735+00:00 0:00:00.490180 356979 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T11:12:32.072716+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-21T10:00:00+00:00 EmrJobFlowSensor 2023-03-21T11:00:53.066763+00:00 2023-03-21T11:10:55.180295+00:00 0:10:02.113532 356971 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-21T11:00:48.116546+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-21T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-21T11:00:28.726828+00:00 2023-03-21T11:00:29.680160+00:00 0:00:00.953332 356969 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-21T11:00:26.097639+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-21T10:00:00+00:00 PythonOperator 2023-03-21T11:00:06.361506+00:00 2023-03-21T11:00:09.512666+00:00 0:00:03.151160 356967 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-21T11:00:04.076597+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-21T09:00:00+00:00 TriggerDagRunOperator 2023-03-21T10:18:28.773416+00:00 2023-03-21T10:18:29.277928+00:00 0:00:00.504512 356958 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T10:18:25.992034+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-21T09:00:00+00:00 TriggerDagRunOperator 2023-03-21T10:18:28.639491+00:00 2023-03-21T10:18:29.101081+00:00 0:00:00.461590 356957 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T10:18:25.992062+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-21T09:00:00+00:00 EmrJobFlowSensor 2023-03-21T10:01:01.581086+00:00 2023-03-21T10:11:03.385661+00:00 0:10:01.804575 356953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-21T10:00:59.359410+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-21T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-21T10:00:39.530883+00:00 2023-03-21T10:00:40.369754+00:00 0:00:00.838871 356951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-21T10:00:37.338520+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-21T09:00:00+00:00 PythonOperator 2023-03-21T10:00:17.434636+00:00 2023-03-21T10:00:21.419665+00:00 0:00:03.985029 356949 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-21T10:00:15.290798+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-21T08:00:00+00:00 TriggerDagRunOperator 2023-03-21T09:25:44.176975+00:00 2023-03-21T09:25:44.661992+00:00 0:00:00.485017 356941 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T09:25:41.770073+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-21T08:00:00+00:00 TriggerDagRunOperator 2023-03-21T09:25:44.120772+00:00 2023-03-21T09:25:44.610328+00:00 0:00:00.489556 356940 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T09:25:41.770101+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-21T08:00:00+00:00 EmrJobFlowSensor 2023-03-21T09:06:59.766613+00:00 2023-03-21T09:17:01.694924+00:00 0:10:01.928311 356936 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-21T09:06:57.390202+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-21T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-21T09:06:39.204064+00:00 2023-03-21T09:06:40.752114+00:00 0:00:01.548050 356934 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-21T09:06:35.336431+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-21T08:00:00+00:00 PythonOperator 2023-03-21T09:06:19.891774+00:00 2023-03-21T09:06:26.727310+00:00 0:00:06.835536 356931 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-21T09:06:15.317592+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-21T07:00:00+00:00 TriggerDagRunOperator 2023-03-21T08:10:10.792328+00:00 2023-03-21T08:10:11.361734+00:00 0:00:00.569406 356920 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T08:10:08.561198+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-21T07:00:00+00:00 TriggerDagRunOperator 2023-03-21T08:10:10.749038+00:00 2023-03-21T08:10:11.283663+00:00 0:00:00.534625 356919 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T08:10:08.561165+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-21T07:00:00+00:00 EmrJobFlowSensor 2023-03-21T08:00:58.817777+00:00 2023-03-21T08:10:00.423528+00:00 0:09:01.605751 356912 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-21T08:00:56.403162+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-21T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-21T08:00:36.910833+00:00 2023-03-21T08:00:37.798286+00:00 0:00:00.887453 356910 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-21T08:00:34.408739+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-21T07:00:00+00:00 PythonOperator 2023-03-21T08:00:15.218604+00:00 2023-03-21T08:00:18.311890+00:00 0:00:03.093286 356908 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-21T08:00:12.398455+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-21T06:00:00+00:00 TriggerDagRunOperator 2023-03-21T07:22:55.460025+00:00 2023-03-21T07:22:56.207498+00:00 0:00:00.747473 356899 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T07:22:52.376820+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-21T06:00:00+00:00 TriggerDagRunOperator 2023-03-21T07:22:54.617278+00:00 2023-03-21T07:22:55.392709+00:00 0:00:00.775431 356898 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T07:22:52.376868+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-21T06:00:00+00:00 EmrJobFlowSensor 2023-03-21T07:01:00.945830+00:00 2023-03-21T07:11:02.844694+00:00 0:10:01.898864 356894 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-21T07:00:58.356046+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-21T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-21T07:00:40.700181+00:00 2023-03-21T07:00:41.977958+00:00 0:00:01.277777 356892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-21T07:00:36.334942+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-21T06:00:00+00:00 PythonOperator 2023-03-21T07:00:16.484030+00:00 2023-03-21T07:00:19.983275+00:00 0:00:03.499245 356890 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-21T07:00:14.309843+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-21T05:00:00+00:00 TriggerDagRunOperator 2023-03-21T06:28:23.064774+00:00 2023-03-21T06:28:23.571273+00:00 0:00:00.506499 356882 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T06:28:20.037057+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-21T05:00:00+00:00 TriggerDagRunOperator 2023-03-21T06:28:22.810855+00:00 2023-03-21T06:28:23.271258+00:00 0:00:00.460403 356881 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T06:28:20.037086+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-21T05:00:00+00:00 EmrJobFlowSensor 2023-03-21T06:02:23.640114+00:00 2023-03-21T06:12:25.495792+00:00 0:10:01.855678 356875 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-21T06:02:21.238300+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-21T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-21T06:02:05.450394+00:00 2023-03-21T06:02:06.828720+00:00 0:00:01.378326 356873 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-21T06:02:01.218886+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-21T05:00:00+00:00 PythonOperator 2023-03-21T06:01:41.494598+00:00 2023-03-21T06:01:45.613413+00:00 0:00:04.118815 356871 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-21T06:01:39.195738+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-21T04:00:00+00:00 TriggerDagRunOperator 2023-03-21T05:30:53.138633+00:00 2023-03-21T05:30:53.615697+00:00 0:00:00.477064 356864 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T05:30:50.510785+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-21T04:00:00+00:00 TriggerDagRunOperator 2023-03-21T05:30:52.914969+00:00 2023-03-21T05:30:53.396890+00:00 0:00:00.481921 356863 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T05:30:50.510813+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-21T04:00:00+00:00 EmrJobFlowSensor 2023-03-21T05:20:35.404915+00:00 2023-03-21T05:30:37.174132+00:00 0:10:01.769217 356860 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-21T05:20:32.294272+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-21T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-21T05:20:15.425718+00:00 2023-03-21T05:20:16.410015+00:00 0:00:00.984297 356857 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-21T05:20:10.191686+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-21T04:00:00+00:00 PythonOperator 2023-03-21T05:19:52.371583+00:00 2023-03-21T05:19:56.340070+00:00 0:00:03.968487 356854 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-21T05:19:50.174465+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-21T03:00:00+00:00 TriggerDagRunOperator 2023-03-21T04:27:17.445319+00:00 2023-03-21T04:27:17.991950+00:00 0:00:00.546631 356845 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T04:27:14.589051+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-21T03:00:00+00:00 TriggerDagRunOperator 2023-03-21T04:27:17.370119+00:00 2023-03-21T04:27:17.855299+00:00 0:00:00.485180 356844 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T04:27:14.589085+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-21T03:00:00+00:00 EmrJobFlowSensor 2023-03-21T04:08:34.514845+00:00 2023-03-21T04:18:36.189837+00:00 0:10:01.674992 356841 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-21T04:08:32.280983+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-21T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-21T04:08:12.517382+00:00 2023-03-21T04:08:13.295029+00:00 0:00:00.777647 356838 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-21T04:08:10.270218+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-21T03:00:00+00:00 PythonOperator 2023-03-21T04:07:50.415664+00:00 2023-03-21T04:07:53.503272+00:00 0:00:03.087608 356835 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-21T04:07:48.240307+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-21T02:00:00+00:00 TriggerDagRunOperator 2023-03-21T03:17:15.243831+00:00 2023-03-21T03:17:15.687044+00:00 0:00:00.443213 356824 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T03:17:12.339014+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-21T02:00:00+00:00 TriggerDagRunOperator 2023-03-21T03:17:14.540169+00:00 2023-03-21T03:17:14.981600+00:00 0:00:00.441431 356823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T03:17:12.339058+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-21T02:00:00+00:00 EmrJobFlowSensor 2023-03-21T03:00:49.469174+00:00 2023-03-21T03:10:51.301052+00:00 0:10:01.831878 356819 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-21T03:00:47.000149+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-21T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-21T03:00:27.277942+00:00 2023-03-21T03:00:28.180715+00:00 0:00:00.902773 356817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-21T03:00:24.906637+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-21T02:00:00+00:00 PythonOperator 2023-03-21T03:00:05.667120+00:00 2023-03-21T03:00:09.848704+00:00 0:00:04.181584 356814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-21T03:00:02.624730+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-21T01:00:00+00:00 TriggerDagRunOperator 2023-03-21T02:11:13.518040+00:00 2023-03-21T02:11:13.975822+00:00 0:00:00.457782 356807 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T02:11:10.889633+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-21T01:00:00+00:00 TriggerDagRunOperator 2023-03-21T02:11:13.312112+00:00 2023-03-21T02:11:13.783866+00:00 0:00:00.471754 356806 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T02:11:10.889678+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-21T01:00:00+00:00 EmrJobFlowSensor 2023-03-21T02:01:01.880775+00:00 2023-03-21T02:11:03.695566+00:00 0:10:01.814791 356798 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-21T02:00:59.194411+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-21T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-21T02:00:39.612020+00:00 2023-03-21T02:00:40.525642+00:00 0:00:00.913622 356796 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-21T02:00:37.190829+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-21T01:00:00+00:00 PythonOperator 2023-03-21T02:00:17.497158+00:00 2023-03-21T02:00:21.050895+00:00 0:00:03.553737 356794 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-21T02:00:15.069912+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-21T00:00:00+00:00 TriggerDagRunOperator 2023-03-21T01:11:32.310842+00:00 2023-03-21T01:11:32.835395+00:00 0:00:00.524553 356772 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T01:11:29.402994+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-21T00:00:00+00:00 TriggerDagRunOperator 2023-03-21T01:11:32.025254+00:00 2023-03-21T01:11:32.538354+00:00 0:00:00.513100 356771 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T01:11:29.402932+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-21T00:00:00+00:00 EmrJobFlowSensor 2023-03-21T01:00:54.754608+00:00 2023-03-21T01:10:56.747275+00:00 0:10:01.992667 356769 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-21T01:00:52.413380+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-21T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-21T01:00:32.921159+00:00 2023-03-21T01:00:33.753076+00:00 0:00:00.831917 356768 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-21T01:00:30.401624+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-21T00:00:00+00:00 PythonOperator 2023-03-21T01:00:11.124900+00:00 2023-03-21T01:00:15.745610+00:00 0:00:04.620710 356766 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-21T01:00:08.423930+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-20T23:00:00+00:00 TriggerDagRunOperator 2023-03-21T00:24:25.036939+00:00 2023-03-21T00:24:25.589012+00:00 0:00:00.552073 356760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T00:24:22.570257+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-20T23:00:00+00:00 TriggerDagRunOperator 2023-03-21T00:24:25.009437+00:00 2023-03-21T00:24:25.655025+00:00 0:00:00.645588 356759 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-21T00:24:22.570229+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-20T23:00:00+00:00 EmrJobFlowSensor 2023-03-21T00:14:10.559640+00:00 2023-03-21T00:24:12.420345+00:00 0:10:01.860705 356756 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-21T00:14:08.354201+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-20T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-21T00:13:50.552805+00:00 2023-03-21T00:13:51.634035+00:00 0:00:01.081230 356753 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-21T00:13:48.337310+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-20T23:00:00+00:00 PythonOperator 2023-03-21T00:13:30.150892+00:00 2023-03-21T00:13:33.557086+00:00 0:00:03.406194 356750 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-21T00:13:26.274544+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-20T22:00:00+00:00 TriggerDagRunOperator 2023-03-20T23:15:59.016235+00:00 2023-03-20T23:15:59.491353+00:00 0:00:00.475118 356740 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T23:15:56.119692+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-20T22:00:00+00:00 TriggerDagRunOperator 2023-03-20T23:15:58.725735+00:00 2023-03-20T23:15:59.168335+00:00 0:00:00.442600 356739 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T23:15:56.119661+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-20T22:00:00+00:00 EmrJobFlowSensor 2023-03-20T23:05:52.450543+00:00 2023-03-20T23:15:54.223530+00:00 0:10:01.772987 356736 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-20T23:05:50.274388+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-20T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-20T23:05:30.448746+00:00 2023-03-20T23:05:31.226968+00:00 0:00:00.778222 356732 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-20T23:05:28.252901+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-20T22:00:00+00:00 PythonOperator 2023-03-20T23:05:08.530702+00:00 2023-03-20T23:05:12.479150+00:00 0:00:03.948448 356728 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-20T23:05:06.243774+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-20T21:00:00+00:00 TriggerDagRunOperator 2023-03-20T22:11:47.972499+00:00 2023-03-20T22:11:48.478035+00:00 0:00:00.505536 356718 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T22:11:45.151603+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-20T21:00:00+00:00 TriggerDagRunOperator 2023-03-20T22:11:47.943364+00:00 2023-03-20T22:11:48.434884+00:00 0:00:00.491520 356717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T22:11:45.151574+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-20T21:00:00+00:00 EmrJobFlowSensor 2023-03-20T22:01:01.796346+00:00 2023-03-20T22:11:03.749874+00:00 0:10:01.953528 356709 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-20T22:00:59.512480+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-20T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-20T22:00:39.683004+00:00 2023-03-20T22:00:40.631205+00:00 0:00:00.948201 356707 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-20T22:00:37.490916+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-20T21:00:00+00:00 PythonOperator 2023-03-20T22:00:19.825338+00:00 2023-03-20T22:00:25.773572+00:00 0:00:05.948234 356705 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-20T22:00:17.476525+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-20T20:00:00+00:00 TriggerDagRunOperator 2023-03-20T21:10:57.966240+00:00 2023-03-20T21:10:58.435678+00:00 0:00:00.469438 356694 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T21:10:55.721048+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-20T20:00:00+00:00 TriggerDagRunOperator 2023-03-20T21:10:57.929237+00:00 2023-03-20T21:10:58.411382+00:00 0:00:00.482145 356693 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T21:10:55.721075+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-20T20:00:00+00:00 EmrJobFlowSensor 2023-03-20T21:00:48.143500+00:00 2023-03-20T21:10:50.053236+00:00 0:10:01.909736 356686 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-20T21:00:45.791594+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-20T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-20T21:00:26.155570+00:00 2023-03-20T21:00:27.014537+00:00 0:00:00.858967 356684 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-20T21:00:23.771198+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-20T20:00:00+00:00 PythonOperator 2023-03-20T21:00:06.325764+00:00 2023-03-20T21:00:09.769683+00:00 0:00:03.443919 356682 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-20T21:00:03.752318+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-20T19:00:00+00:00 TriggerDagRunOperator 2023-03-20T20:12:02.888252+00:00 2023-03-20T20:12:03.399270+00:00 0:00:00.511018 356672 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T20:11:59.897120+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-20T19:00:00+00:00 TriggerDagRunOperator 2023-03-20T20:12:02.698348+00:00 2023-03-20T20:12:03.169332+00:00 0:00:00.470984 356671 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T20:11:59.897155+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-20T19:00:00+00:00 EmrJobFlowSensor 2023-03-20T20:00:52.934830+00:00 2023-03-20T20:10:54.848683+00:00 0:10:01.913853 356663 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-20T20:00:50.407142+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-20T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-20T20:00:30.923643+00:00 2023-03-20T20:00:31.864023+00:00 0:00:00.940380 356661 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-20T20:00:28.387623+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-20T19:00:00+00:00 PythonOperator 2023-03-20T20:00:08.697980+00:00 2023-03-20T20:00:12.760472+00:00 0:00:04.062492 356659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-20T20:00:06.255074+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-20T18:00:00+00:00 TriggerDagRunOperator 2023-03-20T19:11:14.454929+00:00 2023-03-20T19:11:14.920712+00:00 0:00:00.465783 356648 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T19:11:11.981399+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-20T18:00:00+00:00 TriggerDagRunOperator 2023-03-20T19:11:14.223796+00:00 2023-03-20T19:11:14.680565+00:00 0:00:00.456769 356647 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T19:11:11.981427+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-20T18:00:00+00:00 EmrJobFlowSensor 2023-03-20T19:01:06.334408+00:00 2023-03-20T19:11:08.099225+00:00 0:10:01.764817 356641 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-20T19:01:03.408593+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-20T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-20T19:00:43.690881+00:00 2023-03-20T19:00:44.520972+00:00 0:00:00.830091 356639 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-20T19:00:41.395526+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-20T18:00:00+00:00 PythonOperator 2023-03-20T19:00:23.629984+00:00 2023-03-20T19:00:27.632510+00:00 0:00:04.002526 356637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-20T19:00:21.296427+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-20T17:00:00+00:00 TriggerDagRunOperator 2023-03-20T18:11:13.373844+00:00 2023-03-20T18:11:13.887819+00:00 0:00:00.513975 356627 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T18:11:11.137252+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-20T17:00:00+00:00 TriggerDagRunOperator 2023-03-20T18:11:13.323232+00:00 2023-03-20T18:11:13.778303+00:00 0:00:00.455071 356626 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T18:11:11.137218+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-20T17:00:00+00:00 EmrJobFlowSensor 2023-03-20T18:00:50.692148+00:00 2023-03-20T18:10:52.535025+00:00 0:10:01.842877 356620 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-20T18:00:48.430157+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-20T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-20T18:00:33.044338+00:00 2023-03-20T18:00:33.972188+00:00 0:00:00.927850 356618 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-20T18:00:28.348338+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-20T17:00:00+00:00 PythonOperator 2023-03-20T18:00:08.588762+00:00 2023-03-20T18:00:12.689746+00:00 0:00:04.100984 356616 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-20T18:00:06.328393+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-20T16:00:00+00:00 TriggerDagRunOperator 2023-03-20T17:11:51.218886+00:00 2023-03-20T17:11:51.720930+00:00 0:00:00.502044 356602 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T17:11:48.195552+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-20T16:00:00+00:00 EmrJobFlowSensor 2023-03-20T17:01:40.358912+00:00 2023-03-20T17:11:42.201120+00:00 0:10:01.842208 356594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-20T17:01:37.992339+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-20T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-20T17:01:18.165934+00:00 2023-03-20T17:01:19.018242+00:00 0:00:00.852308 356592 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-20T17:01:15.973301+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-20T16:00:00+00:00 PythonOperator 2023-03-20T17:00:56.473940+00:00 2023-03-20T17:00:59.710605+00:00 0:00:03.236665 356590 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-20T17:00:53.955526+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-20T15:00:00+00:00 TriggerDagRunOperator 2023-03-20T16:16:35.339173+00:00 2023-03-20T16:16:35.866170+00:00 0:00:00.526997 356583 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T16:16:32.282046+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-20T15:00:00+00:00 TriggerDagRunOperator 2023-03-20T16:16:34.971567+00:00 2023-03-20T16:16:35.447090+00:00 0:00:00.475523 356582 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-20T16:16:32.281992+00:00 2 default_pool