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-09T19:00:00+00:00 EmrJobFlowSensor 2023-03-09T20:00:54.023454+00:00 2023-03-09T20:10:55.894070+00:00 0:10:01.870616 350954 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-09T20:00:51.697014+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-09T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-09T20:00:33.906950+00:00 2023-03-09T20:00:34.789223+00:00 0:00:00.882273 350952 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-09T20:00:31.692191+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-09T19:00:00+00:00 PythonOperator 2023-03-09T20:00:12.103464+00:00 2023-03-09T20:00:17.527190+00:00 0:00:05.423726 350950 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-09T20:00:09.659121+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-09T18:00:00+00:00 TriggerDagRunOperator 2023-03-09T19:11:20.917877+00:00 2023-03-09T19:11:21.495002+00:00 0:00:00.577125 350939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T19:11:18.508307+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-09T18:00:00+00:00 TriggerDagRunOperator 2023-03-09T19:11:20.945323+00:00 2023-03-09T19:11:21.535005+00:00 0:00:00.589682 350938 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T19:11:18.508335+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-09T18:00:00+00:00 EmrJobFlowSensor 2023-03-09T19:01:01.209366+00:00 2023-03-09T19:11:03.230725+00:00 0:10:02.021359 350931 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-09T19:00:58.652789+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-09T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-09T19:00:40.956968+00:00 2023-03-09T19:00:41.908808+00:00 0:00:00.951840 350929 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-09T19:00:38.629293+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-09T18:00:00+00:00 PythonOperator 2023-03-09T19:00:19.844831+00:00 2023-03-09T19:00:23.583655+00:00 0:00:03.738824 350927 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-09T19:00:16.587130+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-09T17:00:00+00:00 TriggerDagRunOperator 2023-03-09T18:11:21.789197+00:00 2023-03-09T18:11:22.317990+00:00 0:00:00.528793 350916 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T18:11:19.431714+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-09T17:00:00+00:00 TriggerDagRunOperator 2023-03-09T18:11:21.731598+00:00 2023-03-09T18:11:22.215128+00:00 0:00:00.483530 350915 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T18:11:19.431742+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-09T17:00:00+00:00 EmrJobFlowSensor 2023-03-09T18:01:03.161051+00:00 2023-03-09T18:11:05.125040+00:00 0:10:01.963989 350908 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-09T18:01:00.505189+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-09T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-09T18:00:40.707271+00:00 2023-03-09T18:00:41.545813+00:00 0:00:00.838542 350905 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-09T18:00:38.443857+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-09T17:00:00+00:00 PythonOperator 2023-03-09T18:00:21.375192+00:00 2023-03-09T18:00:24.606213+00:00 0:00:03.231021 350904 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-09T18:00:18.364012+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-09T16:00:00+00:00 TriggerDagRunOperator 2023-03-09T17:11:09.342293+00:00 2023-03-09T17:11:09.824474+00:00 0:00:00.482181 350892 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T17:11:06.418617+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-09T16:00:00+00:00 TriggerDagRunOperator 2023-03-09T17:11:09.224466+00:00 2023-03-09T17:11:09.713854+00:00 0:00:00.489388 350891 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T17:11:06.418661+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-09T16:00:00+00:00 EmrJobFlowSensor 2023-03-09T17:00:58.854398+00:00 2023-03-09T17:11:00.687017+00:00 0:10:01.832619 350884 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-09T17:00:56.279817+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-09T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-09T17:00:36.561266+00:00 2023-03-09T17:00:37.424420+00:00 0:00:00.863154 350882 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-09T17:00:34.278240+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-09T16:00:00+00:00 PythonOperator 2023-03-09T17:00:16.446093+00:00 2023-03-09T17:00:20.367302+00:00 0:00:03.921209 350880 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-09T17:00:14.251491+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-09T15:00:00+00:00 TriggerDagRunOperator 2023-03-09T16:11:08.744304+00:00 2023-03-09T16:11:09.266145+00:00 0:00:00.521841 350869 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T16:11:05.422755+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-09T15:00:00+00:00 TriggerDagRunOperator 2023-03-09T16:11:08.234142+00:00 2023-03-09T16:11:08.694113+00:00 0:00:00.459971 350868 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T16:11:05.422801+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-09T15:00:00+00:00 EmrJobFlowSensor 2023-03-09T16:01:02.467176+00:00 2023-03-09T16:11:04.368102+00:00 0:10:01.900926 350861 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-09T16:00:59.959161+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-09T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-09T16:00:40.150601+00:00 2023-03-09T16:00:41.031973+00:00 0:00:00.881372 350859 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-09T16:00:37.929453+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-09T15:00:00+00:00 PythonOperator 2023-03-09T16:00:20.189226+00:00 2023-03-09T16:00:23.444219+00:00 0:00:03.254993 350857 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-09T16:00:17.888911+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-09T14:00:00+00:00 TriggerDagRunOperator 2023-03-09T15:19:24.344025+00:00 2023-03-09T15:19:24.840443+00:00 0:00:00.496418 350849 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T15:19:21.901352+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-09T14:00:00+00:00 TriggerDagRunOperator 2023-03-09T15:19:24.336060+00:00 2023-03-09T15:19:24.809652+00:00 0:00:00.473592 350848 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T15:19:21.901310+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-09T14:00:00+00:00 EmrJobFlowSensor 2023-03-09T15:09:05.188286+00:00 2023-03-09T15:19:07.191203+00:00 0:10:02.002917 350844 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-09T15:09:02.840428+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-09T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-09T15:08:45.392134+00:00 2023-03-09T15:08:46.215022+00:00 0:00:00.822888 350841 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-09T15:08:42.799127+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-09T14:00:00+00:00 PythonOperator 2023-03-09T15:08:22.964599+00:00 2023-03-09T15:08:26.924050+00:00 0:00:03.959451 350838 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-09T15:08:20.780419+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-09T13:00:00+00:00 TriggerDagRunOperator 2023-03-09T14:15:11.958080+00:00 2023-03-09T14:15:12.470440+00:00 0:00:00.512360 350829 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T14:15:09.072866+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-09T13:00:00+00:00 TriggerDagRunOperator 2023-03-09T14:15:11.748708+00:00 2023-03-09T14:15:12.229077+00:00 0:00:00.480369 350828 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T14:15:09.072894+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-09T13:00:00+00:00 EmrJobFlowSensor 2023-03-09T14:02:24.727408+00:00 2023-03-09T14:12:26.622545+00:00 0:10:01.895137 350822 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-09T14:02:22.333529+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-09T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-09T14:02:06.511211+00:00 2023-03-09T14:02:07.894805+00:00 0:00:01.383594 350820 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-09T14:02:02.284158+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-09T13:00:00+00:00 PythonOperator 2023-03-09T14:01:43.127247+00:00 2023-03-09T14:01:46.404929+00:00 0:00:03.277682 350818 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-09T14:01:40.243376+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-09T12:00:00+00:00 TriggerDagRunOperator 2023-03-09T13:11:15.005079+00:00 2023-03-09T13:11:15.673411+00:00 0:00:00.668332 350809 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T13:11:12.494193+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-09T12:00:00+00:00 TriggerDagRunOperator 2023-03-09T13:11:14.845921+00:00 2023-03-09T13:11:15.504045+00:00 0:00:00.658124 350808 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T13:11:12.494224+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-09T12:00:00+00:00 EmrJobFlowSensor 2023-03-09T13:01:06.016834+00:00 2023-03-09T13:11:07.837831+00:00 0:10:01.820997 350802 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-09T13:01:03.632145+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-09T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-09T13:00:44.291836+00:00 2023-03-09T13:00:45.330857+00:00 0:00:01.039021 350800 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-09T13:00:41.534583+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-09T12:00:00+00:00 PythonOperator 2023-03-09T13:00:21.746837+00:00 2023-03-09T13:00:25.676331+00:00 0:00:03.929494 350798 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-09T13:00:19.513523+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-09T11:00:00+00:00 TriggerDagRunOperator 2023-03-09T12:23:41.273194+00:00 2023-03-09T12:23:42.087174+00:00 0:00:00.813980 350790 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T12:23:38.357461+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-09T11:00:00+00:00 TriggerDagRunOperator 2023-03-09T12:23:40.887035+00:00 2023-03-09T12:23:41.630569+00:00 0:00:00.743534 350789 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T12:23:38.357490+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-09T11:00:00+00:00 EmrJobFlowSensor 2023-03-09T12:05:28.794762+00:00 2023-03-09T12:16:31.054901+00:00 0:11:02.260139 350784 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-09T12:05:26.387135+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-09T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-09T12:05:08.681009+00:00 2023-03-09T12:05:09.531781+00:00 0:00:00.850772 350782 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-09T12:05:06.367075+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-09T11:00:00+00:00 PythonOperator 2023-03-09T12:04:46.592150+00:00 2023-03-09T12:04:49.535355+00:00 0:00:02.943205 350779 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-09T12:04:44.354067+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-09T10:00:00+00:00 TriggerDagRunOperator 2023-03-09T11:23:14.298875+00:00 2023-03-09T11:23:15.129464+00:00 0:00:00.830589 350770 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T11:23:11.065224+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-09T10:00:00+00:00 TriggerDagRunOperator 2023-03-09T11:23:13.690189+00:00 2023-03-09T11:23:14.409824+00:00 0:00:00.719635 350769 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T11:23:11.065196+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-09T10:00:00+00:00 EmrJobFlowSensor 2023-03-09T11:01:04.132123+00:00 2023-03-09T11:11:05.976867+00:00 0:10:01.844744 350762 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-09T11:01:01.070239+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-09T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-09T11:00:43.026793+00:00 2023-03-09T11:00:44.524296+00:00 0:00:01.497503 350760 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-09T11:00:39.056030+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-09T10:00:00+00:00 PythonOperator 2023-03-09T11:00:19.254119+00:00 2023-03-09T11:00:23.163097+00:00 0:00:03.908978 350758 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-09T11:00:17.041526+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-09T09:00:00+00:00 TriggerDagRunOperator 2023-03-09T10:11:13.846866+00:00 2023-03-09T10:11:14.656331+00:00 0:00:00.809465 350749 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T10:11:11.122924+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-09T09:00:00+00:00 TriggerDagRunOperator 2023-03-09T10:11:13.824211+00:00 2023-03-09T10:11:14.597308+00:00 0:00:00.773097 350748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T10:11:11.122879+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-09T09:00:00+00:00 EmrJobFlowSensor 2023-03-09T10:00:54.938053+00:00 2023-03-09T10:10:56.798414+00:00 0:10:01.860361 350741 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-09T10:00:52.698818+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-09T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-09T10:00:30.886987+00:00 2023-03-09T10:00:31.854696+00:00 0:00:00.967709 350739 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-09T10:00:28.545861+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-09T09:00:00+00:00 PythonOperator 2023-03-09T10:00:08.964678+00:00 2023-03-09T10:00:12.347180+00:00 0:00:03.382502 350737 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-09T10:00:06.509342+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-09T08:00:00+00:00 TriggerDagRunOperator 2023-03-09T09:11:14.062728+00:00 2023-03-09T09:11:14.799711+00:00 0:00:00.736983 350726 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T09:11:11.460900+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-09T08:00:00+00:00 TriggerDagRunOperator 2023-03-09T09:11:13.798496+00:00 2023-03-09T09:11:14.419669+00:00 0:00:00.621173 350725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T09:11:11.460871+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-09T08:00:00+00:00 EmrJobFlowSensor 2023-03-09T09:01:04.788903+00:00 2023-03-09T09:11:06.619442+00:00 0:10:01.830539 350716 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-09T09:01:02.545077+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-09T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-09T09:00:44.917411+00:00 2023-03-09T09:00:45.869203+00:00 0:00:00.951792 350715 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-09T09:00:42.528009+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-09T08:00:00+00:00 PythonOperator 2023-03-09T09:00:23.046799+00:00 2023-03-09T09:00:26.322445+00:00 0:00:03.275646 350714 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-09T09:00:20.451614+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-09T07:00:00+00:00 TriggerDagRunOperator 2023-03-09T08:10:58.230472+00:00 2023-03-09T08:10:58.705462+00:00 0:00:00.474990 350703 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T08:10:55.516926+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-09T07:00:00+00:00 TriggerDagRunOperator 2023-03-09T08:10:57.907913+00:00 2023-03-09T08:10:58.479098+00:00 0:00:00.571185 350702 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T08:10:55.516896+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-09T07:00:00+00:00 EmrJobFlowSensor 2023-03-09T08:00:52.594452+00:00 2023-03-09T08:10:54.415124+00:00 0:10:01.820672 350695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-09T08:00:50.389376+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-09T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-09T08:00:30.710896+00:00 2023-03-09T08:00:31.599059+00:00 0:00:00.888163 350693 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-09T08:00:28.362184+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-09T07:00:00+00:00 PythonOperator 2023-03-09T08:00:08.863000+00:00 2023-03-09T08:00:12.834972+00:00 0:00:03.971972 350691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-09T08:00:06.351684+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-09T06:00:00+00:00 TriggerDagRunOperator 2023-03-09T07:14:13.063747+00:00 2023-03-09T07:14:13.567408+00:00 0:00:00.503661 350682 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T07:14:10.247210+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-09T06:00:00+00:00 TriggerDagRunOperator 2023-03-09T07:14:13.068800+00:00 2023-03-09T07:14:13.587887+00:00 0:00:00.519087 350681 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T07:14:10.247238+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-09T06:00:00+00:00 EmrJobFlowSensor 2023-03-09T07:01:01.728510+00:00 2023-03-09T07:11:03.582495+00:00 0:10:01.853985 350674 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-09T07:00:59.447799+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-09T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-09T07:00:42.022703+00:00 2023-03-09T07:00:42.955549+00:00 0:00:00.932846 350672 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-09T07:00:39.428946+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-09T06:00:00+00:00 PythonOperator 2023-03-09T07:00:20.188093+00:00 2023-03-09T07:00:23.564029+00:00 0:00:03.375936 350670 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-09T07:00:17.411045+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-09T05:00:00+00:00 TriggerDagRunOperator 2023-03-09T06:11:24.838855+00:00 2023-03-09T06:11:25.324529+00:00 0:00:00.485674 350661 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T06:11:22.275390+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-09T05:00:00+00:00 TriggerDagRunOperator 2023-03-09T06:11:24.837737+00:00 2023-03-09T06:11:25.349459+00:00 0:00:00.511722 350660 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T06:11:22.275350+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-09T05:00:00+00:00 EmrJobFlowSensor 2023-03-09T06:01:05.398606+00:00 2023-03-09T06:11:07.720839+00:00 0:10:02.322233 350652 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-09T06:01:02.110573+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-09T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-09T06:00:42.293561+00:00 2023-03-09T06:00:43.513592+00:00 0:00:01.220031 350650 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-09T06:00:39.994330+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-09T05:00:00+00:00 PythonOperator 2023-03-09T06:00:22.787996+00:00 2023-03-09T06:00:25.942287+00:00 0:00:03.154291 350649 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-09T06:00:19.988778+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-09T04:00:00+00:00 TriggerDagRunOperator 2023-03-09T05:11:15.361407+00:00 2023-03-09T05:11:15.867753+00:00 0:00:00.506346 350639 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T05:11:12.527535+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-09T04:00:00+00:00 TriggerDagRunOperator 2023-03-09T05:11:15.222150+00:00 2023-03-09T05:11:15.693854+00:00 0:00:00.471704 350638 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T05:11:12.527571+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-09T04:00:00+00:00 EmrJobFlowSensor 2023-03-09T05:00:58.100345+00:00 2023-03-09T05:10:59.799781+00:00 0:10:01.699436 350631 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-09T05:00:55.689810+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-09T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-09T05:00:38.118936+00:00 2023-03-09T05:00:39.027982+00:00 0:00:00.909046 350629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-09T05:00:35.611529+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-09T04:00:00+00:00 PythonOperator 2023-03-09T05:00:16.857569+00:00 2023-03-09T05:00:20.139270+00:00 0:00:03.281701 350627 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-09T05:00:13.611880+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-09T03:00:00+00:00 TriggerDagRunOperator 2023-03-09T04:11:19.293565+00:00 2023-03-09T04:11:19.802701+00:00 0:00:00.509136 350616 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T04:11:16.752658+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-09T03:00:00+00:00 TriggerDagRunOperator 2023-03-09T04:11:19.100205+00:00 2023-03-09T04:11:19.652571+00:00 0:00:00.552366 350615 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T04:11:16.752621+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-09T03:00:00+00:00 EmrJobFlowSensor 2023-03-09T04:00:59.865059+00:00 2023-03-09T04:11:01.818931+00:00 0:10:01.953872 350608 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-09T04:00:57.504310+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-09T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-09T04:00:39.894862+00:00 2023-03-09T04:00:40.808820+00:00 0:00:00.913958 350606 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-09T04:00:37.502573+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-09T03:00:00+00:00 PythonOperator 2023-03-09T04:00:18.113942+00:00 2023-03-09T04:00:21.322218+00:00 0:00:03.208276 350604 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-09T04:00:15.491015+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-09T02:00:00+00:00 TriggerDagRunOperator 2023-03-09T03:11:47.324740+00:00 2023-03-09T03:11:47.822079+00:00 0:00:00.497339 350594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T03:11:44.540580+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-09T02:00:00+00:00 TriggerDagRunOperator 2023-03-09T03:11:47.276220+00:00 2023-03-09T03:11:47.760349+00:00 0:00:00.484129 350593 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T03:11:44.540608+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-09T02:00:00+00:00 EmrJobFlowSensor 2023-03-09T03:01:26.051408+00:00 2023-03-09T03:11:28.012679+00:00 0:10:01.961271 350586 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-09T03:01:23.606150+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-09T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-09T03:01:06.226760+00:00 2023-03-09T03:01:07.503672+00:00 0:00:01.276912 350584 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-09T03:01:03.588408+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-09T02:00:00+00:00 PythonOperator 2023-03-09T03:00:44.466039+00:00 2023-03-09T03:00:49.979339+00:00 0:00:05.513300 350582 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-09T03:00:41.561758+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-09T01:00:00+00:00 TriggerDagRunOperator 2023-03-09T02:12:19.188266+00:00 2023-03-09T02:12:19.644183+00:00 0:00:00.455917 350571 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T02:12:16.114532+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-09T01:00:00+00:00 TriggerDagRunOperator 2023-03-09T02:12:19.084115+00:00 2023-03-09T02:12:19.564858+00:00 0:00:00.480743 350570 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T02:12:16.114488+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-09T01:00:00+00:00 EmrJobFlowSensor 2023-03-09T02:01:53.659611+00:00 2023-03-09T02:11:55.426681+00:00 0:10:01.767070 350564 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-09T02:01:51.417924+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-09T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-09T02:01:31.755613+00:00 2023-03-09T02:01:32.609010+00:00 0:00:00.853397 350562 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-09T02:01:29.345021+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-09T01:00:00+00:00 PythonOperator 2023-03-09T02:01:11.562807+00:00 2023-03-09T02:01:14.659443+00:00 0:00:03.096636 350560 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-09T02:01:09.322232+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-09T00:00:00+00:00 TriggerDagRunOperator 2023-03-09T01:11:22.013703+00:00 2023-03-09T01:11:22.519581+00:00 0:00:00.505878 350542 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T01:11:19.393360+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-09T00:00:00+00:00 TriggerDagRunOperator 2023-03-09T01:11:21.814725+00:00 2023-03-09T01:11:22.295952+00:00 0:00:00.481227 350541 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T01:11:19.393388+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-09T00:00:00+00:00 EmrJobFlowSensor 2023-03-09T01:01:12.781445+00:00 2023-03-09T01:11:14.652003+00:00 0:10:01.870558 350534 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-09T01:01:10.354888+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-09T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-09T01:00:52.773534+00:00 2023-03-09T01:00:53.712191+00:00 0:00:00.938657 350532 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-09T01:00:50.330493+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-09T00:00:00+00:00 PythonOperator 2023-03-09T01:00:31.264005+00:00 2023-03-09T01:00:34.669963+00:00 0:00:03.405958 350530 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-09T01:00:28.313003+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-08T23:00:00+00:00 TriggerDagRunOperator 2023-03-09T00:12:15.361742+00:00 2023-03-09T00:12:16.038426+00:00 0:00:00.676684 350519 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T00:12:12.320150+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-08T23:00:00+00:00 TriggerDagRunOperator 2023-03-09T00:12:15.309699+00:00 2023-03-09T00:12:15.897795+00:00 0:00:00.588096 350518 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T00:12:12.320193+00:00 2 default_pool