Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-06T10:00:00+00:00 EmrCreateJobFlowOperator 2023-06-06T11:03:48.119237+00:00 2023-06-06T11:03:48.895720+00:00 0:00:00.776483 391956 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-06T11:03:45.861113+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-06T10:00:00+00:00 PythonOperator 2023-06-06T11:03:26.065037+00:00 2023-06-06T11:03:26.866014+00:00 0:00:00.800977 391954 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-06T11:03:23.839103+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-06T09:00:00+00:00 TriggerDagRunOperator 2023-06-06T10:16:21.924361+00:00 2023-06-06T10:16:22.251874+00:00 0:00:00.327513 391943 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T10:16:19.516380+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-06T09:00:00+00:00 TriggerDagRunOperator 2023-06-06T10:16:21.723455+00:00 2023-06-06T10:16:22.188488+00:00 0:00:00.465033 391942 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T10:16:19.516353+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-06T09:00:00+00:00 EmrJobFlowSensor 2023-06-06T10:05:55.219516+00:00 2023-06-06T10:15:56.955657+00:00 0:10:01.736141 391938 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-06T10:05:52.969290+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-06T09:00:00+00:00 EmrCreateJobFlowOperator 2023-06-06T10:05:35.288736+00:00 2023-06-06T10:05:36.486923+00:00 0:00:01.198187 391935 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-06T10:05:32.952335+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-06T09:00:00+00:00 PythonOperator 2023-06-06T10:05:13.026029+00:00 2023-06-06T10:05:13.998426+00:00 0:00:00.972397 391932 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-06T10:05:10.988003+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-06T08:00:00+00:00 TriggerDagRunOperator 2023-06-06T09:11:27.179185+00:00 2023-06-06T09:11:27.693509+00:00 0:00:00.514324 391921 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T09:11:24.693606+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-06T08:00:00+00:00 TriggerDagRunOperator 2023-06-06T09:11:26.968784+00:00 2023-06-06T09:11:27.558991+00:00 0:00:00.590207 391920 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T09:11:24.693634+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-06T08:00:00+00:00 EmrJobFlowSensor 2023-06-06T09:01:12.803254+00:00 2023-06-06T09:11:14.634556+00:00 0:10:01.831302 391914 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-06T09:01:10.562545+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-06T08:00:00+00:00 EmrCreateJobFlowOperator 2023-06-06T09:00:50.834156+00:00 2023-06-06T09:00:51.692606+00:00 0:00:00.858450 391912 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-06T09:00:48.540074+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-06T08:00:00+00:00 PythonOperator 2023-06-06T09:00:28.668924+00:00 2023-06-06T09:00:29.486575+00:00 0:00:00.817651 391910 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-06T09:00:26.519221+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-06T07:00:00+00:00 TriggerDagRunOperator 2023-06-06T08:31:47.175725+00:00 2023-06-06T08:31:47.505163+00:00 0:00:00.329438 391902 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T08:31:44.518426+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-06T07:00:00+00:00 TriggerDagRunOperator 2023-06-06T08:31:46.959180+00:00 2023-06-06T08:31:47.413123+00:00 0:00:00.453943 391901 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T08:31:44.518466+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-06T07:00:00+00:00 EmrJobFlowSensor 2023-06-06T08:08:00.773425+00:00 2023-06-06T08:18:02.852205+00:00 0:10:02.078780 391897 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-06T08:07:58.742905+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-06T07:00:00+00:00 EmrCreateJobFlowOperator 2023-06-06T08:07:39.625845+00:00 2023-06-06T08:07:40.475300+00:00 0:00:00.849455 391895 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-06T08:07:36.721796+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-06T07:00:00+00:00 PythonOperator 2023-06-06T08:07:17.198362+00:00 2023-06-06T08:07:18.040709+00:00 0:00:00.842347 391891 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-06T08:07:14.703004+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-06T06:00:00+00:00 TriggerDagRunOperator 2023-06-06T07:11:24.696614+00:00 2023-06-06T07:11:25.239822+00:00 0:00:00.543208 391879 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T07:11:22.484563+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-06T06:00:00+00:00 TriggerDagRunOperator 2023-06-06T07:11:24.521535+00:00 2023-06-06T07:11:24.989065+00:00 0:00:00.467530 391878 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T07:11:22.484589+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-06T06:00:00+00:00 EmrJobFlowSensor 2023-06-06T07:01:05.885089+00:00 2023-06-06T07:11:07.863893+00:00 0:10:01.978804 391874 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-06T07:01:03.911401+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-06T06:00:00+00:00 EmrCreateJobFlowOperator 2023-06-06T07:00:43.993183+00:00 2023-06-06T07:00:44.965287+00:00 0:00:00.972104 391872 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-06T07:00:41.992544+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-06T06:00:00+00:00 PythonOperator 2023-06-06T07:00:24.051076+00:00 2023-06-06T07:00:24.845487+00:00 0:00:00.794411 391870 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-06T07:00:21.859844+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-06T05:00:00+00:00 TriggerDagRunOperator 2023-06-06T06:11:14.190343+00:00 2023-06-06T06:11:14.516298+00:00 0:00:00.325955 391862 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T06:11:11.762260+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-06T05:00:00+00:00 TriggerDagRunOperator 2023-06-06T06:11:13.940945+00:00 2023-06-06T06:11:14.368670+00:00 0:00:00.427725 391861 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T06:11:11.762232+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-06T05:00:00+00:00 EmrJobFlowSensor 2023-06-06T06:00:49.054326+00:00 2023-06-06T06:10:50.807861+00:00 0:10:01.753535 391853 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-06T06:00:46.915311+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-06T05:00:00+00:00 EmrCreateJobFlowOperator 2023-06-06T06:00:26.892451+00:00 2023-06-06T06:00:27.813021+00:00 0:00:00.920570 391851 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-06T06:00:24.892719+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-06T05:00:00+00:00 PythonOperator 2023-06-06T06:00:03.529204+00:00 2023-06-06T06:00:04.470874+00:00 0:00:00.941670 391849 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-06T06:00:01.097283+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-06T04:00:00+00:00 TriggerDagRunOperator 2023-06-06T05:18:05.591400+00:00 2023-06-06T05:18:06.078271+00:00 0:00:00.486871 391841 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T05:18:03.219808+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-06T04:00:00+00:00 TriggerDagRunOperator 2023-06-06T05:18:05.467252+00:00 2023-06-06T05:18:05.944221+00:00 0:00:00.476969 391840 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T05:18:03.219837+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-06T04:00:00+00:00 EmrJobFlowSensor 2023-06-06T05:07:57.978794+00:00 2023-06-06T05:17:59.715203+00:00 0:10:01.736409 391835 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-06T05:07:55.737253+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-06T04:00:00+00:00 EmrCreateJobFlowOperator 2023-06-06T05:07:37.959870+00:00 2023-06-06T05:07:38.816046+00:00 0:00:00.856176 391832 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-06T05:07:35.716422+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-06T04:00:00+00:00 PythonOperator 2023-06-06T05:07:16.191128+00:00 2023-06-06T05:07:17.002426+00:00 0:00:00.811298 391829 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-06T05:07:13.698529+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-06T03:00:00+00:00 TriggerDagRunOperator 2023-06-06T04:18:24.784835+00:00 2023-06-06T04:18:25.131873+00:00 0:00:00.347038 391821 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T04:18:22.269995+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-06T03:00:00+00:00 TriggerDagRunOperator 2023-06-06T04:18:24.625123+00:00 2023-06-06T04:18:25.074913+00:00 0:00:00.449790 391820 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T04:18:22.270027+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-06T03:00:00+00:00 EmrJobFlowSensor 2023-06-06T04:00:58.847931+00:00 2023-06-06T04:11:00.768044+00:00 0:10:01.920113 391814 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-06T04:00:56.742648+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-06T03:00:00+00:00 EmrCreateJobFlowOperator 2023-06-06T04:00:36.755614+00:00 2023-06-06T04:00:37.762090+00:00 0:00:01.006476 391812 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-06T04:00:34.724118+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-06T03:00:00+00:00 PythonOperator 2023-06-06T04:00:15.113851+00:00 2023-06-06T04:00:15.944350+00:00 0:00:00.830499 391810 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-06T04:00:12.704679+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-06T02:00:00+00:00 TriggerDagRunOperator 2023-06-06T03:14:52.837196+00:00 2023-06-06T03:14:53.192266+00:00 0:00:00.355070 391800 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T03:14:50.287505+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-06T02:00:00+00:00 TriggerDagRunOperator 2023-06-06T03:14:52.649480+00:00 2023-06-06T03:14:53.130698+00:00 0:00:00.481218 391799 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T03:14:50.287477+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-06T02:00:00+00:00 EmrJobFlowSensor 2023-06-06T03:04:37.500518+00:00 2023-06-06T03:14:39.299500+00:00 0:10:01.798982 391792 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-06T03:04:35.427614+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-06T02:00:00+00:00 EmrCreateJobFlowOperator 2023-06-06T03:04:15.591193+00:00 2023-06-06T03:04:16.454312+00:00 0:00:00.863119 391790 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-06T03:04:13.406724+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-06T02:00:00+00:00 PythonOperator 2023-06-06T03:03:56.009731+00:00 2023-06-06T03:03:56.865269+00:00 0:00:00.855538 391788 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-06T03:03:53.387367+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-06T01:00:00+00:00 TriggerDagRunOperator 2023-06-06T02:11:12.886966+00:00 2023-06-06T02:11:13.259115+00:00 0:00:00.372149 391778 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T02:11:10.612989+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-06T01:00:00+00:00 TriggerDagRunOperator 2023-06-06T02:11:12.753519+00:00 2023-06-06T02:11:13.192389+00:00 0:00:00.438870 391777 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T02:11:10.612957+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-06T01:00:00+00:00 EmrJobFlowSensor 2023-06-06T02:00:54.998059+00:00 2023-06-06T02:10:56.976701+00:00 0:10:01.978642 391770 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-06T02:00:52.857357+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-06T01:00:00+00:00 EmrCreateJobFlowOperator 2023-06-06T02:00:33.136000+00:00 2023-06-06T02:00:34.427371+00:00 0:00:01.291371 391768 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-06T02:00:30.833827+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-06T01:00:00+00:00 PythonOperator 2023-06-06T02:00:13.392746+00:00 2023-06-06T02:00:14.687028+00:00 0:00:01.294282 391766 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-06T02:00:10.816876+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-06T00:00:00+00:00 TriggerDagRunOperator 2023-06-06T01:11:16.254241+00:00 2023-06-06T01:11:16.596307+00:00 0:00:00.342066 391745 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T01:11:14.079114+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-06T00:00:00+00:00 TriggerDagRunOperator 2023-06-06T01:11:16.108646+00:00 2023-06-06T01:11:16.565374+00:00 0:00:00.456728 391744 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T01:11:14.079078+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-06T00:00:00+00:00 EmrJobFlowSensor 2023-06-06T01:00:49.649196+00:00 2023-06-06T01:10:51.391121+00:00 0:10:01.741925 391737 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-06T01:00:47.300844+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-06T00:00:00+00:00 EmrCreateJobFlowOperator 2023-06-06T01:00:29.696587+00:00 2023-06-06T01:00:30.483958+00:00 0:00:00.787371 391735 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-06T01:00:27.302806+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-06T00:00:00+00:00 PythonOperator 2023-06-06T01:00:07.853173+00:00 2023-06-06T01:00:08.814868+00:00 0:00:00.961695 391733 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-06T01:00:05.287204+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-05T23:00:00+00:00 TriggerDagRunOperator 2023-06-06T00:11:01.646470+00:00 2023-06-06T00:11:02.021470+00:00 0:00:00.375000 391722 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T00:10:59.459018+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-05T23:00:00+00:00 TriggerDagRunOperator 2023-06-06T00:11:01.470216+00:00 2023-06-06T00:11:01.908488+00:00 0:00:00.438272 391721 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-06T00:10:59.459052+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-05T23:00:00+00:00 EmrJobFlowSensor 2023-06-06T00:00:46.896213+00:00 2023-06-06T00:10:48.660745+00:00 0:10:01.764532 391712 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-06T00:00:44.628384+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-05T23:00:00+00:00 EmrCreateJobFlowOperator 2023-06-06T00:00:24.824633+00:00 2023-06-06T00:00:25.667482+00:00 0:00:00.842849 391711 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-06T00:00:22.607322+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-05T23:00:00+00:00 PythonOperator 2023-06-06T00:00:05.027900+00:00 2023-06-06T00:00:05.925366+00:00 0:00:00.897466 391710 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-06T00:00:02.592478+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-05T22:00:00+00:00 TriggerDagRunOperator 2023-06-05T23:11:01.906981+00:00 2023-06-05T23:11:02.441585+00:00 0:00:00.534604 391698 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T23:10:59.760252+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-05T22:00:00+00:00 TriggerDagRunOperator 2023-06-05T23:11:01.837038+00:00 2023-06-05T23:11:02.297261+00:00 0:00:00.460223 391697 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T23:10:59.760279+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-05T22:00:00+00:00 EmrJobFlowSensor 2023-06-05T23:00:53.361555+00:00 2023-06-05T23:10:55.286543+00:00 0:10:01.924988 391690 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-05T23:00:51.278323+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-05T22:00:00+00:00 EmrCreateJobFlowOperator 2023-06-05T23:00:31.292854+00:00 2023-06-05T23:00:32.235038+00:00 0:00:00.942184 391687 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-05T23:00:29.256416+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-05T22:00:00+00:00 PythonOperator 2023-06-05T23:00:11.292682+00:00 2023-06-05T23:00:12.291217+00:00 0:00:00.998535 391684 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-05T23:00:09.243099+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-05T21:00:00+00:00 TriggerDagRunOperator 2023-06-05T22:11:06.589135+00:00 2023-06-05T22:11:07.071064+00:00 0:00:00.481929 391672 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T22:11:04.471983+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-05T21:00:00+00:00 TriggerDagRunOperator 2023-06-05T22:11:06.560440+00:00 2023-06-05T22:11:07.074035+00:00 0:00:00.513595 391671 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T22:11:04.471955+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-05T21:00:00+00:00 EmrJobFlowSensor 2023-06-05T22:00:52.323342+00:00 2023-06-05T22:10:53.972277+00:00 0:10:01.648935 391664 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-05T22:00:50.328247+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-05T21:00:00+00:00 EmrCreateJobFlowOperator 2023-06-05T22:00:30.412614+00:00 2023-06-05T22:00:31.295404+00:00 0:00:00.882790 391662 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-05T22:00:28.306684+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-05T21:00:00+00:00 PythonOperator 2023-06-05T22:00:10.463543+00:00 2023-06-05T22:00:11.440413+00:00 0:00:00.976870 391660 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-05T22:00:08.279793+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-05T20:00:00+00:00 TriggerDagRunOperator 2023-06-05T21:11:11.633921+00:00 2023-06-05T21:11:12.077460+00:00 0:00:00.443539 391649 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T21:11:09.576937+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-05T20:00:00+00:00 TriggerDagRunOperator 2023-06-05T21:11:11.518061+00:00 2023-06-05T21:11:11.936934+00:00 0:00:00.418873 391648 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T21:11:09.576971+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-05T20:00:00+00:00 EmrJobFlowSensor 2023-06-05T21:00:55.531435+00:00 2023-06-05T21:10:57.318689+00:00 0:10:01.787254 391642 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-05T21:00:53.553258+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-05T20:00:00+00:00 EmrCreateJobFlowOperator 2023-06-05T21:00:34.378217+00:00 2023-06-05T21:00:35.352300+00:00 0:00:00.974083 391640 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-05T21:00:31.531321+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-05T20:00:00+00:00 PythonOperator 2023-06-05T21:00:13.570660+00:00 2023-06-05T21:00:14.529840+00:00 0:00:00.959180 391638 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-05T21:00:11.509621+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-05T19:00:00+00:00 TriggerDagRunOperator 2023-06-05T20:10:57.642306+00:00 2023-06-05T20:10:58.105204+00:00 0:00:00.462898 391626 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T20:10:55.409326+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-05T19:00:00+00:00 TriggerDagRunOperator 2023-06-05T20:10:57.594623+00:00 2023-06-05T20:10:58.001287+00:00 0:00:00.406664 391625 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T20:10:55.409361+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-05T19:00:00+00:00 EmrJobFlowSensor 2023-06-05T20:00:51.965148+00:00 2023-06-05T20:10:53.729380+00:00 0:10:01.764232 391618 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-05T20:00:49.818235+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-05T19:00:00+00:00 EmrCreateJobFlowOperator 2023-06-05T20:00:29.893476+00:00 2023-06-05T20:00:30.951172+00:00 0:00:01.057696 391616 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-05T20:00:27.801639+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-05T19:00:00+00:00 PythonOperator 2023-06-05T20:00:10.137151+00:00 2023-06-05T20:00:11.126658+00:00 0:00:00.989507 391614 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-05T20:00:07.803451+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-05T18:00:00+00:00 TriggerDagRunOperator 2023-06-05T19:11:09.955343+00:00 2023-06-05T19:11:10.398706+00:00 0:00:00.443363 391601 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T19:11:07.897862+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-05T18:00:00+00:00 TriggerDagRunOperator 2023-06-05T19:11:09.889646+00:00 2023-06-05T19:11:10.372568+00:00 0:00:00.482922 391600 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T19:11:07.897894+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-05T18:00:00+00:00 EmrJobFlowSensor 2023-06-05T19:00:51.638068+00:00 2023-06-05T19:10:53.534410+00:00 0:10:01.896342 391593 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-05T19:00:49.646847+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-05T18:00:00+00:00 EmrCreateJobFlowOperator 2023-06-05T19:00:29.744522+00:00 2023-06-05T19:00:30.702278+00:00 0:00:00.957756 391592 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-05T19:00:27.685520+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-05T18:00:00+00:00 PythonOperator 2023-06-05T19:00:10.038691+00:00 2023-06-05T19:00:11.006594+00:00 0:00:00.967903 391591 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-05T19:00:07.610507+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-05T17:00:00+00:00 TriggerDagRunOperator 2023-06-05T18:11:15.401299+00:00 2023-06-05T18:11:15.857280+00:00 0:00:00.455981 391576 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T18:11:13.360697+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-05T17:00:00+00:00 TriggerDagRunOperator 2023-06-05T18:11:15.344766+00:00 2023-06-05T18:11:15.786907+00:00 0:00:00.442141 391575 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T18:11:13.360728+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-05T17:00:00+00:00 EmrJobFlowSensor 2023-06-05T18:01:01.790763+00:00 2023-06-05T18:11:03.842736+00:00 0:10:02.051973 391569 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-05T18:00:59.789534+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-05T17:00:00+00:00 EmrCreateJobFlowOperator 2023-06-05T18:00:39.988841+00:00 2023-06-05T18:00:40.891433+00:00 0:00:00.902592 391568 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-05T18:00:37.801737+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-05T17:00:00+00:00 PythonOperator 2023-06-05T18:00:19.817222+00:00 2023-06-05T18:00:20.738983+00:00 0:00:00.921761 391567 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-05T18:00:17.786251+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-05T16:00:00+00:00 TriggerDagRunOperator 2023-06-05T17:14:00.539143+00:00 2023-06-05T17:14:01.030049+00:00 0:00:00.490906 391556 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T17:13:58.258177+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-05T16:00:00+00:00 TriggerDagRunOperator 2023-06-05T17:14:00.476962+00:00 2023-06-05T17:14:00.959470+00:00 0:00:00.482508 391555 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T17:13:58.258148+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-05T16:00:00+00:00 EmrJobFlowSensor 2023-06-05T17:03:50.737422+00:00 2023-06-05T17:10:52.398682+00:00 0:07:01.661260 391547 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-05T17:03:47.014346+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-05T15:00:00+00:00 TriggerDagRunOperator 2023-06-05T17:03:50.711700+00:00 2023-06-05T17:03:51.405987+00:00 0:00:00.694287 391546 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T17:03:47.014302+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-05T15:00:00+00:00 TriggerDagRunOperator 2023-06-05T17:03:49.252448+00:00 2023-06-05T17:03:49.664358+00:00 0:00:00.411910 391545 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T17:03:47.014333+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-05T16:00:00+00:00 EmrCreateJobFlowOperator 2023-06-05T17:00:58.804612+00:00 2023-06-05T17:00:59.604958+00:00 0:00:00.800346 391542 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-05T17:00:56.827072+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-05T16:00:00+00:00 PythonOperator 2023-06-05T17:00:38.838822+00:00 2023-06-05T17:00:39.801268+00:00 0:00:00.962446 391540 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-05T17:00:36.812637+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-05T15:00:00+00:00 EmrJobFlowSensor 2023-06-05T16:53:36.387733+00:00 2023-06-05T17:03:38.095595+00:00 0:10:01.707862 391535 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-05T16:53:34.321032+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-06-05T15:00:00+00:00 EmrCreateJobFlowOperator 2023-06-05T16:53:16.307346+00:00 2023-06-05T16:53:17.260299+00:00 0:00:00.952953 391532 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-06-05T16:53:14.303015+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-06-05T15:00:00+00:00 PythonOperator 2023-06-05T16:52:54.252578+00:00 2023-06-05T16:52:55.184014+00:00 0:00:00.931436 391529 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-06-05T16:52:52.286628+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-06-05T14:00:00+00:00 TriggerDagRunOperator 2023-06-05T15:11:02.191631+00:00 2023-06-05T15:11:02.642032+00:00 0:00:00.450401 391521 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T15:11:00.058429+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-06-05T14:00:00+00:00 TriggerDagRunOperator 2023-06-05T15:11:02.190007+00:00 2023-06-05T15:11:02.623179+00:00 0:00:00.433172 391520 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-06-05T15:11:00.058462+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-06-05T14:00:00+00:00 EmrJobFlowSensor 2023-06-05T15:00:49.819608+00:00 2023-06-05T15:10:51.573846+00:00 0:10:01.754238 391513 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-06-05T15:00:47.815103+00:00 2 default_pool